aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Services/Connectors/Neighbour
diff options
context:
space:
mode:
authorJeff Ames2009-06-14 21:37:50 +0000
committerJeff Ames2009-06-14 21:37:50 +0000
commit8d0eb3307fe665aed35209184ff4736e7c6170c4 (patch)
treebd9e4f24df736715ad9fe48f69f3c2421c68195e /OpenSim/Services/Connectors/Neighbour
parentRenamed Region/CoreModules/ServiceConnectors to Region/CoreModules/ServiceCon... (diff)
downloadopensim-SC_OLD-8d0eb3307fe665aed35209184ff4736e7c6170c4.zip
opensim-SC_OLD-8d0eb3307fe665aed35209184ff4736e7c6170c4.tar.gz
opensim-SC_OLD-8d0eb3307fe665aed35209184ff4736e7c6170c4.tar.bz2
opensim-SC_OLD-8d0eb3307fe665aed35209184ff4736e7c6170c4.tar.xz
Update svn properties.
Diffstat (limited to 'OpenSim/Services/Connectors/Neighbour')
-rw-r--r--OpenSim/Services/Connectors/Neighbour/NeighbourServiceConnector.cs332
1 files changed, 166 insertions, 166 deletions
diff --git a/OpenSim/Services/Connectors/Neighbour/NeighbourServiceConnector.cs b/OpenSim/Services/Connectors/Neighbour/NeighbourServiceConnector.cs
index 26f606d..7fff537 100644
--- a/OpenSim/Services/Connectors/Neighbour/NeighbourServiceConnector.cs
+++ b/OpenSim/Services/Connectors/Neighbour/NeighbourServiceConnector.cs
@@ -1,166 +1,166 @@
1/* 1/*
2 * Copyright (c) Contributors, http://opensimulator.org/ 2 * Copyright (c) Contributors, http://opensimulator.org/
3 * See CONTRIBUTORS.TXT for a full list of copyright holders. 3 * See CONTRIBUTORS.TXT for a full list of copyright holders.
4 * 4 *
5 * Redistribution and use in source and binary forms, with or without 5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met: 6 * modification, are permitted provided that the following conditions are met:
7 * * Redistributions of source code must retain the above copyright 7 * * Redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer. 8 * notice, this list of conditions and the following disclaimer.
9 * * Redistributions in binary form must reproduce the above copyright 9 * * Redistributions in binary form must reproduce the above copyright
10 * notice, this list of conditions and the following disclaimer in the 10 * notice, this list of conditions and the following disclaimer in the
11 * documentation and/or other materials provided with the distribution. 11 * documentation and/or other materials provided with the distribution.
12 * * Neither the name of the OpenSimulator Project nor the 12 * * Neither the name of the OpenSimulator Project nor the
13 * names of its contributors may be used to endorse or promote products 13 * names of its contributors may be used to endorse or promote products
14 * derived from this software without specific prior written permission. 14 * derived from this software without specific prior written permission.
15 * 15 *
16 * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 16 * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
17 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 17 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 18 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
19 * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 19 * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
20 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 20 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
21 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 21 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
22 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 22 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
23 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 23 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */ 26 */
27 27
28using log4net; 28using log4net;
29using System; 29using System;
30using System.Collections; 30using System.Collections;
31using System.Collections.Generic; 31using System.Collections.Generic;
32using System.IO; 32using System.IO;
33using System.Net; 33using System.Net;
34using System.Reflection; 34using System.Reflection;
35using System.Text; 35using System.Text;
36using Nini.Config; 36using Nini.Config;
37using OpenSim.Framework; 37using OpenSim.Framework;
38using OpenSim.Framework.Communications; 38using OpenSim.Framework.Communications;
39using OpenSim.Framework.Servers.HttpServer; 39using OpenSim.Framework.Servers.HttpServer;
40using OpenSim.Services.Interfaces; 40using OpenSim.Services.Interfaces;
41using OpenMetaverse; 41using OpenMetaverse;
42using OpenMetaverse.StructuredData; 42using OpenMetaverse.StructuredData;
43 43
44namespace OpenSim.Services.Connectors 44namespace OpenSim.Services.Connectors
45{ 45{
46 public class NeighbourServicesConnector : INeighbourService 46 public class NeighbourServicesConnector : INeighbourService
47 { 47 {
48 private static readonly ILog m_log = 48 private static readonly ILog m_log =
49 LogManager.GetLogger( 49 LogManager.GetLogger(
50 MethodBase.GetCurrentMethod().DeclaringType); 50 MethodBase.GetCurrentMethod().DeclaringType);
51 51
52 protected IGridServices m_MapService = null; 52 protected IGridServices m_MapService = null;
53 53
54 public NeighbourServicesConnector() 54 public NeighbourServicesConnector()
55 { 55 {
56 } 56 }
57 57
58 public NeighbourServicesConnector(IGridServices gridServices) 58 public NeighbourServicesConnector(IGridServices gridServices)
59 { 59 {
60 Initialise(gridServices); 60 Initialise(gridServices);
61 } 61 }
62 62
63 public virtual void Initialise(IGridServices gridServices) 63 public virtual void Initialise(IGridServices gridServices)
64 { 64 {
65 m_MapService = gridServices; 65 m_MapService = gridServices;
66 } 66 }
67 67
68 public virtual bool HelloNeighbour(ulong regionHandle, RegionInfo thisRegion) 68 public virtual bool HelloNeighbour(ulong regionHandle, RegionInfo thisRegion)
69 { 69 {
70 RegionInfo regInfo = m_MapService.RequestNeighbourInfo(regionHandle); 70 RegionInfo regInfo = m_MapService.RequestNeighbourInfo(regionHandle);
71 if ((regInfo != null) && 71 if ((regInfo != null) &&
72 // Don't remote-call this instance; that's a startup hickup 72 // Don't remote-call this instance; that's a startup hickup
73 !((regInfo.ExternalHostName == thisRegion.ExternalHostName) && (regInfo.HttpPort == thisRegion.HttpPort))) 73 !((regInfo.ExternalHostName == thisRegion.ExternalHostName) && (regInfo.HttpPort == thisRegion.HttpPort)))
74 { 74 {
75 return DoHelloNeighbourCall(regInfo, thisRegion); 75 return DoHelloNeighbourCall(regInfo, thisRegion);
76 } 76 }
77 //else 77 //else
78 // m_log.Warn("[REST COMMS]: Region not found " + regionHandle); 78 // m_log.Warn("[REST COMMS]: Region not found " + regionHandle);
79 return false; 79 return false;
80 } 80 }
81 81
82 public bool DoHelloNeighbourCall(RegionInfo region, RegionInfo thisRegion) 82 public bool DoHelloNeighbourCall(RegionInfo region, RegionInfo thisRegion)
83 { 83 {
84 string uri = "http://" + region.ExternalEndPoint.Address + ":" + region.HttpPort + "/region/" + thisRegion.RegionID + "/"; 84 string uri = "http://" + region.ExternalEndPoint.Address + ":" + region.HttpPort + "/region/" + thisRegion.RegionID + "/";
85 //m_log.Debug(" >>> DoHelloNeighbourCall <<< " + uri); 85 //m_log.Debug(" >>> DoHelloNeighbourCall <<< " + uri);
86 86
87 WebRequest HelloNeighbourRequest = WebRequest.Create(uri); 87 WebRequest HelloNeighbourRequest = WebRequest.Create(uri);
88 HelloNeighbourRequest.Method = "POST"; 88 HelloNeighbourRequest.Method = "POST";
89 HelloNeighbourRequest.ContentType = "application/json"; 89 HelloNeighbourRequest.ContentType = "application/json";
90 HelloNeighbourRequest.Timeout = 10000; 90 HelloNeighbourRequest.Timeout = 10000;
91 91
92 // Fill it in 92 // Fill it in
93 OSDMap args = null; 93 OSDMap args = null;
94 try 94 try
95 { 95 {
96 args = thisRegion.PackRegionInfoData(); 96 args = thisRegion.PackRegionInfoData();
97 } 97 }
98 catch (Exception e) 98 catch (Exception e)
99 { 99 {
100 m_log.Debug("[REST COMMS]: PackRegionInfoData failed with exception: " + e.Message); 100 m_log.Debug("[REST COMMS]: PackRegionInfoData failed with exception: " + e.Message);
101 } 101 }
102 // Add the regionhandle of the destination region 102 // Add the regionhandle of the destination region
103 args["destination_handle"] = OSD.FromString(region.RegionHandle.ToString()); 103 args["destination_handle"] = OSD.FromString(region.RegionHandle.ToString());
104 104
105 string strBuffer = ""; 105 string strBuffer = "";
106 byte[] buffer = new byte[1]; 106 byte[] buffer = new byte[1];
107 try 107 try
108 { 108 {
109 strBuffer = OSDParser.SerializeJsonString(args); 109 strBuffer = OSDParser.SerializeJsonString(args);
110 UTF8Encoding str = new UTF8Encoding(); 110 UTF8Encoding str = new UTF8Encoding();
111 buffer = str.GetBytes(strBuffer); 111 buffer = str.GetBytes(strBuffer);
112 112
113 } 113 }
114 catch (Exception e) 114 catch (Exception e)
115 { 115 {
116 m_log.WarnFormat("[REST COMMS]: Exception thrown on serialization of HelloNeighbour: {0}", e.Message); 116 m_log.WarnFormat("[REST COMMS]: Exception thrown on serialization of HelloNeighbour: {0}", e.Message);
117 // ignore. buffer will be empty, caller should check. 117 // ignore. buffer will be empty, caller should check.
118 } 118 }
119 119
120 Stream os = null; 120 Stream os = null;
121 try 121 try
122 { // send the Post 122 { // send the Post
123 HelloNeighbourRequest.ContentLength = buffer.Length; //Count bytes to send 123 HelloNeighbourRequest.ContentLength = buffer.Length; //Count bytes to send
124 os = HelloNeighbourRequest.GetRequestStream(); 124 os = HelloNeighbourRequest.GetRequestStream();
125 os.Write(buffer, 0, strBuffer.Length); //Send it 125 os.Write(buffer, 0, strBuffer.Length); //Send it
126 os.Close(); 126 os.Close();
127 //m_log.InfoFormat("[REST COMMS]: Posted HelloNeighbour request to remote sim {0}", uri); 127 //m_log.InfoFormat("[REST COMMS]: Posted HelloNeighbour request to remote sim {0}", uri);
128 } 128 }
129 //catch (WebException ex) 129 //catch (WebException ex)
130 catch 130 catch
131 { 131 {
132 //m_log.InfoFormat("[REST COMMS]: Bad send on HelloNeighbour {0}", ex.Message); 132 //m_log.InfoFormat("[REST COMMS]: Bad send on HelloNeighbour {0}", ex.Message);
133 133
134 return false; 134 return false;
135 } 135 }
136 136
137 // Let's wait for the response 137 // Let's wait for the response
138 //m_log.Info("[REST COMMS]: Waiting for a reply after DoHelloNeighbourCall"); 138 //m_log.Info("[REST COMMS]: Waiting for a reply after DoHelloNeighbourCall");
139 139
140 try 140 try
141 { 141 {
142 WebResponse webResponse = HelloNeighbourRequest.GetResponse(); 142 WebResponse webResponse = HelloNeighbourRequest.GetResponse();
143 if (webResponse == null) 143 if (webResponse == null)
144 { 144 {
145 m_log.Info("[REST COMMS]: Null reply on DoHelloNeighbourCall post"); 145 m_log.Info("[REST COMMS]: Null reply on DoHelloNeighbourCall post");
146 } 146 }
147 147
148 StreamReader sr = new StreamReader(webResponse.GetResponseStream()); 148 StreamReader sr = new StreamReader(webResponse.GetResponseStream());
149 //reply = sr.ReadToEnd().Trim(); 149 //reply = sr.ReadToEnd().Trim();
150 sr.ReadToEnd().Trim(); 150 sr.ReadToEnd().Trim();
151 sr.Close(); 151 sr.Close();
152 //m_log.InfoFormat("[REST COMMS]: DoHelloNeighbourCall reply was {0} ", reply); 152 //m_log.InfoFormat("[REST COMMS]: DoHelloNeighbourCall reply was {0} ", reply);
153 153
154 } 154 }
155 catch (WebException ex) 155 catch (WebException ex)
156 { 156 {
157 m_log.InfoFormat("[REST COMMS]: exception on reply of DoHelloNeighbourCall {0}", ex.Message); 157 m_log.InfoFormat("[REST COMMS]: exception on reply of DoHelloNeighbourCall {0}", ex.Message);
158 // ignore, really 158 // ignore, really
159 } 159 }
160 160
161 return true; 161 return true;
162 162
163 } 163 }
164 164
165 } 165 }
166} 166}