1 #ifndef __JNET__JLIGIEROBJECTITERATOR__
2 #define __JNET__JLIGIEROBJECTITERATOR__
19 namespace JPP {
using namespace JNET; }
86 for (const_iterator channel = this->begin(); channel != this->end(); ++channel) {
87 if (!channel->isReady()) {
94 for (
iterator channel = this->begin(); channel != this->end(); ) {
102 if (channel->isReady()) {
104 if (channel->prefix.getTag() == getTag<T>()) {
106 channel->seekg(
sizeof(
JPrefix));
120 catch(
const exception& error) {
124 channel = this->erase(channel);
int getSizeOfPacket(const KM3NETDAQ::JDAQAbstractPreamble &preamble)
Get size of packeet.
virtual bool setObject(T &object) override
Set object.
int getSize() const
Get size.
Abstract object iterator.
void setReaderMask(const JAbstractFile &file)
Set reader mask.
int getFileDescriptor() const
Get file descriptor.
do set_variable OUTPUT_DIRECTORY $WORKDIR T
Wrapper class for select call.
void setReceiveBufferSize(const int size)
Set receive buffer size.
JLigierObjectIterator(const int port, const int backlog, const int buffer_size=262144, const int timeout_us=10)
Constructor.
Object iteration through ControlHost server.
void setNonBlocking(const bool on)
Set non-blocking of I/O.
JSocketInputChannel< JPrefix_t > JSocketInputChannel_t
void setKeepAlive(const bool on)
Set keep alive of socket.
bool hasReaderMask(const JAbstractFile &file) const
Has reader file.