ARPDAS_QNX6 1.0
|
#include <DGcol.h>
Public Member Functions | |
collector () | |
virtual | ~collector () |
void | init () |
void | event (enum dg_event evt) |
DG_data * | receive (const char *name, void *data, int data_size, int synch) |
Protected Member Functions | |
void | commit_tstamp (mfc_t MFCtr, time_t time) |
Protected Attributes | |
static unsigned short | minf_row = 0 |
unsigned short | next_minor_frame |
Static Protected Attributes | |
static unsigned short | majf_row = 0 |
Private Attributes | |
std::list< DG_data * > | data_clients |
collector is the portion of the collection processing that is implemented in the tmpplib.
collector::collector | ( | ) |
Definition at line 6 of file DGcol.cc.
References data_generator::regulated, and data_generator::regulation_optional.
void collector::commit_tstamp | ( | mfc_t | MFCtr, |
time_t | time | ||
) | [protected] |
Does not signal whoever is reading the queue
Reimplemented from data_queue.
Definition at line 24 of file DGcol.cc.
References tstamp_t::mfc_num, tstamp_t::secs, tm_info_t::t_stmp, and tm_info.
void collector::event | ( | enum dg_event | evt | ) | [virtual] |
Reimplemented from data_generator.
Reimplemented in tmc_collector.
Definition at line 17 of file DGcol.cc.
References dg_event_start, majf_row, minf_row, and next_minor_frame.
void collector::init | ( | ) |
General DG initialization. Assumes tm_info structure has been defined. Establishes the connection to the TMbfr, specifying the O_NONBLOCK option for collection. Initializes the queue itself. Creates dispatch queue and registers "DG/cmd" device and initializes timer.
Reimplemented from data_queue.
DG_data * collector::receive | ( | const char * | name, |
void * | data, | ||
int | data_size, | ||
int | synch | ||
) |
Collect_Row() is reponsible for: -determining whether a new timestamp is required -filling in/defining the minor fram counter and synch -populating the row of data New timestamp may be required because: -we just started -the minor frame counter is rolling over -we are greater than TS_MFC_LIMIT minor frames from the old timestamp -we have drifted from realtime somehow Implemented in colmain.skel
Definition at line 43 of file DGcol.cc.
References data_clients, and data_generator::dispatch.
std::list<DG_data *> collector::data_clients [private] |
unsigned short collector::majf_row = 0 [static, protected] |
unsigned short collector::minf_row = 0 [protected] |
unsigned short collector::next_minor_frame [protected] |