diff options
Diffstat (limited to 'OpenSim/Server')
12 files changed, 375 insertions, 33 deletions
diff --git a/OpenSim/Server/Base/HttpServerBase.cs b/OpenSim/Server/Base/HttpServerBase.cs index 44ef124..42a8c57 100644 --- a/OpenSim/Server/Base/HttpServerBase.cs +++ b/OpenSim/Server/Base/HttpServerBase.cs | |||
@@ -40,7 +40,7 @@ namespace OpenSim.Server.Base | |||
40 | { | 40 | { |
41 | public class HttpServerBase : ServicesServerBase | 41 | public class HttpServerBase : ServicesServerBase |
42 | { | 42 | { |
43 | // private static readonly ILog m_Log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | 43 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); |
44 | 44 | ||
45 | private uint m_consolePort; | 45 | private uint m_consolePort; |
46 | 46 | ||
@@ -70,6 +70,7 @@ namespace OpenSim.Server.Base | |||
70 | 70 | ||
71 | bool ssl_main = networkConfig.GetBoolean("https_main",false); | 71 | bool ssl_main = networkConfig.GetBoolean("https_main",false); |
72 | bool ssl_listener = networkConfig.GetBoolean("https_listener",false); | 72 | bool ssl_listener = networkConfig.GetBoolean("https_listener",false); |
73 | bool ssl_external = networkConfig.GetBoolean("https_external",false); | ||
73 | 74 | ||
74 | m_consolePort = (uint)networkConfig.GetInt("ConsolePort", 0); | 75 | m_consolePort = (uint)networkConfig.GetInt("ConsolePort", 0); |
75 | 76 | ||
@@ -115,21 +116,29 @@ namespace OpenSim.Server.Base | |||
115 | { | 116 | { |
116 | uint https_port = (uint)networkConfig.GetInt("https_port", 0); | 117 | uint https_port = (uint)networkConfig.GetInt("https_port", 0); |
117 | 118 | ||
118 | string cert_path = networkConfig.GetString("cert_path",String.Empty); | 119 | m_log.WarnFormat("[SSL]: External flag is {0}", ssl_external); |
119 | if (cert_path == String.Empty) | 120 | if (!ssl_external) |
120 | { | 121 | { |
121 | System.Console.WriteLine("ERROR: Path to X509 certificate is missing, server can't start."); | 122 | string cert_path = networkConfig.GetString("cert_path",String.Empty); |
122 | Environment.Exit(1); | 123 | if ( cert_path == String.Empty ) |
124 | { | ||
125 | System.Console.WriteLine("Path to X509 certificate is missing, server can't start."); | ||
126 | Thread.CurrentThread.Abort(); | ||
127 | } | ||
128 | string cert_pass = networkConfig.GetString("cert_pass",String.Empty); | ||
129 | if ( cert_pass == String.Empty ) | ||
130 | { | ||
131 | System.Console.WriteLine("Password for X509 certificate is missing, server can't start."); | ||
132 | Thread.CurrentThread.Abort(); | ||
133 | } | ||
134 | |||
135 | MainServer.AddHttpServer(new BaseHttpServer(https_port, ssl_listener, cert_path, cert_pass)); | ||
123 | } | 136 | } |
124 | 137 | else | |
125 | string cert_pass = networkConfig.GetString("cert_pass",String.Empty); | ||
126 | if (cert_pass == String.Empty) | ||
127 | { | 138 | { |
128 | System.Console.WriteLine("ERROR: Password for X509 certificate is missing, server can't start."); | 139 | m_log.WarnFormat("[SSL]: SSL port is active but no SSL is used because external SSL was requested."); |
129 | Environment.Exit(1); | 140 | MainServer.AddHttpServer(new BaseHttpServer(https_port)); |
130 | } | 141 | } |
131 | |||
132 | MainServer.AddHttpServer(new BaseHttpServer(https_port, ssl_listener, cert_path, cert_pass)); | ||
133 | } | 142 | } |
134 | } | 143 | } |
135 | 144 | ||
diff --git a/OpenSim/Server/Handlers/BakedTextures/XBakesPostHandler.cs b/OpenSim/Server/Handlers/BakedTextures/XBakesPostHandler.cs index e38543b..24f63d9 100644 --- a/OpenSim/Server/Handlers/BakedTextures/XBakesPostHandler.cs +++ b/OpenSim/Server/Handlers/BakedTextures/XBakesPostHandler.cs | |||
@@ -73,4 +73,4 @@ namespace OpenSim.Server.Handlers.BakedTextures | |||
73 | return new byte[0]; | 73 | return new byte[0]; |
74 | } | 74 | } |
75 | } | 75 | } |
76 | } \ No newline at end of file | 76 | } |
diff --git a/OpenSim/Server/Handlers/GridUser/GridUserServerPostHandler.cs b/OpenSim/Server/Handlers/GridUser/GridUserServerPostHandler.cs index 9237c63..b63b594 100644 --- a/OpenSim/Server/Handlers/GridUser/GridUserServerPostHandler.cs +++ b/OpenSim/Server/Handlers/GridUser/GridUserServerPostHandler.cs | |||
@@ -185,6 +185,9 @@ namespace OpenSim.Server.Handlers.GridUser | |||
185 | 185 | ||
186 | GridUserInfo guinfo = m_GridUserService.GetGridUserInfo(user); | 186 | GridUserInfo guinfo = m_GridUserService.GetGridUserInfo(user); |
187 | 187 | ||
188 | if (guinfo == null) | ||
189 | return FailureResult(); | ||
190 | |||
188 | Dictionary<string, object> result = new Dictionary<string, object>(); | 191 | Dictionary<string, object> result = new Dictionary<string, object>(); |
189 | if (guinfo != null) | 192 | if (guinfo != null) |
190 | result["result"] = guinfo.ToKeyValuePairs(); | 193 | result["result"] = guinfo.ToKeyValuePairs(); |
diff --git a/OpenSim/Server/Handlers/Hypergrid/AgentHandlers.cs b/OpenSim/Server/Handlers/Hypergrid/AgentHandlers.cs index 95a0510..f3d678f 100644 --- a/OpenSim/Server/Handlers/Hypergrid/AgentHandlers.cs +++ b/OpenSim/Server/Handlers/Hypergrid/AgentHandlers.cs | |||
@@ -62,7 +62,7 @@ namespace OpenSim.Server.Handlers.Hypergrid | |||
62 | } | 62 | } |
63 | 63 | ||
64 | protected override bool CreateAgent(GridRegion source, GridRegion gatekeeper, GridRegion destination, | 64 | protected override bool CreateAgent(GridRegion source, GridRegion gatekeeper, GridRegion destination, |
65 | AgentCircuitData aCircuit, uint teleportFlags, bool fromLogin, out string reason) | 65 | AgentCircuitData aCircuit, uint teleportFlags, bool fromLogin, EntityTransferContext ctx, out string reason) |
66 | { | 66 | { |
67 | return m_GatekeeperService.LoginAgent(source, aCircuit, destination, out reason); | 67 | return m_GatekeeperService.LoginAgent(source, aCircuit, destination, out reason); |
68 | } | 68 | } |
diff --git a/OpenSim/Server/Handlers/Hypergrid/HomeAgentHandlers.cs b/OpenSim/Server/Handlers/Hypergrid/HomeAgentHandlers.cs index e787f7c..367c481 100644 --- a/OpenSim/Server/Handlers/Hypergrid/HomeAgentHandlers.cs +++ b/OpenSim/Server/Handlers/Hypergrid/HomeAgentHandlers.cs | |||
@@ -118,7 +118,7 @@ namespace OpenSim.Server.Handlers.Hypergrid | |||
118 | 118 | ||
119 | 119 | ||
120 | protected override bool CreateAgent(GridRegion source, GridRegion gatekeeper, GridRegion destination, | 120 | protected override bool CreateAgent(GridRegion source, GridRegion gatekeeper, GridRegion destination, |
121 | AgentCircuitData aCircuit, uint teleportFlags, bool fromLogin, out string reason) | 121 | AgentCircuitData aCircuit, uint teleportFlags, bool fromLogin, EntityTransferContext ctx, out string reason) |
122 | { | 122 | { |
123 | return m_UserAgentService.LoginAgentToGrid(source, aCircuit, gatekeeper, destination, fromLogin, out reason); | 123 | return m_UserAgentService.LoginAgentToGrid(source, aCircuit, gatekeeper, destination, fromLogin, out reason); |
124 | } | 124 | } |
diff --git a/OpenSim/Server/Handlers/Login/LLLoginHandlers.cs b/OpenSim/Server/Handlers/Login/LLLoginHandlers.cs index f2a5678..5d672c3 100644 --- a/OpenSim/Server/Handlers/Login/LLLoginHandlers.cs +++ b/OpenSim/Server/Handlers/Login/LLLoginHandlers.cs | |||
@@ -132,8 +132,13 @@ namespace OpenSim.Server.Handlers.Login | |||
132 | 132 | ||
133 | //m_log.InfoFormat("[LOGIN]: XMLRPC Login Requested for {0} {1}, starting in {2}, using {3}", first, last, startLocation, clientVersion); | 133 | //m_log.InfoFormat("[LOGIN]: XMLRPC Login Requested for {0} {1}, starting in {2}, using {3}", first, last, startLocation, clientVersion); |
134 | 134 | ||
135 | |||
136 | bool LibOMVclient = false; | ||
137 | if (request.Params.Count > 4 && (string)request.Params[4] == "gridproxy") | ||
138 | LibOMVclient = true; | ||
139 | |||
135 | LoginResponse reply = null; | 140 | LoginResponse reply = null; |
136 | reply = m_LocalService.Login(first, last, passwd, startLocation, scopeID, clientVersion, channel, mac, id0, remoteClient); | 141 | reply = m_LocalService.Login(first, last, passwd, startLocation, scopeID, clientVersion, channel, mac, id0, remoteClient, LibOMVclient); |
137 | 142 | ||
138 | XmlRpcResponse response = new XmlRpcResponse(); | 143 | XmlRpcResponse response = new XmlRpcResponse(); |
139 | response.Value = reply.ToHashtable(); | 144 | response.Value = reply.ToHashtable(); |
@@ -216,7 +221,7 @@ namespace OpenSim.Server.Handlers.Login | |||
216 | 221 | ||
217 | LoginResponse reply = null; | 222 | LoginResponse reply = null; |
218 | reply = m_LocalService.Login(map["first"].AsString(), map["last"].AsString(), map["passwd"].AsString(), startLocation, scopeID, | 223 | reply = m_LocalService.Login(map["first"].AsString(), map["last"].AsString(), map["passwd"].AsString(), startLocation, scopeID, |
219 | map["version"].AsString(), map["channel"].AsString(), map["mac"].AsString(), map["id0"].AsString(), remoteClient); | 224 | map["version"].AsString(), map["channel"].AsString(), map["mac"].AsString(), map["id0"].AsString(), remoteClient,false); |
220 | return reply.ToOSDMap(); | 225 | return reply.ToOSDMap(); |
221 | 226 | ||
222 | } | 227 | } |
@@ -259,7 +264,7 @@ namespace OpenSim.Server.Handlers.Login | |||
259 | (sender as WebSocketHttpServerHandler).GetRemoteIPEndpoint(); | 264 | (sender as WebSocketHttpServerHandler).GetRemoteIPEndpoint(); |
260 | LoginResponse reply = null; | 265 | LoginResponse reply = null; |
261 | reply = m_LocalService.Login(first, last, passwd, start, scope, version, | 266 | reply = m_LocalService.Login(first, last, passwd, start, scope, version, |
262 | channel, mac, id0, endPoint); | 267 | channel, mac, id0, endPoint,false); |
263 | sock.SendMessage(OSDParser.SerializeJsonString(reply.ToOSDMap())); | 268 | sock.SendMessage(OSDParser.SerializeJsonString(reply.ToOSDMap())); |
264 | 269 | ||
265 | } | 270 | } |
diff --git a/OpenSim/Server/Handlers/Map/MapAddServerConnector.cs b/OpenSim/Server/Handlers/Map/MapAddServerConnector.cs index 649a27e..38dfffc 100644 --- a/OpenSim/Server/Handlers/Map/MapAddServerConnector.cs +++ b/OpenSim/Server/Handlers/Map/MapAddServerConnector.cs | |||
@@ -118,9 +118,13 @@ namespace OpenSim.Server.Handlers.MapImage | |||
118 | httpResponse.StatusCode = (int)OSHttpStatusCode.ClientErrorBadRequest; | 118 | httpResponse.StatusCode = (int)OSHttpStatusCode.ClientErrorBadRequest; |
119 | return FailureResult("Bad request."); | 119 | return FailureResult("Bad request."); |
120 | } | 120 | } |
121 | uint x = 0, y = 0; | 121 | int x = 0, y = 0; |
122 | UInt32.TryParse(request["X"].ToString(), out x); | 122 | // UUID scopeID = new UUID("07f8d88e-cd5e-4239-a0ed-843f75d09992"); |
123 | UInt32.TryParse(request["Y"].ToString(), out y); | 123 | UUID scopeID = UUID.Zero; |
124 | Int32.TryParse(request["X"].ToString(), out x); | ||
125 | Int32.TryParse(request["Y"].ToString(), out y); | ||
126 | if (request.ContainsKey("SCOPE")) | ||
127 | UUID.TryParse(request["SCOPE"].ToString(), out scopeID); | ||
124 | 128 | ||
125 | m_log.DebugFormat("[MAP ADD SERVER CONNECTOR]: Received map data for region at {0}-{1}", x, y); | 129 | m_log.DebugFormat("[MAP ADD SERVER CONNECTOR]: Received map data for region at {0}-{1}", x, y); |
126 | 130 | ||
@@ -132,7 +136,7 @@ namespace OpenSim.Server.Handlers.MapImage | |||
132 | if (m_GridService != null) | 136 | if (m_GridService != null) |
133 | { | 137 | { |
134 | System.Net.IPAddress ipAddr = GetCallerIP(httpRequest); | 138 | System.Net.IPAddress ipAddr = GetCallerIP(httpRequest); |
135 | GridRegion r = m_GridService.GetRegionByPosition(UUID.Zero, (int)Util.RegionToWorldLoc(x), (int)Util.RegionToWorldLoc(y)); | 139 | GridRegion r = m_GridService.GetRegionByPosition(UUID.Zero, (int)Util.RegionToWorldLoc((uint)x), (int)Util.RegionToWorldLoc((uint)y)); |
136 | if (r != null) | 140 | if (r != null) |
137 | { | 141 | { |
138 | if (r.ExternalEndPoint.Address.ToString() != ipAddr.ToString()) | 142 | if (r.ExternalEndPoint.Address.ToString() != ipAddr.ToString()) |
@@ -153,7 +157,8 @@ namespace OpenSim.Server.Handlers.MapImage | |||
153 | byte[] data = Convert.FromBase64String(request["DATA"].ToString()); | 157 | byte[] data = Convert.FromBase64String(request["DATA"].ToString()); |
154 | 158 | ||
155 | string reason = string.Empty; | 159 | string reason = string.Empty; |
156 | bool result = m_MapService.AddMapTile((int)x, (int)y, data, out reason); | 160 | |
161 | bool result = m_MapService.AddMapTile((int)x, (int)y, data, scopeID, out reason); | ||
157 | 162 | ||
158 | if (result) | 163 | if (result) |
159 | return SuccessResult(); | 164 | return SuccessResult(); |
diff --git a/OpenSim/Server/Handlers/Map/MapGetServerConnector.cs b/OpenSim/Server/Handlers/Map/MapGetServerConnector.cs index 7bb2f39..1ae669c 100644 --- a/OpenSim/Server/Handlers/Map/MapGetServerConnector.cs +++ b/OpenSim/Server/Handlers/Map/MapGetServerConnector.cs | |||
@@ -29,6 +29,7 @@ using System; | |||
29 | using System.IO; | 29 | using System.IO; |
30 | using System.Net; | 30 | using System.Net; |
31 | using System.Reflection; | 31 | using System.Reflection; |
32 | using System.Threading; | ||
32 | 33 | ||
33 | using Nini.Config; | 34 | using Nini.Config; |
34 | using log4net; | 35 | using log4net; |
@@ -37,6 +38,7 @@ using OpenSim.Server.Base; | |||
37 | using OpenSim.Services.Interfaces; | 38 | using OpenSim.Services.Interfaces; |
38 | using OpenSim.Framework.Servers.HttpServer; | 39 | using OpenSim.Framework.Servers.HttpServer; |
39 | using OpenSim.Server.Handlers.Base; | 40 | using OpenSim.Server.Handlers.Base; |
41 | using OpenMetaverse; | ||
40 | 42 | ||
41 | namespace OpenSim.Server.Handlers.MapImage | 43 | namespace OpenSim.Server.Handlers.MapImage |
42 | { | 44 | { |
@@ -70,6 +72,8 @@ namespace OpenSim.Server.Handlers.MapImage | |||
70 | 72 | ||
71 | class MapServerGetHandler : BaseStreamHandler | 73 | class MapServerGetHandler : BaseStreamHandler |
72 | { | 74 | { |
75 | public static ManualResetEvent ev = new ManualResetEvent(true); | ||
76 | |||
73 | // private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | 77 | // private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); |
74 | 78 | ||
75 | private IMapImageService m_MapService; | 79 | private IMapImageService m_MapService; |
@@ -82,10 +86,25 @@ namespace OpenSim.Server.Handlers.MapImage | |||
82 | 86 | ||
83 | protected override byte[] ProcessRequest(string path, Stream request, IOSHttpRequest httpRequest, IOSHttpResponse httpResponse) | 87 | protected override byte[] ProcessRequest(string path, Stream request, IOSHttpRequest httpRequest, IOSHttpResponse httpResponse) |
84 | { | 88 | { |
85 | byte[] result = new byte[0]; | 89 | ev.WaitOne(); |
90 | lock (ev) | ||
91 | { | ||
92 | ev.Reset(); | ||
93 | } | ||
86 | 94 | ||
95 | byte[] result = new byte[0]; | ||
87 | string format = string.Empty; | 96 | string format = string.Empty; |
88 | result = m_MapService.GetMapTile(path.Trim('/'), out format); | 97 | |
98 | // UUID scopeID = new UUID("07f8d88e-cd5e-4239-a0ed-843f75d09992"); | ||
99 | UUID scopeID = UUID.Zero; | ||
100 | |||
101 | string[] bits = path.Trim('/').Split(new char[] {'/'}); | ||
102 | if (bits.Length > 1) | ||
103 | { | ||
104 | scopeID = new UUID(bits[0]); | ||
105 | path = bits[1]; | ||
106 | } | ||
107 | result = m_MapService.GetMapTile(path.Trim('/'), scopeID, out format); | ||
89 | if (result.Length > 0) | 108 | if (result.Length > 0) |
90 | { | 109 | { |
91 | httpResponse.StatusCode = (int)HttpStatusCode.OK; | 110 | httpResponse.StatusCode = (int)HttpStatusCode.OK; |
@@ -100,6 +119,11 @@ namespace OpenSim.Server.Handlers.MapImage | |||
100 | httpResponse.ContentType = "text/plain"; | 119 | httpResponse.ContentType = "text/plain"; |
101 | } | 120 | } |
102 | 121 | ||
122 | lock (ev) | ||
123 | { | ||
124 | ev.Set(); | ||
125 | } | ||
126 | |||
103 | return result; | 127 | return result; |
104 | } | 128 | } |
105 | 129 | ||
diff --git a/OpenSim/Server/Handlers/Map/MapRemoveServerConnector.cs b/OpenSim/Server/Handlers/Map/MapRemoveServerConnector.cs new file mode 100644 index 0000000..4f8f7e1 --- /dev/null +++ b/OpenSim/Server/Handlers/Map/MapRemoveServerConnector.cs | |||
@@ -0,0 +1,253 @@ | |||
1 | /* | ||
2 | * Copyright (c) Contributors, http://opensimulator.org/ | ||
3 | * See CONTRIBUTORS.TXT for a full list of copyright holders. | ||
4 | * | ||
5 | * Redistribution and use in source and binary forms, with or without | ||
6 | * modification, are permitted provided that the following conditions are met: | ||
7 | * * Redistributions of source code must retain the above copyright | ||
8 | * notice, this list of conditions and the following disclaimer. | ||
9 | * * Redistributions in binary form must reproduce the above copyright | ||
10 | * notice, this list of conditions and the following disclaimer in the | ||
11 | * documentation and/or other materials provided with the distribution. | ||
12 | * * Neither the name of the OpenSimulator Project nor the | ||
13 | * names of its contributors may be used to endorse or promote products | ||
14 | * derived from this software without specific prior written permission. | ||
15 | * | ||
16 | * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY | ||
17 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | ||
18 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | ||
19 | * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY | ||
20 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | ||
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 | ||
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 | ||
25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
26 | */ | ||
27 | |||
28 | using System; | ||
29 | using System.Collections.Generic; | ||
30 | using System.IO; | ||
31 | using System.Reflection; | ||
32 | using System.Xml; | ||
33 | |||
34 | using Nini.Config; | ||
35 | using log4net; | ||
36 | using OpenMetaverse; | ||
37 | |||
38 | using OpenSim.Framework; | ||
39 | using OpenSim.Server.Base; | ||
40 | using OpenSim.Services.Interfaces; | ||
41 | using OpenSim.Framework.Servers.HttpServer; | ||
42 | using OpenSim.Server.Handlers.Base; | ||
43 | |||
44 | using GridRegion = OpenSim.Services.Interfaces.GridRegion; | ||
45 | |||
46 | namespace OpenSim.Server.Handlers.MapImage | ||
47 | { | ||
48 | public class MapRemoveServiceConnector : ServiceConnector | ||
49 | { | ||
50 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
51 | |||
52 | private IMapImageService m_MapService; | ||
53 | private IGridService m_GridService; | ||
54 | private string m_ConfigName = "MapImageService"; | ||
55 | |||
56 | public MapRemoveServiceConnector(IConfigSource config, IHttpServer server, string configName) : | ||
57 | base(config, server, configName) | ||
58 | { | ||
59 | IConfig serverConfig = config.Configs[m_ConfigName]; | ||
60 | if (serverConfig == null) | ||
61 | throw new Exception(String.Format("No section {0} in config file", m_ConfigName)); | ||
62 | |||
63 | string mapService = serverConfig.GetString("LocalServiceModule", | ||
64 | String.Empty); | ||
65 | |||
66 | if (mapService == String.Empty) | ||
67 | throw new Exception("No LocalServiceModule in config file"); | ||
68 | |||
69 | Object[] args = new Object[] { config }; | ||
70 | m_MapService = ServerUtils.LoadPlugin<IMapImageService>(mapService, args); | ||
71 | |||
72 | string gridService = serverConfig.GetString("GridService", String.Empty); | ||
73 | if (gridService != string.Empty) | ||
74 | m_GridService = ServerUtils.LoadPlugin<IGridService>(gridService, args); | ||
75 | |||
76 | if (m_GridService != null) | ||
77 | m_log.InfoFormat("[MAP IMAGE HANDLER]: GridService check is ON"); | ||
78 | else | ||
79 | m_log.InfoFormat("[MAP IMAGE HANDLER]: GridService check is OFF"); | ||
80 | |||
81 | bool proxy = serverConfig.GetBoolean("HasProxy", false); | ||
82 | server.AddStreamHandler(new MapServerRemoveHandler(m_MapService, m_GridService, proxy)); | ||
83 | |||
84 | } | ||
85 | } | ||
86 | |||
87 | class MapServerRemoveHandler : BaseStreamHandler | ||
88 | { | ||
89 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
90 | private IMapImageService m_MapService; | ||
91 | private IGridService m_GridService; | ||
92 | bool m_Proxy; | ||
93 | |||
94 | public MapServerRemoveHandler(IMapImageService service, IGridService grid, bool proxy) : | ||
95 | base("POST", "/removemap") | ||
96 | { | ||
97 | m_MapService = service; | ||
98 | m_GridService = grid; | ||
99 | m_Proxy = proxy; | ||
100 | } | ||
101 | |||
102 | public override byte[] Handle(string path, Stream requestData, IOSHttpRequest httpRequest, IOSHttpResponse httpResponse) | ||
103 | { | ||
104 | // m_log.DebugFormat("[MAP SERVICE IMAGE HANDLER]: Received {0}", path); | ||
105 | StreamReader sr = new StreamReader(requestData); | ||
106 | string body = sr.ReadToEnd(); | ||
107 | sr.Close(); | ||
108 | body = body.Trim(); | ||
109 | |||
110 | try | ||
111 | { | ||
112 | Dictionary<string, object> request = ServerUtils.ParseQueryString(body); | ||
113 | |||
114 | if (!request.ContainsKey("X") || !request.ContainsKey("Y")) | ||
115 | { | ||
116 | httpResponse.StatusCode = (int)OSHttpStatusCode.ClientErrorBadRequest; | ||
117 | return FailureResult("Bad request."); | ||
118 | } | ||
119 | int x = 0, y = 0; | ||
120 | Int32.TryParse(request["X"].ToString(), out x); | ||
121 | Int32.TryParse(request["Y"].ToString(), out y); | ||
122 | // UUID scopeID = new UUID("07f8d88e-cd5e-4239-a0ed-843f75d09992"); | ||
123 | UUID scopeID = UUID.Zero; | ||
124 | if (request.ContainsKey("SCOPE")) | ||
125 | UUID.TryParse(request["SCOPE"].ToString(), out scopeID); | ||
126 | |||
127 | m_log.DebugFormat("[MAP REMOVE SERVER CONNECTOR]: Received position data for region at {0}-{1}", x, y); | ||
128 | |||
129 | if (m_GridService != null) | ||
130 | { | ||
131 | System.Net.IPAddress ipAddr = GetCallerIP(httpRequest); | ||
132 | GridRegion r = m_GridService.GetRegionByPosition(UUID.Zero, (int)Util.RegionToWorldLoc((uint)x), (int)Util.RegionToWorldLoc((uint)y)); | ||
133 | if (r != null) | ||
134 | { | ||
135 | if (r.ExternalEndPoint.Address.ToString() != ipAddr.ToString()) | ||
136 | { | ||
137 | m_log.WarnFormat("[MAP IMAGE HANDLER]: IP address {0} may be trying to impersonate region in IP {1}", ipAddr, r.ExternalEndPoint.Address); | ||
138 | return FailureResult("IP address of caller does not match IP address of registered region"); | ||
139 | } | ||
140 | |||
141 | } | ||
142 | else | ||
143 | { | ||
144 | m_log.WarnFormat("[MAP IMAGE HANDLER]: IP address {0} may be rogue. Region not found at coordinates {1}-{2}", | ||
145 | ipAddr, x, y); | ||
146 | return FailureResult("Region not found at given coordinates"); | ||
147 | } | ||
148 | } | ||
149 | |||
150 | string reason = string.Empty; | ||
151 | bool result = m_MapService.RemoveMapTile(x, y, scopeID, out reason); | ||
152 | |||
153 | if (result) | ||
154 | return SuccessResult(); | ||
155 | else | ||
156 | return FailureResult(reason); | ||
157 | |||
158 | } | ||
159 | catch (Exception e) | ||
160 | { | ||
161 | m_log.ErrorFormat("[MAP SERVICE IMAGE HANDLER]: Exception {0} {1}", e.Message, e.StackTrace); | ||
162 | } | ||
163 | |||
164 | return FailureResult("Unexpected server error"); | ||
165 | } | ||
166 | |||
167 | private byte[] SuccessResult() | ||
168 | { | ||
169 | XmlDocument doc = new XmlDocument(); | ||
170 | |||
171 | XmlNode xmlnode = doc.CreateNode(XmlNodeType.XmlDeclaration, | ||
172 | "", ""); | ||
173 | |||
174 | doc.AppendChild(xmlnode); | ||
175 | |||
176 | XmlElement rootElement = doc.CreateElement("", "ServerResponse", | ||
177 | ""); | ||
178 | |||
179 | doc.AppendChild(rootElement); | ||
180 | |||
181 | XmlElement result = doc.CreateElement("", "Result", ""); | ||
182 | result.AppendChild(doc.CreateTextNode("Success")); | ||
183 | |||
184 | rootElement.AppendChild(result); | ||
185 | |||
186 | return DocToBytes(doc); | ||
187 | } | ||
188 | |||
189 | private byte[] FailureResult(string msg) | ||
190 | { | ||
191 | XmlDocument doc = new XmlDocument(); | ||
192 | |||
193 | XmlNode xmlnode = doc.CreateNode(XmlNodeType.XmlDeclaration, | ||
194 | "", ""); | ||
195 | |||
196 | doc.AppendChild(xmlnode); | ||
197 | |||
198 | XmlElement rootElement = doc.CreateElement("", "ServerResponse", | ||
199 | ""); | ||
200 | |||
201 | doc.AppendChild(rootElement); | ||
202 | |||
203 | XmlElement result = doc.CreateElement("", "Result", ""); | ||
204 | result.AppendChild(doc.CreateTextNode("Failure")); | ||
205 | |||
206 | rootElement.AppendChild(result); | ||
207 | |||
208 | XmlElement message = doc.CreateElement("", "Message", ""); | ||
209 | message.AppendChild(doc.CreateTextNode(msg)); | ||
210 | |||
211 | rootElement.AppendChild(message); | ||
212 | |||
213 | return DocToBytes(doc); | ||
214 | } | ||
215 | |||
216 | private byte[] DocToBytes(XmlDocument doc) | ||
217 | { | ||
218 | MemoryStream ms = new MemoryStream(); | ||
219 | XmlTextWriter xw = new XmlTextWriter(ms, null); | ||
220 | xw.Formatting = Formatting.Indented; | ||
221 | doc.WriteTo(xw); | ||
222 | xw.Flush(); | ||
223 | |||
224 | return ms.ToArray(); | ||
225 | } | ||
226 | |||
227 | private System.Net.IPAddress GetCallerIP(IOSHttpRequest request) | ||
228 | { | ||
229 | if (!m_Proxy) | ||
230 | return request.RemoteIPEndPoint.Address; | ||
231 | |||
232 | // We're behind a proxy | ||
233 | string xff = "X-Forwarded-For"; | ||
234 | string xffValue = request.Headers[xff.ToLower()]; | ||
235 | if (xffValue == null || (xffValue != null && xffValue == string.Empty)) | ||
236 | xffValue = request.Headers[xff]; | ||
237 | |||
238 | if (xffValue == null || (xffValue != null && xffValue == string.Empty)) | ||
239 | { | ||
240 | m_log.WarnFormat("[MAP IMAGE HANDLER]: No XFF header"); | ||
241 | return request.RemoteIPEndPoint.Address; | ||
242 | } | ||
243 | |||
244 | System.Net.IPEndPoint ep = Util.GetClientIPFromXFF(xffValue); | ||
245 | if (ep != null) | ||
246 | return ep.Address; | ||
247 | |||
248 | // Oops | ||
249 | return request.RemoteIPEndPoint.Address; | ||
250 | } | ||
251 | |||
252 | } | ||
253 | } | ||
diff --git a/OpenSim/Server/Handlers/Profiles/UserProfilesHandlers.cs b/OpenSim/Server/Handlers/Profiles/UserProfilesHandlers.cs index 49aa8ba..cac38f5 100644 --- a/OpenSim/Server/Handlers/Profiles/UserProfilesHandlers.cs +++ b/OpenSim/Server/Handlers/Profiles/UserProfilesHandlers.cs | |||
@@ -433,6 +433,7 @@ namespace OpenSim.Server.Handlers | |||
433 | } | 433 | } |
434 | #endregion User Preferences | 434 | #endregion User Preferences |
435 | 435 | ||
436 | |||
436 | #region Utility | 437 | #region Utility |
437 | public bool AvatarImageAssetsRequest(OSDMap json, ref JsonRpcResponse response) | 438 | public bool AvatarImageAssetsRequest(OSDMap json, ref JsonRpcResponse response) |
438 | { | 439 | { |
diff --git a/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs b/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs index 98c5312..c19421a 100644 --- a/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs +++ b/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs | |||
@@ -120,6 +120,8 @@ namespace OpenSim.Server.Handlers.Simulation | |||
120 | 120 | ||
121 | protected virtual void DoQueryAccess(Hashtable request, Hashtable responsedata, UUID agentID, UUID regionID) | 121 | protected virtual void DoQueryAccess(Hashtable request, Hashtable responsedata, UUID agentID, UUID regionID) |
122 | { | 122 | { |
123 | EntityTransferContext ctx = new EntityTransferContext(); | ||
124 | |||
123 | if (m_SimulationService == null) | 125 | if (m_SimulationService == null) |
124 | { | 126 | { |
125 | m_log.Debug("[AGENT HANDLER]: Agent QUERY called. Harmless but useless."); | 127 | m_log.Debug("[AGENT HANDLER]: Agent QUERY called. Harmless but useless."); |
@@ -155,6 +157,9 @@ namespace OpenSim.Server.Handlers.Simulation | |||
155 | theirVersion = float.Parse(parts[1]); | 157 | theirVersion = float.Parse(parts[1]); |
156 | } | 158 | } |
157 | 159 | ||
160 | if (args.ContainsKey("context")) | ||
161 | ctx.Unpack((OSDMap)args["context"]); | ||
162 | |||
158 | // Decode the new versioning data | 163 | // Decode the new versioning data |
159 | float minVersionRequired = 0f; | 164 | float minVersionRequired = 0f; |
160 | float maxVersionRequired = 0f; | 165 | float maxVersionRequired = 0f; |
@@ -245,7 +250,6 @@ namespace OpenSim.Server.Handlers.Simulation | |||
245 | 250 | ||
246 | string reason; | 251 | string reason; |
247 | // We're sending the version numbers down to the local connector to do the varregion check. | 252 | // We're sending the version numbers down to the local connector to do the varregion check. |
248 | EntityTransferContext ctx = new EntityTransferContext(); | ||
249 | ctx.InboundVersion = inboundVersion; | 253 | ctx.InboundVersion = inboundVersion; |
250 | ctx.OutboundVersion = outboundVersion; | 254 | ctx.OutboundVersion = outboundVersion; |
251 | if (minVersionProvided == 0f) | 255 | if (minVersionProvided == 0f) |
@@ -262,7 +266,6 @@ namespace OpenSim.Server.Handlers.Simulation | |||
262 | resp["version"] = OSD.FromString(legacyVersion); | 266 | resp["version"] = OSD.FromString(legacyVersion); |
263 | resp["negotiated_inbound_version"] = OSD.FromReal(inboundVersion); | 267 | resp["negotiated_inbound_version"] = OSD.FromReal(inboundVersion); |
264 | resp["negotiated_outbound_version"] = OSD.FromReal(outboundVersion); | 268 | resp["negotiated_outbound_version"] = OSD.FromReal(outboundVersion); |
265 | resp["variable_wearables_count_supported"] = OSD.FromBoolean(true); | ||
266 | 269 | ||
267 | OSDArray featuresWanted = new OSDArray(); | 270 | OSDArray featuresWanted = new OSDArray(); |
268 | foreach (UUID feature in features) | 271 | foreach (UUID feature in features) |
@@ -407,6 +410,8 @@ namespace OpenSim.Server.Handlers.Simulation | |||
407 | 410 | ||
408 | protected void DoAgentPost(Hashtable request, Hashtable responsedata, UUID id) | 411 | protected void DoAgentPost(Hashtable request, Hashtable responsedata, UUID id) |
409 | { | 412 | { |
413 | EntityTransferContext ctx = new EntityTransferContext(); | ||
414 | |||
410 | OSDMap args = Utils.GetOSDMap((string)request["body"]); | 415 | OSDMap args = Utils.GetOSDMap((string)request["body"]); |
411 | if (args == null) | 416 | if (args == null) |
412 | { | 417 | { |
@@ -415,6 +420,9 @@ namespace OpenSim.Server.Handlers.Simulation | |||
415 | return; | 420 | return; |
416 | } | 421 | } |
417 | 422 | ||
423 | if (args.ContainsKey("context")) | ||
424 | ctx.Unpack((OSDMap)args["context"]); | ||
425 | |||
418 | AgentDestinationData data = CreateAgentDestinationData(); | 426 | AgentDestinationData data = CreateAgentDestinationData(); |
419 | UnpackData(args, data, request); | 427 | UnpackData(args, data, request); |
420 | 428 | ||
@@ -461,7 +469,8 @@ namespace OpenSim.Server.Handlers.Simulation | |||
461 | // This is the meaning of POST agent | 469 | // This is the meaning of POST agent |
462 | //m_regionClient.AdjustUserInformation(aCircuit); | 470 | //m_regionClient.AdjustUserInformation(aCircuit); |
463 | //bool result = m_SimulationService.CreateAgent(destination, aCircuit, teleportFlags, out reason); | 471 | //bool result = m_SimulationService.CreateAgent(destination, aCircuit, teleportFlags, out reason); |
464 | bool result = CreateAgent(source, gatekeeper, destination, aCircuit, data.flags, data.fromLogin, out reason); | 472 | |
473 | bool result = CreateAgent(source, gatekeeper, destination, aCircuit, data.flags, data.fromLogin, ctx, out reason); | ||
465 | 474 | ||
466 | resp["reason"] = OSD.FromString(reason); | 475 | resp["reason"] = OSD.FromString(reason); |
467 | resp["success"] = OSD.FromBoolean(result); | 476 | resp["success"] = OSD.FromBoolean(result); |
@@ -536,9 +545,29 @@ namespace OpenSim.Server.Handlers.Simulation | |||
536 | 545 | ||
537 | // subclasses can override this | 546 | // subclasses can override this |
538 | protected virtual bool CreateAgent(GridRegion source, GridRegion gatekeeper, GridRegion destination, | 547 | protected virtual bool CreateAgent(GridRegion source, GridRegion gatekeeper, GridRegion destination, |
539 | AgentCircuitData aCircuit, uint teleportFlags, bool fromLogin, out string reason) | 548 | AgentCircuitData aCircuit, uint teleportFlags, bool fromLogin, EntityTransferContext ctx, out string reason) |
540 | { | 549 | { |
541 | return m_SimulationService.CreateAgent(source, destination, aCircuit, teleportFlags, out reason); | 550 | reason = String.Empty; |
551 | // The data and protocols are already defined so this is just a dummy to satisfy the interface | ||
552 | // TODO: make this end-to-end | ||
553 | if ((teleportFlags & (uint)TeleportFlags.ViaLogin) == 0) | ||
554 | { | ||
555 | Util.FireAndForget(x => | ||
556 | { | ||
557 | string r; | ||
558 | m_SimulationService.CreateAgent(source, destination, aCircuit, teleportFlags, ctx, out r); | ||
559 | m_log.DebugFormat("[AGENT HANDLER]: ASYNC CreateAgent {0}", r); | ||
560 | }); | ||
561 | |||
562 | return true; | ||
563 | } | ||
564 | else | ||
565 | { | ||
566 | |||
567 | bool ret = m_SimulationService.CreateAgent(source, destination, aCircuit, teleportFlags, ctx, out reason); | ||
568 | m_log.DebugFormat("[AGENT HANDLER]: SYNC CreateAgent {0} {1}", ret.ToString(), reason); | ||
569 | return ret; | ||
570 | } | ||
542 | } | 571 | } |
543 | } | 572 | } |
544 | 573 | ||
@@ -639,6 +668,9 @@ namespace OpenSim.Server.Handlers.Simulation | |||
639 | 668 | ||
640 | protected void DoAgentPut(Hashtable request, Hashtable responsedata) | 669 | protected void DoAgentPut(Hashtable request, Hashtable responsedata) |
641 | { | 670 | { |
671 | // TODO: Encode the ENtityTransferContext | ||
672 | EntityTransferContext ctx = new EntityTransferContext(); | ||
673 | |||
642 | OSDMap args = Utils.GetOSDMap((string)request["body"]); | 674 | OSDMap args = Utils.GetOSDMap((string)request["body"]); |
643 | if (args == null) | 675 | if (args == null) |
644 | { | 676 | { |
@@ -659,6 +691,8 @@ namespace OpenSim.Server.Handlers.Simulation | |||
659 | UUID.TryParse(args["destination_uuid"].AsString(), out uuid); | 691 | UUID.TryParse(args["destination_uuid"].AsString(), out uuid); |
660 | if (args.ContainsKey("destination_name") && args["destination_name"] != null) | 692 | if (args.ContainsKey("destination_name") && args["destination_name"] != null) |
661 | regionname = args["destination_name"].ToString(); | 693 | regionname = args["destination_name"].ToString(); |
694 | if (args.ContainsKey("context")) | ||
695 | ctx.Unpack((OSDMap)args["context"]); | ||
662 | 696 | ||
663 | GridRegion destination = new GridRegion(); | 697 | GridRegion destination = new GridRegion(); |
664 | destination.RegionID = uuid; | 698 | destination.RegionID = uuid; |
@@ -681,7 +715,7 @@ namespace OpenSim.Server.Handlers.Simulation | |||
681 | AgentData agent = new AgentData(); | 715 | AgentData agent = new AgentData(); |
682 | try | 716 | try |
683 | { | 717 | { |
684 | agent.Unpack(args, m_SimulationService.GetScene(destination.RegionID)); | 718 | agent.Unpack(args, m_SimulationService.GetScene(destination.RegionID), ctx); |
685 | } | 719 | } |
686 | catch (Exception ex) | 720 | catch (Exception ex) |
687 | { | 721 | { |
@@ -700,7 +734,7 @@ namespace OpenSim.Server.Handlers.Simulation | |||
700 | AgentPosition agent = new AgentPosition(); | 734 | AgentPosition agent = new AgentPosition(); |
701 | try | 735 | try |
702 | { | 736 | { |
703 | agent.Unpack(args, m_SimulationService.GetScene(destination.RegionID)); | 737 | agent.Unpack(args, m_SimulationService.GetScene(destination.RegionID), ctx); |
704 | } | 738 | } |
705 | catch (Exception ex) | 739 | catch (Exception ex) |
706 | { | 740 | { |
@@ -721,7 +755,10 @@ namespace OpenSim.Server.Handlers.Simulation | |||
721 | // subclasses can override this | 755 | // subclasses can override this |
722 | protected virtual bool UpdateAgent(GridRegion destination, AgentData agent) | 756 | protected virtual bool UpdateAgent(GridRegion destination, AgentData agent) |
723 | { | 757 | { |
724 | return m_SimulationService.UpdateAgent(destination, agent); | 758 | // The data and protocols are already defined so this is just a dummy to satisfy the interface |
759 | // TODO: make this end-to-end | ||
760 | EntityTransferContext ctx = new EntityTransferContext(); | ||
761 | return m_SimulationService.UpdateAgent(destination, agent, ctx); | ||
725 | } | 762 | } |
726 | } | 763 | } |
727 | 764 | ||
diff --git a/OpenSim/Server/ServerMain.cs b/OpenSim/Server/ServerMain.cs index 65e9287..ed5a481 100644 --- a/OpenSim/Server/ServerMain.cs +++ b/OpenSim/Server/ServerMain.cs | |||
@@ -29,6 +29,7 @@ using Nini.Config; | |||
29 | using log4net; | 29 | using log4net; |
30 | using System.Reflection; | 30 | using System.Reflection; |
31 | using System; | 31 | using System; |
32 | using System.Net; | ||
32 | using System.Collections.Generic; | 33 | using System.Collections.Generic; |
33 | using OpenSim.Framework.Servers; | 34 | using OpenSim.Framework.Servers; |
34 | using OpenSim.Framework.Servers.HttpServer; | 35 | using OpenSim.Framework.Servers.HttpServer; |
@@ -53,6 +54,10 @@ namespace OpenSim.Server | |||
53 | 54 | ||
54 | public static int Main(string[] args) | 55 | public static int Main(string[] args) |
55 | { | 56 | { |
57 | // Make sure we don't get outbound connections queueing | ||
58 | ServicePointManager.DefaultConnectionLimit = 50; | ||
59 | ServicePointManager.UseNagleAlgorithm = false; | ||
60 | |||
56 | m_Server = new HttpServerBase("R.O.B.U.S.T.", args); | 61 | m_Server = new HttpServerBase("R.O.B.U.S.T.", args); |
57 | 62 | ||
58 | string registryLocation; | 63 | string registryLocation; |