ARPDAS_QNX6 1.0
Public Member Functions | Public Attributes | Static Public Attributes | Protected Member Functions | Protected Attributes | Private Member Functions | Private Attributes
data_client Class Reference

Defines interface for data client connection to TMbfr. More...

#include <DC.h>

Inheritance diagram for data_client:
Collaboration diagram for data_client:

List of all members.

Public Member Functions

 data_client (int bufsize_in, int fast=0, int non_block=0)
 data_client (int bufsize_in, int non_block, char *srcfile)
void operate ()
void resize_buffer (int bufsize_in)
void load_tmdac (char *path)

Public Attributes

static unsigned int majf_row
static unsigned int minf_row

Static Public Attributes

static unsigned int next_minor_frame
static char * srcnode = NULL

Protected Member Functions

virtual void process_data ()=0
virtual void process_init ()
virtual void process_tstamp ()
virtual int process_eof ()
void read ()
void init_tm_type ()

Protected Attributes

int bfr_fd
bool dc_quit
tm_msg_t * msg
int nbQrow
int nbDataHdr
tm_hdrw_t input_tm_type

Private Member Functions

void process_message ()
void init (int bufsize_in, int non_block, const char *srcfile)

Private Attributes

int nQrows
int bufsize
int dc_state
unsigned int bytes_read
unsigned int toread
 number of bytes currently in buf
bool tm_info_ready
 number of bytes needed before next action
char * buf

Detailed Description

Defines interface for data client connection to TMbfr.

Definition at line 14 of file DC.h.

Constructor & Destructor Documentation

data_client::data_client ( int  bufsize_in,
int  fast = 0,
int  non_block = 0 
)

Definition at line 62 of file DC.cc.

References init(), and tm_dev_name().

Here is the call graph for this function:

data_client::data_client ( int  bufsize_in,
int  non_block,
char *  srcfile 
)

Definition at line 58 of file DC.cc.

References init().

Here is the call graph for this function:

Member Function Documentation

void data_client::init ( int  bufsize_in,
int  non_block,
const char *  srcfile 
) [private]

Definition at line 23 of file DC.cc.

References bfr_fd, buf, bufsize, bytes_read, dc_quit, dc_state, DC_STATE_HDR, majf_row, minf_row, msg, new_memory(), next_minor_frame, nl_assert, nl_error, srcnode, tm_info_ready, tm_open_name(), and toread.

Referenced by data_client().

Here is the call graph for this function:

Here is the caller graph for this function:

void data_client::init_tm_type ( ) [protected]

Definition at line 106 of file DC.cc.

References input_tm_type, nbDataHdr, nbQrow, tm_info_t::nrowminf, tm_info, tm_info_ready, tmi, TMTYPE_DATA_T1, TMTYPE_DATA_T2, and TMTYPE_DATA_T3.

Referenced by load_tmdac(), and process_init().

Here is the caller graph for this function:

void data_client::load_tmdac ( char *  path)

Definition at line 207 of file DC.cc.

References init_tm_type().

Here is the call graph for this function:

void data_client::operate ( )

This is the basic operate loop for a simple extraction

Reimplemented in nc_data_client, and ph_data_client.

Definition at line 96 of file DC.cc.

References dc_quit, read(), and tminitfunc().

Here is the call graph for this function:

virtual void data_client::process_data ( ) [protected, pure virtual]

Implemented in ext_data_client, nc_data_client, and ph_data_client.

Referenced by process_message().

Here is the caller graph for this function:

int data_client::process_eof ( ) [protected, virtual]

Definition at line 66 of file DC.cc.

References dc_quit.

Referenced by read().

Here is the caller graph for this function:

void data_client::process_init ( ) [protected, virtual]

Definition at line 124 of file DC.cc.

References tm_msg::body, tm_msg::init, init_tm_type(), tm_info_t::max_rows, msg, nl_error, tm_info_t::nrowminf, tm_info_t::t_stmp, tm_info_t::tm, and tm_info.

Referenced by process_message().

Here is the call graph for this function:

Here is the caller graph for this function:

void data_client::process_message ( ) [private]

Definition at line 137 of file DC.cc.

References tm_msg::body, buf, bufsize, bytes_read, tm_msg::data1, dc_state, DC_STATE_DATA, DC_STATE_HDR, tm_msg::hdr, input_tm_type, msg, tm_data_t1_t::n_rows, nbDataHdr, nbQrow, nl_error, process_data(), process_init(), process_tstamp(), tm_info, tm_info_ready, tm_hdr_t::tm_type, TMTYPE_DATA_T1, TMTYPE_DATA_T2, TMTYPE_DATA_T3, TMTYPE_DATA_T4, TMTYPE_INIT, TMTYPE_TSTAMP, and toread.

Referenced by read().

Here is the call graph for this function:

Here is the caller graph for this function:

void data_client::process_tstamp ( ) [protected, virtual]

Definition at line 133 of file DC.cc.

References tm_msg::body, msg, tm_info_t::t_stmp, tm_info, and tm_msg::ts.

Referenced by process_message().

Here is the caller graph for this function:

void data_client::read ( ) [protected]

Reimplemented in nc_data_client, and ph_data_client.

Definition at line 71 of file DC.cc.

References bfr_fd, buf, bufsize, bytes_read, dc_quit, nl_error, process_eof(), process_message(), and toread.

Referenced by operate().

Here is the call graph for this function:

Here is the caller graph for this function:

void data_client::resize_buffer ( int  bufsize_in)

Definition at line 198 of file DC.cc.

References buf, bufsize, and nl_error.

Member Data Documentation

int data_client::bfr_fd [protected]

Definition at line 28 of file DC.h.

Referenced by init(), ph_data_client::operate(), and read().

char* data_client::buf [private]

Definition at line 44 of file DC.h.

Referenced by init(), process_message(), read(), and resize_buffer().

int data_client::bufsize [private]

Definition at line 39 of file DC.h.

Referenced by init(), process_message(), read(), and resize_buffer().

unsigned int data_client::bytes_read [private]

Definition at line 41 of file DC.h.

Referenced by init(), process_message(), and read().

bool data_client::dc_quit [protected]

Definition at line 30 of file DC.h.

Referenced by init(), operate(), nc_data_client::operate(), process_eof(), read(), and ph_data_client::read().

int data_client::dc_state [private]

Definition at line 40 of file DC.h.

Referenced by init(), and process_message().

tm_hdrw_t data_client::input_tm_type [protected]

Definition at line 34 of file DC.h.

Referenced by init_tm_type(), and process_message().

unsigned int data_client::majf_row

Definition at line 21 of file DC.h.

Referenced by init().

unsigned int data_client::minf_row

Definition at line 21 of file DC.h.

Referenced by init().

tm_msg_t* data_client::msg [protected]

Definition at line 31 of file DC.h.

Referenced by init(), process_init(), process_message(), and process_tstamp().

int data_client::nbDataHdr [protected]

Definition at line 33 of file DC.h.

Referenced by init_tm_type(), and process_message().

int data_client::nbQrow [protected]

Definition at line 32 of file DC.h.

Referenced by init_tm_type(), and process_message().

unsigned int data_client::next_minor_frame [static]

Definition at line 21 of file DC.h.

Referenced by init().

int data_client::nQrows [private]

Definition at line 38 of file DC.h.

char * data_client::srcnode = NULL [static]

Definition at line 22 of file DC.h.

Referenced by dc_set_srcnode(), and init().

bool data_client::tm_info_ready [private]

number of bytes needed before next action

Definition at line 43 of file DC.h.

Referenced by init(), init_tm_type(), and process_message().

unsigned int data_client::toread [private]

number of bytes currently in buf

Definition at line 42 of file DC.h.

Referenced by init(), process_message(), and read().

The documentation for this class was generated from the following files:
 All Classes Files Functions Variables Typedefs Enumerations Enumerator Defines
Generated on Mon Dec 3 2012 12:29:58 for ARPDAS_QNX6 by  doxygen 1.7.4