ICP: TCPEventStreamConnection Class Reference

ICP 1

#include <TCPEventStreamer.h>

Inheritance diagram for TCPEventStreamConnection:

Inheritance graph

Public Member Functions
	TCPEventStreamConnection (const Poco::Net::StreamSocket &s, EventStore &es, const CRPTProxy &crpt)

	~TCPEventStreamConnection ()

void	run ()

void	allEventCallback (const DAEEventHeader head, const DetectorEvent32 det_ev, int n, int event_source_id, const int *mapping)

Private Attributes
EventStore &	m_es

std::list < TCPStreamEventDataNeutron * >	m_buffers

LONGLONG	m_discarded_events

bool	m_discarding_events

Poco::RWLock	m_lock

uint32_t	m_bytes_backlog

const CRPTProxy &	m_crpt

Private Attributes inherited from ISIS::Base
Poco::Logger *	m_logger

Poco::LogStream *	m_logstr

Poco::Mutex	m_logger_lock

Static Private Attributes
static uint32_t	MAX_BYTES_BACKLOG = 10000

Additional Inherited Members
Private Member Functions inherited from ISIS::Base
	Base (const std::string &logger_name="UNKNOWN")

void	setLoggerName (const std::string &logger_name)

virtual	~Base ()

virtual std::string	loggingPrefix () const

void	setThisLoggerLevel (int level)

Static Private Member Functions inherited from ISIS::Base
static void	setAllLoggerLevel (int level)

Detailed Description

Definition at line 51 of file TCPEventStreamer.h.

Constructor & Destructor Documentation

TCPEventStreamConnection::TCPEventStreamConnection	(	const Poco::Net::StreamSocket &	s,
		EventStore &	es,
		const CRPTProxy &	crpt
	)

Definition at line 7 of file TCPEventStreamer.cpp.

References ISIS::Base::setLoggerName().

TCPEventStreamConnection::~TCPEventStreamConnection ( )

Definition at line 12 of file TCPEventStreamer.cpp.

References LOGSTR_INFORMATION, m_buffers, and m_bytes_backlog.

Member Function Documentation

void TCPEventStreamConnection::allEventCallback	(	const DAEEventHeader *	head,
		const DetectorEvent32 *	det_ev,
		int	n,
		int	event_source_id,
		const int *	mapping
	)

Definition at line 86 of file TCPEventStreamer.cpp.

References ISISCRPT_STRUCT::cardIndexFromPos(), CRPTProxy::CRPT(), ISISCRPT_STRUCT::dae1SpecForCardIndex(), DAEEventList::DAETimeToOffset(), TCPStreamEventDataNeutron::data, DAEEventHeader::frame_number, TCPStreamEventHeaderNeutron::frame_number, TCPStreamEventHeaderNeutron::frame_time_zero, NeXusEventCallback::getTimeOffset(), TCPStreamEventDataNeutron::head, TCPStreamEventDataNeutron::head_n, TCPStreamEventDataNeutron::isValid(), LOGSTR_NOTICE, LOGSTR_WARNING, m_buffers, m_crpt, m_discarded_events, m_discarding_events, m_lock, TCPStreamEventHeader::Neutron, TCPStreamEventHeaderNeutron::nevents, PPP_TO_UAMPH, DAEEventHeader::protons, TCPStreamEventHeaderNeutron::protons, ISISCRPT_STRUCT::spectrumDAETR(), ISISCRPT_STRUCT::start_time, and DAEEventHeader::time.

Referenced by run().

void TCPEventStreamConnection::run ( )

Definition at line 29 of file TCPEventStreamer.cpp.

References EventStore::addGoodEventCallback(), allEventCallback(), EventStore::clearCallbacks(), TCPStreamEventDataSetup::head_setup, LOGSTR_INFORMATION, LOGSTR_WARNING, m_buffers, m_crpt, m_discarded_events, m_es, m_lock, ISISCRPT_STRUCT::run_number, TCPStreamEventHeaderSetup::start_time, and ISISCRPT_STRUCT::start_time.

Member Data Documentation

std::list<TCPStreamEventDataNeutron*> TCPEventStreamConnection::m_buffers

private

Definition at line 55 of file TCPEventStreamer.h.

Referenced by allEventCallback(), run(), and ~TCPEventStreamConnection().

uint32_t TCPEventStreamConnection::m_bytes_backlog

private

Definition at line 59 of file TCPEventStreamer.h.

Referenced by ~TCPEventStreamConnection().

const CRPTProxy& TCPEventStreamConnection::m_crpt

private

Definition at line 60 of file TCPEventStreamer.h.

Referenced by allEventCallback(), and run().

LONGLONG TCPEventStreamConnection::m_discarded_events

private

Definition at line 56 of file TCPEventStreamer.h.

Referenced by allEventCallback(), and run().

bool TCPEventStreamConnection::m_discarding_events

private

Definition at line 57 of file TCPEventStreamer.h.

Referenced by allEventCallback().

EventStore& TCPEventStreamConnection::m_es

private

Definition at line 54 of file TCPEventStreamer.h.

Referenced by run().

Poco::RWLock TCPEventStreamConnection::m_lock

private

Definition at line 58 of file TCPEventStreamer.h.

Referenced by allEventCallback(), and run().

uint32_t TCPEventStreamConnection::MAX_BYTES_BACKLOG = 10000

staticprivate

Definition at line 61 of file TCPEventStreamer.h.

The documentation for this class was generated from the following files:

/isis2/instcontrol_temp/ICP/newicp/TCPEventStreamer.h
/isis2/instcontrol_temp/ICP/newicp/TCPEventStreamer.cpp