#include <CRPTProxy.h>

Inheritance diagram for CRPTProxy:

Classes
struct	parameter_t

Public Types
typedef std::map< std::string, parameter_t >	parameter_map_t

Public Member Functions
ISISCRPT_DATA *	crptData ()

Poco::Mutex &	getLockRef ()

Poco::Mutex &	getDataLockRef ()

const std::string &	statusLog () const

const std::string &	eventLog () const

const std::string &	debugLog () const

const std::string &	monitoringLog () const

const std::string &	timeDiffLog () const

parameter_map_t &	sampleParameters ()

parameter_map_t &	beamlineParameters ()

int	assignLogFiles (const std::string &prefix)

int	assignLogFiles (bool use_full_inst_name_for_files, const std::string &data_dir, int run_number_digits)

void	rawDataUpdated ()

time_t	rawDataUpdateTime () const

isisU32_t	rawDataSizeMax () const

isisU32_t	rawDataSizeUsed () const

std::string	dataFileName () const

std::string	dataSectionName () const

isisU32_t *	rawData ()

const isisU32_t *	rawData () const

isisU32_t *	spectrumIntegrals ()

const isisU32_t *	spectrumIntegrals () const

isisU32_t	dataFileSize () const

void	setICPStartTime (time_t t)

void	zeroAllRawData (DAEstatus &status)

void	zeroUsedRawData (DAEstatus &status)

void	zeroEventRawData (DAEstatus &status)

ISISCRPT_STRUCT *	CRPT ()

const ISISCRPT_STRUCT *	CRPT () const

	CRPTProxy ()

bool	isValid () const

ISISCRPT_STRUCT *	operator-> ()

const ISISCRPT_STRUCT *	operator-> () const

int	flushCRPT (DAEstatus &status, bool flush_raw_data=false)

int	mapCRPT (const std::string &crpt_name, const std::string &crpt_data_name, bool read_only, bool existing)

int	loadOrCreateCRPT (const std::string &crpt_file, const std::string &crpt_name, const std::string &crpt_data_file, const std::string &crpt_data_name, int crpt_data_size, ISISDAE::DAEType dae_type, const std::string &comp_name, boost::function< int(DAEstatus &)> readRecoveryFile, DAEstatus &status)

int	loadOrCreateCRPT (const char crpt_file, const char crpt_name, const char crpt_data_file, const char crpt_data_name, int crpt_data_size, ISISDAE::DAEType dae_type, const char *comp_name, boost::function< int(DAEstatus &)> readRecoveryFile, DAEstatus &status)

int	loadCRPT (const char crpt_file, const char crpt_name, const char crpt_data_file, const char crpt_data_name, int crpt_data_size, bool read_only, DAEstatus &status)

int	loadCRPT (const char crpt_file, HANDLE crpt_fh, const char crpt_name, const char crpt_data_file, HANDLE crpt_data_fh, const char crpt_data_name, int crpt_data_size, bool read_only, DAEstatus &status)

int	unloadCRPT (bool delete_crpt_file, bool delete_crpt_data_file, DAEstatus &status)

int	unloadCRPT (DAEstatus &status)

	~CRPTProxy ()

int	createFrom (CRPTProxy &proxy_clone, int id, bool blank_raw_data, DAEstatus &status)

int	updateFrom (CRPTProxy &proxy_clone, bool copy_raw_data, DAEstatus &status)

int	getIntArrayItem (const char item_name, const long spec_array, int nspec, long *larray, DAEstatus &status) const

int	getIntArrayItem (const char item_name, long larray, DAEstatus &status) const

int	getRealArrayItem (const char item_name, const long spec_array, int nspec, double *darray, DAEstatus &status) const

int	getRealArrayItem (const char item_name, const long spec_array, int nspec, float *farray, DAEstatus &status) const

int	getRealArrayItem (const char item_name, double darray, DAEstatus &status) const

int	getRealArrayItem (const char item_name, float farray, DAEstatus &status) const

bool	isRawDataCacheValid () const

uint32_t	spectrumCRPTOffset (int spec, int daq_period) const

Static Public Member Functions
static void	histogramEventsToCRPT (const ISISCRPT_STRUCT crpt1, const ISISCRPT_STRUCT crpt2, ISISCRPT_DATA crpt_data1, ISISCRPT_DATA crpt_data2, const DAEEventHeader head, const DetectorEvent32 ev, int n, int event_source_id)

static void	histogramEventsToCRPT (CRPTProxy &crpt, const DAEEventHeader head, const DetectorEvent32 ev, int n, int event_source_id)

static void	histogramEventsToCRPT (CRPTProxy &crpt1, CRPTProxy &crpt2, const DAEEventHeader head, const DetectorEvent32 ev, int n, int event_source_id)

Private Member Functions
	CRPTProxy (const CRPTProxy &)

void	invalidateHandles ()

int	flushSection (void *address, HANDLE file_handle, DAEstatus &status)

Private Attributes
Poco::Mutex	m_crpt_lock

Poco::Mutex	m_data_lock

ISISCRPT_STRUCT *	m_crpt

ISISCRPT_DATA	m_crpt_data

HANDLE	m_crpt_fh

HANDLE	m_crpt_fm

ISISDAE::DAEType	m_dae_type

std::string	m_comp_name

std::string	m_crpt_file

std::string	m_crpt_name
	name of memory section More...

time_t	m_raw_data_update_time

std::string	m_status_log
	time of last full scale update of raw_data More...

std::string	m_event_log

std::string	m_debug_log

std::string	m_monitoring_log

std::string	m_timediff_log

parameter_map_t	m_sample_parameters

parameter_map_t	m_beamline_parameters

Additional Inherited Members
Protected 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 Protected Member Functions inherited from ISIS::Base
static void	setAllLoggerLevel (int level)

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

Poco::LogStream *	m_logstr

Poco::Mutex	m_logger_lock

Detailed Description

Definition at line 238 of file CRPTProxy.h.

Member Typedef Documentation

typedef std::map<std::string, parameter_t> CRPTProxy::parameter_map_t

Definition at line 248 of file CRPTProxy.h.

Constructor & Destructor Documentation

CRPTProxy::CRPTProxy ( const CRPTProxy & )

inlineprivate

Definition at line 273 of file CRPTProxy.h.

CRPTProxy::CRPTProxy ( )

Definition at line 4 of file CRPTProxy.cpp.

References invalidateHandles().

CRPTProxy::~CRPTProxy ( )

inline

Definition at line 368 of file CRPTProxy.h.

References unloadCRPT().

Member Function Documentation

int CRPTProxy::assignLogFiles ( const std::string & prefix )

Definition at line 388 of file CRPTProxy.cpp.

References m_debug_log, m_event_log, m_monitoring_log, m_status_log, m_timediff_log, and DAEstatus::Success.

Referenced by assignLogFiles(), ISISinstrumentControl::endRunMain(), and ISISinstrumentControl::ISISinstrumentControl().

int CRPTProxy::assignLogFiles	(	bool	use_full_inst_name_for_files,
		const std::string &	data_dir,
		int	run_number_digits
	)

Definition at line 399 of file CRPTProxy.cpp.

References assignLogFiles(), ISISCRPT_STRUCT::inst_abrv, ISISCRPT_STRUCT::inst_name, m_crpt, NULL_TERMINATE, and ISISCRPT_STRUCT::run_number.

parameter_map_t& CRPTProxy::beamlineParameters ( )

inline

Definition at line 293 of file CRPTProxy.h.

References m_beamline_parameters.

Referenced by ISISinstrumentControl::setBeamlineParameters(), ISISinstrumentControl::updateCRPTwithSE(), and ISISinstrumentControl::updateFunc().

int CRPTProxy::createFrom	(	CRPTProxy &	proxy_clone,
		int	id,
		bool	blank_raw_data,
		DAEstatus &	status
	)

Definition at line 355 of file CRPTProxy.cpp.

References createEmptyFile(), dataFileName(), dataFileSize(), dataSectionName(), loadCRPT(), m_crpt_file, m_crpt_name, rawDataSizeMax(), and updateFrom().

ISISCRPT_STRUCT* CRPTProxy::CRPT ( )

inline

Definition at line 348 of file CRPTProxy.h.

References m_crpt.

Referenced by TCPEventStreamConnection::allEventCallback(), ISISinstrumentControl::endRunTask(), histogramEventsToCRPT(), ISISinstrumentControl::ISISinstrumentControl(), ISISinstrumentControl::loadCRPTWithHistogrammedEvents(), ISISinstrumentControl::readISISRAW(), ISISinstrumentControl::saveCRPTToFile(), ISISinstrumentControl::writeISISNeXus(), and ISISinstrumentControl::writeISISRAW().

const ISISCRPT_STRUCT* CRPTProxy::CRPT ( ) const

inline

Definition at line 349 of file CRPTProxy.h.

References m_crpt.

ISISCRPT_DATA* CRPTProxy::crptData ( )

inline

Definition at line 284 of file CRPTProxy.h.

References m_crpt_data.

Referenced by ISISinstrumentControl::loadCRPTWithHistogrammedEvents().

std::string CRPTProxy::dataFileName ( ) const

inline

Definition at line 300 of file CRPTProxy.h.

References ISISCRPT_DATA::fileName(), and m_crpt_data.

Referenced by createFrom().

isisU32_t CRPTProxy::dataFileSize ( ) const

inline

Definition at line 320 of file CRPTProxy.h.

References ISISCRPT_DATA::fileSizeMax(), and m_crpt_data.

Referenced by createFrom().

std::string CRPTProxy::dataSectionName ( ) const

inline

Definition at line 301 of file CRPTProxy.h.

References m_crpt_data, and ISISCRPT_DATA::sectionName().

Referenced by createFrom().

const std::string& CRPTProxy::debugLog ( ) const

inline

Definition at line 289 of file CRPTProxy.h.

References m_debug_log.

Referenced by ISISinstrumentControl::allReportFuncMain(), and ISISinstrumentControl::ISISinstrumentControl().

const std::string& CRPTProxy::eventLog ( ) const

inline

Definition at line 288 of file CRPTProxy.h.

References m_event_log.

Referenced by ISISinstrumentControl::logEvent().

int CRPTProxy::flushCRPT	(	DAEstatus &	status,
		bool	flush_raw_data = `false`
	)

Definition at line 30 of file CRPTProxy.cpp.

References DAEstatus::Failure, ISISCRPT_DATA::flush(), flushSection(), m_crpt, m_crpt_data, m_crpt_fh, and DAEstatus::Success.

Referenced by ISISinstrumentControl::flushCRPT(), loadOrCreateCRPT(), ISISinstrumentControl::updateCRPTWithDAE(), and updateFrom().

int CRPTProxy::flushSection	(	void *	address,
		HANDLE	file_handle,
		DAEstatus &	status
	)

private

Definition at line 10 of file CRPTProxy.cpp.

References DAEstatus::addVa(), ERRTYPE_OUTOFMEM, FAC_CRPT, DAEstatus::Failure, SEV_ERROR, and DAEstatus::Success.

Referenced by flushCRPT().

Poco::Mutex& CRPTProxy::getDataLockRef ( )

inline

Definition at line 286 of file CRPTProxy.h.

References m_data_lock.

Referenced by ISISinstrumentControl::updateCRPTWithDAE().

int CRPTProxy::getIntArrayItem	(	const char *	item_name,
		const long *	spec_array,
		int	nspec,
		long *	larray,
		DAEstatus &	status
	)		const

inline

Definition at line 374 of file CRPTProxy.h.

References ISISCRPT_STRUCT::getIntArrayItem(), m_crpt, rawData(), and rawDataSizeMax().

Referenced by ISISinstrumentControl::getIntArrayItem(), and ISISDSRequest::processCommand().

int CRPTProxy::getIntArrayItem	(	const char *	item_name,
		long *	larray,
		DAEstatus &	status
	)		const

inline

Definition at line 378 of file CRPTProxy.h.

References ISISCRPT_STRUCT::getIntArrayItem(), m_crpt, rawData(), and rawDataSizeMax().

Poco::Mutex& CRPTProxy::getLockRef ( )

inline

Definition at line 285 of file CRPTProxy.h.

References m_crpt_lock.

int CRPTProxy::getRealArrayItem	(	const char *	item_name,
		const long *	spec_array,
		int	nspec,
		double *	darray,
		DAEstatus &	status
	)		const

inline

Definition at line 382 of file CRPTProxy.h.

References ISISCRPT_STRUCT::getRealArrayItem(), m_crpt, rawData(), and rawDataSizeMax().

Referenced by ISISinstrumentControl::getRealArrayItem(), and ISISDSRequest::processCommand().

int CRPTProxy::getRealArrayItem	(	const char *	item_name,
		const long *	spec_array,
		int	nspec,
		float *	farray,
		DAEstatus &	status
	)		const

inline

Definition at line 386 of file CRPTProxy.h.

References ISISCRPT_STRUCT::getRealArrayItem(), m_crpt, rawData(), and rawDataSizeMax().

int CRPTProxy::getRealArrayItem	(	const char *	item_name,
		double *	darray,
		DAEstatus &	status
	)		const

inline

Definition at line 390 of file CRPTProxy.h.

References ISISCRPT_STRUCT::getRealArrayItem(), m_crpt, rawData(), and rawDataSizeMax().

int CRPTProxy::getRealArrayItem	(	const char *	item_name,
		float *	farray,
		DAEstatus &	status
	)		const

inline

Definition at line 394 of file CRPTProxy.h.

References ISISCRPT_STRUCT::getRealArrayItem(), m_crpt, rawData(), and rawDataSizeMax().

void CRPTProxy::histogramEventsToCRPT	(	const ISISCRPT_STRUCT *	crpt1,
		const ISISCRPT_STRUCT *	crpt2,
		ISISCRPT_DATA *	crpt_data1,
		ISISCRPT_DATA *	crpt_data2,
		const DAEEventHeader *	head,
		const DetectorEvent32 *	ev,
		int	n,
		int	event_source_id
	)

static

Todo:: clarify period - think this will always be DAQ as from DC this may get called by multiple threads, hence mutex

Definition at line 437 of file CRPTProxy.cpp.

References ISISCRPT_STRUCT::cardIndexFromPos(), ISISCRPT_STRUCT::dae1SpecForCardIndex(), ISISCRPT_DATA::incrementSpectrum(), ISISCRPT_STRUCT::nper_daq, DAEEventHeader::period, ISISCRPT_STRUCT::randomisedChannelRebin(), ISISCRPT_DATA::rawData(), ISISCRPT_DATA::rawDataSizeMax(), ISISCRPT_STRUCT::spectrumCRPTOffsetImpl(), ISISCRPT_STRUCT::spectrumCRPTTR(), ISISCRPT_STRUCT::spectrumDAETR(), ISISCRPT_STRUCT::tcb_map, and DetectorEvent32::time_channel.

Referenced by ISISinstrumentControl::endRunMain(), histogramEventsToCRPT(), ISISinstrumentControl::ISISinstrumentControl(), and ISISinstrumentControl::loadCRPTWithHistogrammedEvents().

void CRPTProxy::histogramEventsToCRPT	(	CRPTProxy &	crpt,
		const DAEEventHeader *	head,
		const DetectorEvent32 *	ev,
		int	n,
		int	event_source_id
	)

static

Definition at line 420 of file CRPTProxy.cpp.

References CRPT(), histogramEventsToCRPT(), and m_crpt_data.

void CRPTProxy::histogramEventsToCRPT	(	CRPTProxy &	crpt1,
		CRPTProxy &	crpt2,
		const DAEEventHeader *	head,
		const DetectorEvent32 *	ev,
		int	n,
		int	event_source_id
	)

static

Definition at line 425 of file CRPTProxy.cpp.

References CRPT(), histogramEventsToCRPT(), and m_crpt_data.

void CRPTProxy::invalidateHandles ( )

inlineprivate

Definition at line 274 of file CRPTProxy.h.

References ISISCRPT_DATA::init(), m_crpt, m_crpt_data, m_crpt_fh, and m_crpt_fm.

Referenced by CRPTProxy(), mapCRPT(), and unloadCRPT().

bool CRPTProxy::isRawDataCacheValid ( ) const

inline

Definition at line 398 of file CRPTProxy.h.

References m_crpt, m_raw_data_update_time, and ISISCRPT_STRUCT::start_time.

bool CRPTProxy::isValid ( ) const

inline

Definition at line 351 of file CRPTProxy.h.

References m_crpt.

Referenced by ISISinstrumentControl::allReportFuncMain(), ISISinstrumentControl::changeUpdateSettingsXML(), ISISinstrumentControl::getOptions(), ISISinstrumentControl::ISISinstrumentControl(), ISISinstrumentControl::logEvent(), ISISinstrumentControl::refreshCachedValues(), ISISinstrumentControl::setOptions(), ISISinstrumentControl::updateFunc(), and ISISinstrumentControl::updateStatusXML().

int CRPTProxy::loadCRPT	(	const char *	crpt_file,
		const char *	crpt_name,
		const char *	crpt_data_file,
		const char *	crpt_data_name,
		int	crpt_data_size,
		bool	read_only,
		DAEstatus &	status
	)

Todo:: use file_attributes ?

Definition at line 204 of file CRPTProxy.cpp.

References DAEstatus::addVa(), defaultNoInheritHandles(), ERRTYPE_OUTOFMEM, FAC_CRPT, DAEstatus::Failure, and SEV_ERROR.

Referenced by createFrom().

int CRPTProxy::loadCRPT	(	const char *	crpt_file,
		HANDLE	crpt_fh,
		const char *	crpt_name,
		const char *	crpt_data_file,
		HANDLE	crpt_data_fh,
		const char *	crpt_data_name,
		int	crpt_data_size,
		bool	read_only,
		DAEstatus &	status
	)

Definition at line 226 of file CRPTProxy.cpp.

References DAEstatus::add(), DAEstatus::addVa(), ISISCRPT_STRUCT::crpt_load_time, defaultNoInheritHandles(), ERRTYPE_OUTOFMEM, FAC_CRPT, DAEstatus::Failure, ISISCRPT_DATA::load(), m_crpt, m_crpt_data, m_crpt_fh, m_crpt_file, m_crpt_fm, m_crpt_name, m_raw_data_update_time, SEV_ERROR, SEV_WARNING, DAEstatus::Success, and unloadCRPT().

int CRPTProxy::loadOrCreateCRPT	(	const std::string &	crpt_file,
		const std::string &	crpt_name,
		const std::string &	crpt_data_file,
		const std::string &	crpt_data_name,
		int	crpt_data_size,
		ISISDAE::DAEType	dae_type,
		const std::string &	comp_name,
		boost::function< int(DAEstatus &)>	readRecoveryFile,
		DAEstatus &	status
	)

Definition at line 76 of file CRPTProxy.cpp.

Referenced by ISISinstrumentControl::loadCRPT().

int CRPTProxy::loadOrCreateCRPT	(	const char *	crpt_file,
		const char *	crpt_name,
		const char *	crpt_data_file,
		const char *	crpt_data_name,
		int	crpt_data_size,
		ISISDAE::DAEType	dae_type,
		const char *	comp_name,
		boost::function< int(DAEstatus &)>	readRecoveryFile,
		DAEstatus &	status
	)