diff options
| author | yamuna <yamuna@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-04-22 05:06:51 +0000 |
|---|---|---|
| committer | yamuna <yamuna@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-04-22 05:06:51 +0000 |
| commit | 046342096c974f6ab47539675745e037c8d5d531 (patch) | |
| tree | 9edcfd6a364c561d9b437536eda36c83679d1b32 | |
| parent | d63535051a07faecce3f47085550450617b5ec99 (diff) | |
| download | ATCD-046342096c974f6ab47539675745e037c8d5d531.tar.gz | |
*** empty log message ***
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/AV/QoS_UDP.cpp | 34 |
1 files changed, 29 insertions, 5 deletions
diff --git a/TAO/orbsvcs/orbsvcs/AV/QoS_UDP.cpp b/TAO/orbsvcs/orbsvcs/AV/QoS_UDP.cpp index f9326f6fa44..36aebe8265b 100644 --- a/TAO/orbsvcs/orbsvcs/AV/QoS_UDP.cpp +++ b/TAO/orbsvcs/orbsvcs/AV/QoS_UDP.cpp @@ -486,9 +486,19 @@ TAO_AV_UDP_QoS_Flow_Handler::handle_timeout (const ACE_Time_Value &tv, int TAO_AV_UDP_QoS_Flow_Handler::set_remote_address (ACE_Addr *address) { + if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "(%N,%l) TAO_AV_UDP_QoS_Flow_Handler::set_remote_address\n")); + { + char buf [BUFSIZ]; + ACE_INET_Addr *remote_addr = ACE_dynamic_cast (ACE_INET_Addr*, address); + remote_addr->addr_to_string (buf, + BUFSIZ); + + ACE_DEBUG ((LM_DEBUG, + "(%N,%l) TAO_AV_UDP_QoS_Flow_Handler::set_remote_address %s\n", + buf)); + } + ACE_INET_Addr *inet_addr = ACE_dynamic_cast (ACE_INET_Addr*,address); @@ -514,8 +524,14 @@ TAO_AV_UDP_QoS_Flow_Handler::set_remote_address (ACE_Addr *address) ACE_INET_Addr local_addr; this->get_socket ()->get_local_addr (local_addr); - this->qos_session_->source_port (local_addr.get_port_number ()); - + ACE_INET_Addr* src_addr; + ACE_NEW_RETURN (src_addr, + ACE_INET_Addr (local_addr.get_port_number (), + local_addr.get_host_name ()), + -1); + + this->qos_session_->source_addr (src_addr); + if (helper.activate_qos_handler (this->qos_session_, this) == -1) ACE_ERROR_RETURN ((LM_ERROR, @@ -1253,7 +1269,15 @@ TAO_AV_UDP_QoS_Connector::connect (TAO_FlowSpec_Entry *entry, if (this->entry_->role () == TAO_FlowSpec_Entry::TAO_AV_PRODUCER) { - this->qos_session_->source_port (local_addr->get_port_number ()); + //this->qos_session_->source_port (local_addr->get_port_number ()); + ACE_INET_Addr* src_addr; + ACE_NEW_RETURN (src_addr, + ACE_INET_Addr (local_addr->get_port_number (), + local_addr->get_host_name ()), + -1); + + this->qos_session_->source_addr (src_addr); + } handler->qos_session (this->qos_session_); |