#include <DG.h>

Inheritance diagram for data_generator:

Collaboration diagram for data_generator:

Public Member Functions
	data_generator (int nQrows, int low_water)
virtual	~data_generator ()
void	init (int collection)
void	operate ()
int	execute (const char *cmd)
virtual void	event (enum dg_event evt)
virtual void	service_row_timer ()=0
Public Attributes
DG_dispatch *	dispatch
Protected Member Functions
void	transmit_data (int single_row)
Protected Attributes
bool	quit
bool	started
bool	regulated
bool	autostart
bool	regulation_optional
int	dg_bfr_fd
DG_cmd *	cmd
DG_tmr *	tmr
Private Member Functions
void	tm_start (int lock_needed=1)
void	tm_play (int lock_needed=1)
void	tm_stop ()
void	check_writev (int rc, int wr_size, const char *where)
Private Attributes
uint64_t	row_period_nsec_default
uint64_t	row_period_nsec_current

Detailed Description

Definition at line 15 of file DG.h.

Constructor & Destructor Documentation

data_generator::data_generator	(	int	nQrows,
		int	low_water
	)

Definition at line 6 of file DG.cc.

References autostart, dg_bfr_fd, quit, regulated, regulation_optional, and started.

data_generator::~data_generator ( ) [virtual]

Definition at line 16 of file DG.cc.

Member Function Documentation

void data_generator::check_writev	(	int	rc,
		int	wr_size,
		const char *	where
	)		`[private]`

Definition at line 106 of file DG.cc.

References nl_error.

Referenced by init(), and transmit_data().

Here is the caller graph for this function:

void data_generator::event ( enum dg_event evt ) [virtual]

Reimplemented in collector, and tmc_collector.

Definition at line 263 of file DG.cc.

Referenced by execute(), tm_start(), and tm_stop().

Here is the caller graph for this function:

int data_generator::execute ( const char * cmd )

Interperet data generator commands: I need to abstract the "signal handlers" operation. It appears that the key notifications are: Start Stop Quit Change to unregulated output (fast forward)

TM start: "TMc" Set start condition If regulated, program timer else stop timer if ext_stop, signal handlers TM end/stop "TMe" Set stop condition stop timer if ext_time, signal handlers Quit: "" Set stop and quit conditions stop timer if ext_stop or ext_time, signal handlers TM play "TM>" set regulated set row_rate to default if stopped, do start else reprogram timer TM fast forward "TM}" if regulation_optional stop timer set unregulated if stopped, do start else if ext_time, signal handlers TM faster/slower "TM+" "TM-" if regulation_optional if stopped do play else if regulated increase/decrease row_rate program timer TM single step "TMs"

Command Summary: "" Quit "TMc" TM Start "TMe" TM End/Stop/Pause "TMs" Single Step "TM>" Play "TM+" Faster "TM-" Slower "TM}" Fast Forward

Still need to add the search functions: TM Advance to MFCtr TM Advance to Time

Definition at line 176 of file DG.cc.

References dg_bfr_fd, dg_event_fast, dg_event_quit, dispatch, event(), data_queue::lock(), nl_error, quit, DG_dispatch::ready_to_quit(), regulated, regulation_optional, row_period_nsec_current, service_row_timer(), DG_tmr::settime(), started, tm_play(), tm_start(), tm_stop(), tmr, and data_queue::unlock().