TAO_PortableGroup  2.2.4
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Types | Public Member Functions | Private Types | Private Member Functions | Private Attributes | Friends | List of all members
TAO_UIPMC_Mcast_Transport Class Reference

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

#include <UIPMC_Mcast_Transport.h>

Inheritance diagram for TAO_UIPMC_Mcast_Transport:
Inheritance graph
Collaboration diagram for TAO_UIPMC_Mcast_Transport:
Collaboration graph

Public Types

typedef ACE_Hash_Map_Manager
< u_long,
TAO_PG::UIPMC_Recv_Packet
*, ACE_SYNCH_NULL_MUTEX > 		Packets_Map
 

Public Member Functions

 TAO_UIPMC_Mcast_Transport (TAO_UIPMC_Mcast_Connection_Handler *handler, TAO_ORB_Core *orb_core)
 Constructor. More...
 
 ~TAO_UIPMC_Mcast_Transport (void)
 Default destructor. More...
 
virtual int handle_input (TAO_Resume_Handle &rh, ACE_Time_Value *max_wait_time=0)
 Look for the documentation in Transport.h. More...
 
- Public Member Functions inherited from TAO_Transport
virtual int tear_listen_point_list (TAO_InputCDR &cdr)
 
virtual void set_bidir_context_info (TAO_Operation_Details &opdetails)
 

Private Types

typedef ACE_Unbounded_Queue
< TAO_PG::UIPMC_Recv_Packet * > 		Packets_Queue
 Complete packets. More...
 

Private Member Functions

char * recv_packet (char *buf, size_t len, ACE_INET_Addr &from_addr, CORBA::UShort &packet_length, CORBA::ULong &packet_number, bool &stop_packet, u_long &id_hash) const
 
TAO_PG::UIPMC_Recv_Packet * recv_all (TAO_Resume_Handle &rh)
 
void cleanup_packets (bool expired_only)
 

Private Attributes

TAO_UIPMC_Mcast_Connection_Handler * connection_handler_
 
Packets_Map incomplete_
 Incomplete packets. More...
 
TAO_SYNCH_MUTEX recv_lock_
 A lock for ensuring that only one thread is doing recv. More...
 
Packets_Queue complete_
 
TAO_SYNCH_MUTEX complete_lock_
 A lock for access synchronization to complete queue. More...
 

Friends

class TAO_PG::UIPMC_Recv_Packet_Cleanup_Guard
 

Overridden Template Methods

These are implementations of template methods declared by TAO_Transport.

virtual int send_request (TAO_Stub *, TAO_ORB_Core *, TAO_OutputCDR &, TAO_Message_Semantics, ACE_Time_Value *)
 
virtual int send_message (TAO_OutputCDR &, TAO_Stub *=0, TAO_ServerRequest *=0, TAO_Message_Semantics=TAO_Message_Semantics(), ACE_Time_Value *=0)
 Shouldn't ever be called on the server side. More...
 
virtual ACE_Event_Handler * event_handler_i (void)
 
virtual TAO_Connection_Handler * connection_handler_i (void)
 
virtual ssize_t send (iovec *, int, size_t &, ACE_Time_Value const *)
 
virtual ssize_t recv (char *, size_t, ACE_Time_Value const *)
 Shouldn't ever be called. We use recv_all() with different semantics. More...
 
virtual int register_handler (void)
 

Additional Inherited Members

Detailed Description

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

Member Typedef Documentation

typedef ACE_Hash_Map_Manager<u_long, TAO_PG::UIPMC_Recv_Packet *, ACE_SYNCH_NULL_MUTEX> TAO_UIPMC_Mcast_Transport::Packets_Map
typedef ACE_Unbounded_Queue<TAO_PG::UIPMC_Recv_Packet *> TAO_UIPMC_Mcast_Transport::Packets_Queue
private

Complete packets.

Constructor & Destructor Documentation

TAO_UIPMC_Mcast_Transport::TAO_UIPMC_Mcast_Transport ( TAO_UIPMC_Mcast_Connection_Handler *  handler,
TAO_ORB_Core *  orb_core 
)

Constructor.

TAO_UIPMC_Mcast_Transport::~TAO_UIPMC_Mcast_Transport ( void  )

Default destructor.

Member Function Documentation

void TAO_UIPMC_Mcast_Transport::cleanup_packets ( bool  expired_only)
private

Cleanup either all packets or expired only depending the expired_only flag.

TAO_Connection_Handler * TAO_UIPMC_Mcast_Transport::connection_handler_i ( void  )
protectedvirtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing. Shouldn't ever be called on the server side.

Implements TAO_Transport.

ACE_Event_Handler * TAO_UIPMC_Mcast_Transport::event_handler_i ( void  )
protectedvirtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing. Shouldn't ever be called on the server side.

Implements TAO_Transport.

int TAO_UIPMC_Mcast_Transport::handle_input ( TAO_Resume_Handle &  rh,
ACE_Time_Value *  max_wait_time = 0 
)
virtual

Look for the documentation in Transport.h.

ssize_t TAO_UIPMC_Mcast_Transport::recv ( char *  ,
size_t  ,
ACE_Time_Value const *   
)
protectedvirtual

Shouldn't ever be called. We use recv_all() with different semantics.

Implements TAO_Transport.

TAO_PG::UIPMC_Recv_Packet * TAO_UIPMC_Mcast_Transport::recv_all ( TAO_Resume_Handle &  rh)
private

Return the next complete MIOP packet, possiably dequeueing as many as are available first from the socket.

char * TAO_UIPMC_Mcast_Transport::recv_packet ( char *  buf,
size_t  len,
ACE_INET_Addr &  from_addr,
CORBA::UShort &  packet_length,
CORBA::ULong &  packet_number,
bool &  stop_packet,
u_long &  id_hash 
) const
private

Receive a UDP message and extract all necessary info from the MIOP header. If everything is fine return a pointer to the first byte of the non-MIOP data.

int TAO_UIPMC_Mcast_Transport::register_handler ( void  )
protectedvirtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing. Shouldn't ever be called on the server side.

ssize_t TAO_UIPMC_Mcast_Transport::send ( iovec *  ,
int  ,
size_t &  ,
ACE_Time_Value const *   
)
protectedvirtual

Write the complete Message_Block chain to the connection. Shouldn't ever be called on the server side.

Implements TAO_Transport.

int TAO_UIPMC_Mcast_Transport::send_message ( TAO_OutputCDR &  ,
TAO_Stub *  = 0,
TAO_ServerRequest *  = 0,
TAO_Message_Semantics  = TAO_Message_Semantics (),
ACE_Time_Value *  = 0 
)
virtual

Shouldn't ever be called on the server side.

Implements TAO_Transport.

int TAO_UIPMC_Mcast_Transport::send_request ( TAO_Stub *  ,
TAO_ORB_Core *  ,
TAO_OutputCDR &  ,
TAO_Message_Semantics  ,
ACE_Time_Value *   
)
virtual

@TODO: These methods IMHO should have more meaningful names. The names seem to indicate nothing. Shouldn't ever be called on the server side.

Implements TAO_Transport.

Friends And Related Function Documentation

friend class TAO_PG::UIPMC_Recv_Packet_Cleanup_Guard
friend

Member Data Documentation

Packets_Queue TAO_UIPMC_Mcast_Transport::complete_
private
TAO_SYNCH_MUTEX TAO_UIPMC_Mcast_Transport::complete_lock_
private

A lock for access synchronization to complete queue.

TAO_UIPMC_Mcast_Connection_Handler* TAO_UIPMC_Mcast_Transport::connection_handler_
private

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

Packets_Map TAO_UIPMC_Mcast_Transport::incomplete_
private

Incomplete packets.

TAO_SYNCH_MUTEX TAO_UIPMC_Mcast_Transport::recv_lock_
private

A lock for ensuring that only one thread is doing recv.

The documentation for this class was generated from the following files:
Generated by   doxygen 1.8.6