Interprocess communication. More...

Classes
class	JClient
	ControlHost client manager. More...

class	JClientList
	List of ControlHost client managers. More...

class	JControlHost
	ControlHost class. More...

class	JControlHostObjectIterator
	Object iteration through ControlHost. More...

class	JControlHostObjectOutput
	Implemenation of object output through ControlHost. More...

class	JControlHostObjectOutput< JTypeList< JHead_t, JNullType > >
	Terminator class of recursive JControlHostObjectOutput class. More...

class	JControlHostObjectOutput< JTypeList< JHead_t, JTail_t > >
	Implementation of object output for multiple data types. More...

class	JControlHostServer
	Light-weight wrapper class around server socket. More...

class	JDispatch
	Data structure of a ControlHost message. More...

struct	JHostname
	Auxiliary data structure for hostname and port number. More...

class	JLigierObjectIterator
	Object iteration through ControlHost server. More...

class	JMemory_t

class	JPrefix
	ControlHost prefix. More...

class	JSelect
	Wrapper class for select call. More...

class	JSelectReader
	Wrapper class for select call. More...

class	JSelectWriter
	Wrapper class for select call. More...

class	JServerSocket
	TCP Server socket. More...

class	JSocket
	Socket class. More...

class	JSocketAddress
	The JSocketAddress class encapsulates the `sockaddr_in` data structure. More...

class	JSocketBlocking
	Blocking socket I/O. More...

class	JSocketBuffer
	Auxiliary class for non-blocking socket I/O. More...

class	JSocketChannel
	Auxiliary class for socket channel. More...

class	JSocketInputChannel
	Socket input channel. More...

class	JSocketNonblockingReader
	Non-blocking socket reader. More...

class	JSocketNonblockingWriter
	Non-blocking socket writer. More...

class	JSocketOutputChannel
	Socket output channel. More...

class	JSocketStatus
	Auxiliary class for non-blocking socket I/O. More...

class	JSubscription
	ControlHost subscription. More...

struct	JSubscriptionAll
	Auxiliary class for all subscription. More...

struct	JSubscriptionAny
	Auxiliary class for any subscription. More...

class	JSubscriptionList
	Subscription list. More...

class	JTag
	ControlHost tag. More...

class	JUDPSocket
	Server socket. More...

Typedefs
typedef JControlHost	ControlHost
	Match name. More...

typedef JControlHostServer	ControlServ
	Match name. More...

typedef JPrefix	JPrefix_t

typedef JSocketInputChannel< JPrefix_t >	JSocketInputChannel_t

typedef JSocketBuffer< char >	JSocketInputBuffer

typedef JSocketBuffer< const char >	JSocketOutputBuffer

typedef long long int	JTag_t
	Type definition of numerical ControlHost tag. More...

Enumerations
enum	JSubscription_t { SUBSCRIBE_ALL = 'a', SUBSCRIBE_ANY = 'w' }
	ControlHost subscription types. More...

Functions
template<>
int	getSizeOfPacket (const KM3NETDAQ::JDAQAbstractPreamble &preamble)
	Get size of packeet. More...

JSubscriptionList	operator+ (const JSubscription &first, const JSubscription &second)
	Add operator. More...

int	getSizeOfPacket (const JPrefix_t &prefix)
	Get total size of internet packet. More...

void	setSizeOfPacket (const int size, JPrefix_t &prefix)
	Set total size of internet packet. More...

std::ostream &	operator<< (std::ostream &out, const JDispatch &message)
	Print message. More...

std::ostream &	operator<< (std::ostream &out, const JSocket &socket)
	Print socket. More...

std::ostream &	operator<< (std::ostream &out, const JSocketStatus &status)
	Print socket status. More...

std::ostream &	operator<< (std::ostream &out, const JSocketInputBuffer &buffer)
	Print socket input buffer. More...

bool	operator< (const JTag &first, const JTag &second)
	Less than operator for JTag. More...

bool	operator== (const JTag &first, const JTag &second)
	Equal operator for JTag. More...

bool	operator!= (const JTag &first, const JTag &second)
	Not equal operator for JTag. More...

Variables
static const std::string	CHOO_VERSION = "1.0"

static const int	DISPATCH_PORT = 5553
	Default ControlHost port. More...

static const size_t	TAGSIZE = sizeof(JTag_t)

static const JTag	DISPTAG_Subscribe ("_Subscri")
	Special ControlHost tags. More...

static const JTag	DISPTAG_Gime ("_Gime")

static const JTag	DISPTAG_Always ("_Always")

static const JTag	DISPTAG_MyId ("_MyId")

static const JTag	DISPTAG_Born ("Born")

static const JTag	DISPTAG_Died ("Died")

static const JTag	DISPTAG_ShowStat ("_ShowSta")

static const JTag	DISPTAG_WhereIs ("_WhereIs")

static const JTag	DISPTAG_Version ("_Version")

static const JTag	DISPTAG_Debug ("_Debug")

static const JTag	DISPTAG_UNDEFINED (0)

Detailed Description

Interprocess communication.

Author: mdejong; cpellegrino

Typedef Documentation

◆ ControlHost

typedef JControlHost JNET::ControlHost

Match name.

Definition at line 701 of file JControlHost.hh.

◆ ControlServ

typedef JControlHostServer JNET::ControlServ

Match name.

Definition at line 70 of file JControlHostServer.hh.

◆ JPrefix_t

typedef JPrefix JNET::JPrefix_t

Definition at line 29 of file JLigier.cc.

◆ JSocketInputChannel_t

typedef JSocketInputChannel< JPrefix > JNET::JSocketInputChannel_t

Definition at line 30 of file JLigier.cc.

◆ JSocketInputBuffer

typedef JSocketBuffer<char> JNET::JSocketInputBuffer

Definition at line 109 of file JSocketNonblocking.hh.

◆ JSocketOutputBuffer

typedef JSocketBuffer<const char> JNET::JSocketOutputBuffer

Definition at line 110 of file JSocketNonblocking.hh.

◆ JTag_t

typedef long long int JNET::JTag_t

Type definition of numerical ControlHost tag.

Definition at line 28 of file JTag.hh.

Enumeration Type Documentation

◆ JSubscription_t

enum JNET::JSubscription_t

ControlHost subscription types.

Enumerator
SUBSCRIBE_ALL
SUBSCRIBE_ANY

Definition at line 39 of file JControlHost.hh.

                        { 
     SUBSCRIBE_ALL            = 'a',
     SUBSCRIBE_ANY            = 'w'
     //SUBSCRIBE_SHARED_MEMORY  = 'm'
   };

Function Documentation

◆ getSizeOfPacket() [1/2]

template<>

int JNET::getSizeOfPacket ( const KM3NETDAQ::JDAQAbstractPreamble & preamble )

inline

Get size of packeet.

Parameters

preamble DAQ data preamble

Returns: size [B]

Definition at line 75 of file JDataFilter.cc.

   { 
     return preamble.getLength();
   }

◆ operator+()

JSubscriptionList JNET::operator+	(	const JSubscription &	first,
		const JSubscription &	second
	)

inline

Add operator.

Parameters

first	subscription
second	subscription

Returns: subscription list

Definition at line 233 of file JControlHost.hh.

   {
     JSubscriptionList buffer;
  
     buffer.add(first);
     buffer.add(second);
  
     return buffer;
   }

◆ getSizeOfPacket() [2/2]

int JNET::getSizeOfPacket ( const JPrefix_t & prefix )

inline

Get total size of internet packet.

Get size of data, including the header.

Parameters

prefix prefix

Returns: number of bytes

This method should be implemented for each template class for read operations.

Parameters

prefix prefix

Returns: number of bytes

Definition at line 39 of file JLigier.cc.

   {
     return prefix.getSize() + sizeof(JPrefix_t);
   }

◆ setSizeOfPacket()

void JNET::setSizeOfPacket	(	const int	size,
		JPrefix_t &	prefix
	)

inline

Set total size of internet packet.

Set size of data, including the header.

Parameters

size	number of bytes
prefix	prefix

This method should be implemented for each template class for write operations.

Parameters

prefix	prefix
size	number of bytes

Definition at line 51 of file JLigier.cc.

   {
     prefix.setSize(size - sizeof(JPrefix_t));
   }

◆ operator<<() [1/4]

std::ostream& JNET::operator<<	(	std::ostream &	out,
		const JDispatch &	message
	)

inline

Print message.

Parameters

out	output stream
message	message

Returns: output stream

Definition at line 498 of file JLigier.cc.

   {
     return out << "(" << message.getTag() << "," << message.size() << ")";
   }

◆ operator<<() [2/4]

std::ostream& JNET::operator<<	(	std::ostream &	out,
		const JSocket &	socket
	)

inline

Print socket.

Parameters

out	output stream
socket	socket

Returns: output stream

Definition at line 511 of file JLigier.cc.

   {
     return out << "[" << socket.getFileDescriptor() << "]";
   }

◆ operator<<() [3/4]

std::ostream& JNET::operator<<	(	std::ostream &	out,
		const JSocketStatus &	status
	)

inline

Print socket status.

Parameters

out	output stream
status	socket status

Returns: output stream

Definition at line 524 of file JLigier.cc.

   {
     return out << "(" << status.isReady() << "," << status.getCounter() << ")";
   }

◆ operator<<() [4/4]

std::ostream& JNET::operator<<	(	std::ostream &	out,
		const JSocketInputBuffer &	buffer
	)

inline

Print socket input buffer.

Parameters

out	output stream
buffer	socket buffer

Returns: output stream

Definition at line 537 of file JLigier.cc.

   {
     return out << "(" << buffer.isReady() << "," << buffer.getCounter() << "," << buffer.getSize() << ")";
   }

◆ operator<()

bool JNET::operator<	(	const JTag &	first,
		const JTag &	second
	)

inline

Less than operator for JTag.

Parameters

first	tag
second	tag

Returns

Definition at line 260 of file JTag.hh.

   {
     return first.getID() < second.getID();
   }

◆ operator==()

bool JNET::operator==	(	const JTag &	first,
		const JTag &	second
	)

inline

Equal operator for JTag.

Parameters

first	tag
second	tag

Returns

Definition at line 273 of file JTag.hh.

   {
     return first.getID() == second.getID();
   }

◆ operator!=()

bool JNET::operator!=	(	const JTag &	first,
		const JTag &	second
	)

inline

Not equal operator for JTag.

Parameters

first	tag
second	tag

Returns

Definition at line 286 of file JTag.hh.

   {
     return first.getID() != second.getID();
   }

Variable Documentation

◆ CHOO_VERSION

const std::string JNET::CHOO_VERSION = "1.0"

static

Definition at line 33 of file JControlHost.hh.

◆ DISPATCH_PORT

const int JNET::DISPATCH_PORT = 5553

static

Default ControlHost port.

Definition at line 24 of file JHostname.hh.

◆ TAGSIZE

const size_t JNET::TAGSIZE = sizeof(JTag_t)

static

Definition at line 29 of file JTag.hh.

◆ DISPTAG_Subscribe

const JTag JNET::DISPTAG_Subscribe("_Subscri")

static

Special ControlHost tags.

◆ DISPTAG_Gime

const JTag JNET::DISPTAG_Gime("_Gime")

static

◆ DISPTAG_Always

const JTag JNET::DISPTAG_Always("_Always")

static

◆ DISPTAG_MyId

const JTag JNET::DISPTAG_MyId("_MyId")

static

◆ DISPTAG_Born

const JTag JNET::DISPTAG_Born("Born")

static

◆ DISPTAG_Died

const JTag JNET::DISPTAG_Died("Died")

static

◆ DISPTAG_ShowStat

const JTag JNET::DISPTAG_ShowStat("_ShowSta")

static

◆ DISPTAG_WhereIs

const JTag JNET::DISPTAG_WhereIs("_WhereIs")

static

◆ DISPTAG_Version

const JTag JNET::DISPTAG_Version("_Version")

static

◆ DISPTAG_Debug

const JTag JNET::DISPTAG_Debug("_Debug")

static

◆ DISPTAG_UNDEFINED

const JTag JNET::DISPTAG_UNDEFINED(0)

static

Classes

Typedefs

Enumerations

Functions

Variables

Detailed Description

Typedef Documentation

◆ ControlHost

◆ ControlServ

◆ JPrefix_t

◆ JSocketInputChannel_t

◆ JSocketInputBuffer

◆ JSocketOutputBuffer

◆ JTag_t

Enumeration Type Documentation

◆ JSubscription_t

Function Documentation

◆ getSizeOfPacket() [1/2]

◆ operator+()

◆ getSizeOfPacket() [2/2]

◆ setSizeOfPacket()

◆ operator<<() [1/4]

◆ operator<<() [2/4]

◆ operator<<() [3/4]

◆ operator<<() [4/4]

◆ operator<()

◆ operator==()

◆ operator!=()

Variable Documentation

◆ CHOO_VERSION

◆ DISPATCH_PORT

◆ TAGSIZE

◆ DISPTAG_Subscribe

◆ DISPTAG_Gime

◆ DISPTAG_Always

◆ DISPTAG_MyId

◆ DISPTAG_Born

◆ DISPTAG_Died

◆ DISPTAG_ShowStat

◆ DISPTAG_WhereIs

◆ DISPTAG_Version

◆ DISPTAG_Debug

◆ DISPTAG_UNDEFINED