/** * Copyright (c) 2008, Contributors. All rights reserved. * See CONTRIBUTORS.TXT for a full list of copyright holders. * * Redistribution and use in source and binary forms, with or without modification, * are permitted provided that the following conditions are met: * * * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * * Neither the name of the Organizations nor the names of Individual * Contributors may be used to endorse or promote products derived from * this software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL * THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED * OF THE POSSIBILITY OF SUCH DAMAGE. * */ using System; using System.Collections; using System.Collections.Generic; using System.Drawing; using System.Net; using System.Net.Sockets; using System.Reflection; using System.Runtime.Remoting; using System.Security.Authentication; using log4net; using Nwc.XmlRpc; using OpenMetaverse; using OpenMetaverse.Imaging; using OpenSim.Framework; using OpenSim.Framework.Communications; using OpenSim.Framework.Communications.Cache; using OpenSim.Framework.Servers; using OpenSim.Region.Communications.OGS1; using OpenSim.Region.Framework.Scenes; // using OpenSim.Region.Environment.Modules.Framework; namespace OpenSim.Region.Communications.Hypergrid { /// /// This class encapsulates the main hypergrid functions related to creating and managing /// hyperlinks, as well as processing all the inter-region comms between a region and /// an hyperlinked region. /// public class HGGridServices : IGridServices, IInterRegionCommunications, IHyperlink { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); public BaseHttpServer httpListener; public NetworkServersInfo serversInfo; public BaseHttpServer httpServer; protected List m_regionsOnInstance = new List(); // Hyperlink regions are hyperlinks on the map protected List m_hyperlinkRegions = new List(); // Known regions are home regions of visiting foreign users. // They are not on the map as static hyperlinks. They are dynamic hyperlinks, they go away when // the visitor goes away. They are mapped to X=0 on the map. // This is key-ed on agent ID protected Dictionary m_knownRegions = new Dictionary(); protected IAssetCache m_assetcache; protected UserProfileCacheService m_userProfileCache; protected SceneManager m_sceneman; private Dictionary m_queuedGridSettings = new Dictionary(); public virtual string gdebugRegionName { get { return "Override me"; } set { ; } } public string rdebugRegionName { get { return _rdebugRegionName; } set { _rdebugRegionName = value; } } private string _rdebugRegionName = String.Empty; public virtual bool RegionLoginsEnabled { get { return true; } set { ; } } public UserProfileCacheService UserProfileCache { set { m_userProfileCache = value; } } private Random random; /// /// Contructor. Adds "expect_hg_user" and "check" xmlrpc method handlers /// /// /// public HGGridServices(NetworkServersInfo servers_info, BaseHttpServer httpServe, IAssetCache asscache, SceneManager sman) { serversInfo = servers_info; httpServer = httpServe; m_assetcache = asscache; m_sceneman = sman; random = new Random(); httpServer.AddXmlRPCHandler("link_region", LinkRegionRequest); httpServer.AddXmlRPCHandler("expect_hg_user", ExpectHGUser); HGNetworkServersInfo.Init(servers_info.AssetURL, servers_info.InventoryURL, servers_info.UserURL); } // see IGridServices public virtual RegionCommsListener RegisterRegion(RegionInfo regionInfo) { // Region doesn't exist here. Trying to link remote region m_log.Info("[HGrid]: Linking remote region " + regionInfo.ExternalHostName + ":" + regionInfo.HttpPort ); regionInfo.RegionID = LinkRegion(regionInfo); // UUID.Random(); if (!regionInfo.RegionID.Equals(UUID.Zero)) { m_hyperlinkRegions.Add(regionInfo); m_log.Info("[HGrid]: Successfully linked to region_uuid " + regionInfo.RegionID); //Try get the map image GetMapImage(regionInfo); } else { m_log.Info("[HGrid]: No such region " + regionInfo.ExternalHostName + ":" + regionInfo.HttpPort + "(" + regionInfo.InternalEndPoint.Port + ")"); } // Note that these remote regions aren't registered in localBackend, so return null, no local listeners return null; } // see IGridServices public virtual bool DeregisterRegion(RegionInfo regionInfo) { if (m_hyperlinkRegions.Contains(regionInfo)) { m_hyperlinkRegions.Remove(regionInfo); return true; } foreach (KeyValuePair kvp in m_knownRegions) { if (kvp.Value == regionInfo) { m_knownRegions.Remove(kvp.Key); return true; } } return false; } public virtual Dictionary GetGridSettings() { Dictionary returnGridSettings = new Dictionary(); lock (m_queuedGridSettings) { foreach (string Dictkey in m_queuedGridSettings.Keys) { returnGridSettings.Add(Dictkey, m_queuedGridSettings[Dictkey]); } m_queuedGridSettings.Clear(); } return returnGridSettings; } // see IGridServices public virtual List RequestNeighbours(uint x, uint y) { List neighbours = new List(); foreach (RegionInfo reg in m_hyperlinkRegions) { if (reg.RegionLocX != x || reg.RegionLocY != y) { //Console.WriteLine("CommsManager- RequestNeighbours() - found a different region in list, checking location"); if ((reg.RegionLocX > (x - 2)) && (reg.RegionLocX < (x + 2))) { if ((reg.RegionLocY > (y - 2)) && (reg.RegionLocY < (y + 2))) { neighbours.Add(reg); } } } } return neighbours; } /// /// Request information about a region. /// /// /// /// null on a failure to contact or get a response from the grid server /// FIXME: Might be nicer to return a proper exception here since we could inform the client more about the /// nature of the faiulre. /// public virtual RegionInfo RequestNeighbourInfo(UUID Region_UUID) { foreach (RegionInfo info in m_hyperlinkRegions) { if (info.RegionID == Region_UUID) return info; } // I don't trust region uuids to be unique... //foreach (RegionInfo info in m_knownRegions.Values) //{ // if (info.RegionID == Region_UUID) return info; //} return null; } /// /// Request information about a region. /// /// /// public virtual RegionInfo RequestNeighbourInfo(ulong regionHandle) { //Console.WriteLine(" >> RequestNeighbourInfo for " + regionHandle); foreach (RegionInfo info in m_hyperlinkRegions) { //Console.WriteLine(" .. " + info.RegionHandle); if (info.RegionHandle == regionHandle) return info; } foreach (RegionInfo info in m_knownRegions.Values) { if (info.RegionHandle == regionHandle) { //Console.WriteLine("XXX------ known region " + info.RegionHandle); return info; } } return null; } public virtual RegionInfo RequestClosestRegion(string regionName) { foreach (RegionInfo info in m_hyperlinkRegions) { if (info.RegionName == regionName) return info; } return null; } /// /// /// /// /// /// /// /// public virtual List RequestNeighbourMapBlocks(int minX, int minY, int maxX, int maxY) { List neighbours = new List(); foreach (RegionInfo regInfo in m_hyperlinkRegions) { if (((regInfo.RegionLocX >= minX) && (regInfo.RegionLocX <= maxX)) && ((regInfo.RegionLocY >= minY) && (regInfo.RegionLocY <= maxY))) { MapBlockData map = new MapBlockData(); map.Name = regInfo.RegionName; map.X = (ushort)regInfo.RegionLocX; map.Y = (ushort)regInfo.RegionLocY; map.WaterHeight = (byte)regInfo.RegionSettings.WaterHeight; map.MapImageId = regInfo.RegionSettings.TerrainImageID; // Console.WriteLine("ImgID: " + map.MapImageId); map.Agents = 1; map.RegionFlags = 72458694; map.Access = 13; neighbours.Add(map); } } return neighbours; } protected virtual void GetMapImage(RegionInfo info) { try { string regionimage = "regionImage" + info.RegionID.ToString(); regionimage = regionimage.Replace("-", ""); WebClient c = new WebClient(); string uri = "http://" + info.ExternalHostName + ":" + info.HttpPort + "/index.php?method=" + regionimage; //Console.WriteLine("JPEG: " + uri); c.DownloadFile(uri, info.RegionID.ToString() + ".jpg"); Bitmap m = new Bitmap(info.RegionID.ToString() + ".jpg"); //Console.WriteLine("Size: " + m.PhysicalDimension.Height + "-" + m.PhysicalDimension.Width); byte[] imageData = OpenJPEG.EncodeFromImage(m, true); AssetBase ass = new AssetBase(UUID.Random(), "region " + info.RegionID.ToString()); info.RegionSettings.TerrainImageID = ass.Metadata.FullID; ass.Metadata.Type = (int)AssetType.Texture; ass.Metadata.Temporary = false; ass.Data = imageData; m_assetcache.AddAsset(ass); } catch // LEGIT: Catching problems caused by OpenJPEG p/invoke { Console.WriteLine("[HGrid]: Failed getting/storing map image, because it is probably already in the cache"); } } // A little ugly, since this code is exactly the same as OSG1's, and we're already // calling that for when the region in in grid mode... (for the grid regions) // public virtual LandData RequestLandData (ulong regionHandle, uint x, uint y) { m_log.DebugFormat("[HGrid]: requests land data in {0}, at {1}, {2}", regionHandle, x, y); // Remote region Hashtable hash = new Hashtable(); hash["region_handle"] = regionHandle.ToString(); hash["x"] = x.ToString(); hash["y"] = y.ToString(); IList paramList = new ArrayList(); paramList.Add(hash); LandData landData = null; try { RegionInfo info = RequestNeighbourInfo(regionHandle); if (info != null) // just to be sure { XmlRpcRequest request = new XmlRpcRequest("land_data", paramList); string uri = "http://" + info.ExternalEndPoint.Address + ":" + info.HttpPort + "/"; XmlRpcResponse response = request.Send(uri, 10000); if (response.IsFault) { m_log.ErrorFormat("[HGrid]: remote call returned an error: {0}", response.FaultString); } else { hash = (Hashtable)response.Value; try { landData = new LandData(); landData.AABBMax = Vector3.Parse((string)hash["AABBMax"]); landData.AABBMin = Vector3.Parse((string)hash["AABBMin"]); landData.Area = Convert.ToInt32(hash["Area"]); landData.AuctionID = Convert.ToUInt32(hash["AuctionID"]); landData.Description = (string)hash["Description"]; landData.Flags = Convert.ToUInt32(hash["Flags"]); landData.GlobalID = new UUID((string)hash["GlobalID"]); landData.Name = (string)hash["Name"]; landData.OwnerID = new UUID((string)hash["OwnerID"]); landData.SalePrice = Convert.ToInt32(hash["SalePrice"]); landData.SnapshotID = new UUID((string)hash["SnapshotID"]); landData.UserLocation = Vector3.Parse((string)hash["UserLocation"]); m_log.DebugFormat("[HGrid]: Got land data for parcel {0}", landData.Name); } catch (Exception e) { m_log.Error("[HGrid]: Got exception while parsing land-data:", e); } } } else m_log.WarnFormat("[HGrid]: Couldn't find region with handle {0}", regionHandle); } catch (Exception e) { m_log.ErrorFormat("[HGrid]: Couldn't contact region {0}: {1}", regionHandle, e); } return landData; } // Grid Request Processing public virtual List RequestNamedRegions (string name, int maxNumber) { List infos = new List(); foreach (RegionInfo info in m_hyperlinkRegions) { if (info.RegionName.ToLower().Contains(name)) { infos.Add(info); } } return infos; } private UUID LinkRegion(RegionInfo info) { UUID uuid = UUID.Zero; Hashtable hash = new Hashtable(); hash["region_name"] = info.RegionName; IList paramList = new ArrayList(); paramList.Add(hash); XmlRpcRequest request = new XmlRpcRequest("link_region", paramList); string uri = "http://" + info.ExternalEndPoint.Address + ":" + info.HttpPort + "/"; m_log.Debug("[HGrid]: Linking to " + uri); XmlRpcResponse response = request.Send(uri, 10000); if (response.IsFault) { m_log.ErrorFormat("[HGrid]: remote call returned an error: {0}", response.FaultString); } else { hash = (Hashtable)response.Value; //foreach (Object o in hash) // Console.WriteLine(">> " + ((DictionaryEntry)o).Key + ":" + ((DictionaryEntry)o).Value); try { UUID.TryParse((string)hash["uuid"], out uuid); info.RegionID = uuid; if ((string)hash["handle"] != null) { info.regionSecret = (string)hash["handle"]; //Console.WriteLine(">> HERE: " + info.regionSecret); } if (hash["region_image"] != null) { UUID img = UUID.Zero; UUID.TryParse((string)hash["region_image"], out img); info.RegionSettings.TerrainImageID = img; } if (hash["region_name"] != null) { info.RegionName = (string)hash["region_name"]; //Console.WriteLine(">> " + info.RegionName); } if (hash["internal_port"] != null) { int port = Convert.ToInt32((string)hash["internal_port"]); info.InternalEndPoint = new IPEndPoint(IPAddress.Parse("0.0.0.0"), port); //Console.WriteLine(">> " + info.InternalEndPoint.ToString()); } if (hash["remoting_port"] != null) { info.RemotingPort = Convert.ToUInt32(hash["remoting_port"]); //Console.WriteLine(">> " + info.RemotingPort); } } catch (Exception e) { m_log.Error("[HGrid]: Got exception while parsing hyperlink response " + e.StackTrace); } } return uuid; } /// /// Someone wants to link to us /// /// /// public XmlRpcResponse LinkRegionRequest(XmlRpcRequest request) { Hashtable requestData = (Hashtable)request.Params[0]; //string host = (string)requestData["host"]; //string portstr = (string)requestData["port"]; string name = (string)requestData["region_name"]; m_log.DebugFormat("[HGrid]: Hyperlink request"); RegionInfo regInfo = null; foreach (RegionInfo r in m_regionsOnInstance) { if ((r.RegionName != null) && (name != null) && (r.RegionName.ToLower() == name.ToLower())) { regInfo = r; break; } } if (regInfo == null) regInfo = m_regionsOnInstance[0]; // Send out the first region Hashtable hash = new Hashtable(); hash["uuid"] = regInfo.RegionID.ToString(); hash["handle"] = regInfo.RegionHandle.ToString(); //Console.WriteLine(">> Here " + regInfo.RegionHandle); hash["region_image"] = regInfo.RegionSettings.TerrainImageID.ToString(); hash["region_name"] = regInfo.RegionName; hash["internal_port"] = regInfo.InternalEndPoint.Port.ToString(); hash["remoting_port"] = NetworkServersInfo.RemotingListenerPort.ToString(); //Console.WriteLine(">> Here: " + regInfo.InternalEndPoint.Port); XmlRpcResponse response = new XmlRpcResponse(); response.Value = hash; return response; } public bool InformRegionOfUser(RegionInfo regInfo, AgentCircuitData agentData) { //ulong regionHandle = regInfo.RegionHandle; try { //regionHandle = Convert.ToUInt64(regInfo.regionSecret); m_log.Info("[HGrid]: InformRegionOfUser: Remote hyperlinked region " + regInfo.regionSecret); } catch { m_log.Info("[HGrid]: InformRegionOfUser: Local grid region " + regInfo.regionSecret); } string capsPath = agentData.CapsPath; Hashtable loginParams = new Hashtable(); loginParams["session_id"] = agentData.SessionID.ToString(); loginParams["secure_session_id"] = agentData.SecureSessionID.ToString(); loginParams["firstname"] = agentData.firstname; loginParams["lastname"] = agentData.lastname; loginParams["agent_id"] = agentData.AgentID.ToString(); loginParams["circuit_code"] = agentData.circuitcode.ToString(); loginParams["startpos_x"] = agentData.startpos.X.ToString(); loginParams["startpos_y"] = agentData.startpos.Y.ToString(); loginParams["startpos_z"] = agentData.startpos.Z.ToString(); loginParams["caps_path"] = capsPath; CachedUserInfo u = m_userProfileCache.GetUserDetails(agentData.AgentID); if (u != null && u.UserProfile != null) { loginParams["region_uuid"] = u.UserProfile.HomeRegionID.ToString(); // This seems to be always Zero //Console.WriteLine(" --------- Home Region UUID -------"); //Console.WriteLine(" >> " + loginParams["region_uuid"] + " <<"); //Console.WriteLine(" --------- ---------------- -------"); string serverURI = ""; if (u.UserProfile is ForeignUserProfileData) serverURI = HGNetworkServersInfo.ServerURI(((ForeignUserProfileData)u.UserProfile).UserServerURI); loginParams["userserver_id"] = (serverURI == "") || (serverURI == null) ? HGNetworkServersInfo.Singleton.LocalUserServerURI : serverURI; serverURI = HGNetworkServersInfo.ServerURI(u.UserProfile.UserAssetURI); loginParams["assetserver_id"] = (serverURI == "") || (serverURI == null) ? HGNetworkServersInfo.Singleton.LocalAssetServerURI : serverURI; serverURI = HGNetworkServersInfo.ServerURI(u.UserProfile.UserInventoryURI); loginParams["inventoryserver_id"] = (serverURI == "") || (serverURI == null) ? HGNetworkServersInfo.Singleton.LocalInventoryServerURI : serverURI; loginParams["root_folder_id"] = u.UserProfile.RootInventoryFolderID; RegionInfo rinfo = RequestNeighbourInfo(u.UserProfile.HomeRegion); if (rinfo != null) { loginParams["internal_port"] = rinfo.InternalEndPoint.Port.ToString(); if (!IsLocalUser(u)) { loginParams["regionhandle"] = rinfo.regionSecret; // user.CurrentAgent.Handle.ToString(); //Console.WriteLine("XXX--- informregionofuser (foreign user) here handle: " + rinfo.regionSecret); loginParams["home_address"] = ((ForeignUserProfileData)(u.UserProfile)).UserHomeAddress; loginParams["home_port"] = ((ForeignUserProfileData)(u.UserProfile)).UserHomePort; loginParams["home_remoting"] = ((ForeignUserProfileData)(u.UserProfile)).UserHomeRemotingPort; } else { //Console.WriteLine("XXX--- informregionofuser (local user) here handle: " + rinfo.regionSecret); //// local user about to jump out, let's process the name // On second thoughts, let's not do this for the *user*; let's only do it for the *agent* //loginParams["firstname"] = agentData.firstname + "." + agentData.lastname; //loginParams["lastname"] = serversInfo.UserURL; // local user, first time out. let's ask the grid about this user's home region loginParams["regionhandle"] = u.UserProfile.HomeRegion.ToString(); // user.CurrentAgent.Handle.ToString(); loginParams["home_address"] = rinfo.ExternalHostName; Console.WriteLine(" --------- Home Address -------"); Console.WriteLine(" >> " + loginParams["home_address"] + " <<"); Console.WriteLine(" --------- ------------ -------"); loginParams["home_port"] = rinfo.HttpPort.ToString(); loginParams["home_remoting"] = NetworkServersInfo.RemotingListenerPort.ToString(); ; } } else { m_log.Warn("[HGrid]: User's home region info not found: " + u.UserProfile.HomeRegionX + ", " + u.UserProfile.HomeRegionY); } } ArrayList SendParams = new ArrayList(); SendParams.Add(loginParams); // Send string uri = "http://" + regInfo.ExternalHostName + ":" + regInfo.HttpPort + "/"; //Console.WriteLine("XXX uri: " + uri); XmlRpcRequest request = new XmlRpcRequest("expect_hg_user", SendParams); XmlRpcResponse reply; try { reply = request.Send(uri, 6000); } catch (Exception e) { m_log.Warn("[HGrid]: Failed to notify region about user. Reason: " + e.Message); return false; } if (!reply.IsFault) { bool responseSuccess = true; if (reply.Value != null) { Hashtable resp = (Hashtable)reply.Value; if (resp.ContainsKey("success")) { if ((string)resp["success"] == "FALSE") { responseSuccess = false; } } } if (responseSuccess) { m_log.Info("[HGrid]: Successfully informed remote region about user " + agentData.AgentID); return true; } else { m_log.ErrorFormat("[HGrid]: Region responded that it is not available to receive clients"); return false; } } else { m_log.ErrorFormat("[HGrid]: XmlRpc request to region failed with message {0}, code {1} ", reply.FaultString, reply.FaultCode); return false; } } /// /// Received from other HGrid nodes when a user wants to teleport here. This call allows /// the region to prepare for direct communication from the client. Sends back an empty /// xmlrpc response on completion. /// This is somewhat similar to OGS1's ExpectUser, but with the additional task of /// registering the user in the local user cache. /// /// /// public XmlRpcResponse ExpectHGUser(XmlRpcRequest request) { Hashtable requestData = (Hashtable)request.Params[0]; ForeignUserProfileData userData = new ForeignUserProfileData(); userData.FirstName = (string)requestData["firstname"]; userData.SurName = (string)requestData["lastname"]; userData.ID = new UUID((string)requestData["agent_id"]); userData.HomeLocation = new Vector3((float)Convert.ToDecimal((string)requestData["startpos_x"]), (float)Convert.ToDecimal((string)requestData["startpos_y"]), (float)Convert.ToDecimal((string)requestData["startpos_z"])); userData.UserServerURI = (string)requestData["userserver_id"]; userData.UserAssetURI = (string)requestData["assetserver_id"]; userData.UserInventoryURI = (string)requestData["inventoryserver_id"]; UUID rootID = UUID.Zero; UUID.TryParse((string)requestData["root_folder_id"], out rootID); userData.RootInventoryFolderID = rootID; UUID uuid = UUID.Zero; UUID.TryParse((string)requestData["region_uuid"], out uuid); userData.HomeRegionID = uuid; // not quite comfortable about this... ulong userRegionHandle = Convert.ToUInt64((string)requestData["regionhandle"]); //userData.HomeRegion = userRegionHandle; userData.UserHomeAddress = (string)requestData["home_address"]; userData.UserHomePort = (string)requestData["home_port"]; int userhomeinternalport = Convert.ToInt32((string)requestData["internal_port"]); userData.UserHomeRemotingPort = (string)requestData["home_remoting"]; m_log.DebugFormat("[HGrid]: Told by user service to prepare for a connection from {0} {1} {2}", userData.FirstName, userData.SurName, userData.ID); m_log.Debug("[HGrid]: home_address: " + userData.UserHomeAddress + "; home_port: " + userData.UserHomePort + "; remoting: " + userData.UserHomeRemotingPort); XmlRpcResponse resp = new XmlRpcResponse(); if (!RegionLoginsEnabled) { m_log.InfoFormat( "[HGrid]: Denying access for user {0} {1} because region login is currently disabled", userData.FirstName, userData.SurName); Hashtable respdata = new Hashtable(); respdata["success"] = "FALSE"; respdata["reason"] = "region login currently disabled"; resp.Value = respdata; } else { // Finally, everything looks ok //Console.WriteLine("XXX---- EVERYTHING OK ---XXX"); // 1 - Preload the user data m_userProfileCache.PreloadUserCache(userData.ID, userData); if (m_knownRegions.ContainsKey(userData.ID)) { // This was left here when the user departed m_knownRegions.Remove(userData.ID); } // 2 - Load the region info into list of known regions RegionInfo rinfo = new RegionInfo(); rinfo.RegionID = userData.HomeRegionID; rinfo.ExternalHostName = userData.UserHomeAddress; rinfo.HttpPort = Convert.ToUInt32(userData.UserHomePort); rinfo.RemotingPort = Convert.ToUInt32(userData.UserHomeRemotingPort); rinfo.RegionID = userData.HomeRegionID; // X=0 on the map rinfo.RegionLocX = 0; rinfo.RegionLocY = (uint)(random.Next(0, Int32.MaxValue)); //(uint)m_knownRegions.Count; rinfo.regionSecret = userRegionHandle.ToString(); //Console.WriteLine("XXX--- Here: handle = " + rinfo.regionSecret); try { rinfo.InternalEndPoint = new IPEndPoint(IPAddress.Parse("0.0.0.0"), (int)userhomeinternalport); } catch (Exception e) { m_log.Warn("[HGrid]: Exception while constructing internal endpoint: " + e); } rinfo.RemotingAddress = rinfo.ExternalEndPoint.Address.ToString(); //userData.UserHomeAddress; if (!IsComingHome(userData)) { // Change the user's home region here!!! userData.HomeRegion = rinfo.RegionHandle; } if (!m_knownRegions.ContainsKey(userData.ID)) m_knownRegions.Add(userData.ID, rinfo); // 3 - Send the reply Hashtable respdata = new Hashtable(); respdata["success"] = "TRUE"; resp.Value = respdata; DumpUserData(userData); DumpRegionData(rinfo); } return resp; } #region IInterRegionCommunications interface public virtual bool AcknowledgeAgentCrossed(ulong regionHandle, UUID agentId) { return false; } public virtual bool AcknowledgePrimCrossed(ulong regionHandle, UUID primID) { return false; } public virtual bool CheckRegion(string address, uint port) { return false; } public virtual bool ChildAgentUpdate(ulong regionHandle, ChildAgentDataUpdate cAgentData) { return false; } public virtual bool ExpectAvatarCrossing(ulong regionHandle, UUID agentID, Vector3 position, bool isFlying) { // Remote region RegionInfo regInfo = null; ulong remoteHandle = 0; try { regInfo = RequestNeighbourInfo(regionHandle); if (regInfo != null) { try { remoteHandle = Convert.ToUInt64(regInfo.regionSecret); } catch { m_log.Warn("[HGrid]: Invalid remote region with handle " + regInfo.regionSecret); return false; } //Console.WriteLine("XXX---- Sending Expectavatarcrossing into : " + remoteHandle); bool retValue = false; OGS1InterRegionRemoting remObject = (OGS1InterRegionRemoting)Activator.GetObject( typeof(OGS1InterRegionRemoting), "tcp://" + regInfo.RemotingAddress + ":" + regInfo.RemotingPort + "/InterRegions"); if (remObject != null) { retValue = remObject.ExpectAvatarCrossing(remoteHandle, agentID.Guid, new sLLVector3(position), isFlying); } else { m_log.Warn("[HGrid]: Remoting object not found"); } remObject = null; return retValue; } //TODO need to see if we know about where this region is and use .net remoting // to inform it. //NoteDeadRegion(regionHandle); return false; } catch (RemotingException e) { // NoteDeadRegion(regionHandle); m_log.WarnFormat( "[HGrid]: Remoting Error: Unable to connect to adjacent region: {0} {1},{2}", regInfo.RegionName, regInfo.RegionLocX, regInfo.RegionLocY); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch { // NoteDeadRegion(regionHandle); return false; } } public virtual bool ExpectPrimCrossing(ulong regionHandle, UUID primID, Vector3 position, bool isFlying) { return false; } public bool SendUserInformation(RegionInfo regInfo, AgentCircuitData agentData) { CachedUserInfo uinfo = m_userProfileCache.GetUserDetails(agentData.AgentID); if ((IsLocalUser(uinfo) && IsHyperlinkRegion(regInfo.RegionHandle)) || (!IsLocalUser(uinfo) && !IsGoingHome(uinfo, regInfo))) { m_log.Info("[HGrid]: Local user is going to foreign region or foreign user is going elsewhere"); if (!InformRegionOfUser(regInfo, agentData)) { m_log.Warn("[HGrid]: Could not inform remote region of transferring user."); return false; } } //if ((uinfo == null) || !IsGoingHome(uinfo, regInfo)) //{ // m_log.Info("[HGrid]: User seems to be going to foreign region."); // if (!InformRegionOfUser(regInfo, agentData)) // { // m_log.Warn("[HGrid]: Could not inform remote region of transferring user."); // return false; // } //} //else // m_log.Info("[HGrid]: User seems to be going home " + uinfo.UserProfile.FirstName + " " + uinfo.UserProfile.SurName); // May need to change agent's name if (IsLocalUser(uinfo) && IsHyperlinkRegion(regInfo.RegionHandle)) { agentData.firstname = agentData.firstname + "." + agentData.lastname; agentData.lastname = "@" + serversInfo.UserURL.Replace("http://", ""); ; //HGNetworkServersInfo.Singleton.LocalUserServerURI; } return true; } public virtual bool InformRegionOfChildAgent(ulong regionHandle, AgentCircuitData agentData) { // If we're here, it's because regionHandle is a remote, non-grided region m_log.Info("[HGrid]: InformRegionOfChildAgent for " + regionHandle); RegionInfo regInfo = GetHyperlinkRegion(regionHandle); if (regInfo == null) return false; //ulong realHandle = regionHandle; if (!SendUserInformation(regInfo, agentData)) { m_log.Warn("[HGrid]: Failed to inform remote region of user."); //return false; } try { // ... and then m_log.Debug("[HGrid]: Region is hyperlink."); bool retValue = false; try { regionHandle = Convert.ToUInt64(regInfo.regionSecret); } catch (Exception) { m_log.Warn("[HGrid]: Invalid hyperlink region."); return false; } OGS1InterRegionRemoting remObject = (OGS1InterRegionRemoting)Activator.GetObject( typeof(OGS1InterRegionRemoting), "tcp://" + regInfo.RemotingAddress + ":" + regInfo.RemotingPort + "/InterRegions"); if (remObject != null) { sAgentCircuitData sag = new sAgentCircuitData(agentData); //CachedUserInfo uinfo = m_userProfileCache.GetUserDetails(agentData.AgentID); //// May need to change agent's name //if (IsLocalUser(uinfo)) //{ // sag.firstname = agentData.firstname + "." + agentData.lastname; // sag.lastname = serversInfo.UserURL; //HGNetworkServersInfo.Singleton.LocalUserServerURI; //} retValue = remObject.InformRegionOfChildAgent(regionHandle, sag); } else { m_log.Warn("[HGrid]: remoting object not found"); } remObject = null; m_log.Info("[HGrid]: tried to InformRegionOfChildAgent for " + agentData.firstname + " " + agentData.lastname + " and got " + retValue.ToString()); // Remove the info from this region //if (m_knownRegions.ContainsKey(uinfo.UserProfile.ID)) // m_knownRegions.Remove(uinfo.UserProfile.ID); return retValue; } catch (RemotingException e) { //NoteDeadRegion(regionHandle); m_log.WarnFormat( "[HGrid]: Remoting Error: Unable to connect to adjacent region: {0} {1},{2}", regInfo.RegionName, regInfo.RegionLocX, regInfo.RegionLocY); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch (SocketException e) { //NoteDeadRegion(regionHandle); m_log.WarnFormat( "[HGrid]: Remoting Error: Unable to connect to adjacent region: {0} {1},{2}", regInfo.RegionName, regInfo.RegionLocX, regInfo.RegionLocY); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch (InvalidCredentialException e) { //NoteDeadRegion(regionHandle); m_log.WarnFormat( "[HGrid]: Remoting Error: Unable to connect to adjacent region: {0} {1},{2}", regInfo.RegionName, regInfo.RegionLocX, regInfo.RegionLocY); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch (AuthenticationException e) { //NoteDeadRegion(regionHandle); m_log.WarnFormat( "[HGrid]: Remoting Error: Unable to connect to adjacent region: {0} {1},{2}", regInfo.RegionName, regInfo.RegionLocX, regInfo.RegionLocY); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch (Exception e) { //NoteDeadRegion(regionHandle); if (regInfo != null) { m_log.WarnFormat( "[HGrid]: Remoting Error: Unable to connect to adjacent region: {0} {1},{2}", regInfo.RegionName, regInfo.RegionLocX, regInfo.RegionLocY); } m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } } public virtual bool InformRegionOfPrimCrossing(ulong regionHandle, UUID primID, string objData, int XMLMethod) { return false; } public virtual bool RegionUp(SerializableRegionInfo region, ulong regionhandle) { ulong realHandle = FindRegionHandle(regionhandle); if (realHandle == regionhandle) // something wrong, not remote region return false; SerializableRegionInfo regInfo = null; try { // You may ask why this is in here... // The region asking the grid services about itself.. // And, surprisingly, the reason is.. it doesn't know // it's own remoting port! How special. RegionUpData regiondata = new RegionUpData(region.RegionLocX, region.RegionLocY, region.ExternalHostName, region.InternalEndPoint.Port); region = new SerializableRegionInfo(RequestNeighbourInfo(realHandle)); region.RemotingAddress = region.ExternalHostName; region.RemotingPort = NetworkServersInfo.RemotingListenerPort; region.HttpPort = serversInfo.HttpListenerPort; regInfo = new SerializableRegionInfo(RequestNeighbourInfo(regionhandle)); if (regInfo != null) { // If we're not trying to remote to ourselves. if (regInfo.RemotingAddress != region.RemotingAddress && region.RemotingAddress != null) { //don't want to be creating a new link to the remote instance every time like we are here bool retValue = false; OGS1InterRegionRemoting remObject = (OGS1InterRegionRemoting)Activator.GetObject( typeof(OGS1InterRegionRemoting), "tcp://" + regInfo.RemotingAddress + ":" + regInfo.RemotingPort + "/InterRegions"); if (remObject != null) { retValue = remObject.RegionUp(regiondata, realHandle); } else { m_log.Warn("[HGrid]: remoting object not found"); } remObject = null; m_log.Info( "[HGrid]: tried to inform region I'm up"); return retValue; } else { // We're trying to inform ourselves via remoting. // This is here because we're looping over the listeners before we get here. // Odd but it should work. return true; } } return false; } catch (RemotingException e) { m_log.Warn("[HGrid]: Remoting Error: Unable to connect to adjacent region using tcp://" + regInfo.RemotingAddress + ":" + regInfo.RemotingPort + "/InterRegions - @ " + regInfo.RegionLocX + "," + regInfo.RegionLocY + " - Is this neighbor up?"); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch (SocketException e) { m_log.Warn("[HGrid]: Socket Error: Unable to connect to adjacent region using tcp://" + regInfo.RemotingAddress + ":" + regInfo.RemotingPort + "/InterRegions - @ " + regInfo.RegionLocX + "," + regInfo.RegionLocY + " - Is this neighbor up?"); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch (InvalidCredentialException e) { m_log.Warn("[HGrid]: Invalid Credentials: Unable to connect to adjacent region using tcp://" + regInfo.RemotingAddress + ":" + regInfo.RemotingPort + "/InterRegions - @ " + regInfo.RegionLocX + "," + regInfo.RegionLocY); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch (AuthenticationException e) { m_log.Warn("[HGrid]: Authentication exception: Unable to connect to adjacent region using tcp://" + regInfo.RemotingAddress + ":" + regInfo.RemotingPort + "/InterRegions - @ " + regInfo.RegionLocX + "," + regInfo.RegionLocY); m_log.DebugFormat("[HGrid]: {0} {1}", e.Source, e.Message); return false; } catch (Exception e) { m_log.Debug(e.ToString()); return false; } } public virtual bool TellRegionToCloseChildConnection(ulong regionHandle, UUID agentID) { return false; } public virtual List InformFriendsInOtherRegion(UUID agentId, ulong destRegionHandle, List friends, bool online) { return new List(); } public virtual bool TriggerTerminateFriend(ulong regionHandle, UUID agentID, UUID exFriendID) { return true; } #endregion #region Methods triggered by calls from external instances /// /// /// /// /// /// public void AdjustUserInformation(AgentCircuitData agentData) { CachedUserInfo uinfo = m_userProfileCache.GetUserDetails(agentData.AgentID); if ((uinfo != null) && (uinfo.UserProfile != null) && (IsLocalUser(uinfo) || !(uinfo.UserProfile is ForeignUserProfileData))) { //Console.WriteLine("---------------> Local User!"); string[] parts = agentData.firstname.Split(new char[] { '.' }); if (parts.Length == 2) { agentData.firstname = parts[0]; agentData.lastname = parts[1]; } } //else // Console.WriteLine("---------------> Foreign User!"); } #endregion #region IHyperGrid interface public virtual bool IsHyperlinkRegion(ulong ihandle) { if (GetHyperlinkRegion(ihandle) == null) return false; else return true; } public virtual RegionInfo GetHyperlinkRegion(ulong ihandle) { foreach (RegionInfo info in m_hyperlinkRegions) { if (info.RegionHandle == ihandle) return info; } foreach (RegionInfo info in m_knownRegions.Values) { if (info.RegionHandle == ihandle) return info; } return null; } public virtual ulong FindRegionHandle(ulong ihandle) { long ohandle = -1; List rlist = new List(m_hyperlinkRegions); rlist.AddRange(m_knownRegions.Values); foreach (RegionInfo info in rlist) { if (info.RegionHandle == ihandle) { try { ohandle = Convert.ToInt64(info.regionSecret); m_log.Info("[HGrid] remote region " + ohandle); } catch { m_log.Error("[HGrid] Could not convert secret for " + ihandle + " (" + info.regionSecret + ")"); } break; } } return ohandle < 0 ? ihandle : (ulong)ohandle; } #endregion #region Misc protected bool IsComingHome(ForeignUserProfileData userData) { return (userData.UserServerURI == HGNetworkServersInfo.Singleton.LocalUserServerURI); } protected bool IsGoingHome(CachedUserInfo uinfo, RegionInfo rinfo) { if (uinfo.UserProfile == null) return false; string userUserServerURI = String.Empty; if (uinfo.UserProfile is ForeignUserProfileData) { userUserServerURI = HGNetworkServersInfo.ServerURI(((ForeignUserProfileData)uinfo.UserProfile).UserServerURI); } return ((uinfo.UserProfile.HomeRegionID == rinfo.RegionID) && (userUserServerURI != HGNetworkServersInfo.Singleton.LocalUserServerURI)); } protected bool IsLocalUser(CachedUserInfo uinfo) { if (uinfo == null) return true; if (uinfo.UserProfile is ForeignUserProfileData) return HGNetworkServersInfo.Singleton.IsLocalUser(((ForeignUserProfileData)uinfo.UserProfile).UserServerURI); else return true; } protected bool IsLocalRegion(ulong handle) { foreach (RegionInfo reg in m_regionsOnInstance) if (reg.RegionHandle == handle) return true; return false; } private void DumpUserData(ForeignUserProfileData userData) { Console.WriteLine(" ------------ User Data Dump ----------"); Console.WriteLine(" >> Name: " + userData.FirstName + " " + userData.SurName); Console.WriteLine(" >> HomeID: " + userData.HomeRegionID); Console.WriteLine(" >> HomeHandle: " + userData.HomeRegion); Console.WriteLine(" >> HomeX: " + userData.HomeRegionX); Console.WriteLine(" >> HomeY: " + userData.HomeRegionY); Console.WriteLine(" >> UserServer: " + userData.UserServerURI); Console.WriteLine(" >> InvServer: " + userData.UserInventoryURI); Console.WriteLine(" >> AssetServer: " + userData.UserAssetURI); Console.WriteLine(" ------------ -------------- ----------"); } private void DumpRegionData(RegionInfo rinfo) { Console.WriteLine(" ------------ Region Data Dump ----------"); Console.WriteLine(" >> handle: " + rinfo.RegionHandle); Console.WriteLine(" >> coords: " + rinfo.RegionLocX + ", " + rinfo.RegionLocY); Console.WriteLine(" >> secret: " + rinfo.regionSecret); Console.WriteLine(" >> remoting address: " + rinfo.RemotingAddress); Console.WriteLine(" >> remoting port: " + rinfo.RemotingPort); Console.WriteLine(" >> external host name: " + rinfo.ExternalHostName); Console.WriteLine(" >> http port: " + rinfo.HttpPort); Console.WriteLine(" >> external EP address: " + rinfo.ExternalEndPoint.Address); Console.WriteLine(" >> external EP port: " + rinfo.ExternalEndPoint.Port); Console.WriteLine(" ------------ -------------- ----------"); } #endregion } }