/* * Copyright (c) Contributors, http://opensimulator.org/ * 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 OpenSim Project nor the * names of its contributors may be used to endorse or promote products * derived from this software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``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 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.Generic; using System.IO; using System.Net; using System.Threading; using System.Timers; using System.Xml; using Axiom.Math; using libsecondlife; using OpenSim.Framework; using OpenSim.Framework.Communications; using OpenSim.Framework.Communications.Cache; using OpenSim.Framework.Console; using OpenSim.Framework.Servers; using OpenSim.Region.Capabilities; using OpenSim.Region.Environment.Interfaces; using OpenSim.Region.Environment.LandManagement; using OpenSim.Region.Environment.Modules; using OpenSim.Region.Environment.Scenes.Scripting; using OpenSim.Region.Environment.Types; using OpenSim.Region.Physics.Manager; using OpenSim.Region.Terrain; using Timer=System.Timers.Timer; namespace OpenSim.Region.Environment.Scenes { public partial class Scene : SceneBase { public delegate bool FilterAvatarList(ScenePresence avatar); protected Timer m_heartbeatTimer = new Timer(); protected Dictionary m_scenePresences; protected Dictionary m_sceneObjects; private Random Rand = new Random(); private uint _primCount = 702000; private readonly Mutex _primAllocateMutex = new Mutex(false); private int m_timePhase = 24; private int m_timeUpdateCount; public BasicQuadTreeNode QuadTree; private readonly Mutex updateLock; protected ModuleLoader m_moduleLoader; protected StorageManager storageManager; protected AgentCircuitManager authenticateHandler; protected RegionCommsListener regionCommsHost; public CommunicationsManager commsManager; // protected XferManager xferManager; protected Dictionary capsHandlers = new Dictionary(); protected BaseHttpServer httpListener; protected Dictionary Modules = new Dictionary(); public Dictionary ModuleInterfaces = new Dictionary(); protected Dictionary ModuleAPIMethods = new Dictionary(); //API module interfaces public IXfer XferManager; private IHttpRequests m_httpRequestModule; private ISimChat m_simChatModule; private IXMLRPC m_xmlrpcModule; private IWorldComm m_worldCommModule; private IAvatarFactory m_AvatarFactory; // Central Update Loop protected int m_fps = 10; protected int m_frame = 0; protected float m_timespan = 0.1f; protected DateTime m_lastupdate = DateTime.Now; protected float m_timedilation = 1.0f; private int m_update_physics = 1; private int m_update_entitymovement = 1; private int m_update_entities = 1; private int m_update_events = 1; private int m_update_backup = 200; private int m_update_terrain = 50; private int m_update_land = 1; private int m_update_avatars = 1; #region Properties public AgentCircuitManager AuthenticateHandler { get { return authenticateHandler; } } private readonly LandManager m_LandManager; public LandManager LandManager { get { return m_LandManager; } } private readonly EstateManager m_estateManager; private PhysicsScene phyScene; public PhysicsScene PhysScene { set { phyScene = value; } get { return (phyScene); } } public EstateManager EstateManager { get { return m_estateManager; } } private readonly PermissionManager m_permissionManager; public PermissionManager PermissionsMngr { get { return m_permissionManager; } } public Dictionary Objects { get { return m_sceneObjects; } } public int TimePhase { get { return m_timePhase; } } #endregion #region Constructors public Scene(RegionInfo regInfo, AgentCircuitManager authen, CommunicationsManager commsMan, AssetCache assetCach, StorageManager storeManager, BaseHttpServer httpServer, ModuleLoader moduleLoader, bool dumpAssetsToFile) { updateLock = new Mutex(false); m_moduleLoader = moduleLoader; authenticateHandler = authen; commsManager = commsMan; storageManager = storeManager; assetCache = assetCach; m_regInfo = regInfo; m_regionHandle = m_regInfo.RegionHandle; m_regionName = m_regInfo.RegionName; m_datastore = m_regInfo.DataStore; RegisterRegionWithComms(); m_LandManager = new LandManager(this, m_regInfo); m_estateManager = new EstateManager(this, m_regInfo); m_eventManager = new EventManager(); m_permissionManager = new PermissionManager(this); m_eventManager.OnParcelPrimCountAdd += m_LandManager.addPrimToLandPrimCounts; m_eventManager.OnPermissionError += SendPermissionAlert; QuadTree = new BasicQuadTreeNode(null, "/0/", 0, 0, 256, 256); QuadTree.Subdivide(); QuadTree.Subdivide(); MainLog.Instance.Verbose("Creating new entitities instance"); Entities = new Dictionary(); m_scenePresences = new Dictionary(); m_sceneObjects = new Dictionary(); MainLog.Instance.Verbose("Creating LandMap"); Terrain = new TerrainEngine((int) RegionInfo.RegionLocX, (int) RegionInfo.RegionLocY); ScenePresence.LoadAnims(); httpListener = httpServer; m_dumpAssetsToFile = dumpAssetsToFile; } #endregion public void SetModuleInterfaces() { m_simChatModule = RequestModuleInterface(); m_httpRequestModule = RequestModuleInterface(); m_xmlrpcModule = RequestModuleInterface(); m_worldCommModule = RequestModuleInterface(); XferManager = RequestModuleInterface(); } #region Script Handling Methods public void SendCommandToPlugins(string[] args) { m_eventManager.TriggerOnPluginConsole(args); } #endregion /// /// /// public void StartTimer() { m_heartbeatTimer.Enabled = true; m_heartbeatTimer.Interval = (int) (m_timespan*1000); m_heartbeatTimer.Elapsed += new ElapsedEventHandler(Heartbeat); } #region Update Methods /// /// Performs per-frame updates regularly /// /// /// private void Heartbeat(object sender, EventArgs e) { Update(); } /// /// Performs per-frame updates on the scene, this should be the central scene loop /// public override void Update() { TimeSpan SinceLastFrame = DateTime.Now - m_lastupdate; // Aquire a lock so only one update call happens at once updateLock.WaitOne(); try { // Increment the frame counter m_frame++; // Loop it if (m_frame == Int32.MaxValue) m_frame = 0; if (m_frame%m_update_physics == 0) UpdatePreparePhysics(); if (m_frame%m_update_entitymovement == 0) UpdateEntityMovement(); if (m_frame%m_update_physics == 0) UpdatePhysics( Math.Max(SinceLastFrame.TotalSeconds, m_timespan) ); if (m_frame%m_update_entities == 0) UpdateEntities(); if (m_frame%m_update_events == 0) UpdateEvents(); if (m_frame%m_update_backup == 0) UpdateStorageBackup(); if (m_frame%m_update_terrain == 0) UpdateTerrain(); if (m_frame%m_update_land == 0) UpdateLand(); if (m_frame%m_update_avatars == 0) UpdateInWorldTime(); } catch (NotImplementedException) { throw; } catch (Exception e) { MainLog.Instance.Error("Scene", "Failed with exception " + e.ToString()); } finally { updateLock.ReleaseMutex(); m_timedilation = m_timespan/(float) SinceLastFrame.TotalSeconds; m_lastupdate = DateTime.Now; } } private void UpdatePreparePhysics() { // If we are using a threaded physics engine // grab the latest scene from the engine before // trying to process it. // PhysX does this (runs in the background). if (phyScene.IsThreaded) { phyScene.GetResults(); } } private void UpdateInWorldTime() { m_timeUpdateCount++; if (m_timeUpdateCount > 600) { List avatars = GetAvatars(); foreach (ScenePresence avatar in avatars) { avatar.ControllingClient.SendViewerTime(m_timePhase); } m_timeUpdateCount = 0; m_timePhase++; if (m_timePhase > 94) { m_timePhase = 0; } } } private void UpdateLand() { if (m_LandManager.landPrimCountTainted) { //Perform land update of prim count performParcelPrimCountUpdate(); } } private void UpdateTerrain() { if (Terrain.Tainted() && !Terrain.StillEditing()) { CreateTerrainTexture(); lock (Terrain.heightmap) { lock (m_syncRoot) { phyScene.SetTerrain(Terrain.GetHeights1D()); } storageManager.DataStore.StoreTerrain(Terrain.GetHeights2DD(), RegionInfo.RegionID); float[] terData = Terrain.GetHeights1D(); Broadcast(delegate(IClientAPI client) { for (int x = 0; x < 16; x++) { for (int y = 0; y < 16; y++) { if (Terrain.Tainted(x*16, y*16)) { client.SendLayerData(x, y, terData); } } } }); Terrain.ResetTaint(); } } } private void UpdateStorageBackup() { Backup(); } private void UpdateEvents() { m_eventManager.TriggerOnFrame(); } private void UpdateEntities() { List updateEntities = new List(Entities.Values); foreach (EntityBase entity in updateEntities) { entity.Update(); } } private void UpdatePhysics(double elapsed) { lock (m_syncRoot) { phyScene.Simulate((float) elapsed); } } private void UpdateEntityMovement() { List moveEntities = new List(Entities.Values); foreach (EntityBase entity in moveEntities) { entity.UpdateMovement(); } } /// /// Perform delegate action on all clients subscribing to updates from this region. /// /// internal void Broadcast(Action whatToDo) { ForEachScenePresence(delegate(ScenePresence presence) { whatToDo(presence.ControllingClient); }); } /// /// /// /// public bool Backup() { EventManager.TriggerOnBackup(storageManager.DataStore); return true; } #endregion #region Load Terrain /// /// Loads the World heightmap /// /// public override void LoadWorldMap() { try { double[,] map = storageManager.DataStore.LoadTerrain(RegionInfo.RegionID); if (map == null) { if (string.IsNullOrEmpty(m_regInfo.EstateSettings.terrainFile)) { MainLog.Instance.Verbose("TERRAIN", "No default terrain. Generating a new terrain."); Terrain.HillsGenerator(); storageManager.DataStore.StoreTerrain(Terrain.GetHeights2DD(), RegionInfo.RegionID); } else { try { Terrain.LoadFromFileF32(m_regInfo.EstateSettings.terrainFile); Terrain *= m_regInfo.EstateSettings.terrainMultiplier; } catch { MainLog.Instance.Verbose("TERRAIN", "No terrain found in database or default. Generating a new terrain."); Terrain.HillsGenerator(); } storageManager.DataStore.StoreTerrain(Terrain.GetHeights2DD(), RegionInfo.RegionID); } } else { Terrain.SetHeights2D(map); } CreateTerrainTexture(); } catch (Exception e) { MainLog.Instance.Warn("terrain", "World.cs: LoadWorldMap() - Failed with exception " + e.ToString()); } } /// /// /// public void CreateTerrainTexture() { //create a texture asset of the terrain byte[] data = Terrain.ExportJpegImage("defaultstripe.png"); m_regInfo.EstateSettings.terrainImageID = LLUUID.Random(); AssetBase asset = new AssetBase(); asset.FullID = m_regInfo.EstateSettings.terrainImageID; asset.Data = data; asset.Name = "terrainImage"; asset.Type = 0; asset.Temporary = true; commsManager.AssetCache.AddAsset(asset); } #endregion #region Primitives Methods /// /// Loads the World's objects /// public virtual void LoadPrimsFromStorage() { MainLog.Instance.Verbose("Loading objects from datastore"); List PrimsFromDB = storageManager.DataStore.LoadObjects(m_regInfo.RegionID); foreach (SceneObjectGroup prim in PrimsFromDB) { AddEntityFromStorage(prim); SceneObjectPart rootPart = prim.GetChildPart(prim.UUID); if ((rootPart.ObjectFlags & (uint) LLObject.ObjectFlags.Phantom) == 0) rootPart.PhysActor = phyScene.AddPrimShape( rootPart.Name, rootPart.Shape, new PhysicsVector(rootPart.AbsolutePosition.X, rootPart.AbsolutePosition.Y, rootPart.AbsolutePosition.Z), new PhysicsVector(rootPart.Scale.X, rootPart.Scale.Y, rootPart.Scale.Z), new Quaternion(rootPart.RotationOffset.W, rootPart.RotationOffset.X, rootPart.RotationOffset.Y, rootPart.RotationOffset.Z)); } MainLog.Instance.Verbose("Loaded " + PrimsFromDB.Count.ToString() + " SceneObject(s)"); } /// /// Returns a new unallocated primitive ID /// /// A brand new primitive ID public uint PrimIDAllocate() { uint myID; _primAllocateMutex.WaitOne(); ++_primCount; myID = _primCount; _primAllocateMutex.ReleaseMutex(); return myID; } /// /// /// /// /// public void AddNewPrim(LLUUID ownerID, LLVector3 pos, PrimitiveBaseShape shape) { if (PermissionsMngr.CanRezObject(ownerID, pos)) { SceneObjectGroup sceneOb = new SceneObjectGroup(this, m_regionHandle, ownerID, PrimIDAllocate(), pos, shape); AddEntity(sceneOb); SceneObjectPart rootPart = sceneOb.GetChildPart(sceneOb.UUID); // if grass or tree, make phantom if ((rootPart.Shape.PCode == 95) || (rootPart.Shape.PCode == 255)) { rootPart.ObjectFlags += (uint) LLObject.ObjectFlags.Phantom; } // if not phantom, add to physics if ((rootPart.ObjectFlags & (uint) LLObject.ObjectFlags.Phantom) == 0) rootPart.PhysActor = phyScene.AddPrimShape( rootPart.Name, rootPart.Shape, new PhysicsVector(pos.X, pos.Y, pos.Z), new PhysicsVector(shape.Scale.X, shape.Scale.Y, shape.Scale.Z), new Quaternion()); } } public void RemovePrim(uint localID, LLUUID avatar_deleter) { foreach (EntityBase obj in Entities.Values) { if (obj is SceneObjectGroup) { if (((SceneObjectGroup) obj).LocalId == localID) { RemoveEntity((SceneObjectGroup) obj); return; } } } } public void AddEntityFromStorage(SceneObjectGroup sceneObject) { sceneObject.RegionHandle = m_regionHandle; sceneObject.SetScene(this); foreach (SceneObjectPart part in sceneObject.Children.Values) { part.LocalID = PrimIDAllocate(); } sceneObject.UpdateParentIDs(); AddEntity(sceneObject); } public void AddEntity(SceneObjectGroup sceneObject) { if (!Entities.ContainsKey(sceneObject.UUID)) { // QuadTree.AddObject(sceneObject); Entities.Add(sceneObject.UUID, sceneObject); } } public void RemoveEntity(SceneObjectGroup sceneObject) { if (Entities.ContainsKey(sceneObject.UUID)) { m_LandManager.removePrimFromLandPrimCounts(sceneObject); Entities.Remove(sceneObject.UUID); m_LandManager.setPrimsTainted(); } } /// /// Called by a prim when it has been created/cloned, so that its events can be subscribed to /// /// public void AcknowledgeNewPrim(SceneObjectGroup prim) { prim.OnPrimCountTainted += m_LandManager.setPrimsTainted; } public void LoadPrimsFromXml(string fileName) { XmlDocument doc = new XmlDocument(); XmlNode rootNode; int primCount = 0; if ((fileName.StartsWith("http:")) | (File.Exists(fileName))) { XmlTextReader reader = new XmlTextReader(fileName); reader.WhitespaceHandling = WhitespaceHandling.None; doc.Load(reader); reader.Close(); rootNode = doc.FirstChild; foreach (XmlNode aPrimNode in rootNode.ChildNodes) { SceneObjectGroup obj = new SceneObjectGroup(this, m_regionHandle, aPrimNode.OuterXml); //if we want this to be a import method then we need new uuids for the object to avoid any clashes //obj.RegenerateFullIDs(); AddEntity(obj); SceneObjectPart rootPart = obj.GetChildPart(obj.UUID); if ((rootPart.ObjectFlags & (uint) LLObject.ObjectFlags.Phantom) == 0) rootPart.PhysActor = phyScene.AddPrimShape( rootPart.Name, rootPart.Shape, new PhysicsVector(rootPart.AbsolutePosition.X, rootPart.AbsolutePosition.Y, rootPart.AbsolutePosition.Z), new PhysicsVector(rootPart.Scale.X, rootPart.Scale.Y, rootPart.Scale.Z), new Quaternion(rootPart.RotationOffset.W, rootPart.RotationOffset.X, rootPart.RotationOffset.Y, rootPart.RotationOffset.Z)); primCount++; } } else { throw new Exception("Could not open file " + fileName + " for reading"); } } public void SavePrimsToXml(string fileName) { FileStream file = new FileStream(fileName, FileMode.Create); StreamWriter stream = new StreamWriter(file); int primCount = 0; stream.WriteLine("\n"); foreach (EntityBase ent in Entities.Values) { if (ent is SceneObjectGroup) { stream.WriteLine(((SceneObjectGroup) ent).ToXmlString()); primCount++; } } stream.WriteLine("\n"); stream.Close(); file.Close(); } public void LoadPrimsFromXml2(string fileName) { XmlDocument doc = new XmlDocument(); XmlNode rootNode; if ((fileName.StartsWith("http:")) | (File.Exists(fileName))) { XmlTextReader reader = new XmlTextReader(fileName); reader.WhitespaceHandling = WhitespaceHandling.None; doc.Load(reader); reader.Close(); rootNode = doc.FirstChild; foreach (XmlNode aPrimNode in rootNode.ChildNodes) { CreatePrimFromXml(aPrimNode.OuterXml); } } else { throw new Exception("Could not open file " + fileName + " for reading"); } } public void CreatePrimFromXml(string xmlData) { SceneObjectGroup obj = new SceneObjectGroup(xmlData); AddEntityFromStorage(obj); SceneObjectPart rootPart = obj.GetChildPart(obj.UUID); if ((rootPart.ObjectFlags & (uint) LLObject.ObjectFlags.Phantom) == 0) rootPart.PhysActor = phyScene.AddPrimShape( rootPart.Name, rootPart.Shape, new PhysicsVector(rootPart.AbsolutePosition.X, rootPart.AbsolutePosition.Y, rootPart.AbsolutePosition.Z), new PhysicsVector(rootPart.Scale.X, rootPart.Scale.Y, rootPart.Scale.Z), new Quaternion(rootPart.RotationOffset.W, rootPart.RotationOffset.X, rootPart.RotationOffset.Y, rootPart.RotationOffset.Z)); } public void SavePrimsToXml2(string fileName) { FileStream file = new FileStream(fileName, FileMode.Create); StreamWriter stream = new StreamWriter(file); int primCount = 0; stream.WriteLine("\n"); foreach (EntityBase ent in Entities.Values) { if (ent is SceneObjectGroup) { stream.WriteLine(((SceneObjectGroup) ent).ToXmlString2()); primCount++; } } stream.WriteLine("\n"); stream.Close(); file.Close(); } #endregion #region Add/Remove Avatar Methods /// /// /// /// /// public override void AddNewClient(IClientAPI client, bool child) { SubscribeToClientEvents(client); m_estateManager.sendRegionHandshake(client); CreateAndAddScenePresence(client, child); m_LandManager.sendParcelOverlay(client); commsManager.UserProfileCache.AddNewUser(client.AgentId); commsManager.TransactionsManager.AddUser(client.AgentId); } protected virtual void SubscribeToClientEvents(IClientAPI client) { // client.OnStartAnim += StartAnimation; client.OnRegionHandShakeReply += SendLayerData; //remoteClient.OnRequestWearables += new GenericCall(this.GetInitialPrims); client.OnModifyTerrain += ModifyTerrain; //client.OnChatFromViewer += SimChat; client.OnRequestWearables += InformClientOfNeighbours; client.OnAddPrim += AddNewPrim; client.OnUpdatePrimGroupPosition += UpdatePrimPosition; client.OnUpdatePrimSinglePosition += UpdatePrimSinglePosition; client.OnUpdatePrimGroupRotation += UpdatePrimRotation; client.OnUpdatePrimGroupMouseRotation += UpdatePrimRotation; client.OnUpdatePrimSingleRotation += UpdatePrimSingleRotation; client.OnUpdatePrimScale += UpdatePrimScale; client.OnUpdateExtraParams += UpdateExtraParam; client.OnUpdatePrimShape += UpdatePrimShape; client.OnRequestMapBlocks += RequestMapBlocks; client.OnUpdatePrimTexture += UpdatePrimTexture; client.OnTeleportLocationRequest += RequestTeleportLocation; client.OnObjectSelect += SelectPrim; client.OnObjectDeselect += DeselectPrim; client.OnGrabUpdate += MoveObject; client.OnDeRezObject += DeRezObject; client.OnRezObject += RezObject; client.OnNameFromUUIDRequest += commsManager.HandleUUIDNameRequest; client.OnObjectDescription += PrimDescription; client.OnObjectName += PrimName; client.OnLinkObjects += LinkObjects; client.OnObjectDuplicate += DuplicateObject; client.OnParcelPropertiesRequest += new ParcelPropertiesRequest(m_LandManager.handleParcelPropertiesRequest); client.OnParcelDivideRequest += new ParcelDivideRequest(m_LandManager.handleParcelDivideRequest); client.OnParcelJoinRequest += new ParcelJoinRequest(m_LandManager.handleParcelJoinRequest); client.OnParcelPropertiesUpdateRequest += new ParcelPropertiesUpdateRequest(m_LandManager.handleParcelPropertiesUpdateRequest); client.OnParcelSelectObjects += new ParcelSelectObjects(m_LandManager.handleParcelSelectObjectsRequest); client.OnParcelObjectOwnerRequest += new ParcelObjectOwnerRequest(m_LandManager.handleParcelObjectOwnersRequest); client.OnEstateOwnerMessage += new EstateOwnerMessageRequest(m_estateManager.handleEstateOwnerMessage); client.OnCreateNewInventoryItem += CreateNewInventoryItem; client.OnCreateNewInventoryFolder += commsManager.UserProfileCache.HandleCreateInventoryFolder; client.OnFetchInventoryDescendents += commsManager.UserProfileCache.HandleFecthInventoryDescendents; client.OnRequestTaskInventory += RequestTaskInventory; client.OnFetchInventory += commsManager.UserProfileCache.HandleFetchInventory; client.OnUpdateInventoryItem += UDPUpdateInventoryItemAsset; client.OnAssetUploadRequest += commsManager.TransactionsManager.HandleUDPUploadRequest; client.OnXferReceive += commsManager.TransactionsManager.HandleXfer; client.OnRezScript += RezScript; client.OnRemoveTaskItem += RemoveTaskInventory; // client.OnRequestAvatarProperties += RequestAvatarProperty; client.OnGrabObject += ProcessObjectGrab; EventManager.TriggerOnNewClient(client); } protected ScenePresence CreateAndAddScenePresence(IClientAPI client, bool child) { ScenePresence newAvatar = null; byte[] visualParams; AvatarWearable[] wearables; if (m_AvatarFactory == null || !m_AvatarFactory.TryGetIntialAvatarAppearance(client.AgentId, out wearables, out visualParams)) { AvatarFactoryModule.GetDefaultAvatarAppearance(out wearables, out visualParams); } newAvatar = new ScenePresence(client, this, m_regInfo, visualParams, wearables); newAvatar.IsChildAgent = child; if (child) { MainLog.Instance.Verbose("SCENE", RegionInfo.RegionName + ": Creating new child agent."); } else { newAvatar.OnSignificantClientMovement += m_LandManager.handleSignificantClientMovement; MainLog.Instance.Verbose("SCENE", RegionInfo.RegionName + ": Creating new root agent."); MainLog.Instance.Verbose("SCENE", RegionInfo.RegionName + ": Adding Physical agent."); newAvatar.AddToPhysicalScene(); } lock (Entities) { if (!Entities.ContainsKey(client.AgentId)) { Entities.Add(client.AgentId, newAvatar); } else { Entities[client.AgentId] = newAvatar; } } lock (m_scenePresences) { if (m_scenePresences.ContainsKey(client.AgentId)) { m_scenePresences[client.AgentId] = newAvatar; } else { m_scenePresences.Add(client.AgentId, newAvatar); } } return newAvatar; } /// /// /// /// public override void RemoveClient(LLUUID agentID) { m_eventManager.TriggerOnRemovePresence(agentID); ScenePresence avatar = GetScenePresence(agentID); Broadcast(delegate(IClientAPI client) { client.SendKillObject(avatar.RegionHandle, avatar.LocalId); }); ForEachScenePresence( delegate(ScenePresence presence) { presence.CoarseLocationChange(); }); lock (m_scenePresences) { m_scenePresences.Remove(agentID); } lock (Entities) { Entities.Remove(agentID); } avatar.Close(); // Remove client agent from profile, so new logins will work commsManager.UserService.clearUserAgent(agentID); return; } #endregion #region Request m_scenePresences List Methods //The idea is to have a group of method that return a list of avatars meeting some requirement // ie it could be all m_scenePresences within a certain range of the calling prim/avatar. /// /// Request a List of all m_scenePresences in this World /// /// public List GetScenePresences() { List result = new List(m_scenePresences.Values); return result; } public List GetAvatars() { List result = GetScenePresences(delegate(ScenePresence scenePresence) { return !scenePresence.IsChildAgent; }); return result; } /// /// Request a filtered list of m_scenePresences in this World /// /// public List GetScenePresences(FilterAvatarList filter) { List result = new List(); foreach (ScenePresence avatar in m_scenePresences.Values) { if (filter(avatar)) { result.Add(avatar); } } return result; } /// /// Request a Avatar by UUID /// /// /// public ScenePresence GetScenePresence(LLUUID avatarID) { if (m_scenePresences.ContainsKey(avatarID)) { return m_scenePresences[avatarID]; } return null; } /// /// /// /// public void ForEachScenePresence(Action action) { foreach (ScenePresence presence in m_scenePresences.Values) { action(presence); } } public void ForEachObject(Action action) { foreach (SceneObjectGroup presence in m_sceneObjects.Values) { action(presence); } } #endregion /// /// /// /// /// public bool DeleteEntity(LLUUID entID) { if (Entities.ContainsKey(entID)) { Entities.Remove(entID); storageManager.DataStore.RemoveObject(entID, m_regInfo.RegionID); return true; } return false; } public void SendKillObject(uint localID) { Broadcast(delegate(IClientAPI client) { client.SendKillObject(m_regionHandle, localID); }); } public void NotifyMyCoarseLocationChange() { ForEachScenePresence(delegate(ScenePresence presence) { presence.CoarseLocationChange(); }); } public void SendAllSceneObjectsToClient(ScenePresence presence) { foreach (EntityBase ent in Entities.Values) { if (ent is SceneObjectGroup) { // ((SceneObjectGroup)ent).SendFullUpdateToClient(client); ((SceneObjectGroup) ent).ScheduleFullUpdateToAvatar(presence); } } } #region RegionCommsHost /// /// /// public void RegisterRegionWithComms() { regionCommsHost = commsManager.GridService.RegisterRegion(m_regInfo); if (regionCommsHost != null) { regionCommsHost.OnExpectUser += NewUserConnection; regionCommsHost.OnAvatarCrossingIntoRegion += AgentCrossing; } } /// /// /// /// /// public void NewUserConnection(ulong regionHandle, AgentCircuitData agent) { // Console.WriteLine("World.cs - add new user connection"); //should just check that its meant for this region if (regionHandle == m_regInfo.RegionHandle) { if (agent.CapsPath != "") { //Console.WriteLine("new user, so creating caps handler for it"); Caps cap = new Caps(commsManager.AssetCache, httpListener, m_regInfo.ExternalHostName, httpListener.Port, agent.CapsPath, agent.AgentID, m_dumpAssetsToFile); Util.SetCapsURL(agent.AgentID, "http://" + m_regInfo.ExternalHostName + ":" + httpListener.Port.ToString() + "/CAPS/" + agent.CapsPath + "0000/"); cap.RegisterHandlers(); cap.AddNewInventoryItem = AddInventoryItem; cap.ItemUpdatedCall = CapsUpdateInventoryItemAsset; if (capsHandlers.ContainsKey(agent.AgentID)) { MainLog.Instance.Warn("client", "Adding duplicate CAPS entry for user " + agent.AgentID.ToStringHyphenated()); capsHandlers[agent.AgentID] = cap; } else { capsHandlers.Add(agent.AgentID, cap); } } authenticateHandler.AddNewCircuit(agent.circuitcode, agent); } } public void AgentCrossing(ulong regionHandle, LLUUID agentID, LLVector3 position, bool isFlying) { if (regionHandle == m_regInfo.RegionHandle) { if (m_scenePresences.ContainsKey(agentID)) { m_scenePresences[agentID].MakeRootAgent(position, isFlying); } } } private delegate void InformClientOfNeighbourDelegate( IClientAPI remoteClient, AgentCircuitData a, ulong regionHandle, IPEndPoint endPoint); private void InformClientOfNeighbourCompleted(IAsyncResult iar) { InformClientOfNeighbourDelegate icon = (InformClientOfNeighbourDelegate) iar.AsyncState; icon.EndInvoke(iar); } /// /// Async compnent for informing client of which neighbours exists /// /// /// This needs to run asynchronesously, as a network timeout may block the thread for a long while /// /// /// /// /// private void InformClientOfNeighbourAsync(IClientAPI remoteClient, AgentCircuitData a, ulong regionHandle, IPEndPoint endPoint) { MainLog.Instance.Notice("INTERGRID", "Starting to inform client about neighbours"); bool regionAccepted = commsManager.InterRegion.InformRegionOfChildAgent(regionHandle, a); if (regionAccepted) remoteClient.InformClientOfNeighbour(regionHandle, endPoint); MainLog.Instance.Notice("INTERGRID", "Completed inform client about neighbours"); } /// /// /// public void InformClientOfNeighbours(IClientAPI remoteClient) { List neighbours = commsManager.GridService.RequestNeighbours(m_regInfo.RegionLocX, m_regInfo.RegionLocY); if (neighbours != null) { for (int i = 0; i < neighbours.Count; i++) { AgentCircuitData agent = remoteClient.RequestClientInfo(); agent.BaseFolder = LLUUID.Zero; agent.InventoryFolder = LLUUID.Zero; agent.startpos = new LLVector3(128, 128, 70); agent.child = true; InformClientOfNeighbourDelegate d = InformClientOfNeighbourAsync; d.BeginInvoke(remoteClient, agent, neighbours[i].RegionHandle, neighbours[i].ExternalEndPoint, InformClientOfNeighbourCompleted, d); } } } /// /// /// /// /// public RegionInfo RequestNeighbouringRegionInfo(ulong regionHandle) { return commsManager.GridService.RequestNeighbourInfo(regionHandle); } /// /// /// /// /// /// /// public void RequestMapBlocks(IClientAPI remoteClient, int minX, int minY, int maxX, int maxY) { List mapBlocks; mapBlocks = commsManager.GridService.RequestNeighbourMapBlocks(minX, minY, maxX, maxY); remoteClient.SendMapBlock(mapBlocks); } /// /// /// /// /// /// /// /// public void RequestTeleportLocation(IClientAPI remoteClient, ulong regionHandle, LLVector3 position, LLVector3 lookAt, uint flags) { if (regionHandle == m_regionHandle) { if (m_scenePresences.ContainsKey(remoteClient.AgentId)) { remoteClient.SendTeleportLocationStart(); remoteClient.SendLocalTeleport(position, lookAt, flags); m_scenePresences[remoteClient.AgentId].Teleport(position); } } else { RegionInfo reg = RequestNeighbouringRegionInfo(regionHandle); if (reg != null) { remoteClient.SendTeleportLocationStart(); AgentCircuitData agent = remoteClient.RequestClientInfo(); agent.BaseFolder = LLUUID.Zero; agent.InventoryFolder = LLUUID.Zero; // agent.startpos = new LLVector3(128, 128, 70); agent.startpos = position; agent.child = true; m_scenePresences[remoteClient.AgentId].Close(); commsManager.InterRegion.InformRegionOfChildAgent(regionHandle, agent); commsManager.InterRegion.ExpectAvatarCrossing(regionHandle, remoteClient.AgentId, position, false); AgentCircuitData circuitdata = remoteClient.RequestClientInfo(); string capsPath = Util.GetCapsURL(remoteClient.AgentId); remoteClient.SendRegionTeleport(regionHandle, 13, reg.ExternalEndPoint, 4, (1 << 4), capsPath); } } } /// /// /// /// /// /// public bool InformNeighbourOfCrossing(ulong regionhandle, LLUUID agentID, LLVector3 position, bool isFlying) { return commsManager.InterRegion.ExpectAvatarCrossing(regionhandle, agentID, position, isFlying); } public void performParcelPrimCountUpdate() { m_LandManager.resetAllLandPrimCounts(); m_eventManager.TriggerParcelPrimCountUpdate(); m_LandManager.finalizeLandPrimCountUpdate(); m_LandManager.landPrimCountTainted = false; } #endregion public void AddModule(string name, IRegionModule module) { if (!Modules.ContainsKey(name)) { Modules.Add(name, module); } } public void RegisterModuleInterface(M mod) { if (!ModuleInterfaces.ContainsKey(typeof (M))) { ModuleInterfaces.Add(typeof (M), mod); } } public T RequestModuleInterface() { if (ModuleInterfaces.ContainsKey(typeof (T))) { return (T) ModuleInterfaces[typeof (T)]; } else { return default(T); } } public void SetTimePhase(int phase) { m_timePhase = phase; } public void SendUrlToUser(LLUUID avatarID, string objectname, LLUUID objectID, LLUUID ownerID, bool groupOwned, string message, string url) { if (m_scenePresences.ContainsKey(avatarID)) { m_scenePresences[avatarID].ControllingClient.SendLoadURL(objectname, objectID, ownerID, groupOwned, message, url); } } #region Alert Methods private void SendPermissionAlert(LLUUID user, string reason) { SendAlertToUser(user, reason, false); } public void SendGeneralAlert(string message) { foreach (ScenePresence presence in m_scenePresences.Values) { presence.ControllingClient.SendAlertMessage(message); } } public void SendAlertToUser(LLUUID agentID, string message, bool modal) { if (m_scenePresences.ContainsKey(agentID)) { m_scenePresences[agentID].ControllingClient.SendAgentAlertMessage(message, modal); } } public void SendAlertToUser(string firstName, string lastName, string message, bool modal) { foreach (ScenePresence presence in m_scenePresences.Values) { if ((presence.Firstname == firstName) && (presence.Lastname == lastName)) { presence.ControllingClient.SendAgentAlertMessage(message, modal); break; } } } public void HandleAlertCommand(string[] commandParams) { if (commandParams[0] == "general") { string message = CombineParams(commandParams, 1); SendGeneralAlert(message); } else { string message = CombineParams(commandParams, 2); SendAlertToUser(commandParams[0], commandParams[1], message, false); } } private string CombineParams(string[] commandParams, int pos) { string result = ""; for (int i = pos; i < commandParams.Length; i++) { result += commandParams[i] + " "; } return result; } #endregion public void ForceClientUpdate() { foreach (EntityBase ent in Entities.Values) { if (ent is SceneObjectGroup) { ((SceneObjectGroup) ent).ScheduleGroupForFullUpdate(); } } } public void HandleEditCommand(string[] cmmdparams) { Console.WriteLine("Searching for Primitive: '" + cmmdparams[0] + "'"); foreach (EntityBase ent in Entities.Values) { if (ent is SceneObjectGroup) { SceneObjectPart part = ((SceneObjectGroup) ent).GetChildPart(((SceneObjectGroup) ent).UUID); if (part != null) { if (part.Name == cmmdparams[0]) { part.Resize( new LLVector3(Convert.ToSingle(cmmdparams[1]), Convert.ToSingle(cmmdparams[2]), Convert.ToSingle(cmmdparams[3]))); Console.WriteLine("Edited scale of Primitive: " + part.Name); } } } } } public void Show(string ShowWhat) { switch (ShowWhat) { case "users": MainLog.Instance.Error("Current Region: " + RegionInfo.RegionName); MainLog.Instance.Error( String.Format("{0,-16}{1,-16}{2,-25}{3,-25}{4,-16}{5,-16}{6,-16}", "Firstname", "Lastname", "Agent ID", "Session ID", "Circuit", "IP", "World")); foreach (ScenePresence scenePrescence in GetAvatars()) { MainLog.Instance.Error( String.Format("{0,-16}{1,-16}{2,-25}{3,-25}{4,-16},{5,-16}{6,-16}", scenePrescence.Firstname, scenePrescence.Lastname, scenePrescence.UUID, scenePrescence.ControllingClient.AgentId, "Unknown", "Unknown", RegionInfo.RegionName)); } break; case "modules": MainLog.Instance.Error("The currently loaded modules in " + RegionInfo.RegionName + " are:"); foreach (IRegionModule module in Modules.Values) { if (!module.IsSharedModule) { MainLog.Instance.Error("Region Module: " + module.Name); } } break; } } public LLUUID MakeHttpRequest(string url, string type, string body) { if (m_httpRequestModule != null) { return m_httpRequestModule.MakeHttpRequest(url, type, body); } return LLUUID.Zero; } #region Script Engine private List ScriptEngines = new List(); private bool m_dumpAssetsToFile; public void AddScriptEngine(ScriptEngineInterface ScriptEngine, LogBase m_logger) { ScriptEngines.Add(ScriptEngine); ScriptEngine.InitializeEngine(this, m_logger); } #endregion public LLUUID ConvertLocalIDToFullID(uint localID) { bool hasPrim = false; foreach (EntityBase ent in Entities.Values) { if (ent is SceneObjectGroup) { hasPrim = ((SceneObjectGroup) ent).HasChildPrim(localID); if (hasPrim != false) { return ((SceneObjectGroup) ent).GetPartsFullID(localID); } } } return LLUUID.Zero; } public SceneObjectPart GetSceneObjectPart(uint localID) { bool hasPrim = false; foreach (EntityBase ent in Entities.Values) { if (ent is SceneObjectGroup) { hasPrim = ((SceneObjectGroup) ent).HasChildPrim(localID); if (hasPrim != false) { return ((SceneObjectGroup) ent).GetChildPart(localID); } } } return null; } public SceneObjectPart GetSceneObjectPart(LLUUID fullID) { bool hasPrim = false; foreach (EntityBase ent in Entities.Values) { if (ent is SceneObjectGroup) { hasPrim = ((SceneObjectGroup) ent).HasChildPrim(fullID); if (hasPrim != false) { return ((SceneObjectGroup) ent).GetChildPart(fullID); } } } return null; } internal bool TryGetAvatar(LLUUID avatarId, out ScenePresence avatar) { ScenePresence presence; if (m_scenePresences.TryGetValue(avatarId, out presence)) { if (!presence.IsChildAgent) { avatar = presence; return true; } } avatar = null; return false; } public override void Close() { m_heartbeatTimer.Close(); base.Close(); } internal bool TryGetAvatarByName(string avatarName, out ScenePresence avatar) { foreach (ScenePresence presence in m_scenePresences.Values) { if (!presence.IsChildAgent) { string name = presence.ControllingClient.FirstName + " " + presence.ControllingClient.LastName; if (String.Compare(avatarName, name, true) == 0) { avatar = presence; return true; } } } avatar = null; return false; } internal void ForEachClient(Action action) { foreach (ScenePresence presence in m_scenePresences.Values) { action(presence.ControllingClient); } } } }