diff options
Diffstat (limited to '')
-rw-r--r-- | OpenSim/Region/Communications/OGS1/OGS1GridServices.cs | 183 |
1 files changed, 100 insertions, 83 deletions
diff --git a/OpenSim/Region/Communications/OGS1/OGS1GridServices.cs b/OpenSim/Region/Communications/OGS1/OGS1GridServices.cs index b0442d2..b91f4c2 100644 --- a/OpenSim/Region/Communications/OGS1/OGS1GridServices.cs +++ b/OpenSim/Region/Communications/OGS1/OGS1GridServices.cs | |||
@@ -248,39 +248,47 @@ namespace OpenSim.Region.Communications.OGS1 | |||
248 | } | 248 | } |
249 | else | 249 | else |
250 | { | 250 | { |
251 | Hashtable requestData = new Hashtable(); | 251 | try |
252 | requestData["region_handle"] = regionHandle.ToString(); | 252 | { |
253 | requestData["authkey"] = serversInfo.GridSendKey; | 253 | Hashtable requestData = new Hashtable(); |
254 | ArrayList SendParams = new ArrayList(); | 254 | requestData["region_handle"] = regionHandle.ToString(); |
255 | SendParams.Add(requestData); | 255 | requestData["authkey"] = serversInfo.GridSendKey; |
256 | XmlRpcRequest GridReq = new XmlRpcRequest("simulator_data_request", SendParams); | 256 | ArrayList SendParams = new ArrayList(); |
257 | XmlRpcResponse GridResp = GridReq.Send(serversInfo.GridURL, 3000); | 257 | SendParams.Add(requestData); |
258 | XmlRpcRequest GridReq = new XmlRpcRequest("simulator_data_request", SendParams); | ||
259 | XmlRpcResponse GridResp = GridReq.Send(serversInfo.GridURL, 3000); | ||
258 | 260 | ||
259 | Hashtable responseData = (Hashtable) GridResp.Value; | 261 | Hashtable responseData = (Hashtable)GridResp.Value; |
260 | 262 | ||
261 | if (responseData.ContainsKey("error")) | 263 | if (responseData.ContainsKey("error")) |
262 | { | 264 | { |
263 | Console.WriteLine("error received from grid server" + responseData["error"]); | 265 | Console.WriteLine("error received from grid server" + responseData["error"]); |
264 | return null; | 266 | return null; |
265 | } | 267 | } |
266 | 268 | ||
267 | uint regX = Convert.ToUInt32((string) responseData["region_locx"]); | 269 | uint regX = Convert.ToUInt32((string)responseData["region_locx"]); |
268 | uint regY = Convert.ToUInt32((string) responseData["region_locy"]); | 270 | uint regY = Convert.ToUInt32((string)responseData["region_locy"]); |
269 | string internalIpStr = (string) responseData["sim_ip"]; | 271 | string internalIpStr = (string)responseData["sim_ip"]; |
270 | uint port = Convert.ToUInt32(responseData["sim_port"]); | 272 | uint port = Convert.ToUInt32(responseData["sim_port"]); |
271 | string externalUri = (string) responseData["sim_uri"]; | 273 | string externalUri = (string)responseData["sim_uri"]; |
272 | 274 | ||
273 | IPEndPoint neighbourInternalEndPoint = new IPEndPoint(IPAddress.Parse(internalIpStr), (int) port); | 275 | IPEndPoint neighbourInternalEndPoint = new IPEndPoint(IPAddress.Parse(internalIpStr), (int)port); |
274 | string neighbourExternalUri = externalUri; | 276 | string neighbourExternalUri = externalUri; |
275 | regionInfo = new RegionInfo(regX, regY, neighbourInternalEndPoint, internalIpStr); | 277 | regionInfo = new RegionInfo(regX, regY, neighbourInternalEndPoint, internalIpStr); |
276 | 278 | ||
277 | regionInfo.RemotingPort = Convert.ToUInt32((string) responseData["remoting_port"]); | 279 | regionInfo.RemotingPort = Convert.ToUInt32((string)responseData["remoting_port"]); |
278 | regionInfo.RemotingAddress = internalIpStr; | 280 | regionInfo.RemotingAddress = internalIpStr; |
279 | 281 | ||
280 | regionInfo.RegionID = new LLUUID((string) responseData["region_UUID"]); | 282 | regionInfo.RegionID = new LLUUID((string)responseData["region_UUID"]); |
281 | regionInfo.RegionName = (string) responseData["region_name"]; | 283 | regionInfo.RegionName = (string)responseData["region_name"]; |
282 | 284 | ||
283 | m_remoteRegionInfoCache.Add(regionHandle, regionInfo); | 285 | m_remoteRegionInfoCache.Add(regionHandle, regionInfo); |
286 | } | ||
287 | catch (System.Net.WebException) | ||
288 | { | ||
289 | MainLog.Instance.Error("GRID", "Region lookup failed for: " + regionHandle.ToString() + " - Is the GridServer down?"); | ||
290 | return null; | ||
291 | } | ||
284 | } | 292 | } |
285 | 293 | ||
286 | return regionInfo; | 294 | return regionInfo; |
@@ -540,34 +548,33 @@ namespace OpenSim.Region.Communications.OGS1 | |||
540 | } | 548 | } |
541 | 549 | ||
542 | // UGLY! | 550 | // UGLY! |
543 | public bool RegionUp(SearializableRegionInfo region) | 551 | public bool RegionUp(SearializableRegionInfo region, ulong regionhandle) |
544 | { | 552 | { |
545 | 553 | SearializableRegionInfo regInfo = null; | |
546 | // This is stupid. For this to work, when the region registers it must request nearby map blocks. | 554 | try |
547 | // In addition to filling the map blocks, it fills a 'known regions' list. | ||
548 | |||
549 | // This known regions list then gets queried on here to get the remoting data from the neighbors. | ||
550 | // *Pull yourself up by your bootstraps?* | ||
551 | |||
552 | if (m_localBackend.RegionUp(region)) | ||
553 | { | 555 | { |
554 | return true; | 556 | // You may ask why this is in here... |
555 | } | 557 | // The region asking the grid services about itself.. |
556 | 558 | // And, surprisingly, the reason is.. it doesn't know | |
557 | foreach (SimpleRegionInfo knownregion in m_knownRegions) | 559 | // it's own remoting port! How special. |
558 | { | 560 | region = new SearializableRegionInfo(RequestNeighbourInfo(region.RegionHandle)); |
559 | 561 | region.RemotingAddress = region.ExternalHostName; | |
560 | SearializableRegionInfo regInfo = new SearializableRegionInfo(RequestNeighbourInfo(knownregion.RegionID)); | 562 | region.RemotingPort = (uint) NetworkServersInfo.RemotingListenerPort; |
561 | 563 | if (m_localBackend.RegionUp(region,regionhandle)) | |
562 | try | 564 | { |
563 | { | 565 | return true; |
564 | 566 | } | |
565 | if ((!(regInfo.Equals(null)) && regInfo.RemotingAddress.Length > 0)) | 567 | |
568 | regInfo = new SearializableRegionInfo(RequestNeighbourInfo(regionhandle)); | ||
569 | if (regInfo != null) | ||
570 | { | ||
571 | // If we're not trying to remote to ourselves. | ||
572 | if (regInfo.RemotingAddress != region.RemotingAddress && region.RemotingAddress != null) | ||
566 | { | 573 | { |
567 | //don't want to be creating a new link to the remote instance every time like we are here | 574 | //don't want to be creating a new link to the remote instance every time like we are here |
568 | bool retValue = false; | 575 | bool retValue = false; |
569 | 576 | ||
570 | 577 | ||
571 | OGS1InterRegionRemoting remObject = (OGS1InterRegionRemoting)Activator.GetObject( | 578 | OGS1InterRegionRemoting remObject = (OGS1InterRegionRemoting)Activator.GetObject( |
572 | typeof(OGS1InterRegionRemoting), | 579 | typeof(OGS1InterRegionRemoting), |
573 | "tcp://" + regInfo.RemotingAddress + | 580 | "tcp://" + regInfo.RemotingAddress + |
@@ -576,49 +583,59 @@ namespace OpenSim.Region.Communications.OGS1 | |||
576 | 583 | ||
577 | if (remObject != null) | 584 | if (remObject != null) |
578 | { | 585 | { |
579 | retValue = remObject.RegionUp(region); | 586 | retValue = remObject.RegionUp(region, regionhandle); |
580 | } | 587 | } |
581 | else | 588 | else |
582 | { | 589 | { |
583 | Console.WriteLine("remoting object not found"); | 590 | Console.WriteLine("remoting object not found"); |
584 | } | 591 | } |
585 | remObject = null; | 592 | remObject = null; |
586 | MainLog.Instance.Verbose("INTER", gdebugRegionName + ": OGS1 tried to NotifyRegionUp for " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | 593 | MainLog.Instance.Verbose("INTER", gdebugRegionName + ": OGS1 tried to inform region I'm up"); |
587 | 594 | ||
595 | return retValue; | ||
596 | } | ||
597 | else | ||
598 | { | ||
599 | // We're trying to inform ourselves via remoting. | ||
600 | // This is here because we're looping over the listeners before we get here. | ||
601 | // Odd but it should work. | ||
602 | return true; | ||
588 | } | 603 | } |
589 | |||
590 | } | ||
591 | catch (RemotingException e) | ||
592 | { | ||
593 | MainLog.Instance.Warn("Remoting Error: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
594 | MainLog.Instance.Debug(e.ToString()); | ||
595 | //return false; | ||
596 | } | ||
597 | catch (SocketException e) | ||
598 | { | ||
599 | MainLog.Instance.Warn("Socket Error: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
600 | MainLog.Instance.Debug(e.ToString()); | ||
601 | //return false; | ||
602 | } | ||
603 | catch (InvalidCredentialException e) | ||
604 | { | ||
605 | MainLog.Instance.Warn("Invalid Credentials: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
606 | MainLog.Instance.Debug(e.ToString()); | ||
607 | //return false; | ||
608 | } | ||
609 | catch (AuthenticationException e) | ||
610 | { | ||
611 | MainLog.Instance.Warn("Authentication exception: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
612 | MainLog.Instance.Debug(e.ToString()); | ||
613 | //return false; | ||
614 | } | ||
615 | catch (Exception e) | ||
616 | { | ||
617 | MainLog.Instance.Warn("Unknown exception: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
618 | MainLog.Instance.Debug(e.ToString()); | ||
619 | //return false; | ||
620 | } | 604 | } |
605 | |||
606 | return false; | ||
607 | } | ||
608 | catch (RemotingException e) | ||
609 | { | ||
610 | MainLog.Instance.Warn("Remoting Error: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
611 | MainLog.Instance.Debug(e.ToString()); | ||
612 | return false; | ||
613 | } | ||
614 | catch (SocketException e) | ||
615 | { | ||
616 | MainLog.Instance.Warn("Socket Error: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
617 | MainLog.Instance.Debug(e.ToString()); | ||
618 | return false; | ||
621 | } | 619 | } |
620 | catch (InvalidCredentialException e) | ||
621 | { | ||
622 | MainLog.Instance.Warn("Invalid Credentials: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
623 | MainLog.Instance.Debug(e.ToString()); | ||
624 | return false; | ||
625 | } | ||
626 | catch (AuthenticationException e) | ||
627 | { | ||
628 | MainLog.Instance.Warn("Authentication exception: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
629 | MainLog.Instance.Debug(e.ToString()); | ||
630 | return false; | ||
631 | } | ||
632 | catch (Exception e) | ||
633 | { | ||
634 | MainLog.Instance.Warn("Unknown exception: Unable to connect to adjacent region: " + regInfo.RegionLocX + "," + regInfo.RegionLocY); | ||
635 | MainLog.Instance.Debug(e.ToString()); | ||
636 | return false; | ||
637 | } | ||
638 | |||
622 | return true; | 639 | return true; |
623 | } | 640 | } |
624 | /// <summary> | 641 | /// <summary> |
@@ -837,13 +854,13 @@ namespace OpenSim.Region.Communications.OGS1 | |||
837 | } | 854 | } |
838 | } | 855 | } |
839 | 856 | ||
840 | public bool TriggerRegionUp(SearializableRegionInfo regionData) | 857 | public bool TriggerRegionUp(SearializableRegionInfo regionData, ulong regionhandle) |
841 | { | 858 | { |
842 | MainLog.Instance.Verbose("INTER", gdebugRegionName + ": Incoming OGS1 RegionUpReport: " + regionData.RegionLocX + "," + regionData.RegionLocY); | 859 | MainLog.Instance.Verbose("INTER", gdebugRegionName + ": Incoming OGS1 RegionUpReport: " + regionData.RegionLocX + "," + regionData.RegionLocY); |
843 | 860 | ||
844 | try | 861 | try |
845 | { | 862 | { |
846 | return m_localBackend.TriggerRegionUp(new RegionInfo(regionData)); | 863 | return m_localBackend.TriggerRegionUp(new RegionInfo(regionData), regionhandle); |
847 | } | 864 | } |
848 | 865 | ||
849 | catch (RemotingException e) | 866 | catch (RemotingException e) |