#include <SessionState.h>
Public Types | |
typedef std::vector < framing::AMQFrame > | ReplayList |
Public Member Functions | |
void | record (const framing::AMQFrame &f) |
Record frame f for replay. | |
bool | needFlush () const |
void | recordFlush () |
Called when flush for confirmed and completed commands is sent to peer. | |
void | confirmed (const SessionPoint &confirmed) |
Called when the peer confirms up to comfirmed. | |
void | completed (const SequenceSet &commands) |
Called when the peer indicates commands completed. | |
const SessionPoint & | getReplayPoint () const |
Point from which we can replay. | |
ReplayList & | getReplayList () |
Get the replay list, starting from getReplayPoint(). | |
const SessionPoint & | getCommandPoint () |
Point from which the next data will be sent. | |
const SequenceSet & | getIncomplete () const |
Set of outstanding incomplete commands. | |
bool | expected (const SessionPoint &expected) |
Peer expecting commands from this point. |
Records commands for replay, tracks confirmation and completion of sent commands.
void qpid::SessionState::SendState::record | ( | const framing::AMQFrame & | f | ) |
Record frame f for replay.
Should not be called during replay.
bool qpid::SessionState::SendState::needFlush | ( | ) | const |
void qpid::SessionState::SendState::recordFlush | ( | ) |
Called when flush for confirmed and completed commands is sent to peer.
void qpid::SessionState::SendState::confirmed | ( | const SessionPoint & | confirmed | ) |
Called when the peer confirms up to comfirmed.
const SessionPoint& qpid::SessionState::SendState::getReplayPoint | ( | ) | const [inline] |
Point from which we can replay.
All data < replayPoint is confirmed.
const SessionPoint& qpid::SessionState::SendState::getCommandPoint | ( | ) |
Point from which the next data will be sent.
bool qpid::SessionState::SendState::expected | ( | const SessionPoint & | expected | ) |
Peer expecting commands from this point.