Instrument Neutral Distributed Interface INDI
2.0.2
|
Public Member Functions | |
SerializedMsg (Msg *parent) | |
virtual | ~SerializedMsg () |
bool | requestContent (const MsgChunckIterator &position) |
bool | getContent (MsgChunckIterator &position, void *&data, ssize_t &nsend, std::vector< int > &sharedBuffers) |
void | advance (MsgChunckIterator &position, ssize_t s) |
void | release (MsgQueue *from) |
void | addAwaiter (MsgQueue *awaiter) |
ssize_t | queueSize () |
Protected Member Functions | |
bool | async_canceled () |
void | async_updateRequirement (const SerializationRequirement &n) |
void | async_pushChunck (const MsgChunck &m) |
void | async_done () |
bool | isAsyncRunning () |
void | onDataReady () |
virtual bool | generateContentAsync () const =0 |
virtual void | generateContent ()=0 |
void | collectRequirements (SerializationRequirement &req) |
void | abort () |
void | blockReceiver (MsgQueue *toblock) |
Protected Attributes | |
SerializationStatus | asyncStatus |
Msg * | owner |
MsgQueue * | blockedProducer |
std::set< MsgQueue * > | awaiters |
std::list< void * > | ownBuffers |
Friends | |
class | Msg |
class | MsgChunckIterator |
Definition at line 313 of file indiserver.cpp.
SerializedMsg::SerializedMsg | ( | Msg * | parent | ) |
Definition at line 2833 of file indiserver.cpp.
|
virtual |
Definition at line 2850 of file indiserver.cpp.
|
protected |
void SerializedMsg::addAwaiter | ( | MsgQueue * | awaiter | ) |
Definition at line 3019 of file indiserver.cpp.
void SerializedMsg::advance | ( | MsgChunckIterator & | position, |
ssize_t | s | ||
) |
Definition at line 3002 of file indiserver.cpp.
|
protected |
Definition at line 2858 of file indiserver.cpp.
|
protected |
Definition at line 2883 of file indiserver.cpp.
|
protected |
Definition at line 2875 of file indiserver.cpp.
|
protected |
Definition at line 2864 of file indiserver.cpp.
|
protected |
Definition at line 3039 of file indiserver.cpp.
|
protected |
Definition at line 3033 of file indiserver.cpp.
|
protectedpure virtual |
Implemented in SerializedMsgWithoutSharedBuffer, and SerializedMsgWithSharedBuffer.
|
protectedpure virtual |
Implemented in SerializedMsgWithoutSharedBuffer, and SerializedMsgWithSharedBuffer.
bool SerializedMsg::getContent | ( | MsgChunckIterator & | position, |
void *& | data, | ||
ssize_t & | nsend, | ||
std::vector< int > & | sharedBuffers | ||
) |
Definition at line 2966 of file indiserver.cpp.
|
protected |
Definition at line 2935 of file indiserver.cpp.
|
protected |
ssize_t SerializedMsg::queueSize | ( | ) |
Definition at line 3045 of file indiserver.cpp.
void SerializedMsg::release | ( | MsgQueue * | from | ) |
Definition at line 3024 of file indiserver.cpp.
bool SerializedMsg::requestContent | ( | const MsgChunckIterator & | position | ) |
Definition at line 2943 of file indiserver.cpp.
|
friend |
Definition at line 315 of file indiserver.cpp.
|
friend |
Definition at line 316 of file indiserver.cpp.
|
protected |
Definition at line 345 of file indiserver.cpp.
|
protected |
Definition at line 350 of file indiserver.cpp.
|
protected |
Definition at line 348 of file indiserver.cpp.
|
protected |
Definition at line 356 of file indiserver.cpp.
|
protected |
Definition at line 346 of file indiserver.cpp.