covise::DataManagerProcess Class Reference

#include <dmgr.h>

Inheritance diagram for covise::DataManagerProcess:

Collaboration diagram for covise::DataManagerProcess:

Public Member Functions
	DataManagerProcess (char *name, int id, int *key)
	~DataManagerProcess ()
int	DTM_new_desk (void)
int	rmv_rdmgr (char *hostname)
void	rmv_acc2objs (CO_AVL_Node< ObjectEntry > *root, const Connection *conn)
bool	is_connected ()
void	contact_datamanager (int port, Host &host)
void	contact_controller (int port, Host *host)
void	init_object_id ()
void	save_object_id ()
void	start_transfermanager ()
int	get_trfmgr_port ()
void	connect_trfmgr (Host *h, int port)
void	send_trf_msg (Message *)
void	exch_trf_msg (Message *)
void	wait_for_dm_contact ()
int	make_data_connection (char *name, char *new_interface)
int	complete_data_connection (Message *msg)
Message *	wait_for_msg ()
Message *	wait_for_msg (int, const Connection *)
Message *	wait_for_msg (int *, int, const Connection *)
int	handle_msg (Message *msg)
void	ask_for_object (Message *msg)
void	has_object_changed (Message *msg)
DataHandle	get_all_hosts_for_object (const DataHandle &n)
int	add_object (const DataHandle &n, int no, int o, const Connection *c)
int	add_object (const DataHandle &n, int otype, int no, int o, const Connection *c)
int	add_object (ObjectEntry *oe)
ObjectEntry *	get_object (const DataHandle &n)
ObjectEntry *	get_object (const DataHandle &n, const Connection *c)
ObjectEntry *	get_local_object (const DataHandle &n)
int	delete_object (const DataHandle &n)
int	destroy_object (const DataHandle &n, const Connection *c)
ObjectEntry *	create_object_from_msg (Message *msg, DMEntry *dme)
int	update_object_from_msg (Message *msg, DMEntry *dme)
int	forward_new_part (Message *)
int	receive_new_part (Message *)
int	insert_new_part (ObjectEntry *, ObjectEntry *)
coShmPtr *	shm_alloc (ShmMessage *msg)
coShmPtr *	shm_alloc (int type, shmSizeType msize=0)
int	shm_free (coShmPtr *)
void	send_to_all_connections (Message *)
int	shm_free (int, int)
void	print_shared_memory_statistics ()
void *	get_shared_memory_address ()
void	signal_handler (int signo, void *)
void	remove_pid (int pid)
void	clean_all (int)
Public Member Functions inherited from covise::OrdinaryProcess
	OrdinaryProcess (const char *name, int id, sender_type st)
	OrdinaryProcess (const char *n, int arc, char *arv[], sender_type st)
	~OrdinaryProcess ()
void	send_ctl_msg (const Message *)
void	send_ctl_msg (TokenBuffer)
int	get_socket_id (void(*remove_func)(int))
virtual void	contact_controller (int, Host *)
int	is_connected ()
const ControllerConnection *	getControllerConnection ()
Public Member Functions inherited from covise::Process
ConnectionList *	getConnectionList ()
	Process (const char *n, int i, sender_type st)
	Process (const char *n, int i, sender_type st, int port)
	Process (const char *n, int arc, char *arv[], sender_type st)
virtual	~Process ()
void	init_env ()
virtual void	handle_shm_msg (Message *)
void	set_send_type (sender_type st)
Message *	wait_for_msg ()
Message *	check_queue ()
Message *	check_for_msg (float time=0.0)
Message *	wait_for_msg (int, const Connection *)
Message *	wait_for_msg (int *, int, const Connection *)
int	get_id ()
char *	get_list_of_interfaces ()
const char *	getName ()
const char *	get_hostname ()
Host *	get_covise_host ()
Host *	get_host ()
void	covised_rexec (Host *, char *)
void	delete_msg (Message *m)
int	get_hostid ()

Private Attributes
const ServerConnection *	transfermanager = nullptr
const Connection *	tmpconn = nullptr
coShmAlloc *	shm
AVLTree< ObjectEntry > *	objects
List< DMEntry > *	data_mgrs
pid_t *	pid_list
int	no_of_pids

Static Private Attributes
static int	max_t = 0

Friends
void	ObjectEntry::pack_and_send_object (Message *, DataManagerProcess *)

Additional Inherited Members
Static Public Attributes inherited from covise::Process
static Process *	this_process = NULL
Protected Attributes inherited from covise::OrdinaryProcess
const ControllerConnection *	controller
Protected Attributes inherited from covise::Process
const char *	name
int	id
int	hostid
Host *	host
const char *	covise_hostname
sender_type	send_type
ConnectionList *	list_of_connections
List< Message > *	msg_queue
SignalHandler	sig_handler

Constructor & Destructor Documentation

DataManagerProcess()

DataManagerProcess::DataManagerProcess	(	char *	name,
		int	id,
		int *	key
	)

~DataManagerProcess()

covise::DataManagerProcess::~DataManagerProcess ( )

inline

Member Function Documentation

add_object() [1/3]

int DataManagerProcess::add_object	(	const DataHandle &	n,
		int	no,
		int	o,
		const Connection *	c
	)

add_object() [2/3]

int DataManagerProcess::add_object	(	const DataHandle &	n,
		int	otype,
		int	no,
		int	o,
		const Connection *	c
	)

add_object() [3/3]

int DataManagerProcess::add_object

(

ObjectEntry *

oe

)

ask_for_object()

void DataManagerProcess::ask_for_object

(

Message *

msg

)

clean_all()

void DataManagerProcess::clean_all

(

int

)

complete_data_connection()

int DataManagerProcess::complete_data_connection

(

Message *

msg

)

connect_trfmgr()

void covise::DataManagerProcess::connect_trfmgr	(	Host *	h,
		int	port
	)

contact_controller()

void DataManagerProcess::contact_controller ( int  port, Host *  host  )

virtual

Reimplemented from covise::OrdinaryProcess.

contact_datamanager()

void DataManagerProcess::contact_datamanager	(	int	port,
		Host &	host
	)

create_object_from_msg()

ObjectEntry * DataManagerProcess::create_object_from_msg	(	Message *	msg,
		DMEntry *	dme
	)

delete_object()

int DataManagerProcess::delete_object

(

const DataHandle &

n

)

destroy_object()

int DataManagerProcess::destroy_object	(	const DataHandle &	n,
		const Connection *	c
	)

DTM_new_desk()

int DataManagerProcess::DTM_new_desk

(

void

)

exch_trf_msg()

void DataManagerProcess::exch_trf_msg

(

Message *

msg

)

forward_new_part()

int DataManagerProcess::forward_new_part

(

Message *

partmsg

)

get_all_hosts_for_object()

DataHandle DataManagerProcess::get_all_hosts_for_object

(

const DataHandle &

n

)

get_local_object()

ObjectEntry * DataManagerProcess::get_local_object

(

const DataHandle &

n

)

get_object() [1/2]

ObjectEntry * DataManagerProcess::get_object

(

const DataHandle &

n

)

get_object() [2/2]

ObjectEntry * DataManagerProcess::get_object	(	const DataHandle &	n,
		const Connection *	c
	)

get_shared_memory_address()

void * covise::DataManagerProcess::get_shared_memory_address ( )

inline

get_trfmgr_port()

int covise::DataManagerProcess::get_trfmgr_port

(

)

handle_msg()

int DataManagerProcess::handle_msg

(

Message *

msg

)

has_object_changed()

void DataManagerProcess::has_object_changed

(

Message *

msg

)

init_object_id()

void DataManagerProcess::init_object_id

(

)

insert_new_part()

int DataManagerProcess::insert_new_part	(	ObjectEntry *	object,
		ObjectEntry *	part
	)

is_connected()

bool covise::DataManagerProcess::is_connected ( )

inline

make_data_connection()

int DataManagerProcess::make_data_connection	(	char *	name,
		char *	new_interface
	)

print_shared_memory_statistics()

void covise::DataManagerProcess::print_shared_memory_statistics ( )

inline

receive_new_part()

int DataManagerProcess::receive_new_part

(

Message *

msg

)

remove_pid()

void covise::DataManagerProcess::remove_pid ( int  pid )

inline

rmv_acc2objs()

void DataManagerProcess::rmv_acc2objs	(	CO_AVL_Node< ObjectEntry > *	root,
		const Connection *	conn
	)

rmv_rdmgr()

int DataManagerProcess::rmv_rdmgr

(

char *

hostname

)

save_object_id()

void DataManagerProcess::save_object_id

(

)

send_to_all_connections()

void DataManagerProcess::send_to_all_connections

(

Message *

msg

)

send_trf_msg()

void DataManagerProcess::send_trf_msg

(

Message *

msg

)

shm_alloc() [1/2]

coShmPtr * DataManagerProcess::shm_alloc	(	int	type,
		shmSizeType	msize = 0
	)

Collect size in this variable:

shm_alloc() [2/2]

coShmPtr * DataManagerProcess::shm_alloc

(

ShmMessage *

msg

)

shm_free() [1/2]

int DataManagerProcess::shm_free

(

coShmPtr *

ptr

)

shm_free() [2/2]

int DataManagerProcess::shm_free	(	int	shm_seq_no,
		int	offset
	)

signal_handler()

void covise::DataManagerProcess::signal_handler	(	int	signo,
		void *
	)

start_transfermanager()

void DataManagerProcess::start_transfermanager

(

)

update_object_from_msg()

int DataManagerProcess::update_object_from_msg	(	Message *	msg,
		DMEntry *	dme
	)

wait_for_dm_contact()

void DataManagerProcess::wait_for_dm_contact

(

)

wait_for_msg() [1/3]

Message * DataManagerProcess::wait_for_msg

(

)

wait_for_msg() [2/3]

Message * DataManagerProcess::wait_for_msg	(	int *	covise_msg_type,
		int	no,
		const Connection *	conn = 0
	)

wait_for_msg() [3/3]

Message * DataManagerProcess::wait_for_msg	(	int	covise_msg_type,
		const Connection *	conn = 0
	)

Friends And Related Function Documentation

ObjectEntry::pack_and_send_object

void ObjectEntry::pack_and_send_object ( Message *  , DataManagerProcess *    )

friend

Member Data Documentation

data_mgrs

List<DMEntry>* covise::DataManagerProcess::data_mgrs

private

max_t

int DataManagerProcess::max_t = 0

staticprivate

no_of_pids

int covise::DataManagerProcess::no_of_pids

private

objects

AVLTree<ObjectEntry>* covise::DataManagerProcess::objects

private

pid_list

pid_t* covise::DataManagerProcess::pid_list

private

shm

coShmAlloc* covise::DataManagerProcess::shm

private

tmpconn

const Connection* covise::DataManagerProcess::tmpconn = nullptr

private

transfermanager

const ServerConnection* covise::DataManagerProcess::transfermanager = nullptr

private

---

The documentation for this class was generated from the following files:

• dmgr/dmgr.h
• dmgr/dmgr_events.cpp
• dmgr/dmgr_process.cpp
• dmgr/dmgr_statics.cpp