aboutsummaryrefslogtreecommitdiffstatshomepage
diff options
context:
space:
mode:
authorMelanie2012-07-15 23:01:58 +0200
committerMelanie2012-07-15 23:01:58 +0200
commit668723fab31976895ceb42a372cfff7ed5689a9d (patch)
treefbb4e4281218d5557f509bca1db94079df43d3ae
parentTesting changes and instrumentation (diff)
downloadopensim-SC_OLD-668723fab31976895ceb42a372cfff7ed5689a9d.zip
opensim-SC_OLD-668723fab31976895ceb42a372cfff7ed5689a9d.tar.gz
opensim-SC_OLD-668723fab31976895ceb42a372cfff7ed5689a9d.tar.bz2
opensim-SC_OLD-668723fab31976895ceb42a372cfff7ed5689a9d.tar.xz
Remove instrumentation and fix the message delivery issue
-rw-r--r--OpenSim/Region/ClientStack/Linden/UDP/LLUDPServer.cs52
1 files changed, 28 insertions, 24 deletions
diff --git a/OpenSim/Region/ClientStack/Linden/UDP/LLUDPServer.cs b/OpenSim/Region/ClientStack/Linden/UDP/LLUDPServer.cs
index c807260..46337b3 100644
--- a/OpenSim/Region/ClientStack/Linden/UDP/LLUDPServer.cs
+++ b/OpenSim/Region/ClientStack/Linden/UDP/LLUDPServer.cs
@@ -698,42 +698,46 @@ namespace OpenSim.Region.ClientStack.LindenUDP
698 698
699 #region Packet to Client Mapping 699 #region Packet to Client Mapping
700 700
701 // UseCircuitCode handling 701 // If there is already a client for this endpoint, don't process UseCircuitCode
702 if (packet.Type == PacketType.UseCircuitCode) 702 IClientAPI client = null;
703 if (!m_scene.TryGetClient(address, out client))
703 { 704 {
704 lock (m_pendingCache) 705 // UseCircuitCode handling
706 if (packet.Type == PacketType.UseCircuitCode)
705 { 707 {
706 if (m_pendingCache.Contains(address)) 708 // And if there is a UseCircuitCode pending, also drop it
707 return; 709 lock (m_pendingCache)
710 {
711 if (m_pendingCache.Contains(address))
712 return;
708 713
709 m_pendingCache.AddOrUpdate(address, new Queue<UDPPacketBuffer>(), 60); 714 m_pendingCache.AddOrUpdate(address, new Queue<UDPPacketBuffer>(), 60);
710 } 715 }
711 716
712 object[] array = new object[] { buffer, packet }; 717 object[] array = new object[] { buffer, packet };
713 718
714 Util.FireAndForget(HandleUseCircuitCode, array); 719 Util.FireAndForget(HandleUseCircuitCode, array);
715 720
716 return; 721 return;
722 }
717 } 723 }
718 724
719 // Determine which agent this packet came from 725 // If this is a pending connection, enqueue, don't process yet
720 IClientAPI client; 726 lock (m_pendingCache)
721 if (!m_scene.TryGetClient(address, out client) || !(client is LLClientView))
722 { 727 {
723 lock (m_pendingCache) 728 Queue<UDPPacketBuffer> queue;
729 if (m_pendingCache.TryGetValue(address, out queue))
724 { 730 {
725 Queue<UDPPacketBuffer> queue; 731 //m_log.DebugFormat("[LLUDPSERVER]: Enqueued a {0} packet into the pending queue", packet.Type);
726 if (m_pendingCache.TryGetValue(address, out queue)) 732 queue.Enqueue(buffer);
727 { 733 return;
728 m_log.DebugFormat("[LLUDPSERVER]: Enqueued a {0} packet into the pending queue", packet.Type);
729 queue.Enqueue(buffer);
730 }
731 else
732 {
733 m_log.Debug("[LLUDPSERVER]: Received a " + packet.Type + " packet from an unrecognized source: " + address + " in " + m_scene.RegionInfo.RegionName);
734 }
735 } 734 }
735 }
736 736
737 // Determine which agent this packet came from
738 if (client == null || !(client is LLClientView))
739 {
740 //m_log.Debug("[LLUDPSERVER]: Received a " + packet.Type + " packet from an unrecognized source: " + address + " in " + m_scene.RegionInfo.RegionName);
737 return; 741 return;
738 } 742 }
739 743