diff --git a/OpenSim/ApplicationPlugins/Rest/Inventory/RestAppearanceServices.cs b/OpenSim/ApplicationPlugins/Rest/Inventory/RestAppearanceServices.cs
index 019ca73dd1..0188eb716e 100644
--- a/OpenSim/ApplicationPlugins/Rest/Inventory/RestAppearanceServices.cs
+++ b/OpenSim/ApplicationPlugins/Rest/Inventory/RestAppearanceServices.cs
@@ -44,7 +44,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
// private static readonly int PARM_PATH = 1;
- private bool enabled = false;
+// private bool enabled = false;
private string qPrefix = "appearance";
///
@@ -74,7 +74,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
// Activate if everything went OK
- enabled = true;
+// enabled = true;
Rest.Log.InfoFormat("{0} User appearance services initialization complete", MsgId);
}
@@ -95,7 +95,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
public void Close()
{
- enabled = false;
+// enabled = false;
Rest.Log.InfoFormat("{0} User appearance services closing down", MsgId);
}
diff --git a/OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs b/OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs
index c3cf08c18d..b4156621bb 100644
--- a/OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs
+++ b/OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs
@@ -46,12 +46,12 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
public class RestInventoryServices : IRest
{
// private static readonly int PARM_USERID = 0;
- private static readonly int PARM_PATH = 1;
+// private static readonly int PARM_PATH = 1;
// private bool enabled = false;
private string qPrefix = "inventory";
- private static readonly string PRIVATE_ROOT_NAME = "My Inventory";
+// private static readonly string PRIVATE_ROOT_NAME = "My Inventory";
///
/// The constructor makes sure that the service prefix is absolute
diff --git a/OpenSim/Framework/Serialization/External/UserInventoryItemSerializer.cs b/OpenSim/Framework/Serialization/External/UserInventoryItemSerializer.cs
index d5e84c779e..f138437ad5 100644
--- a/OpenSim/Framework/Serialization/External/UserInventoryItemSerializer.cs
+++ b/OpenSim/Framework/Serialization/External/UserInventoryItemSerializer.cs
@@ -303,7 +303,7 @@ namespace OpenSim.Framework.Serialization.External
writer.WriteStartElement("GroupOwned");
writer.WriteString(inventoryItem.GroupOwned.ToString());
writer.WriteEndElement();
- if (inventoryItem.CreatorData != null && inventoryItem.CreatorData != string.Empty)
+ if (options.ContainsKey("creators") && inventoryItem.CreatorData != null && inventoryItem.CreatorData != string.Empty)
writer.WriteElementString("CreatorData", inventoryItem.CreatorData);
else if (options.ContainsKey("profile"))
{
diff --git a/OpenSim/Framework/Servers/BaseOpenSimServer.cs b/OpenSim/Framework/Servers/BaseOpenSimServer.cs
index ebf7ded925..5c3cad4e69 100644
--- a/OpenSim/Framework/Servers/BaseOpenSimServer.cs
+++ b/OpenSim/Framework/Servers/BaseOpenSimServer.cs
@@ -319,18 +319,21 @@ namespace OpenSim.Framework.Servers
return;
}
- string rawLevel = cmd[3];
-
- ILoggerRepository repository = LogManager.GetRepository();
- Level consoleLevel = repository.LevelMap[rawLevel];
-
- if (consoleLevel != null)
- m_consoleAppender.Threshold = consoleLevel;
- else
- Notice(
- String.Format(
- "{0} is not a valid logging level. Valid logging levels are ALL, DEBUG, INFO, WARN, ERROR, FATAL, OFF",
- rawLevel));
+ if (cmd.Length > 3)
+ {
+ string rawLevel = cmd[3];
+
+ ILoggerRepository repository = LogManager.GetRepository();
+ Level consoleLevel = repository.LevelMap[rawLevel];
+
+ if (consoleLevel != null)
+ m_consoleAppender.Threshold = consoleLevel;
+ else
+ Notice(
+ String.Format(
+ "{0} is not a valid logging level. Valid logging levels are ALL, DEBUG, INFO, WARN, ERROR, FATAL, OFF",
+ rawLevel));
+ }
Notice(String.Format("Console log level is {0}", m_consoleAppender.Threshold));
}
diff --git a/OpenSim/Framework/Util.cs b/OpenSim/Framework/Util.cs
index 96292fff2e..821f1a098e 100644
--- a/OpenSim/Framework/Util.cs
+++ b/OpenSim/Framework/Util.cs
@@ -1346,6 +1346,11 @@ namespace OpenSim.Framework
return (ipaddr1 != null) ? "http://" + ipaddr1.ToString() + ":" + port1 : uri;
}
+ public static byte[] StringToBytes256(string str, params object[] args)
+ {
+ return StringToBytes256(string.Format(str, args));
+ }
+
public static byte[] StringToBytes256(string str)
{
if (String.IsNullOrEmpty(str)) { return Utils.EmptyBytes; }
@@ -1364,6 +1369,11 @@ namespace OpenSim.Framework
return data;
}
+ public static byte[] StringToBytes1024(string str, params object[] args)
+ {
+ return StringToBytes1024(string.Format(str, args));
+ }
+
public static byte[] StringToBytes1024(string str)
{
if (String.IsNullOrEmpty(str)) { return Utils.EmptyBytes; }
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs b/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
index f1fdbc513a..d6159cd52e 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
@@ -122,6 +122,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
public int PacketsReceived;
/// Number of packets sent to this client
public int PacketsSent;
+ /// Number of packets resent to this client
+ public int PacketsResent;
/// Total byte count of unacked packets sent to this client
public int UnackedBytes;
@@ -257,9 +259,10 @@ namespace OpenSim.Region.ClientStack.LindenUDP
public string GetStats()
{
return string.Format(
- "{0,7} {1,7} {2,9} {3,8} {4,7} {5,7} {6,7} {7,7} {8,9} {9,7} {10,7}",
+ "{0,7} {1,7} {2,7} {3,9} {4,7} {5,7} {6,7} {7,7} {8,7} {9,8} {10,7} {11,7}",
+ PacketsReceived,
PacketsSent,
- PacketsReceived,
+ PacketsResent,
UnackedBytes,
m_packetOutboxes[(int)ThrottleOutPacketType.Resend].Count,
m_packetOutboxes[(int)ThrottleOutPacketType.Land].Count,
@@ -449,13 +452,16 @@ namespace OpenSim.Region.ClientStack.LindenUDP
/// an outgoing packet from each, obeying the throttling bucket limits
///
///
+ ///
/// Packet queues are inspected in ascending numerical order starting from 0. Therefore, queues with a lower
/// ThrottleOutPacketType number will see their packet get sent first (e.g. if both Land and Wind queues have
/// packets, then the packet at the front of the Land queue will be sent before the packet at the front of the
/// wind queue).
///
- /// This function is only called from a synchronous loop in the
- /// UDPServer so we don't need to bother making this thread safe
+ /// This function is only called from a synchronous loop in the
+ /// UDPServer so we don't need to bother making this thread safe
+ ///
+ ///
/// True if any packets were sent, otherwise false
public bool DequeueOutgoing()
{
@@ -486,7 +492,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP
m_udpServer.SendPacketFinal(nextPacket);
m_nextPackets[i] = null;
packetSent = true;
- this.PacketsSent++;
}
}
else
@@ -503,7 +508,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP
// Send the packet
m_udpServer.SendPacketFinal(packet);
packetSent = true;
- this.PacketsSent++;
}
else
{
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs b/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs
index 703176c21c..cfcc0576ff 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs
@@ -506,7 +506,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP
// Bump up the resend count on this packet
Interlocked.Increment(ref outgoingPacket.ResendCount);
- //Interlocked.Increment(ref Stats.ResentPackets);
// Requeue or resend the packet
if (!outgoingPacket.Client.EnqueueOutgoing(outgoingPacket, false))
@@ -582,6 +581,10 @@ namespace OpenSim.Region.ClientStack.LindenUDP
udpClient.NeedAcks.Add(outgoingPacket);
}
}
+ else
+ {
+ Interlocked.Increment(ref udpClient.PacketsResent);
+ }
#endregion Sequence Number Assignment
diff --git a/OpenSim/Region/CoreModules/Avatar/Assets/GetTextureModule.cs b/OpenSim/Region/CoreModules/Avatar/Assets/GetTextureModule.cs
index 6fb8b4625c..df4d561024 100644
--- a/OpenSim/Region/CoreModules/Avatar/Assets/GetTextureModule.cs
+++ b/OpenSim/Region/CoreModules/Avatar/Assets/GetTextureModule.cs
@@ -245,14 +245,12 @@ namespace OpenSim.Region.CoreModules.Avatar.ObjectCaps
WriteTextureData(httpRequest, httpResponse, texture, format);
return true;
}
-
}
// not found
- m_log.Warn("[GETTEXTURE]: Texture " + textureID + " not found");
+// m_log.Warn("[GETTEXTURE]: Texture " + textureID + " not found");
httpResponse.StatusCode = (int)System.Net.HttpStatusCode.NotFound;
return true;
-
}
private void WriteTextureData(OSHttpRequest request, OSHttpResponse response, AssetBase texture, string format)
diff --git a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
index b1c2a3c683..68538c9801 100644
--- a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
+++ b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
@@ -128,6 +128,11 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
+ " is the user's last name." + Environment.NewLine
+ " is the path inside the user's inventory for the folder/item to be saved." + Environment.NewLine
+ "-p|--profile= adds the url of the profile service to the saved user information." + Environment.NewLine
+<<<<<<< HEAD:OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
+=======
+ + "-c|--creators preserves information about foreign creators." + Environment.NewLine
+ + "-v|--verbose extra debug messages." + Environment.NewLine
+>>>>>>> master:OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
+ " is the filesystem path at which to save the IAR."
+ string.Format(" If this is not given then the filename {0} in the current directory is used", DEFAULT_INV_BACKUP_FILENAME),
HandleSaveInvConsoleCommand);
@@ -394,6 +399,11 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
OptionSet ops = new OptionSet();
//ops.Add("v|version=", delegate(string v) { options["version"] = v; });
ops.Add("p|profile=", delegate(string v) { options["profile"] = v; });
+<<<<<<< HEAD:OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
+=======
+ ops.Add("v|verbose", delegate(string v) { options["verbose"] = v; });
+ ops.Add("c|creators", delegate(string v) { options["creators"] = v; });
+>>>>>>> master:OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
List mainParams = ops.Parse(cmdparams);
diff --git a/OpenSim/Region/CoreModules/Framework/EntityTransfer/EntityTransferModule.cs b/OpenSim/Region/CoreModules/Framework/EntityTransfer/EntityTransferModule.cs
index 9e1d414861..ca29a7c5c6 100644
--- a/OpenSim/Region/CoreModules/Framework/EntityTransfer/EntityTransferModule.cs
+++ b/OpenSim/Region/CoreModules/Framework/EntityTransfer/EntityTransferModule.cs
@@ -1006,7 +1006,7 @@ namespace OpenSim.Region.CoreModules.Framework.EntityTransfer
///
public void EnableChildAgent(ScenePresence sp, GridRegion region)
{
- m_log.DebugFormat("[ENTITY TRANSFER]: Enabling child agent in new neighour {0}", region.RegionName);
+ m_log.DebugFormat("[ENTITY TRANSFER]: Enabling child agent in new neighbour {0}", region.RegionName);
AgentCircuitData currentAgentCircuit = sp.Scene.AuthenticateHandler.GetAgentCircuitData(sp.ControllingClient.CircuitCode);
AgentCircuitData agent = sp.ControllingClient.RequestClientInfo();
diff --git a/OpenSim/Region/CoreModules/Framework/InventoryAccess/HGInventoryAccessModule.cs b/OpenSim/Region/CoreModules/Framework/InventoryAccess/HGInventoryAccessModule.cs
index 34b811428d..4565d103ff 100644
--- a/OpenSim/Region/CoreModules/Framework/InventoryAccess/HGInventoryAccessModule.cs
+++ b/OpenSim/Region/CoreModules/Framework/InventoryAccess/HGInventoryAccessModule.cs
@@ -55,6 +55,7 @@ namespace OpenSim.Region.CoreModules.Framework.InventoryAccess
}
private string m_ProfileServerURI;
+ private bool m_OutboundPermission;
// private bool m_Initialized = false;
@@ -78,7 +79,10 @@ namespace OpenSim.Region.CoreModules.Framework.InventoryAccess
IConfig thisModuleConfig = source.Configs["HGInventoryAccessModule"];
if (thisModuleConfig != null)
+ {
m_ProfileServerURI = thisModuleConfig.GetString("ProfileServerURI", string.Empty);
+ m_OutboundPermission = thisModuleConfig.GetBoolean("OutboundPermission", true);
+ }
else
m_log.Warn("[HG INVENTORY ACCESS MODULE]: HGInventoryAccessModule configs not found. ProfileServerURI not set!");
}
@@ -103,7 +107,7 @@ namespace OpenSim.Region.CoreModules.Framework.InventoryAccess
public void UploadInventoryItem(UUID avatarID, UUID assetID, string name, int userlevel)
{
string userAssetServer = string.Empty;
- if (IsForeignUser(avatarID, out userAssetServer))
+ if (IsForeignUser(avatarID, out userAssetServer) && m_OutboundPermission)
{
Util.FireAndForget(delegate { m_assMapper.Post(assetID, avatarID, userAssetServer); });
}
@@ -197,7 +201,7 @@ namespace OpenSim.Region.CoreModules.Framework.InventoryAccess
if (IsForeignUser(sender, out userAssetServer))
m_assMapper.Get(item.AssetID, sender, userAssetServer);
- if (IsForeignUser(receiver, out userAssetServer))
+ if (IsForeignUser(receiver, out userAssetServer) && m_OutboundPermission)
m_assMapper.Post(item.AssetID, receiver, userAssetServer);
}
diff --git a/OpenSim/Region/CoreModules/ServiceConnectorsOut/Inventory/HGInventoryBroker.cs b/OpenSim/Region/CoreModules/ServiceConnectorsOut/Inventory/HGInventoryBroker.cs
index 39410b561b..3f63db371f 100644
--- a/OpenSim/Region/CoreModules/ServiceConnectorsOut/Inventory/HGInventoryBroker.cs
+++ b/OpenSim/Region/CoreModules/ServiceConnectorsOut/Inventory/HGInventoryBroker.cs
@@ -200,6 +200,11 @@ namespace OpenSim.Region.CoreModules.ServiceConnectorsOut.Inventory
return;
}
}
+ else
+ {
+ m_log.DebugFormat("[HG INVENTORY CONNECTOR]: User {0} does not have InventoryServerURI. OH NOES!", userID);
+ return;
+ }
}
}
}
diff --git a/OpenSim/Region/CoreModules/ServiceConnectorsOut/Inventory/RemoteInventoryServiceConnector.cs b/OpenSim/Region/CoreModules/ServiceConnectorsOut/Inventory/RemoteInventoryServiceConnector.cs
deleted file mode 100644
index 9213132866..0000000000
--- a/OpenSim/Region/CoreModules/ServiceConnectorsOut/Inventory/RemoteInventoryServiceConnector.cs
+++ /dev/null
@@ -1,362 +0,0 @@
-/*
- * 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 OpenSimulator 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 log4net;
-using System;
-using System.Collections.Generic;
-using System.Reflection;
-using Nini.Config;
-using OpenSim.Framework;
-using OpenSim.Framework.Statistics;
-using OpenSim.Services.Connectors;
-using OpenSim.Region.Framework.Interfaces;
-using OpenSim.Region.Framework.Scenes;
-using OpenSim.Services.Interfaces;
-using OpenMetaverse;
-
-namespace OpenSim.Region.CoreModules.ServiceConnectorsOut.Inventory
-{
- public class RemoteInventoryServicesConnector : BaseInventoryConnector, ISharedRegionModule, IInventoryService
- {
- private static readonly ILog m_log =
- LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
-
- private bool m_Enabled = false;
- private bool m_Initialized = false;
- private Scene m_Scene;
- private InventoryServicesConnector m_RemoteConnector;
-
- private IUserManagement m_UserManager;
- private IUserManagement UserManager
- {
- get
- {
- if (m_UserManager == null)
- {
- m_UserManager = m_Scene.RequestModuleInterface();
- }
- return m_UserManager;
- }
- }
-
-
- public Type ReplaceableInterface
- {
- get { return null; }
- }
-
- public string Name
- {
- get { return "RemoteInventoryServicesConnector"; }
- }
-
- public RemoteInventoryServicesConnector()
- {
- }
-
- public RemoteInventoryServicesConnector(IConfigSource source)
- {
- Init(source);
- }
-
- protected override void Init(IConfigSource source)
- {
- m_RemoteConnector = new InventoryServicesConnector(source);
- base.Init(source);
- }
-
- #region ISharedRegionModule
-
- public void Initialise(IConfigSource source)
- {
- IConfig moduleConfig = source.Configs["Modules"];
- if (moduleConfig != null)
- {
- string name = moduleConfig.GetString("InventoryServices", "");
- if (name == Name)
- {
- Init(source);
- m_Enabled = true;
-
- m_log.Info("[INVENTORY CONNECTOR]: Remote inventory enabled");
- }
- }
- }
-
- public void PostInitialise()
- {
- }
-
- public void Close()
- {
- }
-
- public void AddRegion(Scene scene)
- {
-// m_Scene = scene;
- //m_log.Debug("[XXXX] Adding scene " + m_Scene.RegionInfo.RegionName);
-
- if (!m_Enabled)
- return;
-
- if (!m_Initialized)
- {
- m_Initialized = true;
- }
-
- scene.RegisterModuleInterface(this);
- m_cache.AddRegion(scene);
-
- if (m_Scene == null)
- m_Scene = scene;
- }
-
- public void RemoveRegion(Scene scene)
- {
- if (!m_Enabled)
- return;
-
- m_cache.RemoveRegion(scene);
- }
-
- public void RegionLoaded(Scene scene)
- {
- if (!m_Enabled)
- return;
-
- m_log.InfoFormat("[INVENTORY CONNECTOR]: Enabled remote inventory for region {0}", scene.RegionInfo.RegionName);
-
- }
-
- #endregion ISharedRegionModule
-
- #region IInventoryService
-
- public override bool CreateUserInventory(UUID user)
- {
- return false;
- }
-
- public override List GetInventorySkeleton(UUID userId)
- {
- return new List();
- }
-
- public override InventoryCollection GetUserInventory(UUID userID)
- {
- return null;
- }
-
- public override void GetUserInventory(UUID userID, InventoryReceiptCallback callback)
- {
- UUID sessionID = GetSessionID(userID);
- try
- {
- m_RemoteConnector.GetUserInventory(userID.ToString(), sessionID, callback);
- }
- catch (Exception e)
- {
- if (StatsManager.SimExtraStats != null)
- StatsManager.SimExtraStats.AddInventoryServiceRetrievalFailure();
-
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Request inventory operation failed, {0} {1}",
- e.Source, e.Message);
- }
-
- }
-
- // inherited. See base class
- // public InventoryFolderBase GetFolderForType(UUID userID, AssetType type)
-
- public override Dictionary GetSystemFolders(UUID userID)
- {
- UUID sessionID = GetSessionID(userID);
- return m_RemoteConnector.GetSystemFolders(userID.ToString(), sessionID);
- }
-
- public override InventoryCollection GetFolderContent(UUID userID, UUID folderID)
- {
- UUID sessionID = GetSessionID(userID);
- try
- {
- InventoryCollection invCol = m_RemoteConnector.GetFolderContent(userID.ToString(), folderID, sessionID);
- foreach (InventoryItemBase item in invCol.Items)
- UserManager.AddUser(item.CreatorIdAsUuid, item.CreatorData);
- return invCol;
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: GetFolderContent operation failed, {0} {1}",
- e.Source, e.Message);
- }
- InventoryCollection nullCollection = new InventoryCollection();
- nullCollection.Folders = new List();
- nullCollection.Items = new List();
- nullCollection.UserID = userID;
- return nullCollection;
- }
-
- public override List GetFolderItems(UUID userID, UUID folderID)
- {
- UUID sessionID = GetSessionID(userID);
- return m_RemoteConnector.GetFolderItems(userID.ToString(), folderID, sessionID);
- }
-
- public override bool AddFolder(InventoryFolderBase folder)
- {
- if (folder == null)
- return false;
-
- UUID sessionID = GetSessionID(folder.Owner);
- return m_RemoteConnector.AddFolder(folder.Owner.ToString(), folder, sessionID);
- }
-
- public override bool UpdateFolder(InventoryFolderBase folder)
- {
- if (folder == null)
- return false;
-
- UUID sessionID = GetSessionID(folder.Owner);
- return m_RemoteConnector.UpdateFolder(folder.Owner.ToString(), folder, sessionID);
- }
-
- public override bool MoveFolder(InventoryFolderBase folder)
- {
- if (folder == null)
- return false;
-
- UUID sessionID = GetSessionID(folder.Owner);
- return m_RemoteConnector.MoveFolder(folder.Owner.ToString(), folder, sessionID);
- }
-
- public override bool DeleteFolders(UUID ownerID, List folderIDs)
- {
- if (folderIDs == null)
- return false;
- if (folderIDs.Count == 0)
- return false;
-
- UUID sessionID = GetSessionID(ownerID);
- return m_RemoteConnector.DeleteFolders(ownerID.ToString(), folderIDs, sessionID);
- }
-
-
- public override bool PurgeFolder(InventoryFolderBase folder)
- {
- if (folder == null)
- return false;
-
- UUID sessionID = GetSessionID(folder.Owner);
- return m_RemoteConnector.PurgeFolder(folder.Owner.ToString(), folder, sessionID);
- }
-
- // public bool AddItem(InventoryItemBase item) inherited
- // Uses AddItemPlain
-
- protected override bool AddItemPlain(InventoryItemBase item)
- {
- if (item == null)
- return false;
-
- UUID sessionID = GetSessionID(item.Owner);
- return m_RemoteConnector.AddItem(item.Owner.ToString(), item, sessionID);
- }
-
- public override bool UpdateItem(InventoryItemBase item)
- {
- if (item == null)
- return false;
-
- UUID sessionID = GetSessionID(item.Owner);
- return m_RemoteConnector.UpdateItem(item.Owner.ToString(), item, sessionID);
- }
-
- public override bool MoveItems(UUID ownerID, List items)
- {
- if (items == null)
- return false;
-
- UUID sessionID = GetSessionID(ownerID);
- return m_RemoteConnector.MoveItems(ownerID.ToString(), items, sessionID);
- }
-
-
- public override bool DeleteItems(UUID ownerID, List itemIDs)
- {
- if (itemIDs == null)
- return false;
- if (itemIDs.Count == 0)
- return true;
-
- UUID sessionID = GetSessionID(ownerID);
- return m_RemoteConnector.DeleteItems(ownerID.ToString(), itemIDs, sessionID);
- }
-
- public override InventoryItemBase GetItem(InventoryItemBase item)
- {
- if (item == null)
- return null;
-
- UUID sessionID = GetSessionID(item.Owner);
- return m_RemoteConnector.QueryItem(item.Owner.ToString(), item, sessionID);
- }
-
- public override InventoryFolderBase GetFolder(InventoryFolderBase folder)
- {
- if (folder == null)
- return null;
-
- UUID sessionID = GetSessionID(folder.Owner);
- return m_RemoteConnector.QueryFolder(folder.Owner.ToString(), folder, sessionID);
- }
-
- public override bool HasInventoryForUser(UUID userID)
- {
- return false;
- }
-
- public override List GetActiveGestures(UUID userId)
- {
- return new List();
- }
-
- public override int GetAssetPermissions(UUID userID, UUID assetID)
- {
- UUID sessionID = GetSessionID(userID);
- return m_RemoteConnector.GetAssetPermissions(userID.ToString(), assetID, sessionID);
- }
-
-
- #endregion
-
- private UUID GetSessionID(UUID userID)
- {
- return UUID.Zero;
- }
-
- }
-}
diff --git a/OpenSim/Region/CoreModules/ServiceConnectorsOut/Simulation/LocalSimulationConnector.cs b/OpenSim/Region/CoreModules/ServiceConnectorsOut/Simulation/LocalSimulationConnector.cs
index 971a56f979..9363714e3c 100644
--- a/OpenSim/Region/CoreModules/ServiceConnectorsOut/Simulation/LocalSimulationConnector.cs
+++ b/OpenSim/Region/CoreModules/ServiceConnectorsOut/Simulation/LocalSimulationConnector.cs
@@ -225,17 +225,17 @@ namespace OpenSim.Region.CoreModules.ServiceConnectorsOut.Simulation
if (destination == null)
return false;
+ // We limit the number of messages sent for a position change to just one per
+ // simulator so when we receive the update we need to hand it to each of the
+ // scenes; scenes each check to see if the is a scene presence for the avatar
+ // note that we really don't need the GridRegion for this call
foreach (Scene s in m_sceneList)
{
- if (s.RegionInfo.RegionHandle == destination.RegionHandle)
- {
- //m_log.Debug("[LOCAL COMMS]: Found region to send ChildAgentUpdate");
- s.IncomingChildAgentDataUpdate(cAgentData);
- return true;
- }
+ //m_log.Debug("[LOCAL COMMS]: Found region to send ChildAgentUpdate");
+ s.IncomingChildAgentDataUpdate(cAgentData);
}
//m_log.Debug("[LOCAL COMMS]: region not found for ChildAgentUpdate");
- return false;
+ return true;
}
public bool RetrieveAgent(GridRegion destination, UUID id, out IAgentData agent)
diff --git a/OpenSim/Region/Framework/Scenes/SceneCommunicationService.cs b/OpenSim/Region/Framework/Scenes/SceneCommunicationService.cs
index c8af4c38e3..19cb0c16ba 100644
--- a/OpenSim/Region/Framework/Scenes/SceneCommunicationService.cs
+++ b/OpenSim/Region/Framework/Scenes/SceneCommunicationService.cs
@@ -189,7 +189,8 @@ namespace OpenSim.Region.Framework.Scenes
}
}
- public delegate void SendChildAgentDataUpdateDelegate(AgentPosition cAgentData, UUID scopeID, ulong regionHandle);
+ public delegate void SendChildAgentDataUpdateDelegate(AgentPosition cAgentData, UUID scopeID, GridRegion dest);
+
///
/// This informs all neighboring regions about the settings of it's child agent.
@@ -198,31 +199,17 @@ namespace OpenSim.Region.Framework.Scenes
/// This contains information, such as, Draw Distance, Camera location, Current Position, Current throttle settings, etc.
///
///
- private void SendChildAgentDataUpdateAsync(AgentPosition cAgentData, UUID scopeID, ulong regionHandle)
+ private void SendChildAgentDataUpdateAsync(AgentPosition cAgentData, UUID scopeID, GridRegion dest)
{
//m_log.Info("[INTERGRID]: Informing neighbors about my agent in " + m_regionInfo.RegionName);
try
{
- //m_commsProvider.InterRegion.ChildAgentUpdate(regionHandle, cAgentData);
- uint x = 0, y = 0;
- Utils.LongToUInts(regionHandle, out x, out y);
- GridRegion destination = m_scene.GridService.GetRegionByPosition(UUID.Zero, (int)x, (int)y);
- m_scene.SimulationService.UpdateAgent(destination, cAgentData);
+ m_scene.SimulationService.UpdateAgent(dest, cAgentData);
}
catch
{
// Ignore; we did our best
}
-
- //if (regionAccepted)
- //{
- // //m_log.Info("[INTERGRID]: Completed sending a neighbor an update about my agent");
- //}
- //else
- //{
- // //m_log.Info("[INTERGRID]: Failed sending a neighbor an update about my agent");
- //}
-
}
private void SendChildAgentDataUpdateCompleted(IAsyncResult iar)
@@ -236,14 +223,28 @@ namespace OpenSim.Region.Framework.Scenes
// This assumes that we know what our neighbors are.
try
{
+ uint x = 0, y = 0;
+ List simulatorList = new List();
foreach (ulong regionHandle in presence.KnownChildRegionHandles)
{
if (regionHandle != m_regionInfo.RegionHandle)
{
- SendChildAgentDataUpdateDelegate d = SendChildAgentDataUpdateAsync;
- d.BeginInvoke(cAgentData, m_regionInfo.ScopeID, regionHandle,
- SendChildAgentDataUpdateCompleted,
- d);
+ // we only want to send one update to each simulator; the simulator will
+ // hand it off to the regions where a child agent exists, this does assume
+ // that the region position is cached or performance will degrade
+ Utils.LongToUInts(regionHandle, out x, out y);
+ GridRegion dest = m_scene.GridService.GetRegionByPosition(UUID.Zero, (int)x, (int)y);
+ if (! simulatorList.Contains(dest.ServerURI))
+ {
+ // we havent seen this simulator before, add it to the list
+ // and send it an update
+ simulatorList.Add(dest.ServerURI);
+
+ SendChildAgentDataUpdateDelegate d = SendChildAgentDataUpdateAsync;
+ d.BeginInvoke(cAgentData, m_regionInfo.ScopeID, dest,
+ SendChildAgentDataUpdateCompleted,
+ d);
+ }
}
}
}
diff --git a/OpenSim/Region/Framework/Scenes/SceneObjectPart.cs b/OpenSim/Region/Framework/Scenes/SceneObjectPart.cs
index 6496a251e4..d4f3dfe2d4 100644
--- a/OpenSim/Region/Framework/Scenes/SceneObjectPart.cs
+++ b/OpenSim/Region/Framework/Scenes/SceneObjectPart.cs
@@ -2093,8 +2093,9 @@ namespace OpenSim.Region.Framework.Scenes
public void GetProperties(IClientAPI client)
{
+ //Viewer wants date in microseconds so multiply it by 1,000,000.
client.SendObjectPropertiesReply(
- m_fromUserInventoryItemID, (ulong)_creationDate, _creatorID, UUID.Zero, UUID.Zero,
+ m_fromUserInventoryItemID, (ulong)_creationDate*(ulong)1e6, _creatorID, UUID.Zero, UUID.Zero,
_groupID, (short)InventorySerial, _lastOwnerID, UUID, _ownerID,
ParentGroup.RootPart.TouchName, new byte[0], ParentGroup.RootPart.SitName, Name, Description,
ParentGroup.RootPart._ownerMask, ParentGroup.RootPart._nextOwnerMask, ParentGroup.RootPart._groupMask, ParentGroup.RootPart._everyoneMask,
diff --git a/OpenSim/Region/OptionalModules/Agent/UDP/Linden/LindenUDPInfoModule.cs b/OpenSim/Region/OptionalModules/Agent/UDP/Linden/LindenUDPInfoModule.cs
index 87d067c961..6630edb15e 100644
--- a/OpenSim/Region/OptionalModules/Agent/UDP/Linden/LindenUDPInfoModule.cs
+++ b/OpenSim/Region/OptionalModules/Agent/UDP/Linden/LindenUDPInfoModule.cs
@@ -154,24 +154,26 @@ namespace OpenSim.Region.CoreModules.UDP.Linden
report.Append(GetColumnEntry("Type", maxTypeLength, columnPadding));
report.AppendFormat(
- "{0,7} {1,7} {2,9} {3,8} {4,7} {5,7} {6,7} {7,7} {8,9} {9,7} {10,7}\n",
+ "{0,7} {1,7} {2,7} {3,9} {4,7} {5,7} {6,7} {7,7} {8,7} {9,8} {10,7} {11,7}\n",
"Pkts",
"Pkts",
+ "Pkts",
"Bytes",
- "Pkts",
- "Pkts",
- "Pkts",
- "Pkts",
- "Pkts",
- "Pkts",
- "Pkts",
- "Pkts");
+ "Q Pkts",
+ "Q Pkts",
+ "Q Pkts",
+ "Q Pkts",
+ "Q Pkts",
+ "Q Pkts",
+ "Q Pkts",
+ "Q Pkts");
report.AppendFormat("{0,-" + totalInfoFieldsLength + "}", "");
report.AppendFormat(
- "{0,7} {1,7} {2,9} {3,8} {4,7} {5,7} {6,7} {7,7} {8,9} {9,7} {10,7}\n",
- "Out",
+ "{0,7} {1,7} {2,7} {3,9} {4,7} {5,7} {6,7} {7,7} {8,7} {9,8} {10,7} {11,7}\n",
"In",
+ "Out",
+ "Resent",
"Unacked",
"Resend",
"Land",
diff --git a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/IGroupsServicesConnector.cs b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/IGroupsServicesConnector.cs
index 5c779debc5..6d2607541e 100644
--- a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/IGroupsServicesConnector.cs
+++ b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/IGroupsServicesConnector.cs
@@ -63,7 +63,26 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups
void SetAgentActiveGroupRole(UUID RequestingAgentID, UUID AgentID, UUID GroupID, UUID RoleID);
void SetAgentGroupInfo(UUID RequestingAgentID, UUID AgentID, UUID GroupID, bool AcceptNotices, bool ListInProfile);
+ ///
+ /// Get information about a specific group to which the user belongs.
+ ///
+ /// The agent requesting the information.
+ /// The agent requested.
+ /// The group requested.
+ ///
+ /// If the user is a member of the group then the data structure is returned. If not, then null is returned.
+ ///
GroupMembershipData GetAgentGroupMembership(UUID RequestingAgentID, UUID AgentID, UUID GroupID);
+
+ ///
+ /// Get information about the groups to which a user belongs.
+ ///
+ /// The agent requesting the information.
+ /// The agent requested.
+ ///
+ /// Information about the groups to which the user belongs. If the user belongs to no groups then an empty
+ /// list is returned.
+ ///
List GetAgentGroupMemberships(UUID RequestingAgentID, UUID AgentID);
void AddGroupNotice(UUID RequestingAgentID, UUID groupID, UUID noticeID, string fromName, string subject, string message, byte[] binaryBucket);
diff --git a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/SimianGroupsServicesConnectorModule.cs b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/SimianGroupsServicesConnectorModule.cs
index 0d265f2501..81725c55c7 100644
--- a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/SimianGroupsServicesConnectorModule.cs
+++ b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/SimianGroupsServicesConnectorModule.cs
@@ -704,7 +704,6 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups
}
}
-
return findings;
}
@@ -712,54 +711,55 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups
{
if (m_debugEnabled) m_log.InfoFormat("[SIMIAN-GROUPS-CONNECTOR] {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
- GroupMembershipData data = new GroupMembershipData();
-
- ///////////////////////////////
- // Agent Specific Information:
- //
- OSDMap UserActiveGroup;
- if (SimianGetGenericEntry(agentID, "Group", "ActiveGroup", out UserActiveGroup))
- {
- data.Active = UserActiveGroup["GroupID"].AsUUID().Equals(groupID);
- }
+ GroupMembershipData data = null;
+ bool foundData = false;
OSDMap UserGroupMemberInfo;
if (SimianGetGenericEntry(agentID, "GroupMember", groupID.ToString(), out UserGroupMemberInfo))
{
+ data = new GroupMembershipData();
data.AcceptNotices = UserGroupMemberInfo["AcceptNotices"].AsBoolean();
data.Contribution = UserGroupMemberInfo["Contribution"].AsInteger();
data.ListInProfile = UserGroupMemberInfo["ListInProfile"].AsBoolean();
- data.ActiveRole = UserGroupMemberInfo["SelectedRoleID"].AsUUID();
+ data.ActiveRole = UserGroupMemberInfo["SelectedRoleID"].AsUUID();
+
+ ///////////////////////////////
+ // Agent Specific Information:
+ //
+ OSDMap UserActiveGroup;
+ if (SimianGetGenericEntry(agentID, "Group", "ActiveGroup", out UserActiveGroup))
+ {
+ data.Active = UserActiveGroup["GroupID"].AsUUID().Equals(groupID);
+ }
///////////////////////////////
// Role Specific Information:
//
-
OSDMap GroupRoleInfo;
if (SimianGetGenericEntry(groupID, "GroupRole", data.ActiveRole.ToString(), out GroupRoleInfo))
{
data.GroupTitle = GroupRoleInfo["Title"].AsString();
data.GroupPowers = GroupRoleInfo["Powers"].AsULong();
- }
- }
-
- ///////////////////////////////
- // Group Specific Information:
- //
- OSDMap GroupInfo;
- string GroupName;
- if (SimianGetFirstGenericEntry(groupID, "Group", out GroupName, out GroupInfo))
- {
- data.GroupID = groupID;
- data.AllowPublish = GroupInfo["AllowPublish"].AsBoolean();
- data.Charter = GroupInfo["Charter"].AsString();
- data.FounderID = GroupInfo["FounderID"].AsUUID();
- data.GroupName = GroupName;
- data.GroupPicture = GroupInfo["InsigniaID"].AsUUID();
- data.MaturePublish = GroupInfo["MaturePublish"].AsBoolean();
- data.MembershipFee = GroupInfo["MembershipFee"].AsInteger();
- data.OpenEnrollment = GroupInfo["OpenEnrollment"].AsBoolean();
- data.ShowInList = GroupInfo["ShowInList"].AsBoolean();
+ }
+
+ ///////////////////////////////
+ // Group Specific Information:
+ //
+ OSDMap GroupInfo;
+ string GroupName;
+ if (SimianGetFirstGenericEntry(groupID, "Group", out GroupName, out GroupInfo))
+ {
+ data.GroupID = groupID;
+ data.AllowPublish = GroupInfo["AllowPublish"].AsBoolean();
+ data.Charter = GroupInfo["Charter"].AsString();
+ data.FounderID = GroupInfo["FounderID"].AsUUID();
+ data.GroupName = GroupName;
+ data.GroupPicture = GroupInfo["InsigniaID"].AsUUID();
+ data.MaturePublish = GroupInfo["MaturePublish"].AsBoolean();
+ data.MembershipFee = GroupInfo["MembershipFee"].AsInteger();
+ data.OpenEnrollment = GroupInfo["OpenEnrollment"].AsBoolean();
+ data.ShowInList = GroupInfo["ShowInList"].AsBoolean();
+ }
}
return data;
diff --git a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
index 59e905e7ab..e6ebc6e1ff 100644
--- a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
+++ b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
@@ -1917,18 +1917,21 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
protected void SetTexture(SceneObjectPart part, string texture, int face)
{
+<<<<<<< HEAD:OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
if (part == null || part.ParentGroup == null || part.ParentGroup.IsDeleted)
return;
UUID textureID=new UUID();
+=======
+ UUID textureID = new UUID();
+>>>>>>> master:OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
- if (!UUID.TryParse(texture, out textureID))
- {
- textureID=InventoryKey(texture, (int)AssetType.Texture);
- }
-
- if (textureID == UUID.Zero)
- return;
+ textureID = InventoryKey(texture, (int)AssetType.Texture);
+ if (textureID == UUID.Zero)
+ {
+ if (!UUID.TryParse(texture, out textureID))
+ return;
+ }
Primitive.TextureEntry tex = part.Shape.Textures;
@@ -3343,15 +3346,29 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
msg.dialog = (byte)19; // MessageFromObject
msg.fromGroup = false;// fromGroup;
msg.offline = (byte)0; //offline;
+<<<<<<< HEAD:OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
msg.ParentEstateID = World.RegionInfo.EstateSettings.EstateID;
msg.Position = new Vector3(m_host.AbsolutePosition);
msg.RegionID = World.RegionInfo.RegionID.Guid;
msg.binaryBucket = Util.StringToBytes256(m_host.OwnerID.ToString());
+=======
+ msg.ParentEstateID = 0; //ParentEstateID;
+ msg.Position = new Vector3(m_host.AbsolutePosition);
+ msg.RegionID = World.RegionInfo.RegionID.Guid;//RegionID.Guid;
+ msg.binaryBucket
+ = Util.StringToBytes256(
+ "{0}/{1}/{2}/{3}",
+ World.RegionInfo.RegionName,
+ (int)Math.Floor(m_host.AbsolutePosition.X),
+ (int)Math.Floor(m_host.AbsolutePosition.Y),
+ (int)Math.Floor(m_host.AbsolutePosition.Z));
+>>>>>>> master:OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
if (m_TransferModule != null)
{
m_TransferModule.SendInstantMessage(msg, delegate(bool success) {});
}
+
ScriptSleep(2000);
}
diff --git a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs
index cf059b3afa..4d299d6a27 100644
--- a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs
+++ b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs
@@ -711,7 +711,9 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
// and convert the regionName to the target region
if (regionName.Contains(".") && regionName.Contains(":"))
{
-// List regions = World.GridService.GetRegionsByName(World.RegionInfo.ScopeID, regionName, 1);
+ World.GridService.GetRegionsByName(World.RegionInfo.ScopeID, regionName, 1);
+// List regions = World.GridService.GetRegionsByName(World.RegionInfo.ScopeID, regionName, 1);
+
string[] parts = regionName.Split(new char[] { ':' });
if (parts.Length > 2)
regionName = parts[0] + ':' + parts[1] + "/ " + parts[2];
diff --git a/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs b/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs
index b33b0d5847..a6dc2870e7 100644
--- a/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs
+++ b/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs
@@ -110,11 +110,14 @@ namespace OpenSim.Server.Handlers.Simulation
DoAgentDelete(request, responsedata, agentID, action, regionID);
return responsedata;
}
+<<<<<<< HEAD:OpenSim/Server/Handlers/Simulation/AgentHandlers.cs
else if (method.Equals("DELETECHILD"))
{
DoChildAgentDelete(request, responsedata, agentID, action, regionID);
return responsedata;
}
+=======
+>>>>>>> master:OpenSim/Server/Handlers/Simulation/AgentHandlers.cs
else if (method.Equals("QUERYACCESS"))
{
DoQueryAccess(request, responsedata, agentID, regionID);
diff --git a/OpenSim/Services/Connectors/Inventory/HGInventoryServiceConnector.cs b/OpenSim/Services/Connectors/Inventory/HGInventoryServiceConnector.cs
deleted file mode 100644
index 9878855355..0000000000
--- a/OpenSim/Services/Connectors/Inventory/HGInventoryServiceConnector.cs
+++ /dev/null
@@ -1,335 +0,0 @@
-/*
- * 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 OpenSimulator 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 log4net;
-using Nini.Config;
-using System;
-using System.Collections.Generic;
-using System.Reflection;
-using OpenSim.Framework;
-using OpenSim.Services.Interfaces;
-using OpenMetaverse;
-
-namespace OpenSim.Services.Connectors.Inventory
-{
- public class HGInventoryServiceConnector : ISessionAuthInventoryService
- {
- private static readonly ILog m_log =
- LogManager.GetLogger(
- MethodBase.GetCurrentMethod().DeclaringType);
-
- private Dictionary m_connectors = new Dictionary();
-
- public HGInventoryServiceConnector(IConfigSource source)
- {
- IConfig moduleConfig = source.Configs["Modules"];
- if (moduleConfig != null)
- {
-
- IConfig inventoryConfig = source.Configs["InventoryService"];
- if (inventoryConfig == null)
- {
- m_log.Error("[HG INVENTORY SERVICE]: InventoryService missing from OpenSim.ini");
- return;
- }
-
- m_log.Info("[HG INVENTORY SERVICE]: HG inventory service enabled");
- }
- }
-
- private bool StringToUrlAndUserID(string id, out string url, out string userID)
- {
- url = String.Empty;
- userID = String.Empty;
-
- Uri assetUri;
-
- if (Uri.TryCreate(id, UriKind.Absolute, out assetUri) &&
- assetUri.Scheme == Uri.UriSchemeHttp)
- {
- url = "http://" + assetUri.Authority;
- userID = assetUri.LocalPath.Trim(new char[] { '/' });
- return true;
- }
-
- return false;
- }
- private ISessionAuthInventoryService GetConnector(string url)
- {
- InventoryServicesConnector connector = null;
- lock (m_connectors)
- {
- if (m_connectors.ContainsKey(url))
- {
- connector = m_connectors[url];
- }
- else
- {
- // We're instantiating this class explicitly, but this won't
- // work in general, because the remote grid may be running
- // an inventory server that has a different protocol.
- // Eventually we will want a piece of protocol asking
- // the remote server about its kind. Definitely cool thing to do!
- connector = new InventoryServicesConnector(url);
- m_connectors.Add(url, connector);
- }
- }
- return connector;
- }
-
- public string Host
- {
- get { return string.Empty; }
- }
-
- public void GetUserInventory(string id, UUID sessionID, InventoryReceiptCallback callback)
- {
- m_log.Debug("[HGInventory]: GetUserInventory " + id);
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- connector.GetUserInventory(userID, sessionID, callback);
- }
-
- }
-
- ///
- /// Gets the user folder for the given folder-type
- ///
- ///
- ///
- ///
- public Dictionary GetSystemFolders(string id, UUID sessionID)
- {
- m_log.Debug("[HGInventory]: GetSystemFolders " + id);
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.GetSystemFolders(userID, sessionID);
- }
-
- return new Dictionary();
- }
-
- ///
- /// Gets everything (folders and items) inside a folder
- ///
- ///
- ///
- ///
- public InventoryCollection GetFolderContent(string id, UUID folderID, UUID sessionID)
- {
- m_log.Debug("[HGInventory]: GetFolderContent " + id);
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.GetFolderContent(userID, folderID, sessionID);
- }
-
- return null;
- }
-
- public bool AddFolder(string id, InventoryFolderBase folder, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.AddFolder(userID, folder, sessionID);
- }
- return false;
- }
-
- public bool UpdateFolder(string id, InventoryFolderBase folder, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.UpdateFolder(userID, folder, sessionID);
- }
- return false;
- }
-
- public bool MoveFolder(string id, InventoryFolderBase folder, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.MoveFolder(userID, folder, sessionID);
- }
- return false;
- }
-
- public bool DeleteFolders(string id, List folders, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.DeleteFolders(userID, folders, sessionID);
- }
- return false;
- }
-
- public bool PurgeFolder(string id, InventoryFolderBase folder, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.PurgeFolder(userID, folder, sessionID);
- }
- return false;
- }
-
- public List GetFolderItems(string id, UUID folderID, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.GetFolderItems(userID, folderID, sessionID);
- }
- return new List();
- }
-
- public bool AddItem(string id, InventoryItemBase item, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.AddItem(userID, item, sessionID);
- }
- return false;
- }
-
- public bool UpdateItem(string id, InventoryItemBase item, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.UpdateItem(userID, item, sessionID);
- }
- return false;
- }
-
- public bool MoveItems(string id, List items, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.MoveItems(userID, items, sessionID);
- }
- return false;
- }
-
- public bool DeleteItems(string id, List itemIDs, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.DeleteItems(userID, itemIDs, sessionID);
- }
- return false;
- }
-
- public InventoryItemBase QueryItem(string id, InventoryItemBase item, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- //m_log.DebugFormat("[HGInventory CONNECTOR]: calling {0}", url);
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.QueryItem(userID, item, sessionID);
- }
- return null;
- }
-
- public InventoryFolderBase QueryFolder(string id, InventoryFolderBase folder, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.QueryFolder(userID, folder, sessionID);
- }
- return null;
- }
-
- public int GetAssetPermissions(string id, UUID assetID, UUID sessionID)
- {
- string url = string.Empty;
- string userID = string.Empty;
-
- if (StringToUrlAndUserID(id, out url, out userID))
- {
- ISessionAuthInventoryService connector = GetConnector(url);
- return connector.GetAssetPermissions(userID, assetID, sessionID);
- }
- return 0;
- }
- }
-}
diff --git a/OpenSim/Services/Connectors/Inventory/ISessionAuthInventoryService.cs b/OpenSim/Services/Connectors/Inventory/ISessionAuthInventoryService.cs
deleted file mode 100644
index da8c7e2e61..0000000000
--- a/OpenSim/Services/Connectors/Inventory/ISessionAuthInventoryService.cs
+++ /dev/null
@@ -1,140 +0,0 @@
-/*
- * 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 OpenSimulator 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.Collections.Generic;
-using OpenSim.Framework;
-using OpenSim.Services.Interfaces;
-using OpenMetaverse;
-
-namespace OpenSim.Services.Connectors
-{
- ///
- /// Defines all operations to access a remote inventory service
- /// using session authentication as a form of security.
- ///
- public interface ISessionAuthInventoryService
- {
- string Host
- {
- get;
- }
-
- ///
- /// Request the inventory for a user. This is an asynchronous operation that will call the callback when the
- /// inventory has been received
- ///
- ///
- ///
- void GetUserInventory(string userID, UUID session_id, InventoryReceiptCallback callback);
-
- ///
- /// Gets the user folder for the given folder-type
- ///
- ///
- ///
- ///
- Dictionary GetSystemFolders(string userID, UUID session_id);
-
- ///
- /// Gets everything (folders and items) inside a folder
- ///
- ///
- ///
- ///
- InventoryCollection GetFolderContent(string userID, UUID folderID, UUID session_id);
-
- ///
- /// Add a new folder to the user's inventory
- ///
- ///
- /// true if the folder was successfully added
- bool AddFolder(string userID, InventoryFolderBase folder, UUID session_id);
-
- ///
- /// Update a folder in the user's inventory
- ///
- ///
- /// true if the folder was successfully updated
- bool UpdateFolder(string userID, InventoryFolderBase folder, UUID session_id);
-
- ///
- /// Move an inventory folder to a new location
- ///
- /// A folder containing the details of the new location
- /// true if the folder was successfully moved
- bool MoveFolder(string userID, InventoryFolderBase folder, UUID session_id);
-
- ///
- /// Delete a list of inventory folders (from trash)
- ///
- bool DeleteFolders(string userID, List folders, UUID session_id);
-
- ///
- /// Purge an inventory folder of all its items and subfolders.
- ///
- ///
- /// true if the folder was successfully purged
- bool PurgeFolder(string userID, InventoryFolderBase folder, UUID session_id);
-
- ///
- /// Get items from a folder.
- ///
- ///
- /// true if the folder was successfully purged
- List GetFolderItems(string userID, UUID folderID, UUID session_id);
-
- ///
- /// Add a new item to the user's inventory
- ///
- ///
- /// true if the item was successfully added
- bool AddItem(string userID, InventoryItemBase item, UUID session_id);
-
- ///
- /// Update an item in the user's inventory
- ///
- ///
- /// true if the item was successfully updated
- bool UpdateItem(string userID, InventoryItemBase item, UUID session_id);
-
- bool MoveItems(string userID, List items, UUID session_id);
-
- ///
- /// Delete an item from the user's inventory
- ///
- ///
- /// true if the item was successfully deleted
- bool DeleteItems(string userID, List itemIDs, UUID session_id);
-
- InventoryItemBase QueryItem(string userID, InventoryItemBase item, UUID session_id);
-
- InventoryFolderBase QueryFolder(string userID, InventoryFolderBase item, UUID session_id);
-
- int GetAssetPermissions(string userID, UUID assetID, UUID session_id);
-
- }
-}
diff --git a/OpenSim/Services/Connectors/Inventory/InventoryServiceConnector.cs b/OpenSim/Services/Connectors/Inventory/InventoryServiceConnector.cs
deleted file mode 100644
index f86b453665..0000000000
--- a/OpenSim/Services/Connectors/Inventory/InventoryServiceConnector.cs
+++ /dev/null
@@ -1,582 +0,0 @@
-/*
- * 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 OpenSimulator 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 log4net;
-using System;
-using System.Collections.Generic;
-using System.IO;
-using System.Reflection;
-using Nini.Config;
-using OpenSim.Framework;
-using OpenSim.Framework.Servers.HttpServer;
-using OpenSim.Services.Interfaces;
-using OpenMetaverse;
-
-namespace OpenSim.Services.Connectors
-{
- public class InventoryServicesConnector : ISessionAuthInventoryService
- {
- private static readonly ILog m_log =
- LogManager.GetLogger(
- MethodBase.GetCurrentMethod().DeclaringType);
-
- private string m_ServerURI = String.Empty;
-
- private Dictionary m_RequestingInventory = new Dictionary();
- private Dictionary m_RequestTime = new Dictionary();
-
- public InventoryServicesConnector()
- {
- }
-
- public InventoryServicesConnector(string serverURI)
- {
- m_ServerURI = serverURI.TrimEnd('/');
- }
-
- public InventoryServicesConnector(IConfigSource source)
- {
- Initialise(source);
- }
-
- public virtual void Initialise(IConfigSource source)
- {
- IConfig inventoryConfig = source.Configs["InventoryService"];
- if (inventoryConfig == null)
- {
- m_log.Error("[INVENTORY CONNECTOR]: InventoryService missing from OpenSim.ini");
- throw new Exception("InventoryService missing from OpenSim.ini");
- }
-
- string serviceURI = inventoryConfig.GetString("InventoryServerURI",
- String.Empty);
-
- if (serviceURI == String.Empty)
- {
- m_log.Error("[INVENTORY CONNECTOR]: No Server URI named in section InventoryService");
- throw new Exception("Unable to proceed. Please make sure your ini files in config-include are updated according to .example's");
- }
- m_ServerURI = serviceURI.TrimEnd('/');
- }
-
- #region ISessionAuthInventoryService
-
- public string Host
- {
- get { return m_ServerURI; }
- }
-
- ///
- /// Caller must catch eventual Exceptions.
- ///
- ///
- ///
- ///
- public void GetUserInventory(string userIDStr, UUID sessionID, InventoryReceiptCallback callback)
- {
- UUID userID = UUID.Zero;
- if (UUID.TryParse(userIDStr, out userID))
- {
- lock (m_RequestingInventory)
- {
- // *HACK ALERT*
-
- // If an inventory request times out, it blocks any further requests from the
- // same user, even after a relog. This is bad, and makes me sad.
-
- // Really, we should detect a timeout and report a failure to the callback,
- // BUT in my testing i found that it's hard to detect a timeout.. sometimes,
- // a partial response is recieved, and sometimes a null response.
-
- // So, for now, add a timer of ten seconds (which is the request timeout).
-
- // This should basically have the same effect.
-
- lock (m_RequestTime)
- {
- if (m_RequestTime.ContainsKey(userID))
- {
- TimeSpan interval = DateTime.Now - m_RequestTime[userID];
- if (interval.TotalSeconds > 10)
- {
- m_RequestTime.Remove(userID);
- if (m_RequestingInventory.ContainsKey(userID))
- {
- m_RequestingInventory.Remove(userID);
- }
- }
- }
- if (!m_RequestingInventory.ContainsKey(userID))
- {
- m_RequestTime.Add(userID, DateTime.Now);
- m_RequestingInventory.Add(userID, callback);
- }
- else
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: GetUserInventory - ignoring repeated request for user {0}", userID);
- return;
- }
- }
- }
-
- m_log.InfoFormat(
- "[INVENTORY CONNECTOR]: Requesting inventory from {0}/GetInventory/ for user {1}",
- m_ServerURI, userID);
-
- RestSessionObjectPosterResponse requester
- = new RestSessionObjectPosterResponse();
- requester.ResponseCallback = InventoryResponse;
-
- requester.BeginPostObject(m_ServerURI + "/GetInventory/", userID.Guid, sessionID.ToString(), userID.ToString());
- }
- }
-
- ///
- /// Gets the user folder for the given folder-type
- ///
- ///
- ///
- ///
- public Dictionary GetSystemFolders(string userID, UUID sessionID)
- {
- List folders = null;
- Dictionary dFolders = new Dictionary();
- try
- {
- folders = SynchronousRestSessionObjectPoster>.BeginPostObject(
- "POST", m_ServerURI + "/SystemFolders/", new Guid(userID), sessionID.ToString(), userID.ToString());
-
- foreach (InventoryFolderBase f in folders)
- dFolders[(AssetType)f.Type] = f;
-
- return dFolders;
- }
- catch (Exception e)
- {
- // Maybe we're talking to an old inventory server. Try this other thing.
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: GetSystemFolders operation failed, {0} {1} (old sever?). Trying GetInventory.",
- e.Source, e.Message);
-
- try
- {
- InventoryCollection inventory = SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/GetInventory/", new Guid(userID), sessionID.ToString(), userID.ToString());
- folders = inventory.Folders;
- }
- catch (Exception ex)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: GetInventory operation also failed, {0} {1}. Giving up.",
- e.Source, ex.Message);
- }
-
- if ((folders != null) && (folders.Count > 0))
- {
- m_log.DebugFormat("[INVENTORY CONNECTOR]: Received entire inventory ({0} folders) for user {1}",
- folders.Count, userID);
- foreach (InventoryFolderBase f in folders)
- {
- if ((f.Type != (short)AssetType.Folder) && (f.Type != (short)AssetType.Unknown))
- dFolders[(AssetType)f.Type] = f;
- }
-
- UUID rootFolderID = dFolders[AssetType.Animation].ParentID;
- InventoryFolderBase rootFolder = new InventoryFolderBase(rootFolderID, new UUID(userID));
- rootFolder = QueryFolder(userID, rootFolder, sessionID);
- dFolders[AssetType.Folder] = rootFolder;
- m_log.DebugFormat("[INVENTORY CONNECTOR]: {0} system folders for user {1}", dFolders.Count, userID);
- return dFolders;
- }
- }
-
- return new Dictionary();
- }
-
- ///
- /// Gets everything (folders and items) inside a folder
- ///
- ///
- ///
- ///
- public InventoryCollection GetFolderContent(string userID, UUID folderID, UUID sessionID)
- {
- try
- {
- // normal case
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/GetFolderContent/", folderID.Guid, sessionID.ToString(), userID.ToString());
- }
- catch (TimeoutException e)
- {
- m_log.ErrorFormat(
- "[INVENTORY CONNECTOR]: GetFolderContent operation to {0} for {1} timed out {2} {3}.",
- m_ServerURI, folderID, e.Source, e.Message);
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: GetFolderContent operation failed for {0}, {1} {2} (old server?).",
- folderID, e.Source, e.Message);
- }
-
- InventoryCollection nullCollection = new InventoryCollection();
- nullCollection.Folders = new List();
- nullCollection.Items = new List();
- nullCollection.UserID = new UUID(userID);
- return nullCollection;
- }
-
- public bool AddFolder(string userID, InventoryFolderBase folder, UUID sessionID)
- {
- try
- {
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/NewFolder/", folder, sessionID.ToString(), folder.Owner.ToString());
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Add new inventory folder operation failed for {0} {1}, {2} {3}",
- folder.Name, folder.ID, e.Source, e.Message);
- }
-
- return false;
- }
-
- public bool UpdateFolder(string userID, InventoryFolderBase folder, UUID sessionID)
- {
- try
- {
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/UpdateFolder/", folder, sessionID.ToString(), folder.Owner.ToString());
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Update inventory folder operation failed for {0} {1}, {2} {3}",
- folder.Name, folder.ID, e.Source, e.Message);
- }
-
- return false;
- }
-
- public bool DeleteFolders(string userID, List folderIDs, UUID sessionID)
- {
- try
- {
- List guids = new List();
- foreach (UUID u in folderIDs)
- guids.Add(u.Guid);
- return SynchronousRestSessionObjectPoster, bool>.BeginPostObject(
- "POST", m_ServerURI + "/DeleteFolders/", guids, sessionID.ToString(), userID);
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Delete inventory folders operation failed, {0} {1}",
- e.Source, e.Message);
- }
-
- return false;
- }
-
- public bool MoveFolder(string userID, InventoryFolderBase folder, UUID sessionID)
- {
- try
- {
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/MoveFolder/", folder, sessionID.ToString(), folder.Owner.ToString());
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Move inventory folder operation failed for {0} {1}, {2} {3}",
- folder.Name, folder.ID, e.Source, e.Message);
- }
-
- return false;
- }
-
- public bool PurgeFolder(string userID, InventoryFolderBase folder, UUID sessionID)
- {
- try
- {
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/PurgeFolder/", folder, sessionID.ToString(), folder.Owner.ToString());
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Purge inventory folder operation failed for {0} {1}, {2} {3}",
- folder.Name, folder.ID, e.Source, e.Message);
- }
-
- return false;
- }
-
- public List GetFolderItems(string userID, UUID folderID, UUID sessionID)
- {
- try
- {
- InventoryFolderBase folder = new InventoryFolderBase(folderID, new UUID(userID));
- return SynchronousRestSessionObjectPoster>.BeginPostObject(
- "POST", m_ServerURI + "/GetItems/", folder, sessionID.ToString(), userID);
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Get folder items operation failed for folder {0}, {1} {2}",
- folderID, e.Source, e.Message);
- }
-
- return null;
- }
-
- public bool AddItem(string userID, InventoryItemBase item, UUID sessionID)
- {
- try
- {
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/NewItem/", item, sessionID.ToString(), item.Owner.ToString());
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Add new inventory item operation failed for {0} {1}, {2} {3}",
- item.Name, item.ID, e.Source, e.Message);
- }
-
- return false;
- }
-
- public bool UpdateItem(string userID, InventoryItemBase item, UUID sessionID)
- {
- try
- {
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/NewItem/", item, sessionID.ToString(), item.Owner.ToString());
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Update new inventory item operation failed for {0} {1}, {2} {3}",
- item.Name, item.ID, e.Source, e.Message);
- }
-
- return false;
- }
-
- /**
- * MoveItems Async group
- */
-
- delegate void MoveItemsDelegate(string userID, List items, UUID sessionID);
-
- private void MoveItemsAsync(string userID, List items, UUID sessionID)
- {
- if (items == null)
- {
- m_log.WarnFormat("[INVENTORY CONNECTOR]: request to move items got a null list.");
- return;
- }
-
- try
- {
- //SynchronousRestSessionObjectPoster, bool>.BeginPostObject(
- // "POST", m_ServerURI + "/MoveItems/", items, sessionID.ToString(), userID.ToString());
-
- //// Success
- //return;
- string uri = m_ServerURI + "/inventory/" + userID;
- if (SynchronousRestObjectRequester.
- MakeRequest, bool>("PUT", uri, items))
- m_log.DebugFormat("[INVENTORY CONNECTOR]: move {0} items poster succeeded {1}", items.Count, uri);
- else
- m_log.DebugFormat("[INVENTORY CONNECTOR]: move {0} items poster failed {1}", items.Count, uri); ;
-
- return;
-
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Move inventory items operation failed, {0} {1} (old server?). Trying slow way.",
- e.Source, e.Message);
- }
-
- }
-
- private void MoveItemsCompleted(IAsyncResult iar)
- {
- MoveItemsDelegate d = (MoveItemsDelegate)iar.AsyncState;
- d.EndInvoke(iar);
- }
-
- public bool MoveItems(string userID, List items, UUID sessionID)
- {
- MoveItemsDelegate d = MoveItemsAsync;
- d.BeginInvoke(userID, items, sessionID, MoveItemsCompleted, d);
- return true;
- }
-
- public bool DeleteItems(string userID, List items, UUID sessionID)
- {
- try
- {
- List guids = new List();
- foreach (UUID u in items)
- guids.Add(u.Guid);
- return SynchronousRestSessionObjectPoster, bool>.BeginPostObject(
- "POST", m_ServerURI + "/DeleteItem/", guids, sessionID.ToString(), userID);
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Delete inventory items operation failed, {0} {1}",
- e.Source, e.Message);
- }
-
- return false;
- }
-
- public InventoryItemBase QueryItem(string userID, InventoryItemBase item, UUID sessionID)
- {
- try
- {
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/QueryItem/", item, sessionID.ToString(), item.Owner.ToString());
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Query inventory item operation failed, {0} {1}",
- e.Source, e.Message);
- }
-
- return null;
- }
-
- public InventoryFolderBase QueryFolder(string userID, InventoryFolderBase folder, UUID sessionID)
- {
- try
- {
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/QueryFolder/", folder, sessionID.ToString(), userID);
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Query inventory folder operation failed, {0} {1}",
- e.Source, e.Message);
- }
-
- return null;
- }
-
- public int GetAssetPermissions(string userID, UUID assetID, UUID sessionID)
- {
- try
- {
- InventoryItemBase item = new InventoryItemBase();
- item.Owner = new UUID(userID);
- item.AssetID = assetID;
- return SynchronousRestSessionObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "/AssetPermissions/", item, sessionID.ToString(), userID);
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: AssetPermissions operation failed, {0} {1}",
- e.Source, e.Message);
- }
-
- return 0;
- }
-
- #endregion
-
- ///
- /// Callback used by the inventory server GetInventory request
- ///
- ///
- private void InventoryResponse(InventoryCollection response)
- {
- UUID userID = response.UserID;
- InventoryReceiptCallback callback = null;
- lock (m_RequestingInventory)
- {
- if (m_RequestingInventory.ContainsKey(userID))
- {
- callback = m_RequestingInventory[userID];
- m_RequestingInventory.Remove(userID);
- lock (m_RequestTime)
- {
- if (m_RequestTime.ContainsKey(userID))
- {
- m_RequestTime.Remove(userID);
- }
- }
- }
- else
- {
- m_log.WarnFormat(
- "[INVENTORY CONNECTOR]: " +
- "Received inventory response for {0} for which we do not have a record of requesting!",
- userID);
- return;
- }
- }
-
- m_log.InfoFormat("[INVENTORY CONNECTOR]: " +
- "Received inventory response for user {0} containing {1} folders and {2} items",
- userID, response.Folders.Count, response.Items.Count);
-
- InventoryFolderImpl rootFolder = null;
-
- ICollection folders = new List();
- ICollection items = new List();
-
- foreach (InventoryFolderBase folder in response.Folders)
- {
- if (folder.ParentID == UUID.Zero)
- {
- rootFolder = new InventoryFolderImpl(folder);
- folders.Add(rootFolder);
-
- break;
- }
- }
-
- if (rootFolder != null)
- {
- foreach (InventoryFolderBase folder in response.Folders)
- {
- if (folder.ID != rootFolder.ID)
- {
- folders.Add(new InventoryFolderImpl(folder));
- }
- }
-
- foreach (InventoryItemBase item in response.Items)
- {
- items.Add(item);
- }
- }
- else
- {
- m_log.ErrorFormat("[INVENTORY CONNECTOR]: Did not get back an inventory containing a root folder for user {0}", userID);
- }
-
- callback(folders, items);
- }
- }
-}
diff --git a/OpenSim/Services/Connectors/Inventory/QuickAndDirtyInventoryServiceConnector.cs b/OpenSim/Services/Connectors/Inventory/QuickAndDirtyInventoryServiceConnector.cs
deleted file mode 100644
index a7aa1382c4..0000000000
--- a/OpenSim/Services/Connectors/Inventory/QuickAndDirtyInventoryServiceConnector.cs
+++ /dev/null
@@ -1,196 +0,0 @@
-/*
- * 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 OpenSimulator 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 log4net;
-using System;
-using System.Collections.Generic;
-using System.IO;
-using System.Reflection;
-using Nini.Config;
-using OpenSim.Framework;
-using OpenSim.Framework.Servers.HttpServer;
-using OpenSim.Services.Interfaces;
-using OpenMetaverse;
-
-namespace OpenSim.Services.Connectors
-{
- ///
- /// This connector is temporary. It's used by the user server, before that server is refactored.
- ///
- public class QuickAndDirtyInventoryServiceConnector : IInventoryService
- {
-// private static readonly ILog m_log =
-// LogManager.GetLogger(
-// MethodBase.GetCurrentMethod().DeclaringType);
-
- private string m_ServerURI = String.Empty;
-
- //private Dictionary m_RequestingInventory = new Dictionary();
-
- public QuickAndDirtyInventoryServiceConnector()
- {
- }
-
- public QuickAndDirtyInventoryServiceConnector(string serverURI)
- {
- m_ServerURI = serverURI.TrimEnd('/');
- }
-
- ///
- ///
- ///
- ///
- ///
- public bool CreateUserInventory(UUID userId)
- {
- return SynchronousRestObjectPoster.BeginPostObject(
- "POST", m_ServerURI + "CreateInventory/", userId.Guid);
- }
-
- ///
- ///
- ///
- ///
- ///
- public List GetInventorySkeleton(UUID userId)
- {
- return SynchronousRestObjectPoster.BeginPostObject>(
- "POST", m_ServerURI + "RootFolders/", userId.Guid);
- }
-
- ///
- /// Returns a list of all the active gestures in a user's inventory.
- ///
- ///
- /// The of the user
- ///
- ///
- /// A flat list of the gesture items.
- ///
- public List GetActiveGestures(UUID userId)
- {
- return SynchronousRestObjectPoster.BeginPostObject>(
- "POST", m_ServerURI + "ActiveGestures/", userId.Guid);
- }
-
- public InventoryCollection GetUserInventory(UUID userID)
- {
- return null;
- }
-
- public void GetUserInventory(UUID userID, InventoryReceiptCallback callback)
- {
- }
-
- public InventoryFolderBase GetFolderForType(UUID userID, AssetType type)
- {
- return null;
- }
-
- public InventoryCollection GetFolderContent(UUID userID, UUID folderID)
- {
- return null;
- }
-
- public List GetFolderItems(UUID userID, UUID folderID)
- {
- return null;
- }
-
- public bool AddFolder(InventoryFolderBase folder)
- {
- return false;
- }
-
- public bool UpdateFolder(InventoryFolderBase folder)
- {
- return false;
- }
-
- public bool MoveFolder(InventoryFolderBase folder)
- {
- return false;
- }
-
- public bool DeleteFolders(UUID ownerID, List folderIDs)
- {
- return false;
- }
-
-
- public bool PurgeFolder(InventoryFolderBase folder)
- {
- return false;
- }
-
- public bool AddItem(InventoryItemBase item)
- {
- return false;
- }
-
- public bool UpdateItem(InventoryItemBase item)
- {
- return false;
- }
-
- public bool MoveItems(UUID ownerID, List items)
- {
- return false;
- }
-
- public bool DeleteItems(UUID owner, List itemIDs)
- {
- return false;
- }
-
- public InventoryItemBase GetItem(InventoryItemBase item)
- {
- return null;
- }
-
- public InventoryFolderBase GetFolder(InventoryFolderBase folder)
- {
- return null;
- }
-
- public bool HasInventoryForUser(UUID userID)
- {
- return false;
- }
-
- public InventoryFolderBase GetRootFolder(UUID userID)
- {
- return null;
- }
-
- public int GetAssetPermissions(UUID userID, UUID assetID)
- {
- return 0;
- }
-
- }
-}
diff --git a/OpenSim/Services/Connectors/SimianGrid/SimianGridMaptileModule.cs b/OpenSim/Services/Connectors/SimianGrid/SimianGridMaptileModule.cs
new file mode 100644
index 0000000000..93fdae38c1
--- /dev/null
+++ b/OpenSim/Services/Connectors/SimianGrid/SimianGridMaptileModule.cs
@@ -0,0 +1,262 @@
+/*
+ * 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 OpenSimulator 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.Reflection;
+using System.Net;
+using System.IO;
+using System.Timers;
+using System.Drawing;
+using System.Drawing.Imaging;
+
+using log4net;
+using Mono.Addins;
+using Nini.Config;
+using OpenSim.Framework;
+using OpenSim.Region.Framework.Interfaces;
+using OpenSim.Region.Framework.Scenes;
+using OpenMetaverse;
+using OpenMetaverse.StructuredData;
+
+namespace OpenSim.Region.OptionalModules.Simian
+{
+ ///
+ ///
+ ///
+ ///
+
+ [Extension(Path = "/OpenSim/RegionModules", NodeName = "RegionModule", Id = "SimianGridMaptile")]
+ public class SimianGridMaptile : ISharedRegionModule
+ {
+ private static readonly ILog m_log =
+ LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+
+ private bool m_enabled = false;
+ private string m_serverUrl = String.Empty;
+ private Dictionary m_scenes = new Dictionary();
+
+ private int m_refreshtime = 0;
+ private int m_lastrefresh = 0;
+ private System.Timers.Timer m_refreshTimer = new System.Timers.Timer();
+
+ #region ISharedRegionModule
+
+ public Type ReplaceableInterface { get { return null; } }
+ public string Name { get { return "SimianGridMaptile"; } }
+ public void RegionLoaded(Scene scene) { }
+ public void Close() { }
+
+ ///
+ ///
+ ///
+ public void Initialise(IConfigSource source)
+ {
+ IConfig config = source.Configs["SimianGridMaptiles"];
+ if (config == null)
+ return;
+
+ if (! config.GetBoolean("Enabled", false))
+ return;
+
+ m_serverUrl = config.GetString("MaptileURL");
+ if (String.IsNullOrEmpty(m_serverUrl))
+ return;
+
+ int refreshseconds = Convert.ToInt32(config.GetString("RefreshTime"));
+ if (refreshseconds <= 0)
+ return;
+
+ m_refreshtime = refreshseconds * 1000; // convert from seconds to ms
+ m_log.InfoFormat("[SIMIAN MAPTILE] enabled with refresh timeout {0} and URL {1}",
+ m_refreshtime,m_serverUrl);
+
+ m_enabled = true;
+ }
+
+ ///
+ ///
+ ///
+ public void PostInitialise()
+ {
+ if (m_enabled)
+ {
+ m_refreshTimer.Enabled = true;
+ m_refreshTimer.AutoReset = true;
+ m_refreshTimer.Interval = 5 * 60 * 1000; // every 5 minutes
+ m_refreshTimer.Elapsed += new ElapsedEventHandler(HandleMaptileRefresh);
+ }
+ }
+
+
+ ///
+ ///
+ ///
+ public void AddRegion(Scene scene)
+ {
+ if (! m_enabled)
+ return;
+
+ // Every shared region module has to maintain an indepedent list of
+ // currently running regions
+ lock (m_scenes)
+ m_scenes[scene.RegionInfo.RegionID] = scene;
+ }
+
+ ///
+ ///
+ ///
+ public void RemoveRegion(Scene scene)
+ {
+ if (! m_enabled)
+ return;
+
+ lock (m_scenes)
+ m_scenes.Remove(scene.RegionInfo.RegionID);
+ }
+
+ #endregion ISharedRegionModule
+
+ ///
+ ///
+ ///
+ private void HandleMaptileRefresh(object sender, EventArgs ea)
+ {
+ // this approach is a bit convoluted becase we want to wait for the
+ // first upload to happen on startup but after all the objects are
+ // loaded and initialized
+ if (m_lastrefresh > 0 && Util.EnvironmentTickCountSubtract(m_lastrefresh) < m_refreshtime)
+ return;
+
+ m_log.DebugFormat("[SIMIAN MAPTILE] map refresh fired");
+ lock (m_scenes)
+ {
+ foreach (IScene scene in m_scenes.Values)
+ {
+ try
+ {
+ UploadMapTile(scene);
+ }
+ catch (Exception ex)
+ {
+ m_log.WarnFormat("[SIMIAN MAPTILE] something bad happened {0}",ex.Message);
+ }
+ }
+ }
+
+ m_lastrefresh = Util.EnvironmentTickCount();
+ }
+
+ ///
+ ///
+ ///
+ private void UploadMapTile(IScene scene)
+ {
+ m_log.DebugFormat("[SIMIAN MAPTILE]: upload maptile for {0}",scene.RegionInfo.RegionName);
+
+ // Create a PNG map tile and upload it to the AddMapTile API
+ byte[] pngData = Utils.EmptyBytes;
+ IMapImageGenerator tileGenerator = scene.RequestModuleInterface();
+ if (tileGenerator == null)
+ {
+ m_log.Warn("[SIMIAN MAPTILE]: Cannot upload PNG map tile without an ImageGenerator");
+ return;
+ }
+
+ using (Image mapTile = tileGenerator.CreateMapTile())
+ {
+ using (MemoryStream stream = new MemoryStream())
+ {
+ mapTile.Save(stream, ImageFormat.Png);
+ pngData = stream.ToArray();
+ }
+ }
+
+ List postParameters = new List()
+ {
+ new MultipartForm.Parameter("X", scene.RegionInfo.RegionLocX.ToString()),
+ new MultipartForm.Parameter("Y", scene.RegionInfo.RegionLocY.ToString()),
+ new MultipartForm.File("Tile", "tile.png", "image/png", pngData)
+ };
+
+ string errorMessage = null;
+ int tickstart = Util.EnvironmentTickCount();
+
+ // Make the remote storage request
+ try
+ {
+ HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(m_serverUrl);
+ request.Timeout = 20000;
+ request.ReadWriteTimeout = 5000;
+
+ using (HttpWebResponse response = MultipartForm.Post(request, postParameters))
+ {
+ using (Stream responseStream = response.GetResponseStream())
+ {
+ string responseStr = responseStream.GetStreamString();
+ OSD responseOSD = OSDParser.Deserialize(responseStr);
+ if (responseOSD.Type == OSDType.Map)
+ {
+ OSDMap responseMap = (OSDMap)responseOSD;
+ if (responseMap["Success"].AsBoolean())
+ return;
+
+ errorMessage = "Upload failed: " + responseMap["Message"].AsString();
+ }
+ else
+ {
+ errorMessage = "Response format was invalid:\n" + responseStr;
+ }
+ }
+ }
+ }
+ catch (WebException we)
+ {
+ errorMessage = we.Message;
+ if (we.Status == WebExceptionStatus.ProtocolError)
+ {
+ HttpWebResponse webResponse = (HttpWebResponse)we.Response;
+ errorMessage = String.Format("[{0}] {1}",
+ webResponse.StatusCode,webResponse.StatusDescription);
+ }
+ }
+ catch (Exception ex)
+ {
+ errorMessage = ex.Message;
+ }
+ finally
+ {
+ // This just dumps a warning for any operation that takes more than 100 ms
+ int tickdiff = Util.EnvironmentTickCountSubtract(tickstart);
+ m_log.DebugFormat("[SIMIAN MAPTILE]: map tile uploaded in {0}ms",tickdiff);
+ }
+
+ m_log.WarnFormat("[SIMIAN MAPTILE]: Failed to store {0} byte tile for {1}: {2}",
+ pngData.Length, scene.RegionInfo.RegionName, errorMessage);
+ }
+ }
+}
\ No newline at end of file
diff --git a/OpenSim/Services/Connectors/Simulation/SimulationServiceConnector.cs b/OpenSim/Services/Connectors/Simulation/SimulationServiceConnector.cs
index 2c8277ff40..46ad9dd81f 100644
--- a/OpenSim/Services/Connectors/Simulation/SimulationServiceConnector.cs
+++ b/OpenSim/Services/Connectors/Simulation/SimulationServiceConnector.cs
@@ -48,6 +48,9 @@ namespace OpenSim.Services.Connectors.Simulation
{
private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+ // we use this dictionary to track the pending updateagent requests, maps URI --> position update
+ private Dictionary m_updateAgentQueue = new Dictionary();
+
//private GridRegion m_Region;
public SimulationServiceConnector()
@@ -133,10 +136,56 @@ namespace OpenSim.Services.Connectors.Simulation
///
public bool UpdateAgent(GridRegion destination, AgentPosition data)
{
- // we need a better throttle for these
- // return false;
+ // The basic idea of this code is that the first thread that needs to
+ // send an update for a specific avatar becomes the worker for any subsequent
+ // requests until there are no more outstanding requests. Further, only send the most
+ // recent update; this *should* never be needed but some requests get
+ // slowed down and once that happens the problem with service end point
+ // limits kicks in and nothing proceeds
+ string uri = destination.ServerURI + AgentPath() + data.AgentID + "/";
+ lock (m_updateAgentQueue)
+ {
+ if (m_updateAgentQueue.ContainsKey(uri))
+ {
+ // Another thread is already handling
+ // updates for this simulator, just update
+ // the position and return, overwrites are
+ // not a problem since we only care about the
+ // last update anyway
+ m_updateAgentQueue[uri] = data;
+ return true;
+ }
+
+ // Otherwise update the reference and start processing
+ m_updateAgentQueue[uri] = data;
+ }
- return UpdateAgent(destination, (IAgentData)data);
+ AgentPosition pos = null;
+ while (true)
+ {
+ lock (m_updateAgentQueue)
+ {
+ // save the position
+ AgentPosition lastpos = pos;
+
+ pos = m_updateAgentQueue[uri];
+
+ // this is true if no one put a new
+ // update in the map since the last
+ // one we processed, if thats the
+ // case then we are done
+ if (pos == lastpos)
+ {
+ m_updateAgentQueue.Remove(uri);
+ return true;
+ }
+ }
+
+ UpdateAgent(destination,(IAgentData)pos);
+ }
+
+ // unreachable
+ return true;
}
///
diff --git a/OpenSim/Services/GridService/GridService.cs b/OpenSim/Services/GridService/GridService.cs
index 125c2be8cf..aeff9b524f 100644
--- a/OpenSim/Services/GridService/GridService.cs
+++ b/OpenSim/Services/GridService/GridService.cs
@@ -286,7 +286,7 @@ namespace OpenSim.Services.GridService
}
}
- m_log.DebugFormat("[GRID SERVICE]: region {0} has {1} neighours", region.RegionName, rinfos.Count);
+ m_log.DebugFormat("[GRID SERVICE]: region {0} has {1} neighbours", region.RegionName, rinfos.Count);
return rinfos;
}
diff --git a/OpenSim/Services/GridService/HypergridLinker.cs b/OpenSim/Services/GridService/HypergridLinker.cs
index c02c81306f..553c1166d7 100644
--- a/OpenSim/Services/GridService/HypergridLinker.cs
+++ b/OpenSim/Services/GridService/HypergridLinker.cs
@@ -191,6 +191,7 @@ namespace OpenSim.Services.GridService
}
if (parts.Length >= 2)
{
+<<<<<<< HEAD:OpenSim/Services/GridService/HypergridLinker.cs
portstr = parts[1];
//m_log.Debug("-- port = " + portstr);
if (!UInt32.TryParse(portstr, out port))
@@ -219,6 +220,20 @@ namespace OpenSim.Services.GridService
{
regInfo.RegionName = mapName;
return regInfo;
+=======
+ string[] parts = mapName.Split(new char[] {' '});
+ string regionName = String.Empty;
+ if (parts.Length > 1)
+ {
+ regionName = mapName.Substring(parts[0].Length + 1);
+ regionName = regionName.Trim(new char[] {'"'});
+ }
+ if (TryCreateLink(scopeID, xloc, yloc, regionName, 0, null, parts[0], ownerID, out regInfo, out reason))
+ {
+ regInfo.RegionName = mapName;
+ return regInfo;
+ }
+>>>>>>> master:OpenSim/Services/GridService/HypergridLinker.cs
}
return null;
@@ -313,9 +328,9 @@ namespace OpenSim.Services.GridService
regInfo.RegionID = regionID;
- if ( externalName == string.Empty )
+ if (externalName == string.Empty)
regInfo.RegionName = regInfo.ServerURI;
- else
+ else
regInfo.RegionName = externalName;
m_log.Debug("[HYPERGRID LINKER]: naming linked region " + regInfo.RegionName);
diff --git a/bin/assets/TexturesAssetSet/TexturesAssetSet.xml b/bin/assets/TexturesAssetSet/TexturesAssetSet.xml
index 5484ee237f..3af9c994d1 100644
--- a/bin/assets/TexturesAssetSet/TexturesAssetSet.xml
+++ b/bin/assets/TexturesAssetSet/TexturesAssetSet.xml
@@ -413,6 +413,15 @@
+
+
+
+
diff --git a/bin/config-include/GridCommon.ini.example b/bin/config-include/GridCommon.ini.example
index 761e5eb1dd..e1bcf00f51 100644
--- a/bin/config-include/GridCommon.ini.example
+++ b/bin/config-include/GridCommon.ini.example
@@ -88,6 +88,10 @@
; accessible from other grids
;
ProfileServerURI = "http://mygridserver.com:8002/user"
+ ;; If you want to protect your assets from being copied by foreign visitors
+ ;; uncomment the next line. You may want to do this on sims that have licensed content.
+ ; OutboundPermission = False
+
[Modules]
;; Choose 0 or 1 cache modules, and the corresponding config file, if it exists.
diff --git a/bin/config-include/HyperSimianGrid.ini b/bin/config-include/HyperSimianGrid.ini
index 0b011168d8..89d6be79e3 100644
--- a/bin/config-include/HyperSimianGrid.ini
+++ b/bin/config-include/HyperSimianGrid.ini
@@ -82,3 +82,14 @@
[Profiles]
Module = "SimianProfiles"
+
+[HGInventoryAccessModule]
+ ;
+ ; === HG ONLY ===
+ ; Change this to your profile server
+ ; accessible from other grids
+ ;
+ ProfileServerURI = "http://mygridserver.com:8002/user"
+ ;; If you want to protect your assets from being copied by foreign visitors
+ ;; uncomment the next line. You may want to do this on sims that have licensed content.
+ ; OutboundPermission = False
diff --git a/bin/config-include/StandaloneCommon.ini.example b/bin/config-include/StandaloneCommon.ini.example
index 4956bc34fa..213219c12b 100644
--- a/bin/config-include/StandaloneCommon.ini.example
+++ b/bin/config-include/StandaloneCommon.ini.example
@@ -33,6 +33,10 @@
[HGInventoryAccessModule]
ProfileServerURI = "http://127.0.0.1:9000/profiles"
+ ;; If you want to protect your assets from being copied by foreign visitors
+ ;; uncomment the next line. You may want to do this on sims that have licensed content.
+ ; OutboundPermission = False
+
[Modules]
;; Choose 0 or 1 cache modules, and the corresponding config file, if it exists.