A TCP socket that can be connected to a TCP server, implementing MRPT's CStream interface for passing objects as well as generic read/write methods.
Unless otherwise noticed, operations are blocking.
Note that for convenience, DNS lookup is performed with a timeout (default=3000ms), which can be changed by the static member CClientTCPSocket::DNS_LOOKUP_TIMEOUT_MS
Definition at line 36 of file CClientTCPSocket.h.
#include <mrpt/comms/CClientTCPSocket.h>
Public Types | |
enum | TSeekOrigin { sFromBeginning = 0, sFromCurrent = 1, sFromEnd = 2 } |
Used in CStream::Seek. More... | |
Public Member Functions | |
CClientTCPSocket () | |
Default constructor. More... | |
~CClientTCPSocket () | |
Destructor. More... | |
void | connect (const std::string &remotePartAddress, unsigned short remotePartTCPPort, unsigned int timeout_ms=0) |
Establishes a connection with a remote part. More... | |
bool | isConnected () |
Returns true if this objects represents a successfully connected socket. More... | |
void | close () |
Closes the connection. More... | |
void | sendString (const std::string &str) |
Writes a string to the socket. More... | |
uint64_t | Seek (uint64_t Offset, CStream::TSeekOrigin Origin=sFromBeginning) override |
This virtual method has no effect in this implementation over a TCP socket, and its use raises an exception. More... | |
uint64_t | getTotalBytesCount () override |
This virtual method has no effect in this implementation over a TCP socket, and its use raises an exception. More... | |
uint64_t | getPosition () override |
This virtual method has no effect in this implementation over a TCP socket, and its use raises an exception. More... | |
size_t | readAsync (void *Buffer, const size_t Count, const int timeoutStart_ms=-1, const int timeoutBetween_ms=-1) |
A method for reading from the socket with an optional timeout. More... | |
size_t | writeAsync (const void *Buffer, const size_t Count, const int timeout_ms=-1) |
A method for writing to the socket with optional timeouts. More... | |
bool | sendMessage (const mrpt::utils::CMessage &outMsg, const int timeout_ms=-1) |
Send a message through the TCP stream. More... | |
bool | receiveMessage (mrpt::utils::CMessage &inMsg, const unsigned int timeoutStart_ms=100, const unsigned int timeoutBetween_ms=1000) |
Waits for an incoming message through the TCP stream. More... | |
size_t | getReadPendingBytes () |
Return the number of bytes already in the receive queue (they can be read without waiting) More... | |
int | setTCPNoDelay (const int &newValue) |
Set the TCP no delay option of the protocol (Nagle algorithm). More... | |
int | getTCPNoDelay () |
Return the value of the TCPNoDelay option. More... | |
int | setSOSendBufffer (const int &newValue) |
Set the size of the SO send buffer. More... | |
int | getSOSendBufffer () |
Return the current size of the SO send buffer. More... | |
size_t | ReadBuffer (void *Buffer, size_t Count) |
Reads a block of bytes from the stream into Buffer. More... | |
template<typename T > | |
size_t | ReadBufferFixEndianness (T *ptr, size_t ElementCount) |
Reads a sequence of elemental datatypes, taking care of reordering their bytes from the MRPT stream standard (little endianness) to the format of the running architecture. 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... | |
void | WriteBuffer (const void *Buffer, size_t Count) |
Writes a block of bytes to the stream from Buffer. More... | |
template<typename T > | |
void | WriteBufferFixEndianness (const T *ptr, size_t ElementCount) |
Writes a sequence of elemental datatypes, taking care of reordering their bytes from the running architecture to MRPT stream standard (little endianness). More... | |
virtual uint64_t | Seek (uint64_t Offset, CStream::TSeekOrigin Origin=sFromBeginning)=0 |
Introduces a pure virtual method for moving to a specified position in the streamed resource. More... | |
void | WriteObject (const CSerializable *o) |
Writes an object to the stream. More... | |
void | WriteObject (const CSerializable &o) |
CSerializable::Ptr | ReadObject () |
Reads an object from stream, its class determined at runtime, and returns a smart pointer to the object. More... | |
template<typename T > | |
T::Ptr | ReadObject () |
Reads an object from stream, its class determined at runtime, and returns a smart pointer to the object. More... | |
void | ReadObject (CSerializable *existingObj) |
Reads an object from stream, where its class must be the same as the supplied object, where the loaded object will be stored in. More... | |
template<typename... T> | |
mrpt::utils::variant< T... > | ReadVariant () |
Reads a variant from stream, its class determined at runtime, and returns a variant to the object. More... | |
template<typename T > | |
void | WriteVariant (T t) |
Writes a Variant to the stream. More... | |
template<typename T > | |
T | ReadPOD () |
Reads a simple POD type and returns by value. More... | |
CStream & | operator<< (const CSerializable::Ptr &pObj) |
Write an object to a stream in the binary MRPT format. More... | |
CStream & | operator<< (const CSerializable &obj) |
Write an object to a stream in the binary MRPT format. More... | |
CStream & | operator>> (CSerializable::Ptr &pObj) |
CStream & | operator>> (CSerializable &obj) |
template<typename STORED_TYPE , typename CAST_TO_TYPE > | |
void | ReadAsAndCastTo (CAST_TO_TYPE &read_here) |
Read a value from a stream stored in a type different of the target variable, making the conversion via static_cast. 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... | |
void | sendMessage (const utils::CMessage &msg) |
Send a message to the device. More... | |
bool | receiveMessage (utils::CMessage &msg) |
Tries to receive a message from the device. More... | |
bool | getline (std::string &out_str) |
Reads from the stream until a ' ' character is found ('' characters are ignored). More... | |
Static Public Attributes | |
static unsigned int | DNS_LOOKUP_TIMEOUT_MS = 3000 |
See description of CClientTCPSocket. More... | |
Protected Member Functions | |
size_t | Read (void *Buffer, size_t Count) override |
Introduces a virtual method responsible for reading from the stream (This method BLOCKS) This method is implemented as a call to "readAsync" with infinite timeouts. More... | |
size_t | Write (const void *Buffer, size_t Count) override |
Introduces a virtual method responsible for writing to the stream. More... | |
std::string | getLastErrorStr () |
Returns a description of the last Sockets error. More... | |
void | internal_ReadObject (CSerializable *newObj, const std::string &className, bool isOldFormat, int8_t version) |
Read the object. More... | |
void | internal_ReadObjectHeader (std::string &className, bool &isOldFormat, int8_t &version) |
Read the object Header. More... | |
Protected Attributes | |
int | m_hSock |
The handle for the connected TCP socket, or -1. More... | |
std::string | m_remotePartIP |
The IP address of the remote part of the connection. More... | |
unsigned short | m_remotePartPort |
The TCP port of the remote part of the connection. More... | |
Friends | |
class | CServerTCPSocket |
|
inherited |
CClientTCPSocket::CClientTCPSocket | ( | ) |
Default constructor.
Definition at line 49 of file CClientTCPSocket.cpp.
References INVALID_SOCKET, MRPT_END, MRPT_START, and THROW_EXCEPTION.
CClientTCPSocket::~CClientTCPSocket | ( | ) |
Destructor.
Definition at line 72 of file CClientTCPSocket.cpp.
void CClientTCPSocket::close | ( | ) |
Closes the connection.
Definition at line 83 of file CClientTCPSocket.cpp.
References INVALID_SOCKET, MRPT_END, and MRPT_START.
Referenced by mrpt::hwdrivers::CNTRIPClient::private_ntrip_thread().
void CClientTCPSocket::connect | ( | const std::string & | remotePartAddress, |
unsigned short | remotePartTCPPort, | ||
unsigned int | timeout_ms = 0 |
||
) |
Establishes a connection with a remote part.
remotePartAddress | This string can be a host name, like "server" or "www.mydomain.org", or an IP address "11.22.33.44". |
remotePartTCPPort | The port on the remote machine to connect to. |
timeout_ms | The timeout to wait for the connection (0: NO TIMEOUT) |
This | method raises an exception if an error is found with a textual description of the error. |
Definition at line 241 of file CClientTCPSocket.cpp.
References mrpt::comms::net::DNS_resolve_async(), mrpt::format(), INVALID_SOCKET, mrpt::obs::gnss::lon, MRPT_END, MRPT_START, THROW_EXCEPTION, and THROW_EXCEPTION_FMT.
Referenced by mrpt::hwdrivers::CHokuyoURG::checkCOMisOpen(), mrpt::comms::net::http_request(), and mrpt::hwdrivers::CNTRIPClient::private_ntrip_thread().
|
protected |
Returns a description of the last Sockets error.
Definition at line 629 of file CClientTCPSocket.cpp.
References mrpt::comms::net::getLastSocketErrorStr().
|
inherited |
Reads from the stream until a '
' character is found ('' characters are ignored).
Definition at line 780 of file CStream.cpp.
|
inlineoverridevirtual |
This virtual method has no effect in this implementation over a TCP socket, and its use raises an exception.
Implements mrpt::utils::CStream.
Definition at line 136 of file CClientTCPSocket.h.
References MRPT_END, MRPT_START, and THROW_EXCEPTION.
size_t CClientTCPSocket::getReadPendingBytes | ( | ) |
Return the number of bytes already in the receive queue (they can be read without waiting)
Definition at line 554 of file CClientTCPSocket.cpp.
References INVALID_SOCKET, and THROW_EXCEPTION.
Referenced by mrpt::hwdrivers::CHokuyoURG::purgeBuffers().
int CClientTCPSocket::getSOSendBufffer | ( | ) |
Return the current size of the SO send buffer.
Definition at line 616 of file CClientTCPSocket.cpp.
int CClientTCPSocket::getTCPNoDelay | ( | ) |
Return the value of the TCPNoDelay option.
Definition at line 586 of file CClientTCPSocket.cpp.
|
inlineoverridevirtual |
This virtual method has no effect in this implementation over a TCP socket, and its use raises an exception.
Implements mrpt::utils::CStream.
Definition at line 127 of file CClientTCPSocket.h.
References MRPT_END, MRPT_START, and THROW_EXCEPTION.
|
protectedinherited |
Read the object.
Definition at line 523 of file CStream.cpp.
References SERIALIZATION_END_FLAG, THROW_EXCEPTION, THROW_EXCEPTION_FMT, and THROW_TYPED_EXCEPTION.
Referenced by mrpt::utils::CStream::ReadObject(), and mrpt::utils::CStream::ReadVariant().
|
protectedinherited |
Read the object Header.
Definition at line 420 of file CStream.cpp.
References ASSERT_, THROW_EXCEPTION, THROW_STACKED_EXCEPTION_CUSTOM_MSG2, and THROW_TYPED_EXCEPTION.
Referenced by mrpt::utils::CStream::ReadObject(), and mrpt::utils::CStream::ReadVariant().
bool CClientTCPSocket::isConnected | ( | ) |
Returns true if this objects represents a successfully connected socket.
Definition at line 379 of file CClientTCPSocket.cpp.
References INVALID_SOCKET.
Referenced by mrpt::hwdrivers::CHokuyoURG::checkCOMisOpen(), mrpt::comms::net::http_request(), and mrpt::hwdrivers::CNTRIPClient::private_ntrip_thread().
|
inherited |
Write an object to a stream in the binary MRPT format.
Definition at line 201 of file CStream.cpp.
|
inherited |
Write an object to a stream in the binary MRPT format.
Definition at line 208 of file CStream.cpp.
|
inherited |
Definition at line 214 of file CStream.cpp.
|
inherited |
Definition at line 220 of file CStream.cpp.
|
virtualinherited |
Writes a string to the stream in a textual form.
Definition at line 597 of file CStream.cpp.
References MRPT_END, MRPT_START, and vsnprintf.
Referenced by mrpt::hmtslam::CTopLCDetector_GridMatching::computeTopologicalObservationModel(), mrpt::utils::TMatchingPairList::dumpToFile(), mrpt::obs::gnss::Message_NMEA_GGA::dumpToStream(), mrpt::obs::gnss::Message_TOPCON_PZS::dumpToStream(), mrpt::obs::gnss::Message_TOPCON_SATS::dumpToStream(), mrpt::obs::gnss::Message_NMEA_GLL::dumpToStream(), mrpt::obs::gnss::Message_NMEA_RMC::dumpToStream(), mrpt::obs::gnss::Message_NV_OEM6_GENERIC_FRAME::dumpToStream(), mrpt::obs::CObservationGPS::dumpToStream(), mrpt::obs::gnss::Message_NMEA_VTG::dumpToStream(), mrpt::obs::gnss::Message_NV_OEM6_GENERIC_SHORT_FRAME::dumpToStream(), mrpt::obs::gnss::Message_NMEA_ZDA::dumpToStream(), mrpt::obs::gnss::Message_NV_OEM6_RANGECMP::dumpToStream(), mrpt::obs::gnss::Message_NV_OEM6_VERSION::dumpToStream(), mrpt::slam::TKLDParams::dumpToTextStream(), mrpt::slam::CMetricMapBuilderICP::TConfigParams::dumpToTextStream(), mrpt::maps::TMetricMapInitializer::dumpToTextStream(), mrpt::slam::CIncrementalMapPartitioner::TOptions::dumpToTextStream(), mrpt::maps::CGasConcentrationGridMap2D::TInsertionOptions::dumpToTextStream(), mrpt::maps::CWirelessPowerGridMap2D::TInsertionOptions::dumpToTextStream(), mrpt::maps::CHeightGridMap2D_MRF::TInsertionOptions::dumpToTextStream(), mrpt::hmtslam::CTopLCDetector_FabMap::TOptions::dumpToTextStream(), mrpt::hmtslam::CTopLCDetector_GridMatching::TOptions::dumpToTextStream(), mrpt::graphslam::TUncertaintyPath< GRAPH_T >::dumpToTextStream(), mrpt::maps::CReflectivityGridMap2D::TInsertionOptions::dumpToTextStream(), mrpt::slam::CICP::TConfigParams::dumpToTextStream(), mrpt::slam::CGridMapAligner::TConfigParams::dumpToTextStream(), mrpt::graphslam::TSlidingWindow::dumpToTextStream(), mrpt::slam::CMetricMapBuilderRBPF::TConstructionOptions::dumpToTextStream(), mrpt::bayes::TKF_options::dumpToTextStream(), mrpt::utils::CLoadableOptions::dumpToTextStream(), mrpt::graphslam::deciders::CIncrementalNodeRegistrationDecider< GRAPH_T >::TParams::dumpToTextStream(), mrpt::vision::CFeatureExtraction::TOptions::dumpToTextStream(), mrpt::maps::CHeightGridMap2D::TInsertionOptions::dumpToTextStream(), mrpt::maps::COctoMapBase< OCTREE, OCTREE_NODE >::TInsertionOptions::dumpToTextStream(), mrpt::slam::CRangeBearingKFSLAM2D::TOptions::dumpToTextStream(), mrpt::maps::CBeaconMap::TLikelihoodOptions::dumpToTextStream(), mrpt::maps::CMultiMetricMapPDF::TPredictionParams::dumpToTextStream(), mrpt::graphslam::deciders::CFixedIntervalsNRD< GRAPH_T >::TParams::dumpToTextStream(), mrpt::maps::CRandomFieldGridMap3D::TInsertionOptions::dumpToTextStream(), mrpt::maps::CBeaconMap::TInsertionOptions::dumpToTextStream(), mrpt::graphslam::deciders::CRangeScanOps< GRAPH_T >::TParams::dumpToTextStream(), mrpt::graphslam::deciders::CICPCriteriaERD< GRAPH_T >::TParams::dumpToTextStream(), mrpt::slam::CRangeBearingKFSLAM::TOptions::dumpToTextStream(), mrpt::graphslam::optimizers::CLevMarqGSO< GRAPH_T >::OptimizationParams::dumpToTextStream(), mrpt::graphslam::deciders::CICPCriteriaNRD< GRAPH_T >::TParams::dumpToTextStream(), mrpt::maps::CPointsMap::TInsertionOptions::dumpToTextStream(), mrpt::graphslam::optimizers::CLevMarqGSO< GRAPH_T >::GraphVisualizationParams::dumpToTextStream(), mrpt::maps::CLandmarksMap::TInsertionOptions::dumpToTextStream(), mrpt::maps::COctoMapBase< OCTREE, OCTREE_NODE >::TLikelihoodOptions::dumpToTextStream(), mrpt::vision::TStereoSystemParams::dumpToTextStream(), mrpt::maps::CColouredPointsMap::TColourOptions::dumpToTextStream(), mrpt::maps::CPointsMap::TLikelihoodOptions::dumpToTextStream(), mrpt::vision::CFeature::dumpToTextStream(), mrpt::maps::TSetOfMetricMapInitializers::dumpToTextStream(), mrpt::maps::CLandmarksMap::TLikelihoodOptions::dumpToTextStream(), mrpt::hmtslam::CHMTSLAM::TOptions::dumpToTextStream(), mrpt::graphslam::deciders::CLoopCloserERD< GRAPH_T >::TLaserParams::dumpToTextStream(), mrpt::vision::TMatchingOptions::dumpToTextStream(), mrpt::graphslam::deciders::CLoopCloserERD< GRAPH_T >::TLoopClosureParams::dumpToTextStream(), mrpt::maps::COccupancyGridMap2D::TInsertionOptions::dumpToTextStream(), mrpt::maps::COccupancyGridMap2D::TLikelihoodOptions::dumpToTextStream(), mrpt::vision::TMultiResDescMatchOptions::dumpToTextStream(), mrpt::vision::TMultiResDescOptions::dumpToTextStream(), mrpt::maps::CWirelessPowerGridMap2D::TMapDefinition::dumpToTextStream_map_specific(), mrpt::maps::CHeightGridMap2D_MRF::TMapDefinition::dumpToTextStream_map_specific(), mrpt::maps::CHeightGridMap2D::TMapDefinition::dumpToTextStream_map_specific(), mrpt::maps::CGasConcentrationGridMap2D::TMapDefinition::dumpToTextStream_map_specific(), mrpt::maps::CLandmarksMap::TMapDefinition::dumpToTextStream_map_specific(), mrpt::utils::CLoadableOptions::dumpVar_bool(), mrpt::utils::CLoadableOptions::dumpVar_double(), mrpt::utils::CLoadableOptions::dumpVar_float(), mrpt::utils::CLoadableOptions::dumpVar_int(), mrpt::utils::CLoadableOptions::dumpVar_string(), generic_dump_BESTPOS(), generic_dump_MARKTIME(), mrpt::maps::CRandomFieldGridMap2D::TInsertionOptionsCommon::internal_dumpToTextStream_common(), mrpt::slam::CRangeBearingKFSLAM2D::OnGetObservationsAndDataAssociation(), mrpt::utils::CStream::printf_vector(), mrpt::maps::CRandomFieldGridMap3D::saveAsCSV(), mrpt::poses::CPoseInterpolatorBase< 3 >::saveInterpolatedToTextFile(), mrpt::utils::CTimeLogger::saveToCSVFile(), and mrpt::poses::CPoseInterpolatorBase< 3 >::saveToTextFile().
|
inlineinherited |
Prints a vector in the format [A,B,C,...] using CStream::printf, and the fmt string for each vector element T
.
CONTAINER_TYPE | can be any vector<T>, deque<T> or alike. |
Definition at line 370 of file CStream.h.
References mrpt::utils::CStream::printf().
Referenced by mrpt::hmtslam::CTopLCDetector_GridMatching::computeTopologicalObservationModel().
|
overrideprotectedvirtual |
Introduces a virtual method responsible for reading from the stream (This method BLOCKS) This method is implemented as a call to "readAsync" with infinite timeouts.
Implements mrpt::utils::CStream.
Definition at line 110 of file CClientTCPSocket.cpp.
References MRPT_END, and MRPT_START.
|
inlineinherited |
size_t CClientTCPSocket::readAsync | ( | void * | Buffer, |
const size_t | Count, | ||
const int | timeoutStart_ms = -1 , |
||
const int | timeoutBetween_ms = -1 |
||
) |
A method for reading from the socket with an optional timeout.
Buffer | The destination of data. |
Cound | The number of bytes to read. |
timeoutStart_ms | The maximum timeout (in milliseconds) to wait for the starting of data from the other side. |
timeoutBetween_ms | The maximum timeout (in milliseconds) to wait for a chunk of data after a previous one. Set timeout's to -1 to block until the desired number of bytes are read, or an error happens. |
Definition at line 383 of file CClientTCPSocket.cpp.
References INVALID_SOCKET, MRPT_END, MRPT_START, and THROW_EXCEPTION_FMT.
Referenced by mrpt::hwdrivers::CHokuyoURG::assureBufferHasBytes(), mrpt::hwdrivers::CGPSInterface::doProcess(), mrpt::comms::net::http_request(), and mrpt::hwdrivers::CNTRIPClient::private_ntrip_thread().
|
inherited |
Reads a block of bytes from the stream into Buffer.
std::exception | On any error, or if ZERO bytes are read. |
Definition at line 40 of file CStream.cpp.
References ASSERT_, and THROW_EXCEPTION.
Referenced by mrpt::hwdrivers::CHokuyoURG::assureBufferHasBytes(), mrpt::compress::zip::compress_gz_data_block(), mrpt::compress::zip::decompress(), mrpt::compress::zip::decompress_gz_file(), mrpt::hwdrivers::CGPSInterface::doProcess(), fill_input_buffer(), mrpt::system::loadBinaryFile(), mrpt::utils::CMemoryStream::loadBufferFromFile(), mrpt::hwdrivers::CHokuyoURG::purgeBuffers(), mrpt::utils::CStream::ReadBufferFixEndianness(), and mrpt::utils::CStream::ReadBufferImmediate().
|
inlineinherited |
Reads a sequence of elemental datatypes, taking care of reordering their bytes from the MRPT stream standard (little endianness) to the format of the running architecture.
ElementCount | The number of elements (not bytes) to read. |
ptr | A pointer to the first output element in an array (or std::vector<>, etc...). |
std::exception | On any error, or if ZERO bytes are read. |
Definition at line 108 of file CStream.h.
References mrpt::utils::CStream::ReadBuffer(), and mrpt::mrpt::utils::reverseBytesInPlace().
Referenced by mrpt::math::operator>>(), mrpt::utils::CStream::ReadPOD(), and triangle_readFromStream().
|
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.
std::exception | On any error, or if ZERO bytes are read. |
Reimplemented in mrpt::comms::CInterfaceFTDI.
Definition at line 129 of file CStream.h.
References mrpt::utils::CStream::ReadBuffer().
|
inlineinherited |
Reads an object from stream, its class determined at runtime, and returns a smart pointer to the object.
std::exception | On I/O error or undefined class. |
mrpt::utils::CExceptionEOF | On an End-Of-File condition found at a correct place: an EOF that abruptly finishes in the middle of one object raises a plain std::exception instead. |
Definition at line 207 of file CStream.h.
Referenced by mrpt::utils::mrpt_recv_from_zmq(), mrpt::utils::mrpt_recv_from_zmq_into(), mrpt::utils::OctetVectorToObject(), mrpt::utils::operator>>(), mrpt::nav::CAbstractPTGBasedReactive::performNavigationStep(), mrpt::utils::RawStringToObject(), mrpt::utils::StringToObject(), and TEST().
|
inlineinherited |
Reads an object from stream, its class determined at runtime, and returns a smart pointer to the object.
This version is similar to mrpt::make_aligned_shared<T>.
std::exception | On I/O error or undefined class. |
mrpt::utils::CExceptionEOF | On an End-Of-File condition found at a correct place: an EOF that abruptly finishes in the middle of one object raises a plain std::exception instead. |
Definition at line 217 of file CStream.h.
References mrpt::utils::TRuntimeClassId::createObject(), mrpt::utils::findRegisteredClass(), mrpt::utils::CStream::internal_ReadObject(), and mrpt::utils::CStream::internal_ReadObjectHeader().
|
inherited |
Reads an object from stream, where its class must be the same as the supplied object, where the loaded object will be stored in.
std::exception | On I/O error or different class found. |
mrpt::utils::CExceptionEOF | On an End-Of-File condition found at a correct place: an EOF that abruptly finishes in the middle of one object raises a plain std::exception instead. |
Definition at line 566 of file CStream.cpp.
References ASSERT_, mrpt::utils::TRuntimeClassId::className, mrpt::utils::findRegisteredClass(), mrpt::format(), mrpt::utils::CSerializable::GetRuntimeClass(), THROW_EXCEPTION, and THROW_EXCEPTION_FMT.
|
inlineinherited |
Reads a simple POD type and returns by value.
Useful when stream >> var;
cannot be used becuase of errors of misaligned reference binding. Use with macro MRPT_READ_POD
to avoid typing the type T yourself.
s << var;
is safe for misaligned variables. Definition at line 325 of file CStream.h.
References mrpt::utils::CStream::ReadBufferFixEndianness().
|
inlineinherited |
Reads a variant from stream, its class determined at runtime, and returns a variant to the object.
To be compatible with the current polymorphic system this support smart pointer types. For pointer types, This will bind to the first possible pointer type. variant<CSerializable::Ptr, CRenderizable::Ptr>
std::exception | On I/O error or undefined class. |
mrpt::utils::CExceptionEOF | On an End-Of-File condition found at a correct place: an EOF that abruptly finishes in the middle of one object raises a plain std::exception instead. |
Definition at line 282 of file CStream.h.
References mrpt::utils::TRuntimeClassId::createObject(), mrpt::utils::findRegisteredClass(), mrpt::utils::CStream::internal_ReadObject(), mrpt::utils::CStream::internal_ReadObjectHeader(), mrpt::utils::CStream::ReadVariant_helper(), and THROW_EXCEPTION_FMT.
Referenced by mrpt::utils::operator>>().
bool CClientTCPSocket::receiveMessage | ( | mrpt::utils::CMessage & | inMsg, |
const unsigned int | timeoutStart_ms = 100 , |
||
const unsigned int | timeoutBetween_ms = 1000 |
||
) |
Waits for an incoming message through the TCP stream.
inMsg | The received message is placed here. |
timeoutStart_ms | The maximum timeout (in milliseconds) to wait for the starting of data from the other side. |
timeoutBetween_ms | The maximum timeout (in milliseconds) to wait for a chunk of data after a previous one. |
Definition at line 186 of file CClientTCPSocket.cpp.
References mrpt::system::os::_strcmpi(), mrpt::utils::CMessage::content, and mrpt::utils::CMessage::type.
|
inherited |
Tries to receive a message from the device.
std::exception | On communication errors |
Definition at line 686 of file CStream.cpp.
References mrpt::utils::CMessage::content, MAKEWORD16B, mrpt::system::os::memcpy(), MRPT_END, MRPT_START, and mrpt::utils::CMessage::type.
Referenced by mrpt::hwdrivers::CServoeNeck::disableServo(), mrpt::hwdrivers::CServoeNeck::enableServo(), mrpt::hwdrivers::CRoboticHeadInterface::Get3SoundBuffer(), mrpt::hwdrivers::CRoboticHeadInterface::GetGain(), mrpt::hwdrivers::CEnoseModular::getObservation(), mrpt::hwdrivers::CBoardENoses::getObservation(), mrpt::hwdrivers::CServoeNeck::getRegisterValue(), mrpt::hwdrivers::CRoboticHeadInterface::GetSoundLocation(), mrpt::hwdrivers::CServoeNeck::queryFirmwareVersion(), mrpt::hwdrivers::CBoardENoses::queryFirmwareVersion(), mrpt::hwdrivers::CRoboticHeadInterface::SetGain(), mrpt::hwdrivers::CServoeNeck::setRegisterValue(), and mrpt::hwdrivers::CServoeNeck::setRegisterValueAndSpeed().
|
inlineoverride |
This virtual method has no effect in this implementation over a TCP socket, and its use raises an exception.
Definition at line 115 of file CClientTCPSocket.h.
References MRPT_END, MRPT_START, MRPT_UNUSED_PARAM, and THROW_EXCEPTION.
|
pure virtualinherited |
Introduces a pure virtual method for moving to a specified position in the streamed resource.
he Origin parameter indicates how to interpret the Offset parameter. Origin should be one of the following values:
Implemented in mrpt::utils::CFileStream, mrpt::utils::CFileGZInputStream, mrpt::utils::CFileOutputStream, mrpt::utils::CMemoryStream, mrpt::utils::CFileInputStream, and mrpt::utils::CStdOutStream.
bool CClientTCPSocket::sendMessage | ( | const mrpt::utils::CMessage & | outMsg, |
const int | timeout_ms = -1 |
||
) |
Send a message through the TCP stream.
outMsg | The message to be shown. |
timeout_ms | The maximum timeout (in milliseconds) to wait for the socket in each write operation. |
Definition at line 142 of file CClientTCPSocket.cpp.
References mrpt::utils::CMessage::content, and mrpt::utils::CMessage::type.
|
inherited |
Send a message to the device.
Note that only the low byte from the "type" field will be used.
For frames of size < 255 the frame format is an array of bytes in this order:
For frames of size > 255 the frame format is an array of bytes in this order:
std::exception | On communication errors |
Definition at line 649 of file CStream.cpp.
References mrpt::utils::CMessage::content, mrpt::system::os::memcpy(), MRPT_END, MRPT_START, and mrpt::utils::CMessage::type.
Referenced by mrpt::hwdrivers::CServoeNeck::disableServo(), mrpt::hwdrivers::CServoeNeck::enableServo(), mrpt::hwdrivers::CRoboticHeadInterface::Get3SoundBuffer(), mrpt::hwdrivers::CRoboticHeadInterface::GetGain(), mrpt::hwdrivers::CServoeNeck::getRegisterValue(), mrpt::hwdrivers::CRoboticHeadInterface::GetSoundLocation(), mrpt::hwdrivers::CServoeNeck::queryFirmwareVersion(), mrpt::hwdrivers::CBoardENoses::queryFirmwareVersion(), mrpt::hwdrivers::CRoboticHeadInterface::SetGain(), mrpt::hwdrivers::CServoeNeck::setRegisterValue(), and mrpt::hwdrivers::CServoeNeck::setRegisterValueAndSpeed().
void CClientTCPSocket::sendString | ( | const std::string & | str | ) |
Writes a string to the socket.
std::exception | On communication errors |
Definition at line 134 of file CClientTCPSocket.cpp.
Referenced by mrpt::comms::net::http_request(), and mrpt::hwdrivers::CNTRIPClient::private_ntrip_thread().
int CClientTCPSocket::setSOSendBufffer | ( | const int & | newValue | ) |
Set the size of the SO send buffer.
This buffer is used to store data, and is sended when is full.
newValue | New size of the SO send buffer. |
Definition at line 606 of file CClientTCPSocket.cpp.
int CClientTCPSocket::setTCPNoDelay | ( | const int & | newValue | ) |
Set the TCP no delay option of the protocol (Nagle algorithm).
newValue | New value (0 enable Nagle algorithm, 1 disable). |
Definition at line 575 of file CClientTCPSocket.cpp.
|
overrideprotectedvirtual |
Introduces a 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. This method is implemented as a call to "writeAsync" with infinite timeouts.
Implements mrpt::utils::CStream.
Definition at line 122 of file CClientTCPSocket.cpp.
References MRPT_END, and MRPT_START.
size_t CClientTCPSocket::writeAsync | ( | const void * | Buffer, |
const size_t | Count, | ||
const int | timeout_ms = -1 |
||
) |
A method for writing to the socket with optional timeouts.
The method supports writing block by block as the socket allows us to write more data.
Buffer | The data. |
Cound | The number of bytes to write. |
timeout_ms | The maximum timeout (in milliseconds) to wait for the socket to be available for writing (for each block). Set timeout's to -1 to block until the desired number of bytes are written, or an error happens. |
Definition at line 474 of file CClientTCPSocket.cpp.
References INVALID_SOCKET, MRPT_END, MRPT_START, and THROW_EXCEPTION_FMT.
Referenced by mrpt::hwdrivers::CNTRIPClient::private_ntrip_thread().
Writes a block of bytes to the stream from Buffer.
std::exception | On any error |
Definition at line 64 of file CStream.cpp.
References ASSERT_, and THROW_EXCEPTION.
Referenced by mrpt::compress::zip::compress(), mrpt::utils::CMessage::deserializeIntoExistingObject(), mrpt::utils::CMessage::deserializeIntoNewObject(), mrpt::hwdrivers::CHokuyoURG::displaySensorInfo(), mrpt::hwdrivers::CHokuyoURG::displayVersionInfo(), mrpt::hwdrivers::CNTRIPEmitter::doProcess(), mrpt::hwdrivers::CGPSInterface::doProcess(), empty_output_buffer(), mrpt::hwdrivers::CHokuyoURG::enableSCIP20(), mrpt::hwdrivers::CGPSInterface::implement_parser_NOVATEL_OEM6(), mrpt::obs::gnss::Message_NV_OEM6_GENERIC_FRAME::internal_writeToStream(), mrpt::obs::gnss::Message_NV_OEM6_GENERIC_SHORT_FRAME::internal_writeToStream(), mrpt::obs::gnss::Message_NV_OEM6_RANGECMP::internal_writeToStream(), mrpt::obs::gnss::Message_NV_OEM6_VERSION::internal_writeToStream(), mrpt::utils::mrpt_recv_from_zmq_buf(), mrpt::utils::ObjectToString(), mrpt::hwdrivers::CGPSInterface::OnConnectionEstablished(), mrpt::hwdrivers::CGPSInterface::OnConnectionShutdown(), mrpt::utils::operator<<(), mrpt::utils::CMemoryStream::saveBufferToFile(), mrpt::hwdrivers::CGPSInterface::sendCustomCommand(), mrpt::hwdrivers::CBoardENoses::setActiveChamber(), mrpt::hwdrivers::CHokuyoURG::setHighBaudrate(), mrpt::hwdrivers::CHokuyoURG::setHighSensitivityMode(), mrpt::hwdrivers::CHokuyoURG::setMotorSpeed(), mrpt::hwdrivers::CHokuyoURG::startScanningMode(), mrpt::utils::StringToObject(), mrpt::hwdrivers::CHokuyoURG::switchLaserOff(), mrpt::hwdrivers::CHokuyoURG::switchLaserOn(), term_destination(), mrpt::system::vectorToBinaryFile(), mrpt::utils::CStream::WriteBufferFixEndianness(), mrpt::nav::CLogFileRecord::writeToStream(), mrpt::maps::CWirelessPowerGridMap2D::writeToStream(), mrpt::maps::CGasConcentrationGridMap2D::writeToStream(), mrpt::maps::CHeightGridMap2D_MRF::writeToStream(), mrpt::maps::CReflectivityGridMap2D::writeToStream(), mrpt::obs::CObservation2DRangeScan::writeToStream(), mrpt::maps::COccupancyGridMap2D::writeToStream(), mrpt::obs::CObservationVelodyneScan::writeToStream(), mrpt::maps::CRandomFieldGridMap3D::writeToStream(), mrpt::utils::CImage::writeToStream(), and mrpt::opengl::CRenderizable::writeToStreamRender().
|
inlineinherited |
Writes a sequence of elemental datatypes, taking care of reordering their bytes from the running architecture to MRPT stream standard (little endianness).
ElementCount | The number of elements (not bytes) to write. |
ptr | A pointer to the first input element in an array (or std::vector<>, etc...). Example of usage: |
std::exception | On any error |
Definition at line 159 of file CStream.h.
References mrpt::utils::CStream::WriteBuffer().
Referenced by mrpt::math::operator<<(), triangle_writeToStream(), mrpt::math::CMatrix::writeToStream(), mrpt::math::CMatrixD::writeToStream(), mrpt::maps::CWeightedPointsMap::writeToStream(), mrpt::maps::CColouredPointsMap::writeToStream(), mrpt::maps::CSimplePointsMap::writeToStream(), mrpt::obs::CObservation2DRangeScan::writeToStream(), mrpt::maps::COccupancyGridMap2D::writeToStream(), and mrpt::obs::CObservation3DRangeScan::writeToStream().
|
inherited |
Writes an object to the stream.
Definition at line 158 of file CStream.cpp.
References ASSERT_, mrpt::utils::TRuntimeClassId::className, mrpt::utils::CSerializable::GetRuntimeClass(), MRPT_END, MRPT_START, SERIALIZATION_END_FLAG, and mrpt::utils::CSerializable::writeToStream().
Referenced by mrpt::utils::mrpt_send_to_zmq(), mrpt::utils::ObjectToOctetVector(), mrpt::utils::ObjectToRawString(), mrpt::utils::ObjectToString(), mrpt::math::operator<<(), mrpt::utils::CMessage::serializeObject(), and mrpt::utils::CStream::WriteVariant().
|
inlineinherited |
Definition at line 198 of file CStream.h.
References mrpt::utils::CStream::WriteObject().
Referenced by mrpt::utils::CStream::WriteObject().
|
inlineinherited |
Writes a Variant to the stream.
Definition at line 312 of file CStream.h.
References mrpt::utils::CStream::WriteObject().
|
friend |
Definition at line 38 of file CClientTCPSocket.h.
|
static |
See description of CClientTCPSocket.
Definition at line 42 of file CClientTCPSocket.h.
|
protected |
The handle for the connected TCP socket, or -1.
Definition at line 56 of file CClientTCPSocket.h.
|
protected |
The IP address of the remote part of the connection.
Definition at line 59 of file CClientTCPSocket.h.
|
protected |
The TCP port of the remote part of the connection.
Definition at line 61 of file CClientTCPSocket.h.
Page generated by Doxygen 1.8.14 for MRPT 1.9.9 Git: ae4571287 Thu Nov 23 00:06:53 2017 +0100 at dom oct 27 23:51:55 CET 2019 |