Lines Matching refs:fifo
285 UnixFifo* fifo = new(nothrow) UnixFifo(UNIX_MAX_TRANSFER_UNIT, UnixFifoType::Stream);
287 ObjectDeleter<UnixFifo> fifoDeleter(fifo);
291 if ((error = fifo->Init()) != B_OK || (error = peerFifo->Init()) != B_OK)
314 fReceiveFifo = fifo;
507 UnixFifo* fifo = fReceiveFifo;
508 BReference<UnixFifo> _(fifo);
509 UnixFifoLocker fifoLocker(fifo);
514 ssize_t result = fifo->Read(vecs, vecCount, _ancillaryData, NULL, timeout);
517 size_t writable = fifo->Writable();
519 && !fifo->IsWriteShutdown());
523 size_t readable = fifo->Readable();
525 && !fifo->IsReadShutdown());
548 // if (fReceiveFifo == fifo) {
654 // translate the direction into shutdown flags for our and the peer fifo
706 UnixStreamEndpoint* listeningEndpoint, UnixFifo* fifo)
714 fReceiveFifo = fifo;