TAO  2.3.3
Public Member Functions | List of all members
TAO::Flush_Transport_Queueing_Strategy Class Reference

#include <Transport_Queueing_Strategies.h>

Inheritance diagram for TAO::Flush_Transport_Queueing_Strategy:
Inheritance graph
[legend]
Collaboration diagram for TAO::Flush_Transport_Queueing_Strategy:
Collaboration graph
[legend]

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 &current_deadline, bool &set_timer, ACE_Time_Value &interval) const
 Return true if it is time to start. More...
 
- Public Member Functions inherited from TAO::Transport_Queueing_Strategy
virtual ~Transport_Queueing_Strategy (void)
 Destructor. More...
 

Detailed Description

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

Member Function Documentation

bool TAO::Flush_Transport_Queueing_Strategy::buffering_constraints_reached ( TAO_Stub stub,
size_t  msg_count,
size_t  total_bytes,
bool &  must_flush,
const ACE_Time_Value current_deadline,
bool &  set_timer,
ACE_Time_Value interval 
) const
virtual

Return true if it is time to start.

Parameters
stubThe object used to make the request, this is used to obtain the policies currently in effect for the request
msg_countThe number of messages currently queued
total_bytesNumber of bytes currently queued
set_timerReturns true if a timer should be set to drain the queue
intervalIf set_timer returns 1, this parameter contains the timer interval
must_flushIs set to true if things must be flushed at this moment

Implements TAO::Transport_Queueing_Strategy.

bool TAO::Flush_Transport_Queueing_Strategy::must_queue ( bool  queue_empty) const
virtual

Return true if a message must be queued.

Implements TAO::Transport_Queueing_Strategy.


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