123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206 |
- using log4net;
- using System;
- using System.Collections;
- using System.Collections.Generic;
- using System.IO;
- using System.Net;
- using System.Reflection;
- using System.Text;
- using Nini.Config;
- using OpenSim.Framework;
- using OpenSim.Services.Interfaces;
- using OpenMetaverse;
- using OpenMetaverse.StructuredData;
- using GridRegion = OpenSim.Services.Interfaces.GridRegion;
- namespace OpenSim.Services.Connectors
- {
- public class NeighbourServicesConnector : INeighbourService
- {
- private static readonly ILog m_log =
- LogManager.GetLogger(
- MethodBase.GetCurrentMethod().DeclaringType);
- protected IGridService m_GridService = null;
- public NeighbourServicesConnector()
- {
- }
- public NeighbourServicesConnector(IGridService gridServices)
- {
- Initialise(gridServices);
- }
- public virtual void Initialise(IGridService gridServices)
- {
- m_GridService = gridServices;
- }
- public virtual GridRegion HelloNeighbour(ulong regionHandle, RegionInfo thisRegion)
- {
- uint x = 0, y = 0;
- Util.RegionHandleToWorldLoc(regionHandle, out x, out y);
- GridRegion regInfo = m_GridService.GetRegionByPosition(thisRegion.ScopeID, (int)x, (int)y);
- if ((regInfo != null) &&
-
- !((regInfo.ExternalHostName == thisRegion.ExternalHostName) && (regInfo.HttpPort == thisRegion.HttpPort)))
- {
- if (!DoHelloNeighbourCall(regInfo, thisRegion))
- return null;
- }
- else
- return null;
- return regInfo;
- }
- public bool DoHelloNeighbourCall(GridRegion region, RegionInfo thisRegion)
- {
- string uri = region.ServerURI + "region/" + thisRegion.RegionID + "/";
- WebRequest helloNeighbourRequest;
- try
- {
- helloNeighbourRequest = WebRequest.Create(uri);
- }
- catch (Exception e)
- {
- m_log.Warn(string.Format(
- "[NEIGHBOUR SERVICES CONNECTOR]: Unable to parse uri {0} to send HelloNeighbour from {1} to {2}. Exception {3} ",
- uri, thisRegion.RegionName, region.RegionName, e.Message), e);
- return false;
- }
- helloNeighbourRequest.Method = "POST";
- helloNeighbourRequest.ContentType = "application/json";
- helloNeighbourRequest.Timeout = 10000;
-
- OSDMap args = null;
- try
- {
- args = thisRegion.PackRegionInfoData();
- }
- catch (Exception e)
- {
- m_log.Warn(string.Format(
- "[NEIGHBOUR SERVICES CONNECTOR]: PackRegionInfoData failed for HelloNeighbour from {0} to {1}. Exception {2} ",
- thisRegion.RegionName, region.RegionName, e.Message), e);
- return false;
- }
-
- args["destination_handle"] = OSD.FromString(region.RegionHandle.ToString());
- string strBuffer = "";
- byte[] buffer = new byte[1];
- try
- {
- strBuffer = OSDParser.SerializeJsonString(args);
- buffer = Util.UTF8NoBomEncoding.GetBytes(strBuffer);
- }
- catch (Exception e)
- {
- m_log.Warn(string.Format(
- "[NEIGHBOUR SERVICES CONNECTOR]: Exception thrown on serialization of HelloNeighbour from {0} to {1}. Exception {2} ",
- thisRegion.RegionName, region.RegionName, e.Message), e);
- return false;
- }
- Stream os = null;
- try
- {
- helloNeighbourRequest.ContentLength = buffer.Length;
- os = helloNeighbourRequest.GetRequestStream();
- os.Write(buffer, 0, strBuffer.Length);
-
- }
- catch
- {
- return false;
- }
- finally
- {
- if (os != null)
- os.Dispose();
- }
-
-
- try
- {
- using (WebResponse webResponse = helloNeighbourRequest.GetResponse())
- {
- if (webResponse == null)
- {
- m_log.DebugFormat(
- "[NEIGHBOUR SERVICES CONNECTOR]: Null reply on DoHelloNeighbourCall post from {0} to {1}",
- thisRegion.RegionName, region.RegionName);
- }
- using (Stream s = webResponse.GetResponseStream())
- {
- using (StreamReader sr = new StreamReader(s))
- {
- sr.ReadToEnd();
-
-
- }
- }
- }
- }
- catch (Exception e)
- {
- m_log.Warn(string.Format(
- "[NEIGHBOUR SERVICES CONNECTOR]: Exception on reply of DoHelloNeighbourCall from {0} back to {1}. Exception {2} ",
- region.RegionName, thisRegion.RegionName, e.Message), e);
- return false;
- }
- return true;
- }
- }
- }
|