WorldMapModule.cs 79 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943
  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. using System;
  28. using System.Collections;
  29. using System.Collections.Concurrent;
  30. using System.Collections.Generic;
  31. using System.Drawing;
  32. using System.Drawing.Imaging;
  33. using System.IO;
  34. using System.Net;
  35. using System.Reflection;
  36. using System.Runtime.Remoting.Messaging;
  37. using System.Threading;
  38. using log4net;
  39. using Nini.Config;
  40. using OpenMetaverse;
  41. using OpenMetaverse.Imaging;
  42. using OpenMetaverse.StructuredData;
  43. using Mono.Addins;
  44. using OpenSim.Framework;
  45. using OpenSim.Framework.Capabilities;
  46. using OpenSim.Framework.Monitoring;
  47. using OpenSim.Framework.Servers;
  48. using OpenSim.Framework.Servers.HttpServer;
  49. using OpenSim.Region.Framework.Interfaces;
  50. using OpenSim.Region.Framework.Scenes;
  51. using OpenSim.Region.CoreModules.World.Land;
  52. using Caps=OpenSim.Framework.Capabilities.Caps;
  53. using OSDArray=OpenMetaverse.StructuredData.OSDArray;
  54. using OSDMap=OpenMetaverse.StructuredData.OSDMap;
  55. using GridRegion = OpenSim.Services.Interfaces.GridRegion;
  56. namespace OpenSim.Region.CoreModules.World.WorldMap
  57. {
  58. [Extension(Path = "/OpenSim/RegionModules", NodeName = "RegionModule", Id = "WorldMapModule")]
  59. public class WorldMapModule : INonSharedRegionModule, IWorldMapModule
  60. {
  61. private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
  62. #pragma warning disable 414
  63. private static string LogHeader = "[WORLD MAP]";
  64. #pragma warning restore 414
  65. private static readonly string DEFAULT_WORLD_MAP_EXPORT_PATH = "exportmap.jpg";
  66. private static readonly UUID STOP_UUID = UUID.Random();
  67. private BlockingCollection<MapRequestState> requests = new BlockingCollection<MapRequestState>();
  68. private ManualResetEvent m_mapBlockRequestEvent = new ManualResetEvent(false);
  69. private Dictionary<UUID, Queue<MapBlockRequestData>> m_mapBlockRequests = new Dictionary<UUID, Queue<MapBlockRequestData>>();
  70. private IMapImageGenerator m_mapImageGenerator;
  71. private IMapImageUploadModule m_mapImageServiceModule;
  72. protected Scene m_scene;
  73. private List<MapBlockData> cachedMapBlocks = new List<MapBlockData>();
  74. private byte[] myMapImageJPEG;
  75. protected volatile bool m_Enabled = false;
  76. private ExpiringCache<string, int> m_blacklistedurls = new ExpiringCache<string, int>();
  77. private ExpiringCache<ulong, int> m_blacklistedregions = new ExpiringCache<ulong, int>();
  78. private ExpiringCache<ulong, string> m_cachedRegionMapItemsAddress = new ExpiringCache<ulong, string>();
  79. private ExpiringCache<ulong, OSDMap> m_cachedRegionMapItemsResponses =
  80. new ExpiringCache<ulong, OSDMap>();
  81. private List<UUID> m_rootAgents = new List<UUID>();
  82. private volatile bool threadrunning = false;
  83. // expire time for the blacklists in seconds
  84. protected double expireBlackListTime = 600.0; // 10 minutes
  85. // expire mapItems responses time in seconds. Throttles requests to regions that do answer
  86. private const double expireResponsesTime = 120.0; // 2 minutes ?
  87. //private int CacheRegionsDistance = 256;
  88. protected bool m_exportPrintScale = false; // prints the scale of map in meters on exported map
  89. protected bool m_exportPrintRegionName = false; // prints the region name exported map
  90. protected bool m_showNPCs = true;
  91. #region INonSharedRegionModule Members
  92. public virtual void Initialise(IConfigSource config)
  93. {
  94. string[] configSections = new string[] { "Map", "Startup" };
  95. if (Util.GetConfigVarFromSections<string>(
  96. config, "WorldMapModule", configSections, "WorldMap") == "WorldMap")
  97. m_Enabled = true;
  98. expireBlackListTime = (double)Util.GetConfigVarFromSections<int>(config, "BlacklistTimeout", configSections, 10 * 60);
  99. m_exportPrintScale =
  100. Util.GetConfigVarFromSections<bool>(config, "ExportMapAddScale", configSections, m_exportPrintScale);
  101. m_exportPrintRegionName =
  102. Util.GetConfigVarFromSections<bool>(config, "ExportMapAddRegionName", configSections, m_exportPrintRegionName);
  103. m_showNPCs =
  104. Util.GetConfigVarFromSections<bool>(config, "ShowNPCs", configSections, m_showNPCs);
  105. }
  106. public virtual void AddRegion(Scene scene)
  107. {
  108. if (!m_Enabled)
  109. return;
  110. lock (scene)
  111. {
  112. m_scene = scene;
  113. m_scene.RegisterModuleInterface<IWorldMapModule>(this);
  114. m_scene.AddCommand(
  115. "Regions", this, "export-map",
  116. "export-map [<path>]",
  117. "Save an image of the world map", HandleExportWorldMapConsoleCommand);
  118. m_scene.AddCommand(
  119. "Regions", this, "generate map",
  120. "generate map",
  121. "Generates and stores a new maptile.", HandleGenerateMapConsoleCommand);
  122. AddHandlers();
  123. }
  124. }
  125. public virtual void RemoveRegion(Scene scene)
  126. {
  127. if (!m_Enabled)
  128. return;
  129. lock (m_scene)
  130. {
  131. m_Enabled = false;
  132. RemoveHandlers();
  133. m_scene = null;
  134. }
  135. }
  136. public virtual void RegionLoaded(Scene scene)
  137. {
  138. if (!m_Enabled)
  139. return;
  140. m_mapImageGenerator = m_scene.RequestModuleInterface<IMapImageGenerator>();
  141. m_mapImageServiceModule = m_scene.RequestModuleInterface<IMapImageUploadModule>();
  142. }
  143. public virtual void Close()
  144. {
  145. }
  146. public Type ReplaceableInterface
  147. {
  148. get { return null; }
  149. }
  150. public virtual string Name
  151. {
  152. get { return "WorldMapModule"; }
  153. }
  154. #endregion
  155. // this has to be called with a lock on m_scene
  156. protected virtual void AddHandlers()
  157. {
  158. myMapImageJPEG = new byte[0];
  159. string regionimage = "regionImage" + m_scene.RegionInfo.RegionID.ToString();
  160. regionimage = regionimage.Replace("-", "");
  161. m_log.Info("[WORLD MAP]: JPEG Map location: " + m_scene.RegionInfo.ServerURI + "index.php?method=" + regionimage);
  162. /*
  163. MainServer.Instance.AddHTTPHandler(regionimage,
  164. new GenericHTTPDOSProtector(OnHTTPGetMapImage, OnHTTPThrottled, new BasicDosProtectorOptions()
  165. {
  166. AllowXForwardedFor = false,
  167. ForgetTimeSpan = TimeSpan.FromMinutes(2),
  168. MaxRequestsInTimeframe = 4,
  169. ReportingName = "MAPDOSPROTECTOR",
  170. RequestTimeSpan = TimeSpan.FromSeconds(10),
  171. ThrottledAction = BasicDOSProtector.ThrottleAction.DoThrottledMethod
  172. }).Process);
  173. */
  174. MainServer.Instance.AddHTTPHandler(regionimage, OnHTTPGetMapImage);
  175. MainServer.Instance.AddLLSDHandler(
  176. "/MAP/MapItems/" + m_scene.RegionInfo.RegionHandle.ToString(), HandleRemoteMapItemRequest);
  177. m_scene.EventManager.OnRegisterCaps += OnRegisterCaps;
  178. m_scene.EventManager.OnNewClient += OnNewClient;
  179. m_scene.EventManager.OnClientClosed += ClientLoggedOut;
  180. m_scene.EventManager.OnMakeChildAgent += MakeChildAgent;
  181. m_scene.EventManager.OnMakeRootAgent += MakeRootAgent;
  182. m_scene.EventManager.OnRegionUp += OnRegionUp;
  183. StartThread(new object());
  184. }
  185. // this has to be called with a lock on m_scene
  186. protected virtual void RemoveHandlers()
  187. {
  188. StopThread();
  189. m_scene.EventManager.OnRegionUp -= OnRegionUp;
  190. m_scene.EventManager.OnMakeRootAgent -= MakeRootAgent;
  191. m_scene.EventManager.OnMakeChildAgent -= MakeChildAgent;
  192. m_scene.EventManager.OnClientClosed -= ClientLoggedOut;
  193. m_scene.EventManager.OnNewClient -= OnNewClient;
  194. m_scene.EventManager.OnRegisterCaps -= OnRegisterCaps;
  195. m_scene.UnregisterModuleInterface<IWorldMapModule>(this);
  196. string regionimage = "regionImage" + m_scene.RegionInfo.RegionID.ToString();
  197. regionimage = regionimage.Replace("-", "");
  198. MainServer.Instance.RemoveLLSDHandler("/MAP/MapItems/" + m_scene.RegionInfo.RegionHandle.ToString(),
  199. HandleRemoteMapItemRequest);
  200. MainServer.Instance.RemoveHTTPHandler("", regionimage);
  201. }
  202. public void OnRegisterCaps(UUID agentID, Caps caps)
  203. {
  204. //m_log.DebugFormat("[WORLD MAP]: OnRegisterCaps: agentID {0} caps {1}", agentID, caps);
  205. string capspath = "/CAPS/" + UUID.Random();
  206. caps.RegisterHandler(
  207. "MapLayer",
  208. new RestStreamHandler(
  209. "POST",
  210. capspath,
  211. (request, path, param, httpRequest, httpResponse)
  212. => MapLayerRequest(request, path, param, agentID, caps),
  213. "MapLayer",
  214. agentID.ToString()));
  215. }
  216. /// <summary>
  217. /// Callback for a map layer request
  218. /// </summary>
  219. /// <param name="request"></param>
  220. /// <param name="path"></param>
  221. /// <param name="param"></param>
  222. /// <param name="agentID"></param>
  223. /// <param name="caps"></param>
  224. /// <returns></returns>
  225. public string MapLayerRequest(string request, string path, string param,
  226. UUID agentID, Caps caps)
  227. {
  228. // not sure about this....
  229. //try
  230. //
  231. //m_log.DebugFormat("[MAPLAYER]: path: {0}, param: {1}, agent:{2}",
  232. // path, param, agentID.ToString());
  233. // There is a major hack going on in this method. The viewer doesn't request
  234. // map blocks (RequestMapBlocks) above 2048. That means that if we don't hack,
  235. // grids above that cell don't have a map at all. So, here's the hack: we wait
  236. // for this CAP request to come, and we inject the map blocks at this point.
  237. // In a normal scenario, this request simply sends back the MapLayer (the blue color).
  238. // In the hacked scenario, it also sends the map blocks via UDP.
  239. //
  240. // 6/8/2011 -- I'm adding an explicit 2048 check, so that we never forget that there is
  241. // a hack here, and so that regions below 4096 don't get spammed with unnecessary map blocks.
  242. //if (m_scene.RegionInfo.RegionLocX >= 2048 || m_scene.RegionInfo.RegionLocY >= 2048)
  243. //{
  244. // ScenePresence avatarPresence = null;
  245. // m_scene.TryGetScenePresence(agentID, out avatarPresence);
  246. // if (avatarPresence != null)
  247. // {
  248. // bool lookup = false;
  249. // lock (cachedMapBlocks)
  250. // {
  251. // if (cachedMapBlocks.Count > 0 && ((cachedTime + 1800) > Util.UnixTimeSinceEpoch()))
  252. // {
  253. // List<MapBlockData> mapBlocks;
  254. // mapBlocks = cachedMapBlocks;
  255. // avatarPresence.ControllingClient.SendMapBlock(mapBlocks, 0);
  256. // }
  257. // else
  258. // {
  259. // lookup = true;
  260. // }
  261. // }
  262. // if (lookup)
  263. // {
  264. // List<MapBlockData> mapBlocks = new List<MapBlockData>(); ;
  265. // List<GridRegion> regions = m_scene.GridService.GetRegionRange(m_scene.RegionInfo.ScopeID,
  266. // (int)(m_scene.RegionInfo.RegionLocX - 8) * (int)Constants.RegionSize,
  267. // (int)(m_scene.RegionInfo.RegionLocX + 8) * (int)Constants.RegionSize,
  268. // (int)(m_scene.RegionInfo.RegionLocY - 8) * (int)Constants.RegionSize,
  269. // (int)(m_scene.RegionInfo.RegionLocY + 8) * (int)Constants.RegionSize);
  270. // foreach (GridRegion r in regions)
  271. // {
  272. // MapBlockData block = new MapBlockData();
  273. // MapBlockFromGridRegion(block, r, 0);
  274. // mapBlocks.Add(block);
  275. // }
  276. // avatarPresence.ControllingClient.SendMapBlock(mapBlocks, 0);
  277. // lock (cachedMapBlocks)
  278. // cachedMapBlocks = mapBlocks;
  279. // cachedTime = Util.UnixTimeSinceEpoch();
  280. // }
  281. // }
  282. //}
  283. LLSDMapLayerResponse mapResponse = new LLSDMapLayerResponse();
  284. mapResponse.LayerData.Array.Add(GetOSDMapLayerResponse());
  285. return mapResponse.ToString();
  286. }
  287. /// <summary>
  288. ///
  289. /// </summary>
  290. /// <param name="mapReq"></param>
  291. /// <returns></returns>
  292. public LLSDMapLayerResponse GetMapLayer(LLSDMapRequest mapReq)
  293. {
  294. // m_log.DebugFormat("[WORLD MAP]: MapLayer Request in region: {0}", m_scene.RegionInfo.RegionName);
  295. LLSDMapLayerResponse mapResponse = new LLSDMapLayerResponse();
  296. mapResponse.LayerData.Array.Add(GetOSDMapLayerResponse());
  297. return mapResponse;
  298. }
  299. /// <summary>
  300. ///
  301. /// </summary>
  302. /// <returns></returns>
  303. protected static OSDMapLayer GetOSDMapLayerResponse()
  304. {
  305. // not sure about this.... 2048 or master 5000 and hack above?
  306. OSDMapLayer mapLayer = new OSDMapLayer();
  307. mapLayer.Right = 2048;
  308. mapLayer.Top = 2048;
  309. mapLayer.ImageID = new UUID("00000000-0000-1111-9999-000000000006");
  310. return mapLayer;
  311. }
  312. #region EventHandlers
  313. /// <summary>
  314. /// Registered for event
  315. /// </summary>
  316. /// <param name="client"></param>
  317. private void OnNewClient(IClientAPI client)
  318. {
  319. client.OnRequestMapBlocks += RequestMapBlocks;
  320. client.OnMapItemRequest += HandleMapItemRequest;
  321. }
  322. /// <summary>
  323. /// Client logged out, check to see if there are any more root agents in the simulator
  324. /// If not, stop the mapItemRequest Thread
  325. /// Event handler
  326. /// </summary>
  327. /// <param name="AgentId">AgentID that logged out</param>
  328. private void ClientLoggedOut(UUID AgentId, Scene scene)
  329. {
  330. lock (m_rootAgents)
  331. {
  332. m_rootAgents.Remove(AgentId);
  333. }
  334. lock (m_mapBlockRequestEvent)
  335. {
  336. if (m_mapBlockRequests.ContainsKey(AgentId))
  337. m_mapBlockRequests.Remove(AgentId);
  338. }
  339. }
  340. #endregion
  341. /// <summary>
  342. /// Starts the MapItemRequest Thread
  343. /// Note that this only gets started when there are actually agents in the region
  344. /// Additionally, it gets stopped when there are none.
  345. /// </summary>
  346. /// <param name="o"></param>
  347. private void StartThread(object o)
  348. {
  349. if (threadrunning) return;
  350. threadrunning = true;
  351. // m_log.Debug("[WORLD MAP]: Starting remote MapItem request thread");
  352. WorkManager.StartThread(
  353. process,
  354. string.Format("MapItemRequestThread ({0})", m_scene.RegionInfo.RegionName));
  355. WorkManager.StartThread(
  356. MapBlockSendThread,
  357. string.Format("MapBlockSendThread ({0})", m_scene.RegionInfo.RegionName));
  358. }
  359. /// <summary>
  360. /// Enqueues a 'stop thread' MapRequestState. Causes the MapItemRequest thread to end
  361. /// </summary>
  362. private void StopThread()
  363. {
  364. MapRequestState st = new MapRequestState();
  365. st.agentID = STOP_UUID;
  366. st.EstateID = 0;
  367. st.flags = 0;
  368. st.godlike = false;
  369. st.itemtype = 0;
  370. st.regionhandle = 0;
  371. requests.Add(st);
  372. MapBlockRequestData req = new MapBlockRequestData();
  373. req.client = null;
  374. req.minX = 0;
  375. req.maxX = 0;
  376. req.minY = 0;
  377. req.maxY = 0;
  378. req.flags = 0;
  379. lock (m_mapBlockRequestEvent)
  380. {
  381. m_mapBlockRequests[UUID.Zero] = new Queue<MapBlockRequestData>();
  382. m_mapBlockRequests[UUID.Zero].Enqueue(req);
  383. m_mapBlockRequestEvent.Set();
  384. }
  385. }
  386. public virtual void HandleMapItemRequest(IClientAPI remoteClient, uint flags,
  387. uint EstateID, bool godlike, uint itemtype, ulong regionhandle)
  388. {
  389. // m_log.DebugFormat("[WORLD MAP]: Handle MapItem request {0} {1}", regionhandle, itemtype);
  390. lock (m_rootAgents)
  391. {
  392. if (!m_rootAgents.Contains(remoteClient.AgentId))
  393. return;
  394. }
  395. // local or remote request?
  396. if (regionhandle != 0 && regionhandle != m_scene.RegionInfo.RegionHandle)
  397. {
  398. // its Remote Map Item Request
  399. // ensures that the blockingqueue doesn't get borked if the GetAgents() timing changes.
  400. RequestMapItems("", remoteClient.AgentId, flags, EstateID, godlike, itemtype, regionhandle);
  401. return;
  402. }
  403. uint xstart = 0;
  404. uint ystart = 0;
  405. Util.RegionHandleToWorldLoc(m_scene.RegionInfo.RegionHandle, out xstart, out ystart);
  406. // its about this region...
  407. List<mapItemReply> mapitems = new List<mapItemReply>();
  408. mapItemReply mapitem = new mapItemReply();
  409. // viewers only ask for green dots to each region now
  410. // except at login with regionhandle 0
  411. // possible on some other rare ocasions
  412. // use previous hack of sending all items with the green dots
  413. bool adultRegion;
  414. if (regionhandle == 0)
  415. {
  416. switch (itemtype)
  417. {
  418. case (int)GridItemType.AgentLocations:
  419. // Service 6 right now (MAP_ITEM_AGENTS_LOCATION; green dots)
  420. int tc = Environment.TickCount;
  421. if (m_scene.GetRootAgentCount() <= 1) //own position is not sent
  422. {
  423. mapitem = new mapItemReply(
  424. xstart + 1,
  425. ystart + 1,
  426. UUID.Zero,
  427. Util.Md5Hash(m_scene.RegionInfo.RegionName + tc.ToString()),
  428. 0, 0);
  429. mapitems.Add(mapitem);
  430. }
  431. else
  432. {
  433. m_scene.ForEachRootScenePresence(delegate (ScenePresence sp)
  434. {
  435. // Don't send a green dot for yourself
  436. if (sp.UUID != remoteClient.AgentId)
  437. {
  438. if (sp.PresenceType == PresenceType.Npc && !m_showNPCs)
  439. return;
  440. mapitem = new mapItemReply(
  441. xstart + (uint)sp.AbsolutePosition.X,
  442. ystart + (uint)sp.AbsolutePosition.Y,
  443. UUID.Zero,
  444. Util.Md5Hash(m_scene.RegionInfo.RegionName + tc.ToString()),
  445. 1, 0);
  446. mapitems.Add(mapitem);
  447. }
  448. });
  449. }
  450. remoteClient.SendMapItemReply(mapitems.ToArray(), itemtype, flags);
  451. break;
  452. case (int)GridItemType.Telehub:
  453. // Service 1 (MAP_ITEM_TELEHUB)
  454. SceneObjectGroup sog = m_scene.GetSceneObjectGroup(m_scene.RegionInfo.RegionSettings.TelehubObject);
  455. if (sog != null)
  456. {
  457. mapitem = new mapItemReply(
  458. xstart + (uint)sog.AbsolutePosition.X,
  459. ystart + (uint)sog.AbsolutePosition.Y,
  460. UUID.Zero,
  461. sog.Name,
  462. 0, // color (not used)
  463. 0 // 0 = telehub / 1 = infohub
  464. );
  465. mapitems.Add(mapitem);
  466. remoteClient.SendMapItemReply(mapitems.ToArray(), itemtype, flags);
  467. }
  468. break;
  469. case (int)GridItemType.AdultLandForSale:
  470. case (int)GridItemType.LandForSale:
  471. // Service 7 (MAP_ITEM_LAND_FOR_SALE)
  472. adultRegion = m_scene.RegionInfo.RegionSettings.Maturity == 2;
  473. if (adultRegion)
  474. {
  475. if (itemtype == (int)GridItemType.LandForSale)
  476. break;
  477. }
  478. else
  479. {
  480. if (itemtype == (int)GridItemType.AdultLandForSale)
  481. break;
  482. }
  483. // Parcels
  484. ILandChannel landChannel = m_scene.LandChannel;
  485. List<ILandObject> parcels = landChannel.AllParcels();
  486. if ((parcels != null) && (parcels.Count >= 1))
  487. {
  488. foreach (ILandObject parcel_interface in parcels)
  489. {
  490. // Play it safe
  491. if (!(parcel_interface is LandObject))
  492. continue;
  493. LandObject land = (LandObject)parcel_interface;
  494. LandData parcel = land.LandData;
  495. // Show land for sale
  496. if ((parcel.Flags & (uint)ParcelFlags.ForSale) == (uint)ParcelFlags.ForSale)
  497. {
  498. Vector3 min = parcel.AABBMin;
  499. Vector3 max = parcel.AABBMax;
  500. float x = (min.X + max.X) / 2;
  501. float y = (min.Y + max.Y) / 2;
  502. mapitem = new mapItemReply(
  503. xstart + (uint)x,
  504. ystart + (uint)y,
  505. parcel.GlobalID,
  506. parcel.Name,
  507. parcel.Area,
  508. parcel.SalePrice
  509. );
  510. mapitems.Add(mapitem);
  511. }
  512. }
  513. }
  514. remoteClient.SendMapItemReply(mapitems.ToArray(), itemtype, flags);
  515. break;
  516. case (uint)GridItemType.PgEvent:
  517. case (uint)GridItemType.MatureEvent:
  518. case (uint)GridItemType.AdultEvent:
  519. case (uint)GridItemType.Classified:
  520. case (uint)GridItemType.Popular:
  521. // TODO
  522. // just dont not cry about them
  523. break;
  524. default:
  525. // unkown map item type
  526. m_log.DebugFormat("[WORLD MAP]: Unknown MapItem type {1}", itemtype);
  527. break;
  528. }
  529. }
  530. else
  531. {
  532. // send all items till we get a better fix
  533. // Service 6 right now (MAP_ITEM_AGENTS_LOCATION; green dots)
  534. int tc = Environment.TickCount;
  535. if (m_scene.GetRootAgentCount() <= 1) // own is not sent
  536. {
  537. mapitem = new mapItemReply(
  538. xstart + 1,
  539. ystart + 1,
  540. UUID.Zero,
  541. Util.Md5Hash(m_scene.RegionInfo.RegionName + tc.ToString()),
  542. 0, 0);
  543. mapitems.Add(mapitem);
  544. }
  545. else
  546. {
  547. m_scene.ForEachRootScenePresence(delegate (ScenePresence sp)
  548. {
  549. // Don't send a green dot for yourself
  550. if (sp.UUID != remoteClient.AgentId)
  551. {
  552. if (!m_showNPCs && sp.PresenceType == PresenceType.Npc)
  553. return;
  554. mapitem = new mapItemReply(
  555. xstart + (uint)sp.AbsolutePosition.X,
  556. ystart + (uint)sp.AbsolutePosition.Y,
  557. UUID.Zero,
  558. Util.Md5Hash(m_scene.RegionInfo.RegionName + tc.ToString()),
  559. 1, 0);
  560. mapitems.Add(mapitem);
  561. }
  562. });
  563. }
  564. remoteClient.SendMapItemReply(mapitems.ToArray(), 6, flags);
  565. mapitems.Clear();
  566. // Service 1 (MAP_ITEM_TELEHUB)
  567. SceneObjectGroup sog = m_scene.GetSceneObjectGroup(m_scene.RegionInfo.RegionSettings.TelehubObject);
  568. if (sog != null)
  569. {
  570. mapitem = new mapItemReply(
  571. xstart + (uint)sog.AbsolutePosition.X,
  572. ystart + (uint)sog.AbsolutePosition.Y,
  573. UUID.Zero,
  574. sog.Name,
  575. 0, // color (not used)
  576. 0 // 0 = telehub / 1 = infohub
  577. );
  578. mapitems.Add(mapitem);
  579. remoteClient.SendMapItemReply(mapitems.ToArray(), 1, flags);
  580. mapitems.Clear();
  581. }
  582. // Service 7 (MAP_ITEM_LAND_FOR_SALE)
  583. uint its = 7;
  584. if (m_scene.RegionInfo.RegionSettings.Maturity == 2)
  585. its = 10;
  586. // Parcels
  587. ILandChannel landChannel = m_scene.LandChannel;
  588. List<ILandObject> parcels = landChannel.AllParcels();
  589. if ((parcels != null) && (parcels.Count >= 1))
  590. {
  591. foreach (ILandObject parcel_interface in parcels)
  592. {
  593. // Play it safe
  594. if (!(parcel_interface is LandObject))
  595. continue;
  596. LandObject land = (LandObject)parcel_interface;
  597. LandData parcel = land.LandData;
  598. // Show land for sale
  599. if ((parcel.Flags & (uint)ParcelFlags.ForSale) == (uint)ParcelFlags.ForSale)
  600. {
  601. Vector3 min = parcel.AABBMin;
  602. Vector3 max = parcel.AABBMax;
  603. float x = (min.X + max.X) / 2;
  604. float y = (min.Y + max.Y) / 2;
  605. mapitem = new mapItemReply(
  606. xstart + (uint)x,
  607. ystart + (uint)y,
  608. parcel.GlobalID,
  609. parcel.Name,
  610. parcel.Area,
  611. parcel.SalePrice
  612. );
  613. mapitems.Add(mapitem);
  614. }
  615. }
  616. if(mapitems.Count >0)
  617. remoteClient.SendMapItemReply(mapitems.ToArray(), its, flags);
  618. mapitems.Clear();
  619. }
  620. }
  621. }
  622. private int nAsyncRequests = 0;
  623. /// <summary>
  624. /// Processing thread main() loop for doing remote mapitem requests
  625. /// </summary>
  626. public void process()
  627. {
  628. const int MAX_ASYNC_REQUESTS = 20;
  629. ScenePresence av = null;
  630. MapRequestState st = null;
  631. try
  632. {
  633. while (true)
  634. {
  635. av = null;
  636. st = null;
  637. requests.TryTake(out st, 4500);
  638. Watchdog.UpdateThread();
  639. if (st == null || st.agentID == UUID.Zero)
  640. continue;
  641. // end gracefully
  642. if (st.agentID == STOP_UUID)
  643. break;
  644. // agent gone?
  645. m_scene.TryGetScenePresence(st.agentID, out av);
  646. if (av == null || av.IsChildAgent || av.IsDeleted || av.IsInTransit)
  647. continue;
  648. // region unreachable?
  649. if (m_blacklistedregions.Contains(st.regionhandle))
  650. continue;
  651. bool dorequest = true;
  652. OSDMap responseMap = null;
  653. // check if we are already serving this region
  654. lock (m_cachedRegionMapItemsResponses)
  655. {
  656. if (m_cachedRegionMapItemsResponses.Contains(st.regionhandle))
  657. {
  658. m_cachedRegionMapItemsResponses.TryGetValue(st.regionhandle, out responseMap);
  659. dorequest = false;
  660. }
  661. else
  662. m_cachedRegionMapItemsResponses.Add(st.regionhandle, null, expireResponsesTime); // a bit more time for the access
  663. }
  664. if (dorequest)
  665. {
  666. // nothig for region, fire a request
  667. Interlocked.Increment(ref nAsyncRequests);
  668. MapRequestState rst = st;
  669. Util.FireAndForget(x =>
  670. {
  671. RequestMapItemsAsync(rst.agentID, rst.flags, rst.EstateID, rst.godlike, rst.itemtype, rst.regionhandle);
  672. });
  673. }
  674. else
  675. {
  676. // do we have the response?
  677. if (responseMap != null)
  678. {
  679. if(av!=null)
  680. {
  681. // this will mainly only send green dots now
  682. if (responseMap.ContainsKey(st.itemtype.ToString()))
  683. {
  684. List<mapItemReply> returnitems = new List<mapItemReply>();
  685. OSDArray itemarray = (OSDArray)responseMap[st.itemtype.ToString()];
  686. for (int i = 0; i < itemarray.Count; i++)
  687. {
  688. OSDMap mapitem = (OSDMap)itemarray[i];
  689. mapItemReply mi = new mapItemReply();
  690. mi.x = (uint)mapitem["X"].AsInteger();
  691. mi.y = (uint)mapitem["Y"].AsInteger();
  692. mi.id = mapitem["ID"].AsUUID();
  693. mi.Extra = mapitem["Extra"].AsInteger();
  694. mi.Extra2 = mapitem["Extra2"].AsInteger();
  695. mi.name = mapitem["Name"].AsString();
  696. returnitems.Add(mi);
  697. }
  698. av.ControllingClient.SendMapItemReply(returnitems.ToArray(), st.itemtype, st.flags & 0xffff);
  699. }
  700. }
  701. }
  702. else
  703. {
  704. // request still beeing processed, enqueue it back
  705. requests.Add(st);
  706. if (requests.Count < 3)
  707. Thread.Sleep(100);
  708. }
  709. }
  710. while (nAsyncRequests >= MAX_ASYNC_REQUESTS) // hit the break
  711. {
  712. Thread.Sleep(100);
  713. Watchdog.UpdateThread();
  714. }
  715. }
  716. }
  717. catch (Exception e)
  718. {
  719. m_log.ErrorFormat("[WORLD MAP]: Map item request thread terminated abnormally with exception {0}", e);
  720. }
  721. threadrunning = false;
  722. Watchdog.RemoveThread();
  723. }
  724. /// <summary>
  725. /// Enqueue the MapItem request for remote processing
  726. /// </summary>
  727. /// <param name="httpserver">blank string, we discover this in the process</param>
  728. /// <param name="id">Agent ID that we are making this request on behalf</param>
  729. /// <param name="flags">passed in from packet</param>
  730. /// <param name="EstateID">passed in from packet</param>
  731. /// <param name="godlike">passed in from packet</param>
  732. /// <param name="itemtype">passed in from packet</param>
  733. /// <param name="regionhandle">Region we're looking up</param>
  734. public void RequestMapItems(string httpserver, UUID id, uint flags,
  735. uint EstateID, bool godlike, uint itemtype, ulong regionhandle)
  736. {
  737. MapRequestState st = new MapRequestState();
  738. st.agentID = id;
  739. st.flags = flags;
  740. st.EstateID = EstateID;
  741. st.godlike = godlike;
  742. st.itemtype = itemtype;
  743. st.regionhandle = regionhandle;
  744. requests.Add(st);
  745. }
  746. uint[] itemTypesForcedSend = new uint[] { 6, 1, 7, 10 }; // green dots, infohub, land sells
  747. /// <summary>
  748. /// Does the actual remote mapitem request
  749. /// This should be called from an asynchronous thread
  750. /// Request failures get blacklisted until region restart so we don't
  751. /// continue to spend resources trying to contact regions that are down.
  752. /// </summary>
  753. /// <param name="httpserver">blank string, we discover this in the process</param>
  754. /// <param name="id">Agent ID that we are making this request on behalf</param>
  755. /// <param name="flags">passed in from packet</param>
  756. /// <param name="EstateID">passed in from packet</param>
  757. /// <param name="godlike">passed in from packet</param>
  758. /// <param name="itemtype">passed in from packet</param>
  759. /// <param name="regionhandle">Region we're looking up</param>
  760. /// <returns></returns>
  761. private void RequestMapItemsAsync(UUID id, uint flags,
  762. uint EstateID, bool godlike, uint itemtype, ulong regionhandle)
  763. {
  764. // m_log.DebugFormat("[WORLDMAP]: RequestMapItemsAsync; region handle: {0} {1}", regionhandle, itemtype);
  765. string httpserver = "";
  766. bool blacklisted = false;
  767. lock (m_blacklistedregions)
  768. blacklisted = m_blacklistedregions.Contains(regionhandle);
  769. if (blacklisted)
  770. {
  771. Interlocked.Decrement(ref nAsyncRequests);
  772. return;
  773. }
  774. UUID requestID = UUID.Random();
  775. lock (m_cachedRegionMapItemsAddress)
  776. m_cachedRegionMapItemsAddress.TryGetValue(regionhandle, out httpserver);
  777. if (httpserver == null || httpserver.Length == 0)
  778. {
  779. uint x = 0, y = 0;
  780. Util.RegionHandleToWorldLoc(regionhandle, out x, out y);
  781. GridRegion mreg = m_scene.GridService.GetRegionByPosition(m_scene.RegionInfo.ScopeID, (int)x, (int)y);
  782. if (mreg != null)
  783. {
  784. httpserver = mreg.ServerURI + "MAP/MapItems/" + regionhandle.ToString();
  785. lock (m_cachedRegionMapItemsAddress)
  786. m_cachedRegionMapItemsAddress.AddOrUpdate(regionhandle, httpserver, 2.0 * expireBlackListTime);
  787. }
  788. }
  789. lock (m_blacklistedurls)
  790. {
  791. if (httpserver == null || httpserver.Length == 0 || m_blacklistedurls.Contains(httpserver))
  792. {
  793. // Can't find the http server or its blocked
  794. lock (m_blacklistedregions)
  795. m_blacklistedregions.AddOrUpdate(regionhandle, 0, expireBlackListTime);
  796. Interlocked.Decrement(ref nAsyncRequests);
  797. return;
  798. }
  799. }
  800. WebRequest mapitemsrequest = null;
  801. try
  802. {
  803. mapitemsrequest = WebRequest.Create(httpserver);
  804. }
  805. catch (Exception e)
  806. {
  807. m_log.DebugFormat("[WORLD MAP]: Access to {0} failed with {1}", httpserver, e);
  808. Interlocked.Decrement(ref nAsyncRequests);
  809. return;
  810. }
  811. mapitemsrequest.Method = "POST";
  812. mapitemsrequest.ContentType = "application/xml+llsd";
  813. OSDMap RAMap = new OSDMap();
  814. // string RAMapString = RAMap.ToString();
  815. OSD LLSDofRAMap = RAMap; // RENAME if this works
  816. byte[] buffer = OSDParser.SerializeLLSDXmlBytes(LLSDofRAMap);
  817. OSDMap responseMap = new OSDMap();
  818. try
  819. { // send the Post
  820. mapitemsrequest.ContentLength = buffer.Length; //Count bytes to send
  821. using (Stream os = mapitemsrequest.GetRequestStream())
  822. os.Write(buffer, 0, buffer.Length); //Send it
  823. //m_log.DebugFormat("[WORLD MAP]: Getting MapItems from {0}", httpserver);
  824. }
  825. catch (WebException ex)
  826. {
  827. m_log.WarnFormat("[WORLD MAP]: Bad send on GetMapItems {0}", ex.Message);
  828. m_log.WarnFormat("[WORLD MAP]: Blacklisted url {0}", httpserver);
  829. lock (m_blacklistedurls)
  830. m_blacklistedurls.AddOrUpdate(httpserver, 0, expireBlackListTime);
  831. lock (m_blacklistedregions)
  832. m_blacklistedregions.AddOrUpdate(regionhandle, 0, expireBlackListTime);
  833. Interlocked.Decrement(ref nAsyncRequests);
  834. return;
  835. }
  836. catch
  837. {
  838. m_log.DebugFormat("[WORLD MAP]: RequestMapItems failed for {0}", httpserver);
  839. Interlocked.Decrement(ref nAsyncRequests);
  840. return;
  841. }
  842. string response_mapItems_reply = null;
  843. { // get the response
  844. try
  845. {
  846. using (WebResponse webResponse = mapitemsrequest.GetResponse())
  847. {
  848. if (webResponse != null)
  849. {
  850. using (StreamReader sr = new StreamReader(webResponse.GetResponseStream()))
  851. {
  852. response_mapItems_reply = sr.ReadToEnd().Trim();
  853. }
  854. }
  855. else
  856. {
  857. Interlocked.Decrement(ref nAsyncRequests);
  858. return;
  859. }
  860. }
  861. }
  862. catch (WebException)
  863. {
  864. lock (m_blacklistedurls)
  865. m_blacklistedurls.AddOrUpdate(httpserver, 0, expireBlackListTime);
  866. lock (m_blacklistedregions)
  867. m_blacklistedregions.AddOrUpdate(regionhandle, 0, expireBlackListTime);
  868. m_log.WarnFormat("[WORLD MAP]: Blacklisted url {0}", httpserver);
  869. Interlocked.Decrement(ref nAsyncRequests);
  870. return;
  871. }
  872. catch
  873. {
  874. m_log.DebugFormat("[WORLD MAP]: RequestMapItems failed for {0}", httpserver);
  875. lock (m_blacklistedregions)
  876. m_blacklistedregions.AddOrUpdate(regionhandle, 0, expireBlackListTime);
  877. Interlocked.Decrement(ref nAsyncRequests);
  878. return;
  879. }
  880. try
  881. {
  882. responseMap = (OSDMap)OSDParser.DeserializeLLSDXml(response_mapItems_reply);
  883. }
  884. catch (Exception ex)
  885. {
  886. m_log.InfoFormat("[WORLD MAP]: exception on parse of RequestMapItems reply from {0}: {1}", httpserver, ex.Message);
  887. lock (m_blacklistedregions)
  888. m_blacklistedregions.AddOrUpdate(regionhandle, 0, expireBlackListTime);
  889. Interlocked.Decrement(ref nAsyncRequests);
  890. return;
  891. }
  892. }
  893. // cache the response that may include other valid items
  894. lock (m_cachedRegionMapItemsResponses)
  895. m_cachedRegionMapItemsResponses.AddOrUpdate(regionhandle, responseMap, expireResponsesTime);
  896. flags &= 0xffff;
  897. if (id != UUID.Zero)
  898. {
  899. ScenePresence av = null;
  900. m_scene.TryGetScenePresence(id, out av);
  901. if (av != null && !av.IsChildAgent && !av.IsDeleted && !av.IsInTransit)
  902. {
  903. // send all the items or viewers will never ask for them, except green dots
  904. foreach (uint itfs in itemTypesForcedSend)
  905. {
  906. if (responseMap.ContainsKey(itfs.ToString()))
  907. {
  908. List<mapItemReply> returnitems = new List<mapItemReply>();
  909. // OSDArray itemarray = (OSDArray)responseMap[itemtype.ToString()];
  910. OSDArray itemarray = (OSDArray)responseMap[itfs.ToString()];
  911. for (int i = 0; i < itemarray.Count; i++)
  912. {
  913. OSDMap mapitem = (OSDMap)itemarray[i];
  914. mapItemReply mi = new mapItemReply();
  915. mi.x = (uint)mapitem["X"].AsInteger();
  916. mi.y = (uint)mapitem["Y"].AsInteger();
  917. mi.id = mapitem["ID"].AsUUID();
  918. mi.Extra = mapitem["Extra"].AsInteger();
  919. mi.Extra2 = mapitem["Extra2"].AsInteger();
  920. mi.name = mapitem["Name"].AsString();
  921. returnitems.Add(mi);
  922. }
  923. // av.ControllingClient.SendMapItemReply(returnitems.ToArray(), itemtype, flags);
  924. av.ControllingClient.SendMapItemReply(returnitems.ToArray(), itfs, flags);
  925. }
  926. }
  927. }
  928. }
  929. Interlocked.Decrement(ref nAsyncRequests);
  930. }
  931. /// <summary>
  932. /// Requests map blocks in area of minX, maxX, minY, MaxY in world cordinates
  933. /// </summary>
  934. /// <param name="minX"></param>
  935. /// <param name="minY"></param>
  936. /// <param name="maxX"></param>
  937. /// <param name="maxY"></param>
  938. public void RequestMapBlocks(IClientAPI remoteClient, int minX, int minY, int maxX, int maxY, uint flag)
  939. {
  940. // m_log.DebugFormat("[WoldMapModule] RequestMapBlocks {0}={1}={2}={3} {4}", minX, minY, maxX, maxY, flag);
  941. GetAndSendBlocks(remoteClient, minX, minY, maxX, maxY, flag);
  942. }
  943. private const double SPAMBLOCKTIMEms = 300000; // 5 minutes
  944. private Dictionary<UUID,double> spamBlocked = new Dictionary<UUID,double>();
  945. protected virtual List<MapBlockData> GetAndSendBlocks(IClientAPI remoteClient, int minX, int minY, int maxX, int maxY, uint flag)
  946. {
  947. // anti spam because of FireStorm 4.7.7 absurd request repeat rates
  948. // possible others
  949. double now = Util.GetTimeStampMS();
  950. UUID agentID = remoteClient.AgentId;
  951. lock (m_mapBlockRequestEvent)
  952. {
  953. if(spamBlocked.ContainsKey(agentID))
  954. {
  955. if(spamBlocked[agentID] < now &&
  956. (!m_mapBlockRequests.ContainsKey(agentID) ||
  957. m_mapBlockRequests[agentID].Count == 0 ))
  958. {
  959. spamBlocked.Remove(agentID);
  960. m_log.DebugFormat("[WoldMapModule] RequestMapBlocks release spammer {0}", agentID);
  961. }
  962. else
  963. return new List<MapBlockData>();
  964. }
  965. else
  966. {
  967. // ugly slow expire spammers
  968. if(spamBlocked.Count > 0)
  969. {
  970. UUID k = UUID.Zero;
  971. bool expireone = false;
  972. foreach(UUID k2 in spamBlocked.Keys)
  973. {
  974. if(spamBlocked[k2] < now &&
  975. (!m_mapBlockRequests.ContainsKey(k2) ||
  976. m_mapBlockRequests[k2].Count == 0 ))
  977. {
  978. m_log.DebugFormat("[WoldMapModule] RequestMapBlocks release spammer {0}", k2);
  979. k = k2;
  980. expireone = true;
  981. }
  982. break; // doing one at a time
  983. }
  984. if(expireone)
  985. spamBlocked.Remove(k);
  986. }
  987. }
  988. // m_log.DebugFormat("[WoldMapModule] RequestMapBlocks {0}={1}={2}={3} {4}", minX, minY, maxX, maxY, flag);
  989. MapBlockRequestData req = new MapBlockRequestData();
  990. req.client = remoteClient;
  991. req.minX = minX;
  992. req.maxX = maxX;
  993. req.minY = minY;
  994. req.maxY = maxY;
  995. req.flags = flag;
  996. if (!m_mapBlockRequests.ContainsKey(agentID))
  997. m_mapBlockRequests[agentID] = new Queue<MapBlockRequestData>();
  998. if(m_mapBlockRequests[agentID].Count < 150 )
  999. m_mapBlockRequests[agentID].Enqueue(req);
  1000. else
  1001. {
  1002. spamBlocked[agentID] = now + SPAMBLOCKTIMEms;
  1003. m_log.DebugFormat("[WoldMapModule] RequestMapBlocks blocking spammer {0} for {1} s",agentID, SPAMBLOCKTIMEms/1000.0);
  1004. }
  1005. m_mapBlockRequestEvent.Set();
  1006. }
  1007. return new List<MapBlockData>();
  1008. }
  1009. protected void MapBlockSendThread()
  1010. {
  1011. List<MapBlockRequestData> thisRunData = new List<MapBlockRequestData>();
  1012. while (true)
  1013. {
  1014. while(!m_mapBlockRequestEvent.WaitOne(4900))
  1015. {
  1016. Watchdog.UpdateThread();
  1017. if(m_scene == null)
  1018. return;
  1019. }
  1020. Watchdog.UpdateThread();
  1021. lock (m_mapBlockRequestEvent)
  1022. {
  1023. int total = 0;
  1024. foreach (Queue<MapBlockRequestData> q in m_mapBlockRequests.Values)
  1025. {
  1026. if (q.Count > 0)
  1027. thisRunData.Add(q.Dequeue());
  1028. total += q.Count;
  1029. }
  1030. if (total == 0)
  1031. m_mapBlockRequestEvent.Reset();
  1032. }
  1033. if(thisRunData.Count > 0)
  1034. {
  1035. foreach (MapBlockRequestData req in thisRunData)
  1036. {
  1037. // Null client stops thread
  1038. if (req.client == null)
  1039. return;
  1040. GetAndSendBlocksInternal(req.client, req.minX, req.minY, req.maxX, req.maxY, req.flags);
  1041. Watchdog.UpdateThread();
  1042. }
  1043. thisRunData.Clear();
  1044. }
  1045. Thread.Sleep(50);
  1046. }
  1047. }
  1048. protected virtual List<MapBlockData> GetAndSendBlocksInternal(IClientAPI remoteClient, int minX, int minY, int maxX, int maxY, uint flag)
  1049. {
  1050. List<MapBlockData> allBlocks = new List<MapBlockData>();
  1051. List<MapBlockData> mapBlocks = new List<MapBlockData>();
  1052. List<GridRegion> regions = m_scene.GridService.GetRegionRange(m_scene.RegionInfo.ScopeID,
  1053. minX * (int)Constants.RegionSize,
  1054. maxX * (int)Constants.RegionSize,
  1055. minY * (int)Constants.RegionSize,
  1056. maxY * (int)Constants.RegionSize);
  1057. // only send a negative answer for a single region request
  1058. // corresponding to a click on the map. Current viewers
  1059. // keep displaying "loading.." without this
  1060. if (regions.Count == 0 && (flag & 0x10000) != 0 && minX == maxX && minY == maxY)
  1061. {
  1062. MapBlockData block = new MapBlockData();
  1063. block.X = (ushort)minX;
  1064. block.Y = (ushort)minY;
  1065. block.MapImageId = UUID.Zero;
  1066. block.Access = (byte)SimAccess.NonExistent;
  1067. allBlocks.Add(block);
  1068. mapBlocks.Add(block);
  1069. remoteClient.SendMapBlock(mapBlocks, flag & 0xffff);
  1070. return allBlocks;
  1071. }
  1072. flag &= 0xffff;
  1073. foreach (GridRegion r in regions)
  1074. {
  1075. if (r == null)
  1076. continue;
  1077. MapBlockData block = new MapBlockData();
  1078. MapBlockFromGridRegion(block, r, flag);
  1079. mapBlocks.Add(block);
  1080. allBlocks.Add(block);
  1081. if (mapBlocks.Count >= 10)
  1082. {
  1083. remoteClient.SendMapBlock(mapBlocks, flag);
  1084. mapBlocks.Clear();
  1085. Thread.Sleep(50);
  1086. }
  1087. }
  1088. if (mapBlocks.Count > 0)
  1089. remoteClient.SendMapBlock(mapBlocks, flag);
  1090. return allBlocks;
  1091. }
  1092. public void MapBlockFromGridRegion(MapBlockData block, GridRegion r, uint flag)
  1093. {
  1094. if (r == null)
  1095. {
  1096. // we should not get here ??
  1097. // block.Access = (byte)SimAccess.Down; this is for a grid reply on r
  1098. block.Access = (byte)SimAccess.NonExistent;
  1099. block.MapImageId = UUID.Zero;
  1100. return;
  1101. }
  1102. block.Access = r.Access;
  1103. switch (flag)
  1104. {
  1105. case 0:
  1106. block.MapImageId = r.TerrainImage;
  1107. break;
  1108. case 2:
  1109. block.MapImageId = r.ParcelImage;
  1110. break;
  1111. default:
  1112. block.MapImageId = UUID.Zero;
  1113. break;
  1114. }
  1115. block.Name = r.RegionName;
  1116. block.X = (ushort)(r.RegionLocX / Constants.RegionSize);
  1117. block.Y = (ushort)(r.RegionLocY / Constants.RegionSize);
  1118. block.SizeX = (ushort)r.RegionSizeX;
  1119. block.SizeY = (ushort)r.RegionSizeY;
  1120. }
  1121. public Hashtable OnHTTPThrottled(Hashtable keysvals)
  1122. {
  1123. Hashtable reply = new Hashtable();
  1124. int statuscode = 500;
  1125. reply["str_response_string"] = "";
  1126. reply["int_response_code"] = statuscode;
  1127. reply["content_type"] = "text/plain";
  1128. return reply;
  1129. }
  1130. public Hashtable OnHTTPGetMapImage(Hashtable keysvals)
  1131. {
  1132. Hashtable reply = new Hashtable();
  1133. int statuscode = 200;
  1134. byte[] jpeg = new byte[0];
  1135. if (m_scene.RegionInfo.RegionSettings.TerrainImageID != UUID.Zero)
  1136. {
  1137. m_log.Debug("[WORLD MAP]: Sending map image jpeg");
  1138. if (myMapImageJPEG.Length == 0)
  1139. {
  1140. MemoryStream imgstream = null;
  1141. Bitmap mapTexture = new Bitmap(1, 1);
  1142. ManagedImage managedImage;
  1143. Image image = (Image)mapTexture;
  1144. try
  1145. {
  1146. // Taking our jpeg2000 data, decoding it, then saving it to a byte array with regular jpeg data
  1147. imgstream = new MemoryStream();
  1148. // non-async because we know we have the asset immediately.
  1149. AssetBase mapasset = m_scene.AssetService.Get(m_scene.RegionInfo.RegionSettings.TerrainImageID.ToString());
  1150. // Decode image to System.Drawing.Image
  1151. if (OpenJPEG.DecodeToImage(mapasset.Data, out managedImage, out image))
  1152. {
  1153. // Save to bitmap
  1154. mapTexture = new Bitmap(image);
  1155. EncoderParameters myEncoderParameters = new EncoderParameters();
  1156. myEncoderParameters.Param[0] = new EncoderParameter(Encoder.Quality, 95L);
  1157. // Save bitmap to stream
  1158. mapTexture.Save(imgstream, GetEncoderInfo("image/jpeg"), myEncoderParameters);
  1159. // Write the stream to a byte array for output
  1160. jpeg = imgstream.ToArray();
  1161. myMapImageJPEG = jpeg;
  1162. }
  1163. }
  1164. catch (Exception)
  1165. {
  1166. // Dummy!
  1167. m_log.Warn("[WORLD MAP]: Unable to generate Map image");
  1168. }
  1169. finally
  1170. {
  1171. // Reclaim memory, these are unmanaged resources
  1172. // If we encountered an exception, one or more of these will be null
  1173. if (mapTexture != null)
  1174. mapTexture.Dispose();
  1175. if (image != null)
  1176. image.Dispose();
  1177. if (imgstream != null)
  1178. imgstream.Dispose();
  1179. }
  1180. }
  1181. else
  1182. {
  1183. // Use cached version so we don't have to loose our mind
  1184. jpeg = myMapImageJPEG;
  1185. }
  1186. }
  1187. reply["str_response_string"] = Convert.ToBase64String(jpeg);
  1188. reply["int_response_code"] = statuscode;
  1189. reply["content_type"] = "image/jpeg";
  1190. return reply;
  1191. }
  1192. // From msdn
  1193. private static ImageCodecInfo GetEncoderInfo(String mimeType)
  1194. {
  1195. ImageCodecInfo[] encoders;
  1196. encoders = ImageCodecInfo.GetImageEncoders();
  1197. for (int j = 0; j < encoders.Length; ++j)
  1198. {
  1199. if (encoders[j].MimeType == mimeType)
  1200. return encoders[j];
  1201. }
  1202. return null;
  1203. }
  1204. /// <summary>
  1205. /// Export the world map
  1206. /// </summary>
  1207. /// <param name="fileName"></param>
  1208. public void HandleExportWorldMapConsoleCommand(string module, string[] cmdparams)
  1209. {
  1210. if (m_scene.ConsoleScene() == null)
  1211. {
  1212. // FIXME: If console region is root then this will be printed by every module. Currently, there is no
  1213. // way to prevent this, short of making the entire module shared (which is complete overkill).
  1214. // One possibility is to return a bool to signal whether the module has completely handled the command
  1215. m_log.InfoFormat("[WORLD MAP]: Please change to a specific region in order to export its world map");
  1216. return;
  1217. }
  1218. if (m_scene.ConsoleScene() != m_scene)
  1219. return;
  1220. string exportPath;
  1221. if (cmdparams.Length > 1)
  1222. exportPath = cmdparams[1];
  1223. else
  1224. exportPath = DEFAULT_WORLD_MAP_EXPORT_PATH;
  1225. m_log.InfoFormat(
  1226. "[WORLD MAP]: Exporting world map for {0} to {1}", m_scene.RegionInfo.RegionName, exportPath);
  1227. // assumed this is 1m less than next grid line
  1228. int regionsView = (int)m_scene.MaxRegionViewDistance;
  1229. string regionName = m_scene.RegionInfo.RegionName;
  1230. ulong regionHandle = m_scene.RegionInfo.RegionHandle;
  1231. int regionSizeX = (int)m_scene.RegionInfo.RegionSizeX;
  1232. int regionSizeY = (int)m_scene.RegionInfo.RegionSizeY;
  1233. int regionX = (int)m_scene.RegionInfo.WorldLocX;
  1234. int regionY = (int)m_scene.RegionInfo.WorldLocY;
  1235. int startX = regionX - regionsView;
  1236. int startY = regionY - regionsView;
  1237. int endX = regionX + regionSizeX + regionsView;
  1238. int endY = regionY + regionSizeY + regionsView;
  1239. int spanX = endX - startX + 2;
  1240. int spanY = endY - startY + 2;
  1241. Bitmap mapTexture = new Bitmap(spanX, spanY);
  1242. ImageAttributes gatrib = new ImageAttributes();
  1243. gatrib.SetWrapMode(System.Drawing.Drawing2D.WrapMode.TileFlipXY);
  1244. Graphics g = Graphics.FromImage(mapTexture);
  1245. g.CompositingQuality = System.Drawing.Drawing2D.CompositingQuality.HighQuality;
  1246. g.InterpolationMode = System.Drawing.Drawing2D.InterpolationMode.HighQualityBicubic;
  1247. g.SmoothingMode = System.Drawing.Drawing2D.SmoothingMode.HighQuality;
  1248. g.PixelOffsetMode = System.Drawing.Drawing2D.PixelOffsetMode.None;
  1249. SolidBrush sea = new SolidBrush(Color.DarkBlue);
  1250. g.FillRectangle(sea, 0, 0, spanX, spanY);
  1251. sea.Dispose();
  1252. Font drawFont = new Font("Arial", 32);
  1253. SolidBrush drawBrush = new SolidBrush(Color.White);
  1254. List<GridRegion> regions = m_scene.GridService.GetRegionRange(m_scene.RegionInfo.ScopeID,
  1255. startX, startY, endX, endY);
  1256. startX--;
  1257. startY--;
  1258. bool doneLocal = false;
  1259. string filename = "MAP-" + m_scene.RegionInfo.RegionID.ToString() + ".png";
  1260. try
  1261. {
  1262. using(Image localMap = Bitmap.FromFile(filename))
  1263. {
  1264. int x = regionX - startX;
  1265. int y = regionY - startY;
  1266. int sx = regionSizeX;
  1267. int sy = regionSizeY;
  1268. // y origin is top
  1269. g.DrawImage(localMap,new Rectangle(x, spanY - y - sy, sx, sy),
  1270. 0, 0, localMap.Width, localMap.Height, GraphicsUnit.Pixel, gatrib);
  1271. if(m_exportPrintRegionName)
  1272. {
  1273. SizeF stringSize = g.MeasureString(regionName, drawFont);
  1274. g.DrawString(regionName, drawFont, drawBrush, x + 30, spanY - y - 30 - stringSize.Height);
  1275. }
  1276. }
  1277. doneLocal = true;
  1278. }
  1279. catch {}
  1280. if(regions.Count > 0)
  1281. {
  1282. ManagedImage managedImage = null;
  1283. Image image = null;
  1284. foreach(GridRegion r in regions)
  1285. {
  1286. if(r.TerrainImage == UUID.Zero)
  1287. continue;
  1288. if(doneLocal && r.RegionHandle == regionHandle)
  1289. continue;
  1290. AssetBase texAsset = m_scene.AssetService.Get(r.TerrainImage.ToString());
  1291. if(texAsset == null)
  1292. continue;
  1293. if(OpenJPEG.DecodeToImage(texAsset.Data, out managedImage, out image))
  1294. {
  1295. int x = r.RegionLocX - startX;
  1296. int y = r.RegionLocY - startY;
  1297. int sx = r.RegionSizeX;
  1298. int sy = r.RegionSizeY;
  1299. // y origin is top
  1300. g.DrawImage(image,new Rectangle(x, spanY - y - sy, sx, sy),
  1301. 0, 0, image.Width, image.Height, GraphicsUnit.Pixel, gatrib);
  1302. if(m_exportPrintRegionName && r.RegionHandle == regionHandle)
  1303. {
  1304. SizeF stringSize = g.MeasureString(r.RegionName, drawFont);
  1305. g.DrawString(r.RegionName, drawFont, drawBrush, x + 30, spanY - y - 30 - stringSize.Height);
  1306. }
  1307. }
  1308. }
  1309. if(image != null)
  1310. image.Dispose();
  1311. }
  1312. if(m_exportPrintScale)
  1313. {
  1314. String drawString = string.Format("{0}m x {1}m", spanX, spanY);
  1315. g.DrawString(drawString, drawFont, drawBrush, 30, 30);
  1316. }
  1317. drawBrush.Dispose();
  1318. drawFont.Dispose();
  1319. gatrib.Dispose();
  1320. g.Dispose();
  1321. mapTexture.Save(exportPath, ImageFormat.Jpeg);
  1322. mapTexture.Dispose();
  1323. m_log.InfoFormat(
  1324. "[WORLD MAP]: Successfully exported world map for {0} to {1}",
  1325. m_scene.RegionInfo.RegionName, exportPath);
  1326. }
  1327. public void HandleGenerateMapConsoleCommand(string module, string[] cmdparams)
  1328. {
  1329. Scene consoleScene = m_scene.ConsoleScene();
  1330. if (consoleScene != null && consoleScene != m_scene)
  1331. return;
  1332. m_scene.RegenerateMaptileAndReregister(this, null);
  1333. }
  1334. public OSD HandleRemoteMapItemRequest(string path, OSD request, string endpoint)
  1335. {
  1336. uint xstart = 0;
  1337. uint ystart = 0;
  1338. Util.RegionHandleToWorldLoc(m_scene.RegionInfo.RegionHandle, out xstart, out ystart);
  1339. // Service 6 (MAP_ITEM_AGENTS_LOCATION; green dots)
  1340. OSDMap responsemap = new OSDMap();
  1341. int tc = Environment.TickCount;
  1342. if (m_scene.GetRootAgentCount() == 0)
  1343. {
  1344. OSDMap responsemapdata = new OSDMap();
  1345. responsemapdata["X"] = OSD.FromInteger((int)(xstart + 1));
  1346. responsemapdata["Y"] = OSD.FromInteger((int)(ystart + 1));
  1347. responsemapdata["ID"] = OSD.FromUUID(UUID.Zero);
  1348. responsemapdata["Name"] = OSD.FromString(Util.Md5Hash(m_scene.RegionInfo.RegionName + tc.ToString()));
  1349. responsemapdata["Extra"] = OSD.FromInteger(0);
  1350. responsemapdata["Extra2"] = OSD.FromInteger(0);
  1351. OSDArray responsearr = new OSDArray();
  1352. responsearr.Add(responsemapdata);
  1353. responsemap["6"] = responsearr;
  1354. }
  1355. else
  1356. {
  1357. OSDArray responsearr = new OSDArray(); // Don't preallocate. MT (m_scene.GetRootAgentCount());
  1358. m_scene.ForEachRootScenePresence(delegate (ScenePresence sp)
  1359. {
  1360. if (!m_showNPCs && sp.IsNPC)
  1361. return;
  1362. OSDMap responsemapdata = new OSDMap();
  1363. responsemapdata["X"] = OSD.FromInteger((int)(xstart + sp.AbsolutePosition.X));
  1364. responsemapdata["Y"] = OSD.FromInteger((int)(ystart + sp.AbsolutePosition.Y));
  1365. responsemapdata["ID"] = OSD.FromUUID(UUID.Zero);
  1366. responsemapdata["Name"] = OSD.FromString(Util.Md5Hash(m_scene.RegionInfo.RegionName + tc.ToString()));
  1367. responsemapdata["Extra"] = OSD.FromInteger(1);
  1368. responsemapdata["Extra2"] = OSD.FromInteger(0);
  1369. responsearr.Add(responsemapdata);
  1370. });
  1371. responsemap["6"] = responsearr;
  1372. }
  1373. // Service 7/10 (MAP_ITEM_LAND_FOR_SALE/ADULT)
  1374. ILandChannel landChannel = m_scene.LandChannel;
  1375. List<ILandObject> parcels = landChannel.AllParcels();
  1376. if ((parcels != null) && (parcels.Count >= 0))
  1377. {
  1378. OSDArray responsearr = new OSDArray(parcels.Count);
  1379. foreach (ILandObject parcel_interface in parcels)
  1380. {
  1381. // Play it safe
  1382. if (!(parcel_interface is LandObject))
  1383. continue;
  1384. LandObject land = (LandObject)parcel_interface;
  1385. LandData parcel = land.LandData;
  1386. // Show land for sale
  1387. if ((parcel.Flags & (uint)ParcelFlags.ForSale) == (uint)ParcelFlags.ForSale)
  1388. {
  1389. Vector3 min = parcel.AABBMin;
  1390. Vector3 max = parcel.AABBMax;
  1391. float x = (min.X + max.X) / 2;
  1392. float y = (min.Y + max.Y) / 2;
  1393. OSDMap responsemapdata = new OSDMap();
  1394. responsemapdata["X"] = OSD.FromInteger((int)(xstart + x));
  1395. responsemapdata["Y"] = OSD.FromInteger((int)(ystart + y));
  1396. // responsemapdata["Z"] = OSD.FromInteger((int)m_scene.GetGroundHeight(x,y));
  1397. responsemapdata["ID"] = OSD.FromUUID(parcel.GlobalID);
  1398. responsemapdata["Name"] = OSD.FromString(parcel.Name);
  1399. responsemapdata["Extra"] = OSD.FromInteger(parcel.Area);
  1400. responsemapdata["Extra2"] = OSD.FromInteger(parcel.SalePrice);
  1401. responsearr.Add(responsemapdata);
  1402. }
  1403. }
  1404. if(responsearr.Count > 0)
  1405. {
  1406. if(m_scene.RegionInfo.RegionSettings.Maturity == 2)
  1407. responsemap["10"] = responsearr;
  1408. else
  1409. responsemap["7"] = responsearr;
  1410. }
  1411. }
  1412. if (m_scene.RegionInfo.RegionSettings.TelehubObject != UUID.Zero)
  1413. {
  1414. SceneObjectGroup sog = m_scene.GetSceneObjectGroup(m_scene.RegionInfo.RegionSettings.TelehubObject);
  1415. if (sog != null)
  1416. {
  1417. OSDArray responsearr = new OSDArray();
  1418. OSDMap responsemapdata = new OSDMap();
  1419. responsemapdata["X"] = OSD.FromInteger((int)(xstart + sog.AbsolutePosition.X));
  1420. responsemapdata["Y"] = OSD.FromInteger((int)(ystart + sog.AbsolutePosition.Y));
  1421. // responsemapdata["Z"] = OSD.FromInteger((int)m_scene.GetGroundHeight(x,y));
  1422. responsemapdata["ID"] = OSD.FromUUID(sog.UUID);
  1423. responsemapdata["Name"] = OSD.FromString(sog.Name);
  1424. responsemapdata["Extra"] = OSD.FromInteger(0); // color (unused)
  1425. responsemapdata["Extra2"] = OSD.FromInteger(0); // 0 = telehub / 1 = infohub
  1426. responsearr.Add(responsemapdata);
  1427. responsemap["1"] = responsearr;
  1428. }
  1429. }
  1430. return responsemap;
  1431. }
  1432. public void GenerateMaptile()
  1433. {
  1434. // Cannot create a map for a nonexistent heightmap
  1435. if (m_scene.Heightmap == null)
  1436. return;
  1437. if (m_mapImageGenerator == null)
  1438. {
  1439. Console.WriteLine("No map image generator available for {0}", m_scene.Name);
  1440. return;
  1441. }
  1442. m_log.DebugFormat("[WORLD MAP]: Generating map image for {0}", m_scene.Name);
  1443. using (Bitmap mapbmp = m_mapImageGenerator.CreateMapTile())
  1444. {
  1445. GenerateMaptile(mapbmp);
  1446. if (m_mapImageServiceModule != null)
  1447. m_mapImageServiceModule.UploadMapTile(m_scene, mapbmp);
  1448. }
  1449. }
  1450. private void GenerateMaptile(Bitmap mapbmp)
  1451. {
  1452. bool needRegionSave = false;
  1453. // remove old assets
  1454. UUID lastID = m_scene.RegionInfo.RegionSettings.TerrainImageID;
  1455. if (lastID != UUID.Zero)
  1456. {
  1457. m_scene.AssetService.Delete(lastID.ToString());
  1458. m_scene.RegionInfo.RegionSettings.TerrainImageID = UUID.Zero;
  1459. myMapImageJPEG = new byte[0];
  1460. needRegionSave = true;
  1461. }
  1462. lastID = m_scene.RegionInfo.RegionSettings.ParcelImageID;
  1463. if (lastID != UUID.Zero)
  1464. {
  1465. m_scene.AssetService.Delete(lastID.ToString());
  1466. m_scene.RegionInfo.RegionSettings.ParcelImageID = UUID.Zero;
  1467. needRegionSave = true;
  1468. }
  1469. if(mapbmp != null)
  1470. {
  1471. try
  1472. {
  1473. byte[] data;
  1474. // if large region limit its size since new viewers will not use it
  1475. // but it is still usable for ossl
  1476. if(m_scene.RegionInfo.RegionSizeX > Constants.RegionSize ||
  1477. m_scene.RegionInfo.RegionSizeY > Constants.RegionSize)
  1478. {
  1479. int bx = mapbmp.Width;
  1480. int by = mapbmp.Height;
  1481. int mb = bx;
  1482. if(mb < by)
  1483. mb = by;
  1484. if(mb > Constants.RegionSize && mb > 0)
  1485. {
  1486. float scale = (float)Constants.RegionSize/(float)mb;
  1487. using(Bitmap scaledbmp = Util.ResizeImageSolid(mapbmp, (int)(bx * scale), (int)(by * scale)))
  1488. data = OpenJPEG.EncodeFromImage(scaledbmp, true);
  1489. }
  1490. else
  1491. data = OpenJPEG.EncodeFromImage(mapbmp, true);
  1492. }
  1493. else
  1494. data = OpenJPEG.EncodeFromImage(mapbmp, true);
  1495. if (data != null && data.Length > 0)
  1496. {
  1497. UUID terrainImageID = UUID.Random();
  1498. AssetBase asset = new AssetBase(
  1499. terrainImageID,
  1500. "terrainImage_" + m_scene.RegionInfo.RegionID.ToString(),
  1501. (sbyte)AssetType.Texture,
  1502. m_scene.RegionInfo.RegionID.ToString());
  1503. asset.Data = data;
  1504. asset.Description = m_scene.RegionInfo.RegionName;
  1505. asset.Temporary = false;
  1506. asset.Flags = AssetFlags.Maptile;
  1507. // Store the new one
  1508. m_log.DebugFormat("[WORLD MAP]: Storing map image {0} for {1}", asset.ID, m_scene.RegionInfo.RegionName);
  1509. m_scene.AssetService.Store(asset);
  1510. m_scene.RegionInfo.RegionSettings.TerrainImageID = terrainImageID;
  1511. needRegionSave = true;
  1512. }
  1513. }
  1514. catch (Exception e)
  1515. {
  1516. m_log.Error("[WORLD MAP]: Failed generating terrain map: " + e);
  1517. }
  1518. }
  1519. // V2/3 still seem to need this, or we are missing something somewhere
  1520. byte[] overlay = GenerateOverlay();
  1521. if (overlay != null)
  1522. {
  1523. UUID parcelImageID = UUID.Random();
  1524. AssetBase parcels = new AssetBase(
  1525. parcelImageID,
  1526. "parcelImage_" + m_scene.RegionInfo.RegionID.ToString(),
  1527. (sbyte)AssetType.Texture,
  1528. m_scene.RegionInfo.RegionID.ToString());
  1529. parcels.Data = overlay;
  1530. parcels.Description = m_scene.RegionInfo.RegionName;
  1531. parcels.Temporary = false;
  1532. parcels.Flags = AssetFlags.Maptile;
  1533. m_scene.AssetService.Store(parcels);
  1534. m_scene.RegionInfo.RegionSettings.ParcelImageID = parcelImageID;
  1535. needRegionSave = true;
  1536. }
  1537. if (needRegionSave)
  1538. m_scene.RegionInfo.RegionSettings.Save();
  1539. }
  1540. private void MakeRootAgent(ScenePresence avatar)
  1541. {
  1542. lock (m_rootAgents)
  1543. {
  1544. if (!m_rootAgents.Contains(avatar.UUID))
  1545. {
  1546. m_rootAgents.Add(avatar.UUID);
  1547. }
  1548. }
  1549. }
  1550. private void MakeChildAgent(ScenePresence avatar)
  1551. {
  1552. lock (m_rootAgents)
  1553. {
  1554. m_rootAgents.Remove(avatar.UUID);
  1555. }
  1556. lock (m_mapBlockRequestEvent)
  1557. {
  1558. if (m_mapBlockRequests.ContainsKey(avatar.UUID))
  1559. m_mapBlockRequests.Remove(avatar.UUID);
  1560. }
  1561. }
  1562. public void OnRegionUp(GridRegion otherRegion)
  1563. {
  1564. ulong regionhandle = otherRegion.RegionHandle;
  1565. string httpserver = otherRegion.ServerURI + "MAP/MapItems/" + regionhandle.ToString();
  1566. lock (m_blacklistedregions)
  1567. {
  1568. if (m_blacklistedregions.Contains(regionhandle))
  1569. m_blacklistedregions.Remove(regionhandle);
  1570. }
  1571. lock (m_blacklistedurls)
  1572. {
  1573. if (m_blacklistedurls.Contains(httpserver))
  1574. m_blacklistedurls.Remove(httpserver);
  1575. }
  1576. lock (m_cachedRegionMapItemsAddress)
  1577. {
  1578. m_cachedRegionMapItemsAddress.AddOrUpdate(regionhandle,
  1579. httpserver, 5.0 * expireBlackListTime);
  1580. }
  1581. }
  1582. private Byte[] GenerateOverlay()
  1583. {
  1584. int landTileSize = LandManagementModule.LandUnit;
  1585. // These need to be ints for bitmap generation
  1586. int regionSizeX = (int)m_scene.RegionInfo.RegionSizeX;
  1587. int regionLandTilesX = regionSizeX / landTileSize;
  1588. int regionSizeY = (int)m_scene.RegionInfo.RegionSizeY;
  1589. int regionLandTilesY = regionSizeY / landTileSize;
  1590. bool landForSale = false;
  1591. ILandObject land;
  1592. // scan terrain avoiding potencial merges of large bitmaps
  1593. //TODO create the sell bitmap at landchannel / landmaster ?
  1594. // and auction also, still not suported
  1595. bool[,] saleBitmap = new bool[regionLandTilesX, regionLandTilesY];
  1596. for (int x = 0, xx = 0; x < regionLandTilesX; x++ ,xx += landTileSize)
  1597. {
  1598. for (int y = 0, yy = 0; y < regionLandTilesY; y++, yy += landTileSize)
  1599. {
  1600. land = m_scene.LandChannel.GetLandObject(xx, yy);
  1601. if (land != null && (land.LandData.Flags & (uint)ParcelFlags.ForSale) != 0)
  1602. {
  1603. saleBitmap[x, y] = true;
  1604. landForSale = true;
  1605. }
  1606. else
  1607. saleBitmap[x, y] = false;
  1608. }
  1609. }
  1610. if (!landForSale)
  1611. {
  1612. m_log.DebugFormat("[WORLD MAP]: Region {0} has no parcels for sale, not generating overlay", m_scene.RegionInfo.RegionName);
  1613. return null;
  1614. }
  1615. m_log.DebugFormat("[WORLD MAP]: Region {0} has parcels for sale, generating overlay", m_scene.RegionInfo.RegionName);
  1616. using (Bitmap overlay = new Bitmap(regionSizeX, regionSizeY))
  1617. {
  1618. Color background = Color.FromArgb(0, 0, 0, 0);
  1619. using (Graphics g = Graphics.FromImage(overlay))
  1620. {
  1621. using (SolidBrush transparent = new SolidBrush(background))
  1622. g.FillRectangle(transparent, 0, 0, regionSizeX, regionSizeY);
  1623. // make it a bit transparent
  1624. using (SolidBrush yellow = new SolidBrush(Color.FromArgb(192, 249, 223, 9)))
  1625. {
  1626. for (int x = 0; x < regionLandTilesX; x++)
  1627. {
  1628. for (int y = 0; y < regionLandTilesY; y++)
  1629. {
  1630. if (saleBitmap[x, y])
  1631. g.FillRectangle(
  1632. yellow,
  1633. x * landTileSize,
  1634. regionSizeX - landTileSize - (y * landTileSize),
  1635. landTileSize,
  1636. landTileSize);
  1637. }
  1638. }
  1639. }
  1640. }
  1641. try
  1642. {
  1643. return OpenJPEG.EncodeFromImage(overlay, false);
  1644. }
  1645. catch (Exception e)
  1646. {
  1647. m_log.DebugFormat("[WORLD MAP]: Error creating parcel overlay: " + e.ToString());
  1648. }
  1649. }
  1650. return null;
  1651. }
  1652. }
  1653. public class MapRequestState
  1654. {
  1655. public UUID agentID;
  1656. public uint flags;
  1657. public uint EstateID;
  1658. public bool godlike;
  1659. public uint itemtype;
  1660. public ulong regionhandle;
  1661. }
  1662. public struct MapBlockRequestData
  1663. {
  1664. public IClientAPI client;
  1665. public int minX;
  1666. public int minY;
  1667. public int maxX;
  1668. public int maxY;
  1669. public uint flags;
  1670. }
  1671. }