Scopira 20080306

scopira::agent::cluster_agent Class Reference

#include <clusteragent.h>

Inheritance diagram for scopira::agent::cluster_agent:
scopira::agent::local_agent scopira::agent::agent_i scopira::tool::object

List of all members.

Classes

struct  admin_area
class  admin_msg
class  cron_item
class  link
struct  meta_area
class  meta_node
class  net_link
class  network_msg
struct  peer_area
class  reply_msg
struct  resolve_area
struct  xtion_area

Public Types

enum  { default_port_c = 5555 }
 

default port used by the master


Public Member Functions

 cluster_agent (void)
 ctor
virtual ~cluster_agent ()
 dtor
virtual void notify_stop (void)
 notifies the agent to stop
virtual void enqueue_network_quit (void)
virtual bool failed (void) const
virtual void set_agenterror_reactor (agenterror_reactor_i *r)
 sets the agenterror handler... there can only be one, eh
virtual int find_services (scopira::tool::uuid &serviceid, scopira::basekit::narray< scopira::tool::uuid > &out)
virtual void reg_context (scopira::tool::uuid &ctxid, taskmsg_reactor_i *reac)
 register a content
virtual void unreg_context (scopira::tool::uuid ctxid)
 unregister a content
virtual int universe_size (void)
virtual scopira::tool::uuid get_agent_id (void)
virtual scopira::tool::uuid launch_task (const std::type_info &t, scopira::tool::uuid where)
virtual scopira::tool::uuid launch_group (int numps, const std::type_info &t)
virtual void launch_slaves (scopira::tool::uuid masterid, int numtotalps, const std::type_info &t, scopira::basekit::narray< scopira::tool::uuid > &peers)
virtual void kill_task (scopira::tool::uuid ps)
virtual bool wait_task (scopira::tool::uuid ps, int msec)
virtual bool is_alive_task (scopira::tool::uuid ps)
virtual void send_msg_bcast (scopira::tool::uuid src, scopira::tool::uuid destserviceid, scopira::tool::bufferflow *buf)
const node_specspec (void) const

Protected Member Functions

virtual void la_send_msg (scopira::tool::uuid src, scopira::tool::uuid dest, scopira::tool::bufferflow *buf)
 la calls this as a last resort (after trying local delivery)
virtual void la_dead_task (scopira::tool::uuid taskid)
 la calls this after a local task is terminated

Friends

class scopira::agent::uptime_task

Detailed Description

A network-aware agent that likes to work in stable and powerful clusters.

Author:
Aleksander Demko

Member Function Documentation

virtual void scopira::agent::cluster_agent::enqueue_network_quit ( void  ) [virtual]

block the caller until this agent_i has terminated because of a agent end message

Reimplemented from scopira::agent::local_agent.

virtual bool scopira::agent::cluster_agent::failed ( void  ) const [virtual]

has this agent successfully booted up? if not, you shouldnt use it and probably just nuke it.

Reimplemented from scopira::agent::local_agent.


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