diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.cpp | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.cpp index 544bf3a1891..838f2b431ad 100644 --- a/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.cpp @@ -401,9 +401,15 @@ TAO_ECG_UDP_Receiver::handle_input (ACE_SOCK_Dgram& dgram) // from.get_ip_address (), from.get_port_number (), // fragment_id, fragment_count)); + TAO_ECG_UDP_Request_Index map_index (from, request_id); Request_Map_Entry* entry; + ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, + tao_mon, + this->request_map_protector_, + -1); + if (this->request_map_.find (map_index, entry) == -1) { // ACE_DEBUG ((LM_DEBUG, @@ -548,6 +554,11 @@ int TAO_ECG_UDP_Receiver::handle_timeout (const ACE_Time_Value& /* tv */, const void* /* act */) { + ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, + tao_mon, + this->request_map_protector_, + -1); + Request_Map::iterator begin = this->request_map_.begin (); Request_Map::iterator end = this->request_map_.end (); { |