AsyncBsdSocketLib::FifoReceiver Class Reference

FIFO (named pipe) IPC receiver (reader) More...

#include <fifo_receiver.h>

Inheritance diagram for AsyncBsdSocketLib::FifoReceiver:

Public Member Functions
	FifoReceiver (std::string pathname)
	Constructor.
int	Connection () const noexcept override
	Connection descriptor for sending and receiving.
bool	TrySetup () noexcept override
	Try to setup the communicator.
template<std::size_t N>
ssize_t	Receive (std::array< uint8_t, N > &buffer) const noexcept
	Receive a byte array from the FIFO pipe.
Public Member Functions inherited from AsyncBsdSocketLib::Communicator
int	Descriptor () const noexcept
	File descriptor.
virtual bool	TryClose () noexcept
	Try to close the communicator.

Additional Inherited Members
Protected Attributes inherited from AsyncBsdSocketLib::Communicator
int	FileDescriptor
	File descriptor.

Detailed Description

FIFO (named pipe) IPC receiver (reader)

Constructor & Destructor Documentation

FifoReceiver()

AsyncBsdSocketLib::FifoReceiver::FifoReceiver

(

std::string

pathname

)

Constructor.

Parameters

pathname

FIFO file path

Member Function Documentation

Connection()

int AsyncBsdSocketLib::FifoReceiver::Connection ( ) const

overridevirtualnoexcept

Connection descriptor for sending and receiving.

Returns

A non-negative value if there is a valid connection; otherwise -1

Implements AsyncBsdSocketLib::Communicator.

Receive()

template<std::size_t N>

ssize_t AsyncBsdSocketLib::FifoReceiver::Receive ( std::array< uint8_t, N > & buffer ) const

inlinenoexcept

Receive a byte array from the FIFO pipe.

Template Parameters

N	Receive buffer size

Parameters

buffer

Receive buffer byte array

Returns

Size of received bytes (-1 in case of receiving failed)

Warning

Due to edge-triggered polling, starvation can occur

TrySetup()

bool AsyncBsdSocketLib::FifoReceiver::TrySetup ( )

overridevirtualnoexcept

Try to setup the communicator.

Returns

True if the communicator is successfully set up; otherwise false

Implements AsyncBsdSocketLib::Communicator.