Main MRPT website > C++ reference for MRPT 1.9.9
List of all members | Public Types | Public Member Functions | Public Attributes | Protected Attributes | Private Member Functions | Friends
mrpt::io::CPipeWriteEndPoint Class Reference

Detailed Description

The write end-point in a pipe created with mrpt::synch::CPipe.

Use the method CStream::Write() of the base class CStream for blocking writing.

Definition at line 151 of file CPipe.h.

#include <mrpt/io/CPipe.h>

Inheritance diagram for mrpt::io::CPipeWriteEndPoint:
Inheritance graph

Public Types

enum  TSeekOrigin { sFromBeginning = 0, sFromCurrent = 1, sFromEnd = 2 }
 Used in CStream::Seek. More...
 

Public Member Functions

 CPipeWriteEndPoint (const std::string &serialized)
 De-serializes one end-point description, for example, from a parent process. More...
 
size_t Read (void *Buffer, size_t Count)
 Write-only pipe: read launches exception. More...
 
std::string serialize ()
 Converts the end-point into a string suitable for reconstruction at a child process. More...
 
bool isOpen () const
 Returns false if the pipe was closed due to some error. More...
 
void close ()
 Closes the pipe (normally not needed to be called by users, automatically done at destructor) More...
 
virtual size_t Write (const void *Buffer, size_t Count) override
 Introduces a pure virtual method responsible for writing to the stream. More...
 
virtual uint64_t Seek (int64_t of, CStream::TSeekOrigin o=sFromBeginning) override
 Without effect in this class. More...
 
virtual uint64_t getTotalBytesCount () const override
 Without effect in this class. More...
 
virtual uint64_t getPosition () const override
 Without effect in this class. More...
 
virtual size_t ReadBufferImmediate (void *Buffer, size_t Count)
 Reads a block of bytes from the stream into Buffer, and returns the amound of bytes actually read, without waiting for more extra bytes to arrive (just those already enqued in the stream). More...
 
virtual int printf (const char *fmt,...) MRPT_printf_format_check(2
 Writes a string to the stream in a textual form. More...
 
template<typename CONTAINER_TYPE >
virtual int void printf_vector (const char *fmt, const CONTAINER_TYPE &V, char separator=',')
 Prints a vector in the format [A,B,C,...] using CStream::printf, and the fmt string for each vector element T. More...
 
bool getline (std::string &out_str)
 Reads from the stream until a '
' character is found ('\r' characters are ignored). More...
 

Public Attributes

unsigned int timeout_read_start_us
 (Default=0) Timeout for read operations: microseconds (us) to wait for the first byte. More...
 
unsigned int timeout_read_between_us
 (Default=0) Timeout between burst reads operations: microseconds (us) to wait between two partial reads inside one large read. More...
 

Protected Attributes

voidm_pipe_file
 

Private Member Functions

 CPipeWriteEndPoint ()
 

Friends

class CPipe
 

Member Enumeration Documentation

◆ TSeekOrigin

Used in CStream::Seek.

Enumerator
sFromBeginning 
sFromCurrent 
sFromEnd 

Definition at line 34 of file io/CStream.h.

Constructor & Destructor Documentation

◆ CPipeWriteEndPoint() [1/2]

CPipeWriteEndPoint::CPipeWriteEndPoint ( const std::string serialized)
explicit

De-serializes one end-point description, for example, from a parent process.

Definition at line 246 of file CPipe.cpp.

◆ CPipeWriteEndPoint() [2/2]

CPipeWriteEndPoint::CPipeWriteEndPoint ( )
private

Definition at line 245 of file CPipe.cpp.

Member Function Documentation

◆ close()

void CPipeBaseEndPoint::close ( )
inherited

Closes the pipe (normally not needed to be called by users, automatically done at destructor)

Definition at line 59 of file CPipe.cpp.

References mrpt::io::CPipeBaseEndPoint::m_pipe_file.

Referenced by mrpt::io::CPipeBaseEndPoint::Read(), and mrpt::io::CPipeBaseEndPoint::~CPipeBaseEndPoint().

◆ getline()

bool CStream::getline ( std::string out_str)
inherited

Reads from the stream until a '
' character is found ('\r' characters are ignored).

Returns
false on EOF or any other read error.

Definition at line 69 of file CStream.cpp.

◆ getPosition()

uint64_t CPipeBaseEndPoint::getPosition ( ) const
overridevirtualinherited

Without effect in this class.

Implements mrpt::io::CStream.

Definition at line 118 of file CPipe.cpp.

◆ getTotalBytesCount()

uint64_t CPipeBaseEndPoint::getTotalBytesCount ( ) const
overridevirtualinherited

Without effect in this class.

Implements mrpt::io::CStream.

Definition at line 117 of file CPipe.cpp.

◆ isOpen()

bool mrpt::io::CPipeBaseEndPoint::isOpen ( ) const
inlineinherited

Returns false if the pipe was closed due to some error.

Definition at line 95 of file CPipe.h.

References mrpt::io::CPipeBaseEndPoint::m_pipe_file.

◆ printf()

int CStream::printf ( const char *  fmt,
  ... 
)
virtualinherited

Writes a string to the stream in a textual form.

See also
CStdOutStream

Definition at line 30 of file CStream.cpp.

References MRPT_END, MRPT_START, and vsnprintf.

Referenced by mrpt::hmtslam::CTopLCDetector_GridMatching::computeTopologicalObservationModel(), and mrpt::io::CStream::printf_vector().

◆ printf_vector()

template<typename CONTAINER_TYPE >
virtual int void mrpt::io::CStream::printf_vector ( const char *  fmt,
const CONTAINER_TYPE &  V,
char  separator = ',' 
)
inlineinherited

Prints a vector in the format [A,B,C,...] using CStream::printf, and the fmt string for each vector element T.

Template Parameters
CONTAINER_TYPEcan be any vector<T>, deque<T> or alike.

Definition at line 104 of file io/CStream.h.

References mrpt::io::CStream::printf().

Referenced by mrpt::hmtslam::CTopLCDetector_GridMatching::computeTopologicalObservationModel().

◆ Read()

size_t mrpt::io::CPipeWriteEndPoint::Read ( void Buffer,
size_t  Count 
)
inlinevirtual

Write-only pipe: read launches exception.

Reimplemented from mrpt::io::CPipeBaseEndPoint.

Definition at line 161 of file CPipe.h.

◆ ReadBufferImmediate()

virtual size_t mrpt::io::CStream::ReadBufferImmediate ( void Buffer,
size_t  Count 
)
inlinevirtualinherited

Reads a block of bytes from the stream into Buffer, and returns the amound of bytes actually read, without waiting for more extra bytes to arrive (just those already enqued in the stream).

Note that this method will fallback to ReadBuffer() in most CStream classes but in some hardware-related classes.

Exceptions
std::exceptionOn any error, or if ZERO bytes are read.

Reimplemented in mrpt::comms::CInterfaceFTDI.

Definition at line 64 of file io/CStream.h.

References mrpt::io::CStream::Read().

◆ Seek()

uint64_t CPipeBaseEndPoint::Seek ( int64_t  of,
CStream::TSeekOrigin  o = sFromBeginning 
)
overridevirtualinherited

Without effect in this class.

Implements mrpt::io::CStream.

Definition at line 116 of file CPipe.cpp.

◆ serialize()

std::string CPipeBaseEndPoint::serialize ( )
inherited

Converts the end-point into a string suitable for reconstruction at a child process.

This invalidates this object, since only one real end-point can exist at once.

Definition at line 105 of file CPipe.cpp.

References ASSERTMSG_, mrpt::io::CPipeBaseEndPoint::m_pipe_file, and mrpt::to_string().

◆ Write()

size_t CPipeBaseEndPoint::Write ( const void Buffer,
size_t  Count 
)
overridevirtualinherited

Introduces a pure virtual method responsible for writing to the stream.

Write attempts to write up to Count bytes to Buffer, and returns the number of bytes actually written.

Implements mrpt::io::CStream.

Reimplemented in mrpt::io::CPipeReadEndPoint.

Definition at line 219 of file CPipe.cpp.

References ASSERTMSG_, and mrpt::io::CPipeBaseEndPoint::m_pipe_file.

Friends And Related Function Documentation

◆ CPipe

friend class CPipe
friend

Definition at line 153 of file CPipe.h.

Member Data Documentation

◆ m_pipe_file

void* mrpt::io::CPipeBaseEndPoint::m_pipe_file
protectedinherited

◆ timeout_read_between_us

unsigned int mrpt::io::CPipeBaseEndPoint::timeout_read_between_us
inherited

(Default=0) Timeout between burst reads operations: microseconds (us) to wait between two partial reads inside one large read.

0 means infinite timeout.

Definition at line 92 of file CPipe.h.

Referenced by mrpt::io::CPipeBaseEndPoint::Read().

◆ timeout_read_start_us

unsigned int mrpt::io::CPipeBaseEndPoint::timeout_read_start_us
inherited

(Default=0) Timeout for read operations: microseconds (us) to wait for the first byte.

0 means infinite timeout.

Definition at line 88 of file CPipe.h.

Referenced by mrpt::io::CPipeBaseEndPoint::Read().




Page generated by Doxygen 1.8.17 for MRPT 1.9.9 Git: ad3a9d8ae Tue May 1 23:10:22 2018 -0700 at miƩ 12 jul 2023 10:03:34 CEST