qpid::SessionState::SendState Class Reference

State for commands sent. More...

#include <SessionState.h>

Collaboration diagram for qpid::SessionState::SendState:

Collaboration graph
[legend]

List of all members.

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 SessionPointgetReplayPoint () const
 Point from which we can replay.
ReplayList & getReplayList ()
 Get the replay list, starting from getReplayPoint().
const SessionPointgetCommandPoint ()
 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.


Detailed Description

State for commands sent.

Records commands for replay, tracks confirmation and completion of sent commands.


Member Function Documentation

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

Returns:
true if we should send flush for confirmed and completed commands.

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.

Returns:
true if replay is required, sets replayPoint.


The documentation for this class was generated from the following file:

Generated on Thu May 15 22:22:36 2008 for Qpid by  doxygen 1.5.5