Go to the documentation of this file. 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 getFileDescriptor() const
Get file descriptor.
JSocketInputChannel< JPrefix_t > JSocketInputChannel_t
Object iteration through ControlHost server.
Interprocess communication.
void setReceiveBufferSize(const int size)
Set receive buffer size.
Wrapper class for select call.
This name space includes all other name spaces (except KM3NETDAQ, KM3NET and ANTARES).
bool hasReaderMask(const JAbstractFile &file) const
Has reader file.
void accept(const int server)
Accept connection from a server.
Abstract object iterator.
void setKeepAlive(const bool on)
Set keep alive of socket.
void setReaderMask(const JAbstractFile &file)
Set reader mask.
void setNonBlocking(const bool on)
Set non-blocking of I/O.
virtual bool setObject(T &object)
Set object.
JLigierObjectIterator(const int port, const int backlog, const int buffer_size=262144, const int timeout_us=10)
Constructor.
int getSize() const
Get size.
int getSizeOfPacket(const KM3NETDAQ::JDAQAbstractPreamble &preamble)
Get size of packeet.