diff options
| author | Johnny Willemsen <jwillemsen@remedy.nl> | 2005-04-11 08:46:32 +0000 |
|---|---|---|
| committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2005-04-11 08:46:32 +0000 |
| commit | 81883ddb15d8a133b300e2eef805ed6c13eb8634 (patch) | |
| tree | 6df12b569632a4c02f398cbd142a906ee79dab5d | |
| parent | 109d0e8e46c7bb6036de39e86a8ae48666ecef51 (diff) | |
| download | ATCD-81883ddb15d8a133b300e2eef805ed6c13eb8634.tar.gz | |
ChangeLogTag: Mon Apr 11 09:41:12 UTC 2005 Johnny Willemsen <jwillemsen@remedy.nl>
| -rw-r--r-- | TAO/ChangeLog | 7 | ||||
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/ECG_Mcast_EH.cpp | 8 |
2 files changed, 13 insertions, 2 deletions
diff --git a/TAO/ChangeLog b/TAO/ChangeLog index e0ec5cfdd33..b6e5b5a2597 100644 --- a/TAO/ChangeLog +++ b/TAO/ChangeLog @@ -1,3 +1,10 @@ +Mon Apr 11 09:41:12 UTC 2005 Johnny Willemsen <jwillemsen@remedy.nl> + + * orbsvcs/orbsvcs/Naming/Naming_Client.cpp: + * orbsvcs/orbsvcs/Naming/Naming_Server.cpp: + When we print out that we caught an exception make clear in which + method we caught it. + Mon Apr 11 09:38:12 UTC 2005 Johnny Willemsen <jwillemsen@remedy.nl> * tao/Valuetype/ValueBase.h: diff --git a/TAO/orbsvcs/orbsvcs/Event/ECG_Mcast_EH.cpp b/TAO/orbsvcs/orbsvcs/Event/ECG_Mcast_EH.cpp index 5c52c8e7b3c..434131ed80f 100644 --- a/TAO/orbsvcs/orbsvcs/Event/ECG_Mcast_EH.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/ECG_Mcast_EH.cpp @@ -228,7 +228,12 @@ TAO_ECG_Mcast_EH::add_new_subscriptions (Address_Set& multicast_addresses) this->subscriptions_[subscriptions_size] = new_subscription; ACE_SOCK_Dgram_Mcast *socket = new_subscription.dgram; - socket->enable (ACE_NONBLOCK); + socket->subscribe (new_subscription.mcast_addr, 1, this->net_if_); + if ( socket->enable (ACE_NONBLOCK) != 0 ) { + ACE_ERROR ((LM_ERROR, + "Error: %d - Unable to enable nonblocking on mcast_eh\n", + errno )); + } if (this->recvbuf_size_ != 0 && (((ACE_SOCK_Dgram *)socket)->set_option(SOL_SOCKET, @@ -242,7 +247,6 @@ TAO_ECG_Mcast_EH::add_new_subscriptions (Address_Set& multicast_addresses) errno, this->recvbuf_size_)); } - socket->subscribe (new_subscription.mcast_addr, 1, this->net_if_); (void) this->reactor ()->register_handler ( socket->get_handle (), this, |