TAO
2.1.8
|
#include <Transport_Queueing_Strategies.h>
Public Member Functions | |
virtual bool | must_queue (bool queue_empty) const |
Return true if a message must be queued. More... | |
virtual bool | buffering_constraints_reached (TAO_Stub *stub, size_t msg_count, size_t total_bytes, bool &must_flush, const ACE_Time_Value ¤t_deadline, bool &set_timer, ACE_Time_Value &interval) const |
Return true if it is time to start. More... | |
![]() | |
virtual | ~Transport_Queueing_Strategy (void) |
Destructor. More... | |
This strategy doesn't not queue by default, but when a message is queued we always flush it to the transport. This is used for oneways with SYNC_WITH_TRANSPORT, SYNC_WITH_SERVER and SYNC_WITH_TARGET
|
virtual |
Return true if it is time to start.
stub | The object used to make the request, this is used to obtain the policies currently in effect for the request |
msg_count | The number of messages currently queued |
total_bytes | Number of bytes currently queued |
set_timer | Returns true if a timer should be set to drain the queue |
interval | If set_timer returns 1, this parameter contains the timer interval |
must_flush | Is set to true if things must be flushed at this moment |
Implements TAO::Transport_Queueing_Strategy.
|
virtual |
Return true if a message must be queued.
Implements TAO::Transport_Queueing_Strategy.