UnixFifo
= new (std::nothrow) UnixFifo(UNIX_MAX_TRANSFER_UNIT, UnixFifoType::Datagram);
UnixFifo* targetFifo = targetEndpoint->fReceiveFifo;
BReference<UnixFifo> targetFifoReference(targetFifo);
fReceiveFifo = new (std::nothrow) UnixFifo(UNIX_MAX_TRANSFER_UNIT,
UnixFifo* fifo = fReceiveFifo;
BReference<UnixFifo> fifoReference(fifo);
class UnixFifo;
UnixFifo* fReceiveFifo;
UnixFifo::UnixFifo(size_t capacity, UnixFifoType type)
UnixFifo::~UnixFifo()
UnixFifo::Init()
UnixFifo::Shutdown(uint32 shutdown)
UnixFifo::Read(const iovec* vecs, size_t vecCount,
UnixFifo::Write(const iovec* vecs, size_t vecCount,
UnixFifo::Readable() const
UnixFifo::Writable() const
UnixFifo::SetBufferCapacity(size_t capacity)
UnixFifo::_Read(UnixRequest& request, bigtime_t timeout)
UnixFifo::_Write(UnixRequest& request, bigtime_t timeout)
UnixFifo::_WriteNonBlocking(UnixRequest& request)
UnixFifo::_MinimumWritableSize(const UnixRequest& request) const
class UnixFifo final : public BReferenceable {
UnixFifo(size_t capacity, UnixFifoType type);
~UnixFifo();
typedef AutoLocker<UnixFifo> UnixFifoLocker;
UnixFifo* fifo = new(nothrow) UnixFifo(socket->receive.buffer_size, type);
UnixFifo* peerFifo = new(nothrow) UnixFifo(socket->send.buffer_size, type);
ObjectDeleter<UnixFifo> fifoDeleter(fifo);
ObjectDeleter<UnixFifo> peerFifoDeleter(peerFifo);
UnixFifo* peerFifo = peerEndpoint->fReceiveFifo;
BReference<UnixFifo> _(peerFifo);
UnixFifo* fifo = fReceiveFifo;
BReference<UnixFifo> _(fifo);
UnixFifo* peerFifo = fPeerEndpoint->fReceiveFifo;
UnixStreamEndpoint* listeningEndpoint, UnixFifo* fifo)
class UnixFifo;
UnixStreamEndpoint* listeningEndpoint, UnixFifo* fifo);
UnixFifo* fReceiveFifo;