diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/AV/TCP.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/AV/TCP.cpp | 678 |
1 files changed, 0 insertions, 678 deletions
diff --git a/TAO/orbsvcs/orbsvcs/AV/TCP.cpp b/TAO/orbsvcs/orbsvcs/AV/TCP.cpp deleted file mode 100644 index 36d994ddca5..00000000000 --- a/TAO/orbsvcs/orbsvcs/AV/TCP.cpp +++ /dev/null @@ -1,678 +0,0 @@ -// $Id$ - -#include "TCP.h" -#include "AVStreams_i.h" - -//------------------------------------------------------------ -// TAO_AV_TCP_Transport -//------------------------------------------------------------ - -TAO_AV_TCP_Transport::TAO_AV_TCP_Transport (void) - :handler_ (0) -{ -} - -TAO_AV_TCP_Transport::TAO_AV_TCP_Transport (TAO_AV_TCP_Flow_Handler *handler) - :handler_ (handler) -{ -} - -TAO_AV_TCP_Transport::~TAO_AV_TCP_Transport (void) -{ -} - -int -TAO_AV_TCP_Transport::open (ACE_Addr * /*address*/) -{ - return 0; -} - -int -TAO_AV_TCP_Transport::close (void) -{ - return 0; -} - -int -TAO_AV_TCP_Transport::mtu (void) -{ - return -1; -} - -ACE_Addr* -TAO_AV_TCP_Transport::get_peer_addr (void) -{ - return 0; -} - -ssize_t -TAO_AV_TCP_Transport::send (const ACE_Message_Block *mblk, ACE_Time_Value *) -{ - // For the most part this was copied from GIOP::send_request and - // friends. - - iovec iov[IOV_MAX]; - int iovcnt = 0; - ssize_t n = 0; - ssize_t nbytes = 0; - - for (const ACE_Message_Block *i = mblk; - i != 0; - i = i->cont ()) - { - // Make sure there is something to send! - if (i->length () > 0) - { - iov[iovcnt].iov_base = i->rd_ptr (); - iov[iovcnt].iov_len = i->length (); - iovcnt++; - - // The buffer is full make a OS call. @@ TODO this should - // be optimized on a per-platform basis, for instance, some - // platforms do not implement writev() there we should copy - // the data into a buffer and call send_n(). In other cases - // there may be some limits on the size of the iovec, there - // we should set IOV_MAX to that limit. - if (iovcnt == IOV_MAX) - { - n = this->handler_->peer ().sendv_n ((const iovec *) iov, - iovcnt); - if (n < 1) - return n; - - nbytes += n; - iovcnt = 0; - } - } - } - - // Check for remaining buffers to be sent! - if (iovcnt != 0) - { - n = this->handler_->peer ().sendv_n ((const iovec *) iov, - iovcnt); - if (n < 1) - return n; - - nbytes += n; - } - - return nbytes; -} - -ssize_t -TAO_AV_TCP_Transport::send (const char *buf, - size_t len, - ACE_Time_Value *) -{ - return this->handler_->peer ().send_n (buf, len); -} - -ssize_t -TAO_AV_TCP_Transport::send (const iovec *iov, - int iovcnt, - ACE_Time_Value *) -{ - return this->handler_->peer ().sendv_n ((const iovec *) iov, - iovcnt); -} - -ssize_t -TAO_AV_TCP_Transport::recv (char *buf, - size_t len, - ACE_Time_Value *) -{ - return this->handler_->peer ().recv (buf, len); -} - -ssize_t -TAO_AV_TCP_Transport::recv (char *buf, - size_t len, - int flags, - ACE_Time_Value *) -{ - return this->handler_->peer ().recv (buf, - len, - flags); -} - -ssize_t -TAO_AV_TCP_Transport::recv (iovec *iov, - int iovcnt, - ACE_Time_Value *) -{ - return handler_->peer ().recvv_n (iov, iovcnt); -} - -//------------------------------------------------------------ -// TAO_AV_TCP_Protocol_Factory -//------------------------------------------------------------ - -TAO_AV_TCP_Factory::TAO_AV_TCP_Factory (void) -{ -} - -TAO_AV_TCP_Factory::~TAO_AV_TCP_Factory (void) -{ -} - -int -TAO_AV_TCP_Factory::init (int /* argc */, - char * /* argv */ []) -{ - return 0; -} - -int -TAO_AV_TCP_Factory::match_protocol (const char *protocol_string) -{ - if (ACE_OS::strcasecmp (protocol_string,"TCP") == 0) - return 1; - return 0; -} - -TAO_AV_Acceptor* -TAO_AV_TCP_Factory::make_acceptor (void) -{ - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_TCP_Factory::make_acceptor ")); - TAO_AV_Acceptor *acceptor = 0; - ACE_NEW_RETURN (acceptor, - TAO_AV_TCP_Acceptor, - 0); - return acceptor; -} - -TAO_AV_Connector* -TAO_AV_TCP_Factory::make_connector (void) -{ - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_TCP_Factory::make_connector ")); - TAO_AV_Connector *connector = 0; - ACE_NEW_RETURN (connector, - TAO_AV_TCP_Connector, - 0); - return connector; -} - -//------------------------------------------------------------ -// TAO_AV_TCP_Object -//------------------------------------------------------------ - -int -TAO_AV_TCP_Object::handle_input (void) -{ - int n = this->transport_->recv (this->frame_.rd_ptr (), - this->frame_.size ()); - if (n == -1) - ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Flow_Handler::handle_input recv failed\n"),-1); - if (n == 0) - ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Flow_Handler::handle_input connection closed\n"),-1); - this->frame_.wr_ptr (this->frame_.rd_ptr () + n); - - return this->callback_->receive_frame (&this->frame_); -} - -int -TAO_AV_TCP_Object::send_frame (ACE_Message_Block *frame, - TAO_AV_frame_info * /*frame_info*/) -{ - int result = this->transport_->send (frame); - if (result < 0) - return result; - return 0; -} - -int -TAO_AV_TCP_Object::send_frame (const iovec *iov, - int iovcnt, - TAO_AV_frame_info * /*frame_info*/) -{ - return this->transport_->send (iov,iovcnt); -} - -TAO_AV_TCP_Object::TAO_AV_TCP_Object (TAO_AV_Callback *callback, - TAO_AV_Transport *transport) - :TAO_AV_Protocol_Object (callback,transport) -{ - // @@ Is this a good size? - this->frame_.size (BUFSIZ); -} - -TAO_AV_TCP_Object::~TAO_AV_TCP_Object (void) -{ - // No-op -} -int -TAO_AV_TCP_Object::destroy (void) -{ - this->callback_->handle_destroy (); - return 0; -} - -//------------------------------------------------------------ -// TAO_AV_TCP_Flow_Factory -//------------------------------------------------------------ -TAO_AV_TCP_Flow_Factory::TAO_AV_TCP_Flow_Factory (void) -{ -} - -TAO_AV_TCP_Flow_Factory::~TAO_AV_TCP_Flow_Factory (void) -{ -} - -int -TAO_AV_TCP_Flow_Factory::init (int /* argc */, - char * /* argv */ []) -{ - return 0; -} - -int -TAO_AV_TCP_Flow_Factory::match_protocol (const char *flow_string) -{ - if (ACE_OS::strcasecmp (flow_string,"TCP") == 0) - return 1; - return 0; -} - -TAO_AV_Protocol_Object* -TAO_AV_TCP_Flow_Factory::make_protocol_object (TAO_FlowSpec_Entry *entry, - TAO_Base_StreamEndPoint *endpoint, - TAO_AV_Flow_Handler *handler, - TAO_AV_Transport *transport) -{ - TAO_AV_Callback *callback = 0; - endpoint->get_callback (entry->flowname (), - callback); - - TAO_AV_TCP_Object *object = 0; - ACE_NEW_RETURN (object, - TAO_AV_TCP_Object (callback, - transport), - 0); - callback->open (object, - handler); - endpoint->set_protocol_object (entry->flowname (), - object); - return object; -} - -//------------------------------------------------------------ -// TAO_AV_TCP_Base_Connector -//------------------------------------------------------------ - -int -TAO_AV_TCP_Base_Connector::connector_open (TAO_AV_TCP_Connector *connector, - ACE_Reactor *reactor) -{ - this->connector_ = connector; - this->reactor_ = reactor; - - int result = ACE_Connector <TAO_AV_TCP_Flow_Handler,ACE_SOCK_CONNECTOR>::open (reactor); - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Base_Connector::open failed\n"),-1); - return 0; -} - -int -TAO_AV_TCP_Base_Connector::make_svc_handler (TAO_AV_TCP_Flow_Handler *&tcp_handler) -{ - int result = - this->connector_->make_svc_handler (tcp_handler); - if (result < 0) - return result; - tcp_handler->reactor (this->reactor_); - return 0; -} - -int -TAO_AV_TCP_Base_Connector::connector_connect (TAO_AV_TCP_Flow_Handler *&handler, - const ACE_INET_Addr &remote_addr) -{ - int result = ACE_Connector <TAO_AV_TCP_Flow_Handler,ACE_SOCK_CONNECTOR>::connect (handler, - remote_addr); - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Base_Connector::connect failed\n"),-1); - return 0; -} - -//------------------------------------------------------------ -// TAO_AV_TCP_Connector -//------------------------------------------------------------ -TAO_AV_TCP_Connector::TAO_AV_TCP_Connector (void) -{ -} - -TAO_AV_TCP_Connector::~TAO_AV_TCP_Connector (void) -{ -} - -int -TAO_AV_TCP_Connector::make_svc_handler (TAO_AV_TCP_Flow_Handler *&tcp_handler) -{ - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_TCP_Connector::make_svc_handler\n")); - // TAO_AV_Callback *callback = 0; - if (this->endpoint_ != 0) - { -// this->endpoint_->get_callback (this->flowname_.c_str (), -// callback); - ACE_NEW_RETURN (tcp_handler, - // TAO_AV_TCP_Flow_Handler (callback), - TAO_AV_TCP_Flow_Handler, - -1); - TAO_AV_Protocol_Object *object = - this->flow_protocol_factory_->make_protocol_object (this->entry_, - this->endpoint_, - tcp_handler, - tcp_handler->transport ()); - tcp_handler->protocol_object (object); - // callback->protocol_object (object); -// this->endpoint_->set_protocol_object (this->flowname_.c_str (), -// object); - this->endpoint_->set_flow_handler (this->flowname_.c_str (),tcp_handler); - this->entry_->protocol_object (object); - this->entry_->handler (tcp_handler); - } - return 0; -} - -int -TAO_AV_TCP_Connector::open (TAO_Base_StreamEndPoint *endpoint, - TAO_AV_Core *av_core, - TAO_AV_Flow_Protocol_Factory *factory) - -{ - this->endpoint_ = endpoint; - this->flow_protocol_factory_ = factory; - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_TCP_Connector::open ")); - int result = this->connector_.connector_open(this, - av_core->reactor ()); - return result; -} - -int -TAO_AV_TCP_Connector::connect (TAO_FlowSpec_Entry *entry, - TAO_AV_Transport *&transport) -{ - this->entry_ = entry; - this->flowname_ = entry->flowname (); - ACE_Addr *remote_addr = entry->address (); - ACE_INET_Addr *inet_addr = ACE_dynamic_cast (ACE_INET_Addr *,remote_addr); - TAO_AV_TCP_Flow_Handler *handler; - int result = this->connector_.connector_connect (handler, - *inet_addr); - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_connector::open failed\n"),-1); - entry->handler (handler); - transport = handler->transport (); - return 0; -} - -int -TAO_AV_TCP_Connector::close (void) -{ - return 0; -} - -//------------------------------------------------------------ -// TAO_AV_TCP_Base_Connector -//------------------------------------------------------------ - -int -TAO_AV_TCP_Base_Acceptor::open (TAO_AV_TCP_Acceptor *acceptor, - ACE_Reactor *reactor, - const ACE_INET_Addr &local_addr, - TAO_FlowSpec_Entry *entry) -{ - this->acceptor_ = acceptor; - this->reactor_ = reactor; - this->entry_ = entry; - - int result = ACE_Acceptor <TAO_AV_TCP_Flow_Handler,ACE_SOCK_ACCEPTOR>::open (local_addr,reactor); - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Base_Connector::open failed\n"),-1); - return 0; -} - -int -TAO_AV_TCP_Base_Acceptor::make_svc_handler (TAO_AV_TCP_Flow_Handler *&handler) -{ - int result = this->acceptor_->make_svc_handler (handler); - if (result < 0) - return result; - handler->reactor (this->reactor_); - this->entry_->handler (handler); - return 0; -} - - -//------------------------------------------------------------ -// TAO_AV_TCP_Acceptor -//------------------------------------------------------------ - -TAO_AV_TCP_Acceptor::TAO_AV_TCP_Acceptor (void) -{ -} - -TAO_AV_TCP_Acceptor::~TAO_AV_TCP_Acceptor (void) -{ -} - -int -TAO_AV_TCP_Acceptor::make_svc_handler (TAO_AV_TCP_Flow_Handler *&tcp_handler) -{ - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_TCP_Acceptor::make_svc_handler\n")); - // TAO_AV_Callback *callback = 0; - if (this->endpoint_ != 0) - { -// this->endpoint_->get_callback (this->flowname_.c_str (), -// callback); - ACE_NEW_RETURN (tcp_handler, - // TAO_AV_TCP_Flow_Handler (callback), - TAO_AV_TCP_Flow_Handler, - -1); - TAO_AV_Protocol_Object *object = -// this->flow_protocol_factory_->make_protocol_object (callback, -// tcp_handler->transport ()); - this->flow_protocol_factory_->make_protocol_object (this->entry_, - this->endpoint_, - tcp_handler, - tcp_handler->transport ()); - tcp_handler->protocol_object (object); - // callback->protocol_object (object); -// this->endpoint_->set_protocol_object (this->flowname_.c_str (), -// object); - this->endpoint_->set_flow_handler (this->flowname_.c_str (),tcp_handler); - this->entry_->protocol_object (object); - this->entry_->handler (tcp_handler); - } - return 0; -} - -int -TAO_AV_TCP_Acceptor::open (TAO_Base_StreamEndPoint *endpoint, - TAO_AV_Core *av_core, - TAO_FlowSpec_Entry *entry, - TAO_AV_Flow_Protocol_Factory *factory) -{ - this->flow_protocol_factory_ = factory; - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_TCP_Acceptor::open ")); - this->av_core_ = av_core; - this->endpoint_ = endpoint; - this->entry_ = entry; - this->flowname_ = entry->flowname (); - ACE_Addr *address = entry->address (); - ACE_INET_Addr *inet_addr = (ACE_INET_Addr *) address; - inet_addr->set (inet_addr->get_port_number (), - inet_addr->get_host_name ()); - char buf[BUFSIZ]; - inet_addr->addr_to_string (buf, - BUFSIZ); - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_TCP_Acceptor::open: %s", - buf)); - int result = this->acceptor_.open (this, - av_core->reactor (), - *inet_addr, - entry); - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Acceptor::open failed"),-1); - entry->set_local_addr (address); - return 0; -} - -int -TAO_AV_TCP_Acceptor::open_default (TAO_Base_StreamEndPoint *endpoint, - TAO_AV_Core *av_core, - TAO_FlowSpec_Entry *entry, - TAO_AV_Flow_Protocol_Factory *factory) -{ - this->flow_protocol_factory_ = factory; - this->av_core_ = av_core; - this->endpoint_ = endpoint; - this->entry_ = entry; - this->flowname_ = entry->flowname (); - ACE_INET_Addr *address; - ACE_NEW_RETURN (address, - ACE_INET_Addr ("0"), - -1); - int result = this->acceptor_.open (this, - av_core->reactor (), - *address, - entry); - - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Acceptor::open failed"),-1); - this->acceptor_.acceptor ().get_local_addr (*address); - address->set (address->get_port_number (), - address->get_host_name ()); - char buf[BUFSIZ]; - address->addr_to_string (buf,BUFSIZ); - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_TCP_Acceptor::open_default: %s\n",buf)); - entry->set_local_addr (address); - return 0; -} - - -int -TAO_AV_TCP_Acceptor::close (void) -{ - return 0; -} - -//------------------------------------------------------------ -// TAO_AV_TCP_Flow_Handler -//------------------------------------------------------------ - -TAO_AV_TCP_Flow_Handler::TAO_AV_TCP_Flow_Handler (TAO_AV_Callback * /*callback*/) - // :TAO_AV_Flow_Handler (callback) -{ - ACE_NEW (this->transport_, - TAO_AV_TCP_Transport (this)); -} - -TAO_AV_Transport * -TAO_AV_TCP_Flow_Handler::transport (void) -{ - return this->transport_; -} - -int -TAO_AV_TCP_Flow_Handler::open (void * /*arg*/) -{ - - 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 */ - - // 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) - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG, - "(%P|%t) connection to server <%s> on %d\n", - server, this->peer ().get_handle ())); - - this->peer ().enable (ACE_NONBLOCK); - // Register the handler with the reactor. - if (this->reactor () - && this->reactor ()->register_handler - (this, - ACE_Event_Handler::READ_MASK) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - ASYS_TEXT ("%p\n"), - ASYS_TEXT ("unable to register client handler")), - -1); - return 0; -} - -int -TAO_AV_TCP_Flow_Handler::handle_input (ACE_HANDLE /*fd*/) -{ - return this->protocol_object_->handle_input (); -} - -int -TAO_AV_TCP_Flow_Handler::handle_timeout (const ACE_Time_Value &tv, - const void *arg) -{ - return TAO_AV_Flow_Handler::handle_timeout (tv,arg); -} - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_Acceptor<TAO_AV_TCP_Flow_Handler, ACE_SOCK_ACCEPTOR>; -template class ACE_Connector<TAO_AV_TCP_Flow_Handler, ACE_SOCK_CONNECTOR>; - -template class ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler>; -template class ACE_Map_Entry<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *>; -template class ACE_Map_Manager<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *, ACE_SYNCH_RW_MUTEX>; -template class ACE_Map_Iterator_Base<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *, ACE_SYNCH_RW_MUTEX>; -template class ACE_Map_Iterator<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *, ACE_SYNCH_RW_MUTEX>; -template class ACE_Map_Reverse_Iterator<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *, ACE_SYNCH_RW_MUTEX>; - -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_Acceptor<TAO_AV_TCP_Flow_Handler, ACE_SOCK_Acceptor, ACE_INET_Addr> -#pragma instantiate ACE_Connector<TAO_AV_TCP_Flow_Handler, ACE_SOCK_Connector, ACE_INET_Addr> - -#pragma instantiate ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> -#pragma instantiate ACE_Map_Entry<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *> -#pragma instantiate ACE_Map_Manager<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *, ACE_SYNCH_RW_MUTEX> -#pragma instantiate ACE_Map_Iterator_Base<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *, ACE_SYNCH_RW_MUTEX> -#pragma instantiate ACE_Map_Iterator<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *, ACE_SYNCH_RW_MUTEX> -#pragma instantiate ACE_Map_Reverse_Iterator<ACE_HANDLE, ACE_Svc_Tuple<TAO_AV_TCP_Flow_Handler> *, ACE_SYNCH_RW_MUTEX> - -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ - -ACE_STATIC_SVC_DEFINE (TAO_AV_TCP_Flow_Factory, - ASYS_TEXT ("TCP_Flow_Factory"), - ACE_SVC_OBJ_T, - &ACE_SVC_NAME (TAO_AV_TCP_Flow_Factory), - ACE_Service_Type::DELETE_THIS | - ACE_Service_Type::DELETE_OBJ, - 0) - -ACE_FACTORY_DEFINE (AV, TAO_AV_TCP_Flow_Factory) - -ACE_STATIC_SVC_DEFINE (TAO_AV_TCP_Factory, - ASYS_TEXT ("TCP_Factory"), - ACE_SVC_OBJ_T, - &ACE_SVC_NAME (TAO_AV_TCP_Factory), - ACE_Service_Type::DELETE_THIS | - ACE_Service_Type::DELETE_OBJ, - 0) - -ACE_FACTORY_DEFINE (AV, TAO_AV_TCP_Factory) |