#include <DG_data.h>

Inheritance diagram for DG_data:

Collaboration diagram for DG_data:

Public Member Functions
	DG_data (DG_dispatch disp, const char name, void *data, int data_size, int synch)
	~DG_data ()
int	ready_to_quit ()
int	io_write (resmgr_context_t ctp, IOFUNC_OCB_T ocb, int nonblock)
void	synch ()
int	stale (int max_stale=SHRT_MAX)
Private Attributes
int	dev_id
const char *	name
int	stale_count
void *	dptr
int	dsize
bool	synched
struct data_dev_attr	data_attr
struct data_dev_ocb *	blocked
Static Private Attributes
static resmgr_connect_funcs_t	connect_funcs
static resmgr_io_funcs_t	io_funcs
static bool	funcs_initialized = false
static bool	quitting = false

Detailed Description

Definition at line 29 of file DG_data.h.

Constructor & Destructor Documentation

DG_data::DG_data	(	DG_dispatch *	disp,
		const char *	name,
		void *	data,
		int	data_size,
		int	synch
	)

Definition at line 53 of file DG_data.cc.

References DG_dispatch_client::attach(), data_dev_attr::attr, connect_funcs, data_attr, dev_id, DG_data_io_close_ocb(), DG_data_io_notify(), DG_data_io_write(), data_dev_attr::DGd, DGdata_mountpoint, DG_dispatch::dpp, dpp, dptr, dsize, funcs_initialized, io_funcs, name, nl_error, data_dev_attr::notify, resmgr_attr, stale_count, synch(), synched, tm_dev_name(), and data_dev_attr::written.

Here is the call graph for this function:

DG_data::~DG_data ( )

Definition at line 98 of file DG_data.cc.

Member Function Documentation

int DG_data::io_write	(	resmgr_context_t *	ctp,
		IOFUNC_OCB_T *	ocb,
		int	nonblock
	)

Definition at line 106 of file DG_data.cc.

References blocked, data_attr, dptr, dsize, data_dev_ocb::msgsize, quitting, stale_count, synched, and data_dev_attr::written.

int DG_data::ready_to_quit ( ) [virtual]

DG_data::ready_to_quit() returns true if we are ready to terminate. For DG/data, that means all writers have closed their connections and we have detached the device.

Implements DG_dispatch_client.

Definition at line 173 of file DG_data.cc.

References data_dev_attr::attr, data_attr, dev_id, DG_dispatch_client::dispatch, DG_dispatch::dpp, name, nl_error, and quitting.