| ackBlock(com_id_t msg_id, int timeout_ms=-1) | StreamSource | |
| acknowledgeMsg(com_id_t msg_id) (defined in StreamSource) | StreamSource | |
| check_dest() (defined in Messager) | Messager | |
| createMsg() | Messager | [inline] |
| flush(com_id_t msg_id=0) | StreamSource | |
| getDest() const | Messager | [inline] |
| getExclusiveID() const (defined in Messager) | Messager | [inline] |
| getID() const | Messager | [inline] |
| getManager() const (defined in Messager) | Messager | [inline] |
| getMaxSize() const | Messager | [inline] |
| getSID() const | StreamSource | [inline] |
| invalidate() (defined in Messager) | Messager | [inline] |
| Messager(CommManager *mgr, RemoteManager *dest, int max_size, com_id_t id, com_id_t exclusive_dest=0, MessagePool *pool=NULL) (defined in Messager) | Messager | |
| numToSend() | StreamSource | [inline] |
| popOldestMsg() | StreamSource | |
| popPendingMsg() | StreamSource | |
| releaseMsg(Message *m) | Messager | [inline] |
| resendPending(int min_age) (defined in StreamSource) | StreamSource | |
| retreivePendingMsg(com_id_t msg_id) | StreamSource | |
| sendDouble(double d) | StreamSource | |
| sendInt(int i) | StreamSource | |
| sendMsg(Message *) | StreamSource | |
| setMaxSize(int new_max_size) (defined in Messager) | Messager | [inline] |
| StreamSource(CommManager *mgr, RemoteManager *dest, int max_size, com_id_t stream_id, com_id_t exclusive_dest=0, MessagePool *pool=NULL) (defined in StreamSource) | StreamSource | |
| valid() const (defined in Messager) | Messager | [inline] |
| ~Messager() (defined in Messager) | Messager | |
| ~StreamSource() (defined in StreamSource) | StreamSource | |