diff options
author | yamuna <yamuna@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-04-15 20:57:06 +0000 |
---|---|---|
committer | yamuna <yamuna@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-04-15 20:57:06 +0000 |
commit | 11790fa7ce2d16d8384c6efed0ac4041d6e098c0 (patch) | |
tree | ebc7ea96c1a1241e015af1de9522b9b45ec29984 | |
parent | 71ff0e13c591fe86f88bc26710a8c10f5cb8e2fd (diff) | |
download | ATCD-11790fa7ce2d16d8384c6efed0ac4041d6e098c0.tar.gz |
*** empty log message ***
-rw-r--r-- | TAO/orbsvcs/orbsvcs/AV/AV_Core.cpp | 72 |
1 files changed, 36 insertions, 36 deletions
diff --git a/TAO/orbsvcs/orbsvcs/AV/AV_Core.cpp b/TAO/orbsvcs/orbsvcs/AV/AV_Core.cpp index c0c455c80ea..70d33a30226 100644 --- a/TAO/orbsvcs/orbsvcs/AV/AV_Core.cpp +++ b/TAO/orbsvcs/orbsvcs/AV/AV_Core.cpp @@ -307,27 +307,27 @@ TAO_AV_Core::init_forward_flows (TAO_Base_StreamEndPoint *endpoint, { case TAO_FlowSpec_Entry::TAO_AV_DIR_OUT: { - if (entry->handler () != 0) - { - // @@Naga: This wont be called in the case of Full Profile. - // For IN flows on the A side we should remove the handlers from the reactor. - ACE_Event_Handler *event_handler = entry->handler ()->event_handler (); - result = event_handler->reactor ()->remove_handler (event_handler, - ACE_Event_Handler::READ_MASK); - if (result < 0) - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_Core::init_forward_flows: remove_handler failed\n")); - } + if (entry->handler () != 0) + { + // @@Naga: This wont be called in the case of Full Profile. + // For IN flows on the A side we should remove the handlers from the reactor. + ACE_Event_Handler *event_handler = entry->handler ()->event_handler (); + result = event_handler->reactor ()->remove_handler (event_handler, + ACE_Event_Handler::READ_MASK); + if (result < 0) + if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_Core::init_forward_flows: remove_handler failed\n")); + } } default: break; } - // Now if the address_set has been changed due to the addition of a control entry we should - // add that to the flow_spec_set also. - if (flow_spec_set.find (entry) < 0) - { - // entry doesn't exist so add it. - flow_spec_set.insert (entry); - } + // Now if the address_set has been changed due to the addition of a control entry we should + // add that to the flow_spec_set also. + if (flow_spec_set.find (entry) < 0) + { + // entry doesn't exist so add it. + flow_spec_set.insert (entry); + } } } if (flow_set.size () > 0) @@ -335,8 +335,8 @@ TAO_AV_Core::init_forward_flows (TAO_Base_StreamEndPoint *endpoint, TAO_AV_FlowSpecSet tmp_flow_set (flow_set); flow_set.reset (); TAO_AV_FlowSpecSetItor end = tmp_flow_set.end (); - for (TAO_AV_FlowSpecSetItor start = tmp_flow_set.begin (); - start != end; ++start) + TAO_AV_FlowSpecSetItor start = tmp_flow_set.begin (); + for (start; start != end; ++start) { TAO_FlowSpec_Entry *entry = *start; TAO_FlowSpec_Entry *new_entry; @@ -377,8 +377,8 @@ TAO_AV_Core::init_forward_flows (TAO_Base_StreamEndPoint *endpoint, if (result == -1) ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_Core::init_Forward_flows: Acceptor_registry open failed\n"),-1); end = address_flow_set.end (); - for (TAO_AV_FlowSpecSetItor start = address_flow_set.begin (); - start != end; ++start) + start = address_flow_set.begin (); + for (start; start != end; ++start) { TAO_FlowSpec_Entry *entry = (*start); switch (entry->direction ()) @@ -388,11 +388,11 @@ TAO_AV_Core::init_forward_flows (TAO_Base_StreamEndPoint *endpoint, if (entry->handler () != 0) { // For IN flows on the A side we should remove the handlers from the reactor. - ACE_Event_Handler *event_handler = entry->handler ()->event_handler (); - result = event_handler->reactor ()->remove_handler (event_handler, - ACE_Event_Handler::READ_MASK); - if (result < 0) - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_Core::init_forward_flows: remove_handler failed\n")); + ACE_Event_Handler *event_handler = entry->handler ()->event_handler (); + result = event_handler->reactor ()->remove_handler (event_handler, + ACE_Event_Handler::READ_MASK); + if (result < 0) + if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_AV_Core::init_forward_flows: remove_handler failed\n")); } } default: @@ -400,11 +400,11 @@ TAO_AV_Core::init_forward_flows (TAO_Base_StreamEndPoint *endpoint, } // Now if the address_set has been changed due to the addition of a control entry we should // add that to the flow_spec_set also. - if (flow_spec_set.find (entry) < 0) - { - // entry doesn't exist so add it. - flow_spec_set.insert (entry); - } + if (flow_spec_set.find (entry) < 0) + { + // entry doesn't exist so add it. + flow_spec_set.insert (entry); + } } } @@ -427,13 +427,13 @@ TAO_AV_Core::init_forward_flows (TAO_Base_StreamEndPoint *endpoint, (*connect)->carrier_protocol_str (), local_addr, local_control_addr); - /* - ACE_Addr *addr; - if ((addr = (*connect)->get_peer_addr ()) != 0) + /* + ACE_Addr *addr; + if ((addr = (*connect)->get_peer_addr ()) != 0) { - entry.set_peer_addr (addr); + entry.set_peer_addr (addr); }; - */ + */ int len = new_flowspec.length (); if (i == len) new_flowspec.length (len+1); |