| _auxiliary_priority (defined in CommManager) | CommManager | [protected] |
| _id (defined in CommManager) | CommManager | [protected] |
| _list_lock (defined in CommManager) | CommManager | [protected] |
| _mailboxes (defined in CommManager) | CommManager | [protected] |
| _mailers (defined in CommManager) | CommManager | [protected] |
| _next_message_id (defined in CommManager) | CommManager | [protected] |
| _next_messaging_id (defined in CommManager) | CommManager | [protected] |
| _portal_list (defined in CommManager) | CommManager | [protected] |
| _protocol_list (defined in CommManager) | CommManager | [protected] |
| _protocol_pool (defined in CommManager) | CommManager | [protected] |
| _protocol_pool_mutex (defined in CommManager) | CommManager | [protected] |
| _remote_lock (defined in CommManager) | CommManager | [protected] |
| _remotes (defined in CommManager) | CommManager | [protected] |
| _resend_interval (defined in CommManager) | CommManager | [protected] |
| _resend_tid (defined in CommManager) | CommManager | [protected] |
| _running (defined in CommManager) | CommManager | [protected] |
| _send_list (defined in CommManager) | CommManager | [protected] |
| _send_mutex (defined in CommManager) | CommManager | [protected] |
| _send_tid (defined in CommManager) | CommManager | [protected] |
| _send_var (defined in CommManager) | CommManager | [protected] |
| _stream_buckets (defined in CommManager) | CommManager | [protected] |
| _stream_sinks (defined in CommManager) | CommManager | [protected] |
| _stream_sources (defined in CommManager) | CommManager | [protected] |
| _table | CommManager | [protected] |
| _table_mutex | CommManager | [protected] |
| acquire_protocol() (defined in CommManager) | CommManager | [protected] |
| CommManager(int resend_millisecs=200, int priority=-2) | CommManager | |
| createMailbox(int size, com_id_t mailbox_id, com_id_t exclusive_client=0) | CommManager | |
| createMailer(const char *spec, int size, com_id_t mailbox_id, com_id_t exclusive_dest=0) | CommManager | |
| createMailer(RemoteManager *dest, int size, com_id_t mailbox_id, com_id_t exclusive_dest=0) | CommManager | |
| createMailerByHost(const char *host, int port, int size, com_id_t mailbox_id, com_id_t exclusive_dest=0) | CommManager | |
| createManager(const char *spec, int resend_millisecs=200, int priority=-2) | CommManager | [static] |
| createStreamSink(int size, com_id_t stream_id, int max_buffer, com_id_t exclusive_client=0) | CommManager | |
| createStreamSource(const char *spec, int size, com_id_t stream_id, com_id_t exclusive_dest=0, MessagePool *pool=NULL) | CommManager | |
| createStreamSource(RemoteManager *dest, int size, com_id_t stream_id, com_id_t exclusive_dest=0, MessagePool *pool=NULL) | CommManager | |
| createStreamSourceByHost(const char *host, int port, int size, com_id_t stream_id, com_id_t exclusive_dest=0, MessagePool *pool=NULL) | CommManager | |
| destroyMailbox(Mailbox *) | CommManager | |
| destroyMailer(Mailer *) | CommManager | |
| destroyStreamSink(StreamSink *) | CommManager | |
| destroyStreamSource(StreamSource *) | CommManager | |
| find_mailbox(com_id_t mailbox_id) (defined in CommManager) | CommManager | [protected] |
| find_mailer(com_id_t mailbox_id) (defined in CommManager) | CommManager | [protected] |
| find_sink(com_id_t stream_id) (defined in CommManager) | CommManager | [protected] |
| find_source(com_id_t stream_id) (defined in CommManager) | CommManager | [protected] |
| getID() | CommManager | [inline] |
| getSymbol(const char *name) | CommManager | |
| getSymbolTable() | CommManager | [inline] |
| immediateMailMsg(RemoteManager *dest, com_id_t mailbox_id, Message *msg) (defined in CommManager) | CommManager | |
| immediateStreamMsg(RemoteManager *dest, com_id_t stream_id, com_id_t source_id, Message *msg) (defined in CommManager) | CommManager | [protected] |
| init(int resend_interval=200) | CommManager | [protected] |
| initPortal(const char *spec) | CommManager | |
| instance(utils::SymbolTable *table) | CommManager | [static] |
| launchAuxiliaryThread(pthread_t *tid, void *(*start_routine)(void *), void *arg) | CommManager | |
| lockSymbolTable() | CommManager | |
| nextMessageID() (defined in CommManager) | CommManager | [inline] |
| nextMessagingID() | CommManager | [inline] |
| now() | CommManager | [static] |
| NUM_BUCKETS (defined in CommManager) | CommManager | [protected, static] |
| openRemote(const char *spec) | CommManager | |
| openRemoteByHost(const char *host, int port) | CommManager | |
| pack_byte(Byte *&buf, Byte data) (defined in CommManager) | CommManager | [inline, protected] |
| pack_id(Byte *&buf, int data) (defined in CommManager) | CommManager | [inline, protected] |
| pack_int(Byte *&buf, int data) (defined in CommManager) | CommManager | [inline, protected] |
| pack_short(Byte *&buf, short data) (defined in CommManager) | CommManager | [inline, protected] |
| processMessage(Message *msg) | CommManager | |
| record_contact(RemoteManager *dest) (defined in CommManager) | CommManager | [protected] |
| release_protocol(ProtocolBuffer *) (defined in CommManager) | CommManager | [protected] |
| resend_bucket(int i) (defined in CommManager) | CommManager | [protected] |
| resend_entry(void *) (defined in CommManager) | CommManager | [protected, static] |
| runResendThread() (defined in CommManager) | CommManager | [protected] |
| runSendThread() (defined in CommManager) | CommManager | [protected] |
| send(Message *msg) (defined in CommManager) | CommManager | [protected] |
| send_entry(void *) (defined in CommManager) | CommManager | [protected, static] |
| sendMailMsg(Mailer *mailer, Message *msg) (defined in CommManager) | CommManager | |
| sendPing(RemoteManager *dest) (defined in CommManager) | CommManager | [protected] |
| sendProtocolMsg(ProtocolBuffer *buf, RemoteManager *dest) (defined in CommManager) | CommManager | [protected] |
| sendStreamMsg(StreamSource *source, Message *msg) (defined in CommManager) | CommManager | |
| setSymbol(const char *name, const void *data, utils::SymbolManager *cleaner=(utils::SymbolManager *) NULL, bool overwrite=false) | CommManager | |
| shutdown() | CommManager | |
| startThreads(int priority=-2) (defined in CommManager) | CommManager | [protected] |
| stream_bucket(com_id_t stream_id) (defined in CommManager) | CommManager | [inline, protected] |
| unlockSymbolTable() | CommManager | |
| unpack_byte(Byte *&buf, int &len) (defined in CommManager) | CommManager | [inline, protected] |
| unpack_id(Byte *&buf, int &len) (defined in CommManager) | CommManager | [inline, protected] |
| unpack_int(Byte *&buf, int &len) (defined in CommManager) | CommManager | [inline, protected] |
| unpack_short(Byte *&buf, int &len) (defined in CommManager) | CommManager | [inline, protected] |
| ~CommManager() | CommManager | |