1 #ifndef __JNET__JSOCKETCHANNEL__
2 #define __JNET__JSOCKETCHANNEL__
17 namespace JPP {
using namespace JNET; }
33 template<
class JPrefix_t>
44 template<
class JPrefix_t>
85 template<
class JPrefix_t>
192 template<
class JPrefix_t>
226 const int length =
tellp();
virtual int read(char *buffer, const int length) override
Read byte array.
JByteArrayReader()
Default constructor.
Byte array binary output.
int tellp() const
Get write position.
void seekp(const int pos)
Set write position.
virtual int write(const char *buffer, const int length) override
Write byte array.
Exception for socket channel.
void set(const JSocketBuffer< JElement_t > &buffer)
Initialise buffer.
Auxiliary class for socket channel.
void reset()
Reset channel.
Non-blocking socket reader.
JStatus_t read()
Continuation of non-blocking read method.
Non-blocking socket writer.
JStatus_t write()
Continuation of non-blocking write method.
JSocketOutputChannel(JTCPSocket &socket)
Constructor.
void reset()
Reset channel.
JStatus_t write()
Interruptable write method.
JStatus_t getStatus() const
Get status of I/O.
bool isReady() const
Check ready status.
bool isBusy() const
Check busy status.
bool isReset() const
Check reset status.
int getSizeOfPacket(const KM3NETDAQ::JDAQAbstractPreamble &preamble)
Get size of packeet.
void setSizeOfPacket(const int size, JPrefix_t &prefix)
Set total size of internet packet.
This name space includes all other name spaces (except KM3NETDAQ, KM3NET and ANTARES).