COVISE Core
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros
Public Member Functions | Private Attributes | Static Private Attributes | Friends | List of all members
covise::DataManagerProcess Class Reference

#include <dmgr.h>

Inheritance diagram for covise::DataManagerProcess:
Inheritance graph
[legend]
Collaboration diagram for covise::DataManagerProcess:
Collaboration graph
[legend]

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, 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 prepare_for_contact (int *port)
 
void wait_for_contact ()
 
void wait_for_dm_contact ()
 
int make_data_connection (char *name, char *new_interface)
 
int complete_data_connection (Message *msg)
 
Messagewait_for_msg ()
 
Messagewait_for_msg (int, Connection *)
 
Messagewait_for_msg (int *, int, Connection *)
 
int handle_msg (Message *msg, bool &localAlloc)
 
void deleteMessageData (Message *msg)
 
void ask_for_object (Message *msg)
 
void has_object_changed (Message *msg)
 
char * get_all_hosts_for_object (char *)
 
int add_object (char *n, int no, int o, Connection *c)
 
int add_object (char *n, int otype, int no, int o, Connection *c)
 
int add_object (ObjectEntry *oe)
 
ObjectEntryget_object (char *n)
 
ObjectEntryget_object (char *n, Connection *c)
 
ObjectEntryget_local_object (char *n)
 
int delete_object (char *n)
 
int destroy_object (char *n, Connection *c)
 
ObjectEntrycreate_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 *)
 
coShmPtrshm_alloc (ShmMessage *msg)
 
coShmPtrshm_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 ()
 
voidget_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))
 
int is_connected ()
 
ControllerConnectiongetControllerConnection ()
 
- Public Member Functions inherited from covise::Process
ConnectionListgetConnectionList ()
 
 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)
 
Messagewait_for_msg ()
 
Messagecheck_queue ()
 
Messagecheck_for_msg (float time=0.0)
 
Messagewait_for_msg (int, Connection *)
 
Messagewait_for_msg (int *, int, Connection *)
 
int get_id ()
 
char * get_list_of_interfaces ()
 
const char * getName ()
 
const char * get_hostname ()
 
Hostget_covise_host ()
 
Hostget_host ()
 
void covised_rexec (Host *, char *)
 
void delete_msg (Message *m)
 
int get_hostid ()
 

Private Attributes

ServerConnectiontransfermanager
 
ServerConnectiontmpconn
 
coShmAllocshm
 
AVLTree< ObjectEntry > * objects
 
List< DMEntry > * data_mgrs
 
pid_t * pid_list
 
int no_of_pids
 
bool is_bad_
 

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 Processthis_process = NULL
 
- Protected Attributes inherited from covise::OrdinaryProcess
ControllerConnectioncontroller
 
- Protected Attributes inherited from covise::Process
const char * name
 
int id
 
int hostid
 
Hosthost
 
char * covise_hostname
 
sender_type send_type
 
ConnectionListlist_of_connections
 
List< Message > * msg_queue
 
SignalHandler sig_handler
 

Constructor & Destructor Documentation

DataManagerProcess::DataManagerProcess ( char *  name,
int  id,
int *  key 
)
covise::DataManagerProcess::~DataManagerProcess ( )
inline

Member Function Documentation

int DataManagerProcess::add_object ( char *  n,
int  no,
int  o,
Connection c 
)
int DataManagerProcess::add_object ( char *  n,
int  otype,
int  no,
int  o,
Connection c 
)
int DataManagerProcess::add_object ( ObjectEntry oe)
void DataManagerProcess::ask_for_object ( Message msg)
void DataManagerProcess::clean_all ( int  )
int DataManagerProcess::complete_data_connection ( Message msg)
void covise::DataManagerProcess::connect_trfmgr ( Host h,
int  port 
)
void DataManagerProcess::contact_controller ( int  port,
Host host 
)
virtual

Reimplemented from covise::OrdinaryProcess.

void DataManagerProcess::contact_datamanager ( int  port,
Host host 
)
ObjectEntry * DataManagerProcess::create_object_from_msg ( Message msg,
DMEntry dme 
)
int DataManagerProcess::delete_object ( char *  n)
void DataManagerProcess::deleteMessageData ( Message msg)
int DataManagerProcess::destroy_object ( char *  n,
Connection c 
)
int DataManagerProcess::DTM_new_desk ( void  )
void DataManagerProcess::exch_trf_msg ( Message msg)
int DataManagerProcess::forward_new_part ( Message partmsg)
char * DataManagerProcess::get_all_hosts_for_object ( char *  n)
ObjectEntry * DataManagerProcess::get_local_object ( char *  n)
ObjectEntry * DataManagerProcess::get_object ( char *  n)
ObjectEntry * DataManagerProcess::get_object ( char *  n,
Connection c 
)
void* covise::DataManagerProcess::get_shared_memory_address ( )
inline
int covise::DataManagerProcess::get_trfmgr_port ( )
int DataManagerProcess::handle_msg ( Message msg,
bool &  localAlloc 
)
void DataManagerProcess::has_object_changed ( Message msg)
void DataManagerProcess::init_object_id ( )
int DataManagerProcess::insert_new_part ( ObjectEntry object,
ObjectEntry part 
)
bool covise::DataManagerProcess::is_connected ( )
inline
int DataManagerProcess::make_data_connection ( char *  name,
char *  new_interface 
)
void DataManagerProcess::prepare_for_contact ( int *  port)
void covise::DataManagerProcess::print_shared_memory_statistics ( )
inline
int DataManagerProcess::receive_new_part ( Message msg)
void covise::DataManagerProcess::remove_pid ( int  pid)
inline
void DataManagerProcess::rmv_acc2objs ( CO_AVL_Node< ObjectEntry > *  root,
Connection conn 
)
int DataManagerProcess::rmv_rdmgr ( char *  hostname)
void DataManagerProcess::save_object_id ( )
void DataManagerProcess::send_to_all_connections ( Message msg)
void DataManagerProcess::send_trf_msg ( Message msg)
coShmPtr * DataManagerProcess::shm_alloc ( ShmMessage msg)
coShmPtr * DataManagerProcess::shm_alloc ( int  type,
shmSizeType  msize = 0 
)

Collect size in this variable:

int DataManagerProcess::shm_free ( coShmPtr ptr)
int DataManagerProcess::shm_free ( int  shm_seq_no,
int  offset 
)
void covise::DataManagerProcess::signal_handler ( int  signo,
void  
)
void DataManagerProcess::start_transfermanager ( )
int DataManagerProcess::update_object_from_msg ( Message msg,
DMEntry dme 
)
void DataManagerProcess::wait_for_contact ( )
void DataManagerProcess::wait_for_dm_contact ( )
Message * DataManagerProcess::wait_for_msg ( )
Message * DataManagerProcess::wait_for_msg ( int  covise_msg_type,
Connection conn = 0 
)
Message * DataManagerProcess::wait_for_msg ( int *  covise_msg_type,
int  no,
Connection conn = 0 
)

Friends And Related Function Documentation

Member Data Documentation

List<DMEntry>* covise::DataManagerProcess::data_mgrs
private
bool covise::DataManagerProcess::is_bad_
private
int DataManagerProcess::max_t = 0
staticprivate
int covise::DataManagerProcess::no_of_pids
private
AVLTree<ObjectEntry>* covise::DataManagerProcess::objects
private
pid_t* covise::DataManagerProcess::pid_list
private
coShmAlloc* covise::DataManagerProcess::shm
private
ServerConnection* covise::DataManagerProcess::tmpconn
private
ServerConnection* covise::DataManagerProcess::transfermanager
private

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