TAO_Strategies  2.2.6
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Private Attributes | List of all members
TAO_SHMIOP_Connection_Handler Class Reference

Handles requests on a single connection. More...

#include <SHMIOP_Connection_Handler.h>

Inheritance diagram for TAO_SHMIOP_Connection_Handler:
Inheritance graph
Collaboration diagram for TAO_SHMIOP_Connection_Handler:
Collaboration graph

Public Member Functions

 TAO_SHMIOP_Connection_Handler (ACE_Thread_Manager *t=0)
 Constructor. More...
 
 TAO_SHMIOP_Connection_Handler (TAO_ORB_Core *orb_core)
 Constructor. More...
 
 ~TAO_SHMIOP_Connection_Handler (void)
 Destructor. More...
 
virtual int open (void *)
 
int close (u_long=0)
 
int add_transport_to_cache (void)
 Add ourselves to Cache. More...
 
virtual int open_handler (void *)
 
Event Handler overloads
virtual int resume_handler (void)
 
virtual int close_connection (void)
 
virtual int handle_input (ACE_HANDLE)
 
virtual int handle_output (ACE_HANDLE)
 
virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask)
 
virtual int handle_timeout (const ACE_Time_Value &current_time, const void *act=0)
 
- Public Member Functions inherited from ACE_Task< SYNCH_TRAITS >
 ACE_Task (ACE_Thread_Manager *thr_mgr=0, ACE_Message_Queue< ACE_SYNCH_USE, TIME_POLICY > *mq=0)
 
virtual ~ACE_Task (void)
 
ACE_Message_Queue
< ACE_SYNCH_USE, TIME_POLICY > * 
msg_queue (void)
 
void msg_queue (ACE_Message_Queue< ACE_SYNCH_USE, TIME_POLICY > *)
 
ACE_Time_Value_T< TIME_POLICY > gettimeofday (void) const
 
void set_time_policy (TIME_POLICY const &time_policy)
 
int putq (ACE_Message_Block *, ACE_Time_Value *timeout=0)
 
int getq (ACE_Message_Block *&mb, ACE_Time_Value *timeout=0)
 
int ungetq (ACE_Message_Block *, ACE_Time_Value *timeout=0)
 
int reply (ACE_Message_Block *mb, ACE_Time_Value *tv=0)
 
int put_next (ACE_Message_Block *msg, ACE_Time_Value *timeout=0)
 
const ACE_TCHARname (void) const
 
ACE_Task< ACE_SYNCH_USE,
TIME_POLICY > * 
next (void)
 
void next (ACE_Task< ACE_SYNCH_USE, TIME_POLICY > *)
 
ACE_Task< ACE_SYNCH_USE,
TIME_POLICY > * 
sibling (void)
 
ACE_Module< ACE_SYNCH_USE,
TIME_POLICY > * 
module (void) const
 
int flush (u_long flag=ACE_Task_Flags::ACE_FLUSHALL)
 
void water_marks (ACE_IO_Cntl_Msg::ACE_IO_Cntl_Cmds, size_t)
 
void dump (void) const
 
- Public Member Functions inherited from TAO_Connection_Handler
 TAO_Connection_Handler (TAO_ORB_Core *orb_core)
 
virtual ~TAO_Connection_Handler (void)
 
TAO_Transporttransport (void)
 
void transport (TAO_Transport *transport)
 
bool is_closed (void) const
 
bool is_open (void) const
 
bool is_timeout (void) const
 
bool is_connecting (void) const
 
int svc_i (void)
 
virtual int close_handler (u_long flags=0)
 
void connection_pending (void)
 
void cancel_pending_connection (void)
 
virtual int set_dscp_codepoint (CORBA::Boolean set_network_priority)
 
virtual int set_dscp_codepoint (CORBA::Long dscp_codepoint)
 
 TAO_LF_CH_Event (void)
 
virtual ~TAO_LF_CH_Event (void)
 
int successful (void) const
 
int error_detected (void) const
 

Protected Member Functions

TAO_Connection Handler overloads
virtual int release_os_resources (void)
 
virtual int handle_write_ready (const ACE_Time_Value *timeout)
 
- Protected Member Functions inherited from TAO_Connection_Handler
TAO_ORB_Coreorb_core (void)
 
int shared_open (void)
 
int set_socket_option (ACE_SOCK &sock, int snd_size, int rcv_size)
 
int handle_output_eh (ACE_HANDLE h, ACE_Event_Handler *eh)
 
int handle_input_eh (ACE_HANDLE h, ACE_Event_Handler *eh)
 
int handle_input_internal (ACE_HANDLE h, ACE_Event_Handler *eh)
 
int close_connection_eh (ACE_Event_Handler *eh)
 
virtual void pre_io_hook (int &return_value)
 
virtual void pos_io_hook (int &return_value)
 
virtual int is_state_final (void)
 

Private Attributes

int resume_flag_
 

Additional Inherited Members

- Public Attributes inherited from ACE_Task< SYNCH_TRAITS >
ACE_Message_Queue
< ACE_SYNCH_USE, TIME_POLICY > * 
msg_queue_
 
bool delete_msg_queue_
 
ACE_Module< ACE_SYNCH_USE,
TIME_POLICY > * 
mod_
 
ACE_Task< ACE_SYNCH_USE,
TIME_POLICY > * 
next_
 
 ACE_ALLOC_HOOK_DECLARE
 

Detailed Description

Handles requests on a single connection.

The Connection handler which is common for the Acceptor and the Connector

Constructor & Destructor Documentation

TAO_SHMIOP_Connection_Handler::TAO_SHMIOP_Connection_Handler ( ACE_Thread_Manager t = 0)

Constructor.

TAO_SHMIOP_Connection_Handler::TAO_SHMIOP_Connection_Handler ( TAO_ORB_Core orb_core)

Constructor.

TAO_SHMIOP_Connection_Handler::~TAO_SHMIOP_Connection_Handler ( void  )

Destructor.

Member Function Documentation

int TAO_SHMIOP_Connection_Handler::add_transport_to_cache ( void  )

Add ourselves to Cache.

int TAO_SHMIOP_Connection_Handler::close ( u_long  flags = 0)

Close called by the Acceptor or Connector when connection establishment fails.

int TAO_SHMIOP_Connection_Handler::close_connection ( void  )
virtual
int TAO_SHMIOP_Connection_Handler::handle_close ( ACE_HANDLE  ,
ACE_Reactor_Mask   
)
virtual
int TAO_SHMIOP_Connection_Handler::handle_input ( ACE_HANDLE  h)
virtual
int TAO_SHMIOP_Connection_Handler::handle_output ( ACE_HANDLE  handle)
virtual
int TAO_SHMIOP_Connection_Handler::handle_timeout ( const ACE_Time_Value current_time,
const void *  act = 0 
)
virtual

Reimplemented from ACE_Svc_Handler< class, class >.

int TAO_SHMIOP_Connection_Handler::handle_write_ready ( const ACE_Time_Value timeout)
protectedvirtual

Reimplemented from TAO_Connection_Handler.

int TAO_SHMIOP_Connection_Handler::open ( void *  )
virtual

Called by the <Strategy_Acceptor> when the handler is completely connected. Argument is unused.

int TAO_SHMIOP_Connection_Handler::open_handler ( void *  v)
virtual

Connection_Handler overloads

Implements TAO_Connection_Handler.

int TAO_SHMIOP_Connection_Handler::release_os_resources ( void  )
protectedvirtual

Reimplemented from TAO_Connection_Handler.

int TAO_SHMIOP_Connection_Handler::resume_handler ( void  )
virtual

Member Data Documentation

int TAO_SHMIOP_Connection_Handler::resume_flag_
private

Flag that we will be passing to the event handler to indicate whether the handle will be resumed by the method or not.


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