diff options
Diffstat (limited to 'ThirdParty/3Di')
-rw-r--r-- | ThirdParty/3Di/LoadBalancer/TcpServer.cs | 8 | ||||
-rw-r--r-- | ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs | 60 |
2 files changed, 34 insertions, 34 deletions
diff --git a/ThirdParty/3Di/LoadBalancer/TcpServer.cs b/ThirdParty/3Di/LoadBalancer/TcpServer.cs index fd5e9e2..376c0a5 100644 --- a/ThirdParty/3Di/LoadBalancer/TcpServer.cs +++ b/ThirdParty/3Di/LoadBalancer/TcpServer.cs | |||
@@ -159,14 +159,14 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
159 | 159 | ||
160 | state.ms_ptr.Seek(0, SeekOrigin.End); | 160 | state.ms_ptr.Seek(0, SeekOrigin.End); |
161 | // call loadbarancer function | 161 | // call loadbarancer function |
162 | if (PacketHandler != null) | 162 | if (PacketHandler == null) |
163 | { | 163 | { |
164 | //MainLog.Instance.Verbose("TCPSERVER", "calling PacketHandler"); | 164 | //MainLog.Instance.Verbose("TCPSERVER", "PacketHandler not found"); |
165 | PacketHandler(state.header, packet); | ||
166 | } | 165 | } |
167 | else | 166 | else |
168 | { | 167 | { |
169 | //MainLog.Instance.Verbose("TCPSERVER", "PacketHandler not found"); | 168 | //MainLog.Instance.Verbose("TCPSERVER", "calling PacketHandler"); |
169 | PacketHandler(state.header, packet); | ||
170 | } | 170 | } |
171 | 171 | ||
172 | int read_size = state.header.numbytes + TcpClient.internalPacketHeaderSize; | 172 | int read_size = state.header.numbytes + TcpClient.internalPacketHeaderSize; |
diff --git a/ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs b/ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs index e65e7e5..a1476fa 100644 --- a/ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs +++ b/ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs | |||
@@ -396,36 +396,7 @@ namespace OpenSim.ApplicationPlugins.RegionProxy | |||
396 | //m_log.ErrorFormat("[PROXY] Got message from {0} in thread {1}, size {2}", senderEP, sd.clientEP, numBytes); | 396 | //m_log.ErrorFormat("[PROXY] Got message from {0} in thread {1}, size {2}", senderEP, sd.clientEP, numBytes); |
397 | EndPoint client = proxy_map.GetClient(senderEP); | 397 | EndPoint client = proxy_map.GetClient(senderEP); |
398 | 398 | ||
399 | if (client != null) | 399 | if (client == null) |
400 | { | ||
401 | try | ||
402 | { | ||
403 | client = ProxyCodec.DecodeProxyMessage(buffer, ref numBytes); | ||
404 | try | ||
405 | { | ||
406 | // This message comes from a region object, forward it to the its client | ||
407 | sd.server.SendTo(buffer, numBytes, SocketFlags.None, client); | ||
408 | //m_log.InfoFormat("[PROXY] Sending region message from {0} to {1}, size {2}", senderEP, client, numBytes); | ||
409 | } | ||
410 | catch (Exception e) | ||
411 | { | ||
412 | OpenPort(sd); // reopen the port just in case | ||
413 | m_log.ErrorFormat("[PROXY] Failed sending region message from {0} to {1}", senderEP, client); | ||
414 | m_log.Error("[PROXY]" + e.Message); | ||
415 | m_log.Error("[PROXY]" + e.StackTrace); | ||
416 | return; | ||
417 | } | ||
418 | } | ||
419 | catch (Exception e) | ||
420 | { | ||
421 | OpenPort(sd); // reopen the port just in case | ||
422 | m_log.ErrorFormat("[PROXY] Failed decoding region message from {0}", senderEP); | ||
423 | m_log.Error("[PROXY]" + e.Message); | ||
424 | m_log.Error("[PROXY]" + e.StackTrace); | ||
425 | return; | ||
426 | } | ||
427 | } | ||
428 | else | ||
429 | { | 400 | { |
430 | // This message comes from a client object, forward it to the the region(s) | 401 | // This message comes from a client object, forward it to the the region(s) |
431 | ProxyCodec.EncodeProxyMessage(buffer, ref numBytes, senderEP); | 402 | ProxyCodec.EncodeProxyMessage(buffer, ref numBytes, senderEP); |
@@ -454,6 +425,35 @@ namespace OpenSim.ApplicationPlugins.RegionProxy | |||
454 | } | 425 | } |
455 | } | 426 | } |
456 | } | 427 | } |
428 | else | ||
429 | { | ||
430 | try | ||
431 | { | ||
432 | client = ProxyCodec.DecodeProxyMessage(buffer, ref numBytes); | ||
433 | try | ||
434 | { | ||
435 | // This message comes from a region object, forward it to the its client | ||
436 | sd.server.SendTo(buffer, numBytes, SocketFlags.None, client); | ||
437 | //m_log.InfoFormat("[PROXY] Sending region message from {0} to {1}, size {2}", senderEP, client, numBytes); | ||
438 | } | ||
439 | catch (Exception e) | ||
440 | { | ||
441 | OpenPort(sd); // reopen the port just in case | ||
442 | m_log.ErrorFormat("[PROXY] Failed sending region message from {0} to {1}", senderEP, client); | ||
443 | m_log.Error("[PROXY]" + e.Message); | ||
444 | m_log.Error("[PROXY]" + e.StackTrace); | ||
445 | return; | ||
446 | } | ||
447 | } | ||
448 | catch (Exception e) | ||
449 | { | ||
450 | OpenPort(sd); // reopen the port just in case | ||
451 | m_log.ErrorFormat("[PROXY] Failed decoding region message from {0}", senderEP); | ||
452 | m_log.Error("[PROXY]" + e.Message); | ||
453 | m_log.Error("[PROXY]" + e.StackTrace); | ||
454 | return; | ||
455 | } | ||
456 | } | ||
457 | } | 457 | } |
458 | 458 | ||
459 | #region Nested type: ProxyMap | 459 | #region Nested type: ProxyMap |