Lines Matching refs:fifo
334 UnixFifo* fifo = new(nothrow) UnixFifo(UNIX_MAX_TRANSFER_UNIT);
336 ObjectDeleter<UnixFifo> fifoDeleter(fifo);
340 if ((error = fifo->Init()) != B_OK || (error = peerFifo->Init()) != B_OK)
363 fReceiveFifo = fifo;
544 UnixFifo* fifo = fReceiveFifo;
545 BReference<UnixFifo> _(fifo);
546 UnixFifoLocker fifoLocker(fifo);
551 ssize_t result = fifo->Read(vecs, vecCount, _ancillaryData, timeout);
554 size_t writable = fifo->Writable();
556 && !fifo->IsWriteShutdown());
560 size_t readable = fifo->Readable();
562 && !fifo->IsReadShutdown());
585 // if (fReceiveFifo == fifo) {
687 // translate the direction into shutdown flags for our and the peer fifo
739 UnixEndpoint* listeningEndpoint, UnixFifo* fifo)
747 fReceiveFifo = fifo;