diff options
Diffstat (limited to 'TAO/examples/PluggableUDP/DIOP/DIOP_Connection_Handler.h')
| -rw-r--r-- | TAO/examples/PluggableUDP/DIOP/DIOP_Connection_Handler.h | 189 |
1 files changed, 0 insertions, 189 deletions
diff --git a/TAO/examples/PluggableUDP/DIOP/DIOP_Connection_Handler.h b/TAO/examples/PluggableUDP/DIOP/DIOP_Connection_Handler.h deleted file mode 100644 index 8409c449340..00000000000 --- a/TAO/examples/PluggableUDP/DIOP/DIOP_Connection_Handler.h +++ /dev/null @@ -1,189 +0,0 @@ -// This may look like C, but it's really -*- C++ -*- -// =================================================================== -/** - * @file DIOP_Connection_Handler.h - * - * $Id$ - * - * @author Originally by Chris Cleeland as DIOP_Connect.h - * @author modified by Balachandran Natarajan <bala@cs.wustl.edu> - */ -// =================================================================== - -#ifndef TAO_DIOP_CONNECTION_HANDLER_H -#define TAO_DIOP_CONNECTION_HANDLER_H -#include "ace/pre.h" - -#include "ace/Reactor.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -#pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include "ace/Acceptor.h" - -#include "tao/corbafwd.h" -#include "tao/Wait_Strategy.h" -#include "tao/Connection_Handler.h" -#include "DIOP_Transport.h" -//#include "tao/DIOPC.h" -#include "ace/SOCK_Dgram.h" -#include "diop_export.h" - -// Forward Decls -class TAO_Pluggable_Messaging; - -// **************************************************************** - -/** - * @class TAO_DIOP_Properties - * - * @brief TCP protocol properties specification for a set of - * connections. - * - */ - -class TAO_DIOP_Export TAO_DIOP_Properties -{ - -public: - int send_buffer_size; - int recv_buffer_size; - int no_delay; -}; - - - -// **************************************************************** - -/** - * @class TAO_DIOP_Connection_Handler - * - * @brief Handles requests on a single connection. - * - * The Connection handler which is common for the Acceptor and - * the Connector - */ - - -class TAO_DIOP_Export TAO_DIOP_Connection_Handler : public TAO_DIOP_SVC_HANDLER, - public TAO_Connection_Handler -{ - -public: - - TAO_DIOP_Connection_Handler (ACE_Thread_Manager* t = 0); - - /// Constructor. <arg> parameter is used by the Acceptor to pass the - /// protocol configuration properties for this connection. - TAO_DIOP_Connection_Handler (TAO_ORB_Core *orb_core, - CORBA::Boolean flag, - void *arg); - - - /// Destructor. - ~TAO_DIOP_Connection_Handler (void); - - /// Called by the <Strategy_Acceptor> when the handler is completely - /// connected. Argument is unused. - virtual int open (void *); - - // @@ Frank: Similar to open, but called on server - virtual int open_server (void); - - /// = Active object activation method. - virtual int activate (long flags = THR_NEW_LWP, - 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_names[] = 0); - - /// Only used when the handler is turned into an active object by - /// calling <activate>. This serves as the event loop in such cases. - virtual int svc (void); - - /// Perform appropriate closing. - virtual int handle_close (ACE_HANDLE = ACE_INVALID_HANDLE, - ACE_Reactor_Mask = ACE_Event_Handler::NULL_MASK); - - /// Return the underlying transport object - TAO_Transport *transport (void); - - /// Return the underlying handle - virtual ACE_HANDLE fetch_handle (void); - - /// Called when buffering timer expires. - virtual int handle_timeout (const ACE_Time_Value &tv, - const void *arg = 0); - - /// Object termination hook. - virtual int close (u_long flags = 0); - - /// Add ourselves to Cache. - int add_handler_to_cache (void); - - // @@ Frank: Not needed - /* - /// Process the <listen_list> - int process_listen_point_list (DIOP::ListenPointList &listen_list); - */ - - // @@ Frank: From DIOP_Connect.h - ACE_HANDLE get_handle (void) const; - - const ACE_INET_Addr &addr (void); - - void addr (const ACE_INET_Addr &addr); - - const ACE_SOCK_Dgram &dgram (void); - // @@ Frank: End DIOP_Connect.h -protected: - - /// = Event Handler overloads - - /// Reads a message from the <peer()>, dispatching and servicing it - /// appropriately. - /// handle_input() just delegates on handle_input_i() which timeouts - /// after <max_wait_time>, this is used in thread-per-connection to - /// ensure that server threads eventually exit. - - virtual int handle_input (ACE_HANDLE = ACE_INVALID_HANDLE); - virtual int handle_input_i (ACE_HANDLE = ACE_INVALID_HANDLE, - ACE_Time_Value *max_wait_time = 0); - - // @@ Frank: From DIOP_Connect.h - virtual int handle_cleanup (); - - // @@ Frank: From DIOP_Connect.h - ACE_SOCK_Dgram udp_socket_; - - ACE_INET_Addr addr_; - // @@ Frank: From DIOP_Connect.h - -private: - - /// Transport object reference. - TAO_DIOP_Transport transport_; - - /// Reference count.It is used to count nested upcalls on this - /// svc_handler i.e., the connection can close during nested upcalls, - /// you should not delete the svc_handler until the stack unwinds - /// from the nested upcalls. - u_long refcount_; - - /// TCP configuration for this connection. - TAO_DIOP_Properties *tcp_properties_; -}; - - -#if defined (__ACE_INLINE__) -#include "DIOP_Connection_Handler.i" -#endif /* __ACE_INLINE__ */ - -#include "ace/post.h" -#endif /* TAO_DIOP_CONNECTION_HANDLER_H */ |