TAO_PortableGroup  2.1.6
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Private Member Functions | Private Attributes
TAO_UIPMC_Transport Class Reference

Specialization of the base TAO_Transport class to handle the client side MIOP protocol. More...

#include <UIPMC_Transport.h>

Inheritance diagram for TAO_UIPMC_Transport:
Inheritance graph
Collaboration diagram for TAO_UIPMC_Transport:
Collaboration graph

List of all members.

Public Member Functions

 TAO_UIPMC_Transport (TAO_UIPMC_Connection_Handler *handler, TAO_ORB_Core *orb_core)
 Constructor.
 ~TAO_UIPMC_Transport (void)
 Default destructor.
- Public Member Functions inherited from TAO_Transport
 TAO_Transport (CORBA::ULong tag, TAO_ORB_Core *orb_core, size_t input_cdr_size=ACE_CDR::DEFAULT_BUFSIZE)
virtual ~TAO_Transport (void)
CORBA::ULong tag (void) const
TAO_ORB_Coreorb_core (void) const
TAO_Transport_Mux_Strategytms (void) const
TAO_Wait_Strategywait_strategy (void) const
Drain_Result handle_output (TAO::Transport::Drain_Constraints const &c)
int bidirectional_flag (void) const
void bidirectional_flag (int flag)
void cache_map_entry (TAO::Transport_Cache_Manager::HASH_MAP_ENTRY *entry)
TAO::Transport_Cache_Manager::HASH_MAP_ENTRY * cache_map_entry (void)
size_t id (void) const
void id (size_t id)
TAO::Connection_Role opened_as (void) const
void opened_as (TAO::Connection_Role)
unsigned long purging_order (void) const
void purging_order (unsigned long value)
bool queue_is_empty (void)
bool register_if_necessary (void)
void provide_handler (TAO::Connection_Handler_Set &handlers)
bool provide_blockable_handler (TAO::Connection_Handler_Set &handlers)
virtual int remove_handler (void)
bool idle_after_send (void)
bool idle_after_reply (void)
virtual void close_connection (void)
void messaging_init (TAO_GIOP_Message_Version const &version)
virtual int tear_listen_point_list (TAO_InputCDR &cdr)
virtual bool post_connect_hook (void)
ACE_Event_Handler::Reference_Count add_reference (void)
ACE_Event_Handler::Reference_Count remove_reference (void)
TAO_GIOP_Message_Basemessaging_object (void)
bool is_connected (void) const
bool post_open (size_t id)
void pre_close (void)
TAO_Connection_Handlerconnection_handler (void)
TAO_OutputCDRout_stream (void)
TAO_SYNCH_MUTEXoutput_cdr_lock (void)
void set_flush_in_post_open (void)
bool can_be_purged (void)
virtual void set_bidir_context_info (TAO_Operation_Details &opdetails)
int generate_locate_request (TAO_Target_Specification &spec, TAO_Operation_Details &opdetails, TAO_OutputCDR &output)
virtual int generate_request_header (TAO_Operation_Details &opd, TAO_Target_Specification &spec, TAO_OutputCDR &msg)
int recache_transport (TAO_Transport_Descriptor_Interface *desc)
virtual int handle_input (TAO_Resume_Handle &rh, ACE_Time_Value *max_wait_time=0)
virtual int send_message_shared (TAO_Stub *stub, TAO_Message_Semantics message_semantics, const ACE_Message_Block *message_block, ACE_Time_Value *max_wait_time)
int format_queue_message (TAO_OutputCDR &stream, ACE_Time_Value *max_wait_time, TAO_Stub *stub)
int send_message_block_chain (const ACE_Message_Block *message_block, size_t &bytes_transferred, ACE_Time_Value *max_wait_time=0)
int send_message_block_chain_i (const ACE_Message_Block *message_block, size_t &bytes_transferred, TAO::Transport::Drain_Constraints const &dc)
int purge_entry (void)
int make_idle (void)
int update_transport (void)
int handle_timeout (const ACE_Time_Value &current_time, const void *act)
size_t recv_buffer_size (void) const
size_t sent_byte_count (void) const
TAO_Codeset_Translator_Basechar_translator (void) const
TAO_Codeset_Translator_Basewchar_translator (void) const
void char_translator (TAO_Codeset_Translator_Base *)
void wchar_translator (TAO_Codeset_Translator_Base *)
void assign_translators (TAO_InputCDR *, TAO_OutputCDR *)
void clear_translators (TAO_InputCDR *, TAO_OutputCDR *)
CORBA::Boolean is_tcs_set () const
void first_request_sent (bool flag=false)
bool first_request () const
void send_connection_closed_notifications (void)
TAO::Transport::Stats * stats (void) const

Private Member Functions

bool write_unique_id (TAO_OutputCDR &miop_hdr) const
 Construct and write a unique ID to the MIOP header.
void throttle_send_rate (ACE_UINT64 max_fragment_rate, u_long max_fragment_size, u_long this_send_size)

Private Attributes

TAO_UIPMC_Connection_Handlerconnection_handler_
u_long uuid_hash_
 This UUID used by client for making unique MIOP IDs.
u_long total_bytes_outstanding_
ACE_Time_Value time_last_sent_

Overridden Template Methods

These are implementations of template methods declared by TAO_Transport.

virtual int send_request (TAO_Stub *stub, TAO_ORB_Core *orb_core, TAO_OutputCDR &stream, TAO_Message_Semantics message_semantics, ACE_Time_Value *max_wait_time)
virtual int send_message (TAO_OutputCDR &stream, TAO_Stub *stub=0, TAO_ServerRequest *request=0, TAO_Message_Semantics message_semantics=TAO_Message_Semantics(), ACE_Time_Value *max_time_wait=0)
virtual ACE_Event_Handlerevent_handler_i (void)
virtual TAO_Connection_Handlerconnection_handler_i (void)
virtual ssize_t send (iovec *iov, int iovcnt, size_t &bytes_transferred, const ACE_Time_Value *max_wait_time)
 Write the complete Message_Block chain to the connection.
virtual ssize_t recv (char *buf, size_t len, ACE_Time_Value const *s=0)
 Shouldn't ever be called on the client side (read len bytes into buf).
virtual int register_handler (void)

Additional Inherited Members

- Public Types inherited from TAO_Transport
enum  Drain_Result_Enum
- Public Attributes inherited from TAO_Transport
 DR_ERROR
 DR_OK
 DR_QUEUE_EMPTY
 DR_WOULDBLOCK
- Protected Member Functions inherited from TAO_Transport
int process_parsed_messages (TAO_Queued_Data *qd, TAO_Resume_Handle &rh)
int send_message_shared_i (TAO_Stub *stub, TAO_Message_Semantics message_semantics, const ACE_Message_Block *message_block, ACE_Time_Value *max_wait_time)
int queue_message_i (const ACE_Message_Block *message_block, ACE_Time_Value *max_wait_time, bool back=true)
ACE_Time_Value const * io_timeout (TAO::Transport::Drain_Constraints const &dc) const
- Protected Attributes inherited from TAO_Transport
CORBA::ULong const tag_
TAO_ORB_Core *const orb_core_
TAO::Transport_Cache_Manager::HASH_MAP_ENTRY * cache_map_entry_
TAO_Transport_Mux_Strategytms_
TAO_Wait_Strategyws_
int bidirectional_flag_
TAO::Connection_Role opening_connection_role_
TAO_Queued_Messagehead_
TAO_Queued_Messagetail_
TAO_Incoming_Message_Queue incoming_message_queue_
TAO::Incoming_Message_Stack incoming_message_stack_
ACE_Time_Value current_deadline_
long flush_timer_id_
TAO_Transport_Timer transport_timer_
ACE_Lockhandler_lock_
size_t id_
unsigned long purging_order_
size_t recv_buffer_size_
size_t sent_byte_count_
bool is_connected_

Detailed Description

Specialization of the base TAO_Transport class to handle the client side MIOP protocol.


Constructor & Destructor Documentation

TAO_UIPMC_Transport::TAO_UIPMC_Transport ( TAO_UIPMC_Connection_Handler handler,
TAO_ORB_Core orb_core 
)

Constructor.

TAO_UIPMC_Transport::~TAO_UIPMC_Transport ( void  )

Default destructor.


Member Function Documentation

TAO_Connection_Handler * TAO_UIPMC_Transport::connection_handler_i ( void  )
protectedvirtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing.

Implements TAO_Transport.

ACE_Event_Handler * TAO_UIPMC_Transport::event_handler_i ( void  )
protectedvirtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing.

Implements TAO_Transport.

ssize_t TAO_UIPMC_Transport::recv ( char *  buf,
size_t  len,
ACE_Time_Value const *  s = 0 
)
protectedvirtual

Shouldn't ever be called on the client side (read len bytes into buf).

Implements TAO_Transport.

int TAO_UIPMC_Transport::register_handler ( void  )
protectedvirtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing.

Reimplemented from TAO_Transport.

ssize_t TAO_UIPMC_Transport::send ( iovec *  iov,
int  iovcnt,
size_t &  bytes_transferred,
const ACE_Time_Value max_wait_time 
)
protectedvirtual

Write the complete Message_Block chain to the connection.

Implements TAO_Transport.

int TAO_UIPMC_Transport::send_message ( TAO_OutputCDR stream,
TAO_Stub stub = 0,
TAO_ServerRequest request = 0,
TAO_Message_Semantics  message_semantics = TAO_Message_Semantics (),
ACE_Time_Value max_time_wait = 0 
)
virtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing.

Implements TAO_Transport.

int TAO_UIPMC_Transport::send_request ( TAO_Stub stub,
TAO_ORB_Core orb_core,
TAO_OutputCDR stream,
TAO_Message_Semantics  message_semantics,
ACE_Time_Value max_wait_time 
)
virtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing.

Implements TAO_Transport.

void TAO_UIPMC_Transport::throttle_send_rate ( ACE_UINT64  max_fragment_rate,
u_long  max_fragment_size,
u_long  this_send_size 
)
private

Throttle back clients send rate so as to not exceed client/server buffers and servant message processing time.

bool TAO_UIPMC_Transport::write_unique_id ( TAO_OutputCDR miop_hdr) const
private

Construct and write a unique ID to the MIOP header.


Member Data Documentation

TAO_UIPMC_Connection_Handler* TAO_UIPMC_Transport::connection_handler_
private

The connection service handler used for accessing lower layer communication protocols.

ACE_Time_Value TAO_UIPMC_Transport::time_last_sent_
private
u_long TAO_UIPMC_Transport::total_bytes_outstanding_
private

On the client side the total amount of outstanding data being transmitted and the time when this was last updated.

u_long TAO_UIPMC_Transport::uuid_hash_
private

This UUID used by client for making unique MIOP IDs.


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