MpiBcastStream Class Reference

Implements communication via MPI broadcast. More...

#include <mpi_carrier/MpiBcastStream.h>

Inheritance diagram for MpiBcastStream:

Public Member Functions
	MpiBcastStream (std::string name, MpiComm *comm)
	~MpiBcastStream ()
ssize_t	read (yarp::os::Bytes &b) override
	Read a block of data from the stream.
void	write (const yarp::os::Bytes &b) override
	Write a block of bytes to the stream.
void	startJoin ()
void	post ()
void	close () override
	Terminate the stream.
void	execCmd (int cmd)
void	write (const yarp::os::Bytes &b) override=0
	Write a block of bytes to the stream.
ssize_t	read (yarp::os::Bytes &b) override=0
	Read a block of data from the stream.
Public Member Functions inherited from MpiStream
	MpiStream (std::string name, MpiComm *comm)
virtual	~MpiStream ()
bool	isOk () const override
	Check if the stream is ok or in an error state.
void	interrupt () override
	Interrupt the stream.
InputStream &	getInputStream () override
	Get an InputStream to read from.
OutputStream &	getOutputStream () override
	Get an OutputStream to write to.
const yarp::os::Contact &	getLocalAddress () const override
	Get the address of the local side of the stream.
const yarp::os::Contact &	getRemoteAddress () const override
	Get the address of the remote side of the stream.
void	resetBuffer ()
void	reset () override
	Reset the stream.
void	beginPacket () override
	Mark the beginning of a logical packet.
void	endPacket () override
	Mark the end of a logical packet (see beginPacket).
Public Member Functions inherited from yarp::os::TwoWayStream
virtual	~TwoWayStream ()
	Destructor.
Public Member Functions inherited from yarp::os::InputStream
	InputStream ()
	Constructor.
virtual	~InputStream ()
	Destructor.
virtual void	check ()
	Perform maintenance actions, if needed.
virtual int	read ()
	Read and return a single byte.
virtual yarp::conf::ssize_t	read (Bytes &b, size_t offset, yarp::conf::ssize_t len)
	Read a block of data from the stream.
virtual yarp::conf::ssize_t	partialRead (yarp::os::Bytes &b)
	Like read, but solicit partial responses.
virtual bool	setReadTimeout (double timeout)
	Set activity timeout.
std::string	readLine (const char terminal='\n', bool *success=nullptr)
	Read a block of text terminated with a specific marker (or EOF).
yarp::conf::ssize_t	readFull (Bytes &b)
	Keep reading until buffer is full.
yarp::conf::ssize_t	readDiscard (size_t len)
	Read and discard a fixed number of bytes.
virtual bool	setReadEnvelopeCallback (readEnvelopeCallbackType callback, void *data)
	Install a callback that the InputStream will have to call when the envelope is read from a message in carriers that cannot be escaped.
Public Member Functions inherited from yarp::os::OutputStream
virtual	~OutputStream ()
	Destructor.
virtual void	write (char ch)
	Write a single byte to the stream.
virtual void	write (const Bytes &b, int offset, int len)
	Write a block of bytes to the stream.
virtual void	flush ()
	Make sure all pending write operations are finished.
virtual void	writeLine (const char *data, int len)
	Write some text followed by a line feed.
virtual bool	setWriteTimeout (double timeout)
	Set activity timeout.
virtual bool	setTypeOfService (int tos)
virtual int	getTypeOfService ()

Additional Inherited Members
Public Types inherited from yarp::os::InputStream
typedef void(*	readEnvelopeCallbackType) (void *, const yarp::os::Bytes &envelope)
	Callback type for setting the envelope from a message in carriers that cannot be escaped.
Protected Attributes inherited from MpiStream
int	readAvail
int	readAt
char *	readBuffer
bool	terminate
std::string	name
MpiComm *	comm
yarp::os::Contact	local
yarp::os::Contact	remote

Detailed Description

Implements communication via MPI broadcast.

Definition at line 20 of file MpiBcastStream.h.

Constructor & Destructor Documentation

MpiBcastStream()

MpiBcastStream::MpiBcastStream ( std::string  name, MpiComm *  comm  )

inline

Definition at line 24 of file MpiBcastStream.h.

~MpiBcastStream()

MpiBcastStream::~MpiBcastStream ( )

inline

Definition at line 25 of file MpiBcastStream.h.

Member Function Documentation

close()

void MpiBcastStream::close ( )

inlineoverridevirtual

Terminate the stream.

Implements MpiStream.

Definition at line 38 of file MpiBcastStream.h.

execCmd()

void MpiBcastStream::execCmd

(

int

cmd

)

Definition at line 22 of file MpiBcastStream.cpp.

post()

void MpiBcastStream::post ( )

inline

Definition at line 35 of file MpiBcastStream.h.

read() [1/2]

ssize_t MpiBcastStream::read ( yarp::os::Bytes &  b )

overridevirtual

Read a block of data from the stream.

Should block and wait for data.

Parameters

b[out]

the block of data to read to

Returns

the number of bytes read, or -1 upon error

Implements MpiStream.

Definition at line 49 of file MpiBcastStream.cpp.

read() [2/2]

ssize_t MpiStream::read ( yarp::os::Bytes &  b )

overridevirtual

Read a block of data from the stream.

Should block and wait for data.

Parameters

b[out]

the block of data to read to

Returns

the number of bytes read, or -1 upon error

Implements MpiStream.

startJoin()

void MpiBcastStream::startJoin

(

)

Definition at line 12 of file MpiBcastStream.cpp.

write() [1/2]

void MpiBcastStream::write ( const yarp::os::Bytes &  b )

overridevirtual

Write a block of bytes to the stream.

Parameters

b	the bytes to write

Implements MpiStream.

Definition at line 98 of file MpiBcastStream.cpp.

write() [2/2]

void MpiStream::write ( const yarp::os::Bytes &  b )

overridevirtual

Write a block of bytes to the stream.

Parameters

b	the bytes to write

Implements MpiStream.

---

The documentation for this class was generated from the following files:

• src/carriers/mpi_carrier/MpiBcastStream.h
• src/carriers/mpi_carrier/MpiBcastStream.cpp