exclusiveClient() const (defined in StreamSink) | StreamSink | [inline] |
flush() | StreamSink | |
getBufferSize() const | StreamSink | [inline] |
getID() const | StreamSink | [inline] |
getMaxSize() const | StreamSink | [inline] |
numToReceive() | StreamSink | [inline] |
pollData() | StreamSink | |
processMsg(com_id_t msg_id, RemoteManager *dest, TimeStamp receipt_time, Byte *buf, int len) (defined in StreamSink) | StreamSink | |
releaseMsg(Message *) (defined in StreamSink) | StreamSink | |
setBufferSize(int b) | StreamSink | [inline] |
StreamSink(int max_size, com_id_t stream_id, int max_buffer, com_id_t exclusive_client=0) (defined in StreamSink) | StreamSink | |
waitData(int msecs_timeout) | StreamSink | |
~StreamSink() (defined in StreamSink) | StreamSink |