diff options
Diffstat (limited to 'TAO/tao/IIOP_Connect.cpp')
-rw-r--r-- | TAO/tao/IIOP_Connect.cpp | 444 |
1 files changed, 0 insertions, 444 deletions
diff --git a/TAO/tao/IIOP_Connect.cpp b/TAO/tao/IIOP_Connect.cpp deleted file mode 100644 index e6cec142a38..00000000000 --- a/TAO/tao/IIOP_Connect.cpp +++ /dev/null @@ -1,444 +0,0 @@ -// $Id$ - -#include "tao/IIOP_Connect.h" -#include "tao/Timeprobe.h" -#include "tao/IIOP_Transport.h" -#include "tao/debug.h" -#include "tao/ORB_Core.h" -#include "tao/ORB.h" -#include "tao/CDR.h" -#include "tao/Wait_Strategy.h" - -#if !defined (__ACE_INLINE__) -# include "tao/IIOP_Connect.i" -#endif /* ! __ACE_INLINE__ */ - -ACE_RCSID(tao, Connect, "$Id$") - -#if defined (ACE_ENABLE_TIMEPROBES) - - static const char *TAO_Connect_Timeprobe_Description[] = -{ - "Server_Connection_Handler::send_response - start", - "Server_Connection_Handler::send_response - end", - - "Server_Connection_Handler::handle_input - start", - "Server_Connection_Handler::handle_input - end", - - "Server_Connection_Handler::handle_locate - start", - "Server_Connection_Handler::handle_locate - end", - - "Server_Connection_Handler::receive_request - end", - - "IIOP_Client_Connection_Handler::send_request - start", - "IIOP_Client_Connection_Handler::send_request - end", - - "GIOP::Send_Request - return" -}; - -enum -{ - // Timeprobe description table start key - TAO_SERVER_CONNECTION_HANDLER_SEND_RESPONSE_START = 300, - TAO_SERVER_CONNECTION_HANDLER_SEND_RESPONSE_END, - - TAO_SERVER_CONNECTION_HANDLER_HANDLE_INPUT_START, - TAO_SERVER_CONNECTION_HANDLER_HANDLE_INPUT_END, - - TAO_SERVER_CONNECTION_HANDLER_HANDLE_LOCATE_START, - TAO_SERVER_CONNECTION_HANDLER_HANDLE_LOCATE_END, - - TAO_SERVER_CONNECTION_HANDLER_RECEIVE_REQUEST_END, - - TAO_IIOP_CLIENT_CONNECTION_HANDLER_SEND_REQUEST_START, - TAO_IIOP_CLIENT_CONNECTION_HANDLER_SEND_REQUEST_END, - - GIOP_SEND_REQUEST_RETURN -}; - -// Setup Timeprobes -ACE_TIMEPROBE_EVENT_DESCRIPTIONS (TAO_Connect_Timeprobe_Description, - TAO_SERVER_CONNECTION_HANDLER_SEND_RESPONSE_START); - -#endif /* ACE_ENABLE_TIMEPROBES */ - -TAO_IIOP_Handler_Base::TAO_IIOP_Handler_Base (TAO_ORB_Core *orb_core) - : TAO_SVC_HANDLER (orb_core->thr_mgr (), 0, 0) -{ -} - -TAO_IIOP_Handler_Base::TAO_IIOP_Handler_Base (ACE_Thread_Manager *t) - : TAO_SVC_HANDLER (t, 0, 0) -{ -} - -TAO_IIOP_Server_Connection_Handler::TAO_IIOP_Server_Connection_Handler (ACE_Thread_Manager *t) - : TAO_IIOP_Handler_Base (t), - orb_core_ (0), - tss_resources_ (0), - input_ (ACE_CDR::DEFAULT_BUFSIZE) -{ - // This constructor should *never* get called, it is just here to - // make the compiler happy: the default implementation of the - // Creation_Strategy requires a constructor with that signature, we - // don't use that implementation, but some (most?) compilers - // instantiate it anyway. - ACE_ASSERT (this->orb_core_ != 0); -} - -TAO_IIOP_Server_Connection_Handler::TAO_IIOP_Server_Connection_Handler (TAO_ORB_Core *orb_core) - : TAO_IIOP_Handler_Base (orb_core), - orb_core_ (orb_core), - tss_resources_ (TAO_ORB_CORE_TSS_RESOURCES::instance ()), - input_ (orb_core->create_input_cdr_data_block (ACE_CDR::DEFAULT_BUFSIZE), - TAO_ENCAP_BYTE_ORDER, - orb_core) -{ - transport_ = new TAO_IIOP_Server_Transport (this, - this->orb_core_); -} - -TAO_IIOP_Server_Connection_Handler::~TAO_IIOP_Server_Connection_Handler (void) -{ - delete this->transport_; - this->transport_ = 0; -} - -TAO_Transport * -TAO_IIOP_Server_Connection_Handler::transport (void) -{ - // @@ For now return nothing since all is not in place! - return transport_; -} - -int -TAO_IIOP_Server_Connection_Handler::open (void*) -{ -#if !defined (ACE_LACKS_SOCKET_BUFSIZ) - int sndbufsize = - this->orb_core_->orb_params ()->sock_sndbuf_size (); - int rcvbufsize = - this->orb_core_->orb_params ()->sock_rcvbuf_size (); - - if (this->peer ().set_option (SOL_SOCKET, - SO_SNDBUF, - (void *) &sndbufsize, - sizeof (sndbufsize)) == -1 - && errno != ENOTSUP) - return -1; - else if (this->peer ().set_option (SOL_SOCKET, - SO_RCVBUF, - (void *) &rcvbufsize, - sizeof (rcvbufsize)) == -1 - && errno != ENOTSUP) - return -1; -#endif /* !ACE_LACKS_SOCKET_BUFSIZ */ - -#if defined (TCP_NODELAY) - int nodelay = 1; - if (this->peer ().set_option (IPPROTO_TCP, - TCP_NODELAY, - (void *) &nodelay, - sizeof (nodelay)) == -1) - return -1; -#endif /* TCP_NODELAY */ - - (void) this->peer ().enable (ACE_CLOEXEC); - // Set the close-on-exec flag for that file descriptor. If the - // operation fails we are out of luck (some platforms do not support - // it and return -1). - - // Called by the <Strategy_Acceptor> when the handler is completely - // connected. - ACE_INET_Addr addr; - - if (this->peer ().get_remote_addr (addr) == -1) - return -1; - - char client[MAXHOSTNAMELEN + 16]; - (void) addr.addr_to_string (client, sizeof (client)); - - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) connection from client <%s> on %d\n", - client, this->peer ().get_handle ())); - return 0; -} - -int -TAO_IIOP_Server_Connection_Handler::activate (long flags, - int n_threads, - int force_active, - long priority, - int grp_id, - ACE_Task_Base *task, - ACE_hthread_t thread_handles[], - void *stack[], - size_t stack_size[], - ACE_thread_t thread_names[]) -{ - if (TAO_orbdebug) - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) TAO_IIOP_Server_Connection_Handler::activate %d threads, flags = %d\n", - n_threads, - flags, - THR_BOUND)); - - return TAO_SVC_HANDLER::activate (flags, - n_threads, - force_active, - priority, - grp_id, - task, - thread_handles, - stack, - stack_size, - thread_names); -} - -int -TAO_IIOP_Server_Connection_Handler::handle_close (ACE_HANDLE handle, - ACE_Reactor_Mask rm) -{ - if (TAO_orbdebug) - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) TAO_IIOP_Server_Connection_Handler::handle_close (%d, %d)\n", - handle, - rm)); - - return TAO_SVC_HANDLER::handle_close (handle, rm); -} - -int -TAO_IIOP_Server_Connection_Handler::svc (void) -{ - // This method is called when an instance is "activated", i.e., - // turned into an active object. Presumably, activation spawns a - // thread with this method as the "worker function". - int result = 0; - - // Inheriting the ORB_Core tss stuff from the parent thread. - this->orb_core_->inherit_from_parent_thread (this->tss_resources_); - - if (TAO_orbdebug) - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) TAO_IIOP_Server_Connection_Handler::svc begin\n")); - - // Here we simply synthesize the "typical" event loop one might find - // in a reactive handler, except that this can simply block waiting - // for input. - - while ((result = handle_input ()) >= 0) - continue; - - if (TAO_orbdebug) - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) TAO_IIOP_Server_Connection_Handler::svc end\n")); - - return result; -} - -void -TAO_IIOP_Server_Connection_Handler::send_response (TAO_OutputCDR &output) -{ - TAO_FUNCTION_PP_TIMEPROBE (TAO_SERVER_CONNECTION_HANDLER_SEND_RESPONSE_START); - - TAO_GIOP::send_message (this->transport_, - output, - this->orb_core_); -} - -int -TAO_IIOP_Server_Connection_Handler::handle_input (ACE_HANDLE) -{ - int result = TAO_GIOP::handle_input (this->transport (), - this->orb_core_, - this->message_header_, - this->current_offset_, - this->input_); - - if (result == -1 && TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, - "TAO (%P|%t) - %p\n", - "IIOP_Server_CH::handle_input, handle_input")); - } - if (result == 1) - { - TAO_GIOP_MessageHeader header_copy = this->message_header_; - this->message_header_.message_size = 0; - TAO_GIOP::process_server_message (this->transport (), - this->orb_core_, - this->input_, - header_copy); - result = 0; - } - return result; -} - -// **************************************************************** - -// transport obj. -TAO_IIOP_Client_Connection_Handler:: -TAO_IIOP_Client_Connection_Handler (ACE_Thread_Manager *t, - TAO_ORB_Core* orb_core) - : TAO_IIOP_Handler_Base (t) -{ - transport_ = new TAO_IIOP_Client_Transport (this, - orb_core); -} - -TAO_IIOP_Client_Connection_Handler::~TAO_IIOP_Client_Connection_Handler (void) -{ - delete this->transport_; - this->transport_ = 0; -} - -TAO_Transport * -TAO_IIOP_Client_Connection_Handler::transport (void) -{ - return this->transport_; -} - -// @@ Should I do something here to enable non-blocking?? (Alex). -// @@ Alex: I don't know if this is the place to do it, but the way to -// do it is: -// if (this->peer ().enable (ACE_NONBLOCK) == -1) -// return -1; -// Probably we will need to use the transport to decide if it is -// needed or not. - -int -TAO_IIOP_Client_Connection_Handler::open (void *) -{ - // @@ TODO: This flags should be set using the RT CORBA policies... - - // Here is where we could enable all sorts of things such as - // nonblock I/O, sock buf sizes, TCP no-delay, etc. - - // @@ We should use this->orb_core_!! -#if !defined (ACE_LACKS_SOCKET_BUFSIZ) - int sndbufsize = - this->transport ()->orb_core ()->orb_params ()->sock_sndbuf_size (); - int rcvbufsize = - this->transport ()->orb_core ()->orb_params ()->sock_rcvbuf_size (); - - if (this->peer ().set_option (SOL_SOCKET, - SO_SNDBUF, - (void *) &sndbufsize, - sizeof (sndbufsize)) == -1 - && errno != ENOTSUP) - return -1; - else if (this->peer ().set_option (SOL_SOCKET, - SO_RCVBUF, - (void *) &rcvbufsize, - sizeof (rcvbufsize)) == -1 - && errno != ENOTSUP) - return -1; -#endif /* ACE_LACKS_SOCKET_BUFSIZ */ - - int nodelay = 1; - -#if defined (TCP_NODELAY) - if (this->peer ().set_option (IPPROTO_TCP, - TCP_NODELAY, - (void *) &nodelay, - sizeof (nodelay)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "NODELAY failed\n"), - -1); -#endif /* TCP_NODELAY */ - - (void) this->peer ().enable (ACE_CLOEXEC); - // Set the close-on-exec flag for that file descriptor. If the - // operation fails we are out of luck (some platforms do not support - // it and return -1). - - // Called by the <Strategy_Acceptor> when the handler is completely - // connected. - ACE_INET_Addr addr; - - if (this->peer ().get_remote_addr (addr) == -1) - return -1; - - char server[MAXHOSTNAMELEN + 16]; - - (void) addr.addr_to_string (server, sizeof (server)); - - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) connection to server <%s> on %d\n", - server, this->peer ().get_handle ())); - - // Register the handler with the Reactor if necessary. - return this->transport ()->wait_strategy ()->register_handler (); -} - -int -TAO_IIOP_Client_Connection_Handler::handle_input (ACE_HANDLE) -{ - // Call the waiter to handle the input. - return this->transport ()->wait_strategy ()->handle_input (); -} - -int -TAO_IIOP_Client_Connection_Handler::handle_close (ACE_HANDLE handle, - ACE_Reactor_Mask rm) -{ - // @@ Alex: we need to figure out if the transport decides to close - // us or something else. If it is something else (for example - // the cached connector trying to make room for other - // connections) then we should let the transport know, so it can - // in turn take appropiate action (such as sending exceptions to - // all waiting reply handlers). - - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) TAO_IIOP_Client_Connection_Handler::" - "handle_close (%d, %d)\n", handle, rm)); - - if (this->recycler ()) - this->recycler ()->mark_as_closed (this->recycling_act ()); - - // Deregister this handler with the ACE_Reactor. - if (this->reactor ()) - { - ACE_Reactor_Mask mask = ACE_Event_Handler::ALL_EVENTS_MASK | - ACE_Event_Handler::DONT_CALL; - - // Make sure there are no timers. - this->reactor ()->cancel_timer (this); - - // Remove self from reactor. - this->reactor ()->remove_handler (this, mask); - } - - this->peer ().close (); - - return 0; -} - -int -TAO_IIOP_Client_Connection_Handler::close (u_long flags) -{ - this->destroy (); - - return 0; -} - -// **************************************************************** - -// @@ Are these instantiations still required?? Where? Not on this -// file, so they shouldn't be here! - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) - -template class ACE_Unbounded_Set<ACE_INET_Addr>; -template class ACE_Unbounded_Set_Iterator<ACE_INET_Addr>; - -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) - -#pragma instantiate ACE_Unbounded_Set<ACE_INET_Addr> -#pragma instantiate ACE_Unbounded_Set_Iterator<ACE_INET_Addr> - -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |