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();
void seekp(const int pos)
Set write position.
void set(const JSocketBuffer< JElement_t > &buffer)
Initialise buffer.
int getSizeOfPacket(const KM3NETDAQ::JDAQAbstractPreamble &preamble)
JSocketOutputChannel(JSocket &socket)
Constructor.
virtual int write(const char *buffer, const int length)
Write byte array.
Exception for socket channel.
JStatus_t write()
Interruptable write method.
Non-blocking socket reader.
Auxiliary class for socket channel.
void reset()
Reset channel.
JStatus_t getStatus() const
Get status of I/O.
Non-blocking socket writer.
bool isReady() const
Check ready status.
JStatus_t write()
Continuation of non-blocking write method.
JStatus_t read()
Continuation of non-blocking read method.
bool isReset() const
Check reset status.
virtual int read(char *buffer, const int length)
Read byte array.
void setSizeOfPacket(const int size, JPrefix_t &prefix)
Set total size of internet packet.
Byte array binary output.
JByteArrayReader()
Default constructor.
bool isBusy() const
Check busy status.
int tellp() const
Get write position.
void reset()
Reset channel.