Handles requests on a single connection. More...

#include <SHMIOP_Connection_Handler.h>

Inheritance diagram for TAO_SHMIOP_Connection_Handler:

Collaboration diagram for TAO_SHMIOP_Connection_Handler:

Public Member Functions
	TAO_SHMIOP_Connection_Handler (ACE_Thread_Manager *t=0)
	Constructor.
	TAO_SHMIOP_Connection_Handler (TAO_ORB_Core *orb_core)
	Constructor.
	~TAO_SHMIOP_Connection_Handler (void)
	Destructor.
virtual int	open (void *)
int	close (u_long=0)
int	add_transport_to_cache (void)
	Add ourselves to Cache.

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	open (void *=0)
virtual int	close (u_long flags=0)
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 int	handle_close (ACE_HANDLE=ACE_INVALID_HANDLE, ACE_Reactor_Mask=ACE_Event_Handler::ALL_EVENTS_MASK)
virtual int	handle_timeout (const ACE_Time_Value &time, const void *)
virtual ACE_HANDLE	get_handle (void) const
virtual void	set_handle (ACE_HANDLE)
ACE_PEER_STREAM &	peer (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)
	ACE_Task (ACE_Thread_Manager thr_mgr=0, ACE_Message_Queue< ACE_SYNCH_USE > mq=0)
virtual	~ACE_Task (void)
ACE_Message_Queue < ACE_SYNCH_USE > *	msg_queue (void)
void	msg_queue (ACE_Message_Queue< ACE_SYNCH_USE > *)
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_TCHAR *	name (void) const
ACE_Task< ACE_SYNCH_USE > *	next (void)
void	next (ACE_Task< ACE_SYNCH_USE > *)
ACE_Task< ACE_SYNCH_USE > *	sibling (void)
ACE_Module< ACE_SYNCH_USE > *	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)
	ACE_Task_Base (ACE_Thread_Manager *=0)
virtual	~ACE_Task_Base (void)
virtual int	module_closed (void)
virtual int	put (ACE_Message_Block , ACE_Time_Value =0)
virtual int	svc (void)
virtual int	activate (long flags=THR_NEW_LWP\|THR_JOINABLE\|THR_INHERIT_SCHED, int n_threads=1, int force_active=0, long priority=ACE_DEFAULT_THREAD_PRIORITY, int grp_id=-1, ACE_Task_Base task=0, ACE_hthread_t thread_handles[]=0, void stack[]=0, size_t stack_size[]=0, ACE_thread_t thread_ids[]=0, const char *thr_name[]=0)
virtual int	wait (void)
virtual int	suspend (void)
virtual int	resume (void)
int	grp_id (void) const
void	grp_id (int)
ACE_Thread_Manager *	thr_mgr (void) const
void	thr_mgr (ACE_Thread_Manager *)
int	is_reader (void) const
int	is_writer (void) const
size_t	thr_count (void) const
ACE_thread_t	last_thread (void) const
	ACE_Service_Object (ACE_Reactor *=0)
virtual	~ACE_Service_Object (void)
virtual	~ACE_Event_Handler (void)
virtual int	priority (void) const
virtual void	priority (int priority)
virtual int	handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int	handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int	handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int	handle_exit (ACE_Process *)
virtual int	handle_signal (int signum, siginfo_t =0, ucontext_t =0)
virtual int	resume_handler (void)
virtual int	handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
virtual int	handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
virtual void	reactor (ACE_Reactor *reactor)
virtual ACE_Reactor *	reactor (void) const
virtual ACE_Reactor_Timer_Interface *	reactor_timer_interface (void) const
virtual Reference_Count	add_reference (void)
virtual Reference_Count	remove_reference (void)
Reference_Counting_Policy &	reference_counting_policy (void)
	ACE_Shared_Object (void)
virtual	~ACE_Shared_Object (void)
Public Member Functions inherited from TAO_Connection_Handler
	TAO_Connection_Handler (TAO_ORB_Core *orb_core)
virtual	~TAO_Connection_Handler (void)
TAO_Transport *	transport (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
	TAO_LF_Event (void)
virtual	~TAO_LF_Event (void)
virtual int	bind (TAO_LF_Follower *follower)
virtual int	unbind (TAO_LF_Follower *follower)
void	reset_state (int new_state)
void	state_changed (int new_state, TAO_Leader_Follower &lf)
int	keep_waiting (void)
Public Member Functions inherited from TAO_LF_CH_Event
	TAO_LF_CH_Event (void)
virtual	~TAO_LF_CH_Event (void)
	TAO_LF_Event (void)
virtual	~TAO_LF_Event (void)
virtual int	bind (TAO_LF_Follower *follower)
virtual int	unbind (TAO_LF_Follower *follower)
void	reset_state (int new_state)
void	state_changed (int new_state, TAO_Leader_Follower &lf)
int	keep_waiting (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 ACE_Svc_Handler< class, class >
	ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)
Protected Member Functions inherited from TAO_Connection_Handler
TAO_ORB_Core *	orb_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)
Protected Member Functions inherited from TAO_LF_CH_Event
virtual int	is_state_final (void)
virtual void	state_changed_i (int new_state)=0

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
Static Public Member Functions inherited from ACE_Svc_Handler< class, class >
static ACE_THR_FUNC_RETURN	svc_run (void *)
static void	cleanup (void object, void params)
Static Public Member Functions inherited from TAO_Connection_Handler
static const char *	state_name (int st)
Public Attributes inherited from ACE_Svc_Handler< class, class >
ACE_Message_Queue < ACE_SYNCH_USE > *	msg_queue_
bool	delete_msg_queue_
ACE_Module< ACE_SYNCH_USE > *	mod_
ACE_Task< ACE_SYNCH_USE > *	next_
	ACE_ALLOC_HOOK_DECLARE
Public Attributes inherited from TAO_Connection_Handler
	LFS_IDLE
	LFS_ACTIVE
	LFS_CONNECTION_WAIT
	LFS_SUCCESS
	LFS_FAILURE
	LFS_TIMEOUT
	LFS_CONNECTION_CLOSED
Protected Types inherited from ACE_Svc_Handler< class, class >
typedef ACE_Atomic_Op < ACE_SYNCH_MUTEX, Reference_Count >	Atomic_Reference_Count
Protected Attributes inherited from ACE_Svc_Handler< class, class >
ACE_PEER_STREAM	peer_
bool	dynamic_
bool	closing_
ACE_Connection_Recycling_Strategy *	recycler_
const void *	recycling_act_
Protected Attributes inherited from TAO_Connection_Handler
int	state_
TAO_LF_Follower *	follower_

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

Implements TAO_Connection_Handler.

int TAO_SHMIOP_Connection_Handler::handle_close	(	ACE_HANDLE	,
		ACE_Reactor_Mask
	)

virtual

int TAO_SHMIOP_Connection_Handler::handle_input ( ACE_HANDLE h )

virtual

Implements TAO_Connection_Handler.

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

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:

Public Member Functions

Protected Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation