WorldMapModule.cs 79 KB

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