TAO_Strategies  2.1.8
 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_Svc_Handler< class, class >
 ACE_Svc_Handler (ACE_Thread_Manager *thr_mgr=0, ACE_Message_Queue< ACE_SYNCH_USE > *mq=0, ACE_Reactor *reactor=ACE_Reactor::instance())
 
virtual ~ACE_Svc_Handler (void)
 
virtual int idle (u_long flags=0)
 
virtual ACE_Recyclable_State recycle_state (void) const
 
virtual int recycle_state (ACE_Recyclable_State new_state)
 
virtual void cleanup_hint (void **act_holder=0)
 
virtual int init (int argc, ACE_TCHAR *argv[])
 
virtual int fini (void)
 
virtual int info (ACE_TCHAR **info_string, size_t length) const
 
virtual ACE_HANDLE get_handle (void) const
 
virtual void set_handle (ACE_HANDLE)
 
ACE_PEER_STREAMpeer (void) const
 
void * operator new (size_t n)
 
void * operator new (size_t n, void *p)
 
virtual void destroy (void)
 
void operator delete (void *)
 
void operator delete (void *, void *)
 
void shutdown (void)
 
void dump (void) const
 
virtual void recycler (ACE_Connection_Recycling_Strategy *recycler, const void *recycling_act)
 
virtual
ACE_Connection_Recycling_Strategy
recycler (void) const
 
virtual const void * recycling_act (void) const
 
virtual int recycle (void *=0)
 
- Public Member Functions inherited from ACE_Task< ACE_SYNCH_USE >
 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 Types inherited from ACE_Svc_Handler< class, class >
typedef ACE_PEER_STREAM_ADDR addr_type
 
typedef ACE_PEER_STREAM stream_type
 
- Public Attributes inherited from ACE_Task< ACE_SYNCH_USE >
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
 
- Protected Attributes inherited from ACE_Svc_Handler< class, class >
ACE_PEER_STREAM peer_
 
bool dynamic_
 
bool closing_
 
ACE_Connection_Recycling_Strategyrecycler_
 
const void * recycling_act_
 
- Protected Attributes inherited from TAO_Connection_Handler
int state_
 
TAO_LF_Followerfollower_
 

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)
virtual

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

Reimplemented from ACE_Svc_Handler< class, class >.

int TAO_SHMIOP_Connection_Handler::close_connection ( void  )
virtual
int TAO_SHMIOP_Connection_Handler::handle_close ( ACE_HANDLE  ,
ACE_Reactor_Mask   
)
virtual

Reimplemented from ACE_Svc_Handler< class, class >.

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.

Reimplemented from ACE_Svc_Handler< class, class >.

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: