aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--OpenSim/ApplicationPlugins/RemoteController/RemoteAdminPlugin.cs5
-rw-r--r--OpenSim/ApplicationPlugins/Rest/Inventory/Rest.cs6
-rw-r--r--OpenSim/ApplicationPlugins/Rest/Inventory/RestAssetServices.cs12
-rw-r--r--OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs4
-rw-r--r--OpenSim/Client/Linden/LLClientStackModule.cs2
-rw-r--r--OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs2
-rw-r--r--OpenSim/Framework/Communications/Capabilities/Caps.cs7
-rw-r--r--OpenSim/Framework/Communications/Services/HGInventoryService.cs9
-rw-r--r--OpenSim/Region/Application/OpenSimBase.cs2
-rw-r--r--OpenSim/Region/ClientStack/ClientStackManager.cs8
-rw-r--r--OpenSim/Region/ClientStack/IClientNetworkServer.cs2
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/J2KImage.cs11
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs107
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/LLImageManager.cs7
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs5
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs2
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/Tests/PacketHandlerTests.cs2
-rw-r--r--OpenSim/Region/CoreModules/Agent/AssetTransaction/AgentAssetsTransactions.cs9
-rw-r--r--OpenSim/Region/CoreModules/Agent/AssetTransaction/AssetXferUploader.cs4
-rw-r--r--OpenSim/Region/CoreModules/Agent/Capabilities/CapabilitiesModule.cs2
-rw-r--r--OpenSim/Region/CoreModules/Agent/TextureDownload/UserTextureDownloadService.cs9
-rw-r--r--OpenSim/Region/CoreModules/Asset/CoreAssetCache.cs6
-rw-r--r--OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs11
-rw-r--r--OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs4
-rw-r--r--OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs17
-rw-r--r--OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/Tests/InventoryArchiverTests.cs218
-rw-r--r--OpenSim/Region/CoreModules/Hypergrid/HGStandaloneInventoryModule.cs3
-rw-r--r--OpenSim/Region/CoreModules/Scripting/DynamicTexture/DynamicTextureModule.cs5
-rw-r--r--OpenSim/Region/CoreModules/ServiceConnectors/Asset/HGAssetBroker.cs2
-rw-r--r--OpenSim/Region/CoreModules/ServiceConnectors/Asset/LocalAssetServiceConnector.cs2
-rw-r--r--OpenSim/Region/CoreModules/ServiceConnectors/Asset/RemoteAssetServiceConnector.cs2
-rw-r--r--OpenSim/Region/CoreModules/ServiceConnectors/User/LocalUserServiceConnector.cs2
-rw-r--r--OpenSim/Region/CoreModules/ServiceConnectors/User/RemoteUserServiceConnector.cs2
-rw-r--r--OpenSim/Region/CoreModules/World/Archiver/ArchiveReadRequest.cs2
-rw-r--r--OpenSim/Region/CoreModules/World/Archiver/ArchiveWriteRequestPreparation.cs4
-rw-r--r--OpenSim/Region/CoreModules/World/Archiver/AssetsRequest.cs20
-rw-r--r--OpenSim/Region/CoreModules/World/Archiver/Tests/ArchiverTests.cs240
-rw-r--r--OpenSim/Region/CoreModules/World/WorldMap/TexturedMapTileRenderer.cs2
-rw-r--r--OpenSim/Region/CoreModules/World/WorldMap/WorldMapModule.cs8
-rw-r--r--OpenSim/Region/Framework/Scenes/Scene.Inventory.cs22
-rw-r--r--OpenSim/Region/Framework/Scenes/Scene.cs2
-rw-r--r--OpenSim/Region/Framework/Scenes/SceneManager.cs2
-rw-r--r--OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs14
-rw-r--r--OpenSim/Region/Framework/Scenes/SceneObjectPart.cs16
-rw-r--r--OpenSim/Region/Framework/Scenes/SceneObjectPartInventory.cs5
-rw-r--r--OpenSim/Region/Framework/Scenes/ScenePresence.cs2
-rw-r--r--OpenSim/Region/Framework/Scenes/Tests/SceneObjectBasicTests.cs48
-rw-r--r--OpenSim/Region/Framework/Scenes/UuidGatherer.cs13
-rw-r--r--OpenSim/Region/OptionalModules/Scripting/Minimodule/Graphics.cs4
-rw-r--r--OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs14
-rw-r--r--OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs8
-rw-r--r--OpenSim/Services/AssetService/HGAssetService.cs2
-rw-r--r--OpenSim/SimulatorServices/RegionAssetService.cs (renamed from OpenSim/Region/CoreModules/Framework/Services/RegionAssetService.cs)261
-rw-r--r--OpenSim/Tests/Common/Setup/SceneSetupHelpers.cs14
54 files changed, 676 insertions, 518 deletions
diff --git a/OpenSim/ApplicationPlugins/RemoteController/RemoteAdminPlugin.cs b/OpenSim/ApplicationPlugins/RemoteController/RemoteAdminPlugin.cs
index e499f64..9a25faa 100644
--- a/OpenSim/ApplicationPlugins/RemoteController/RemoteAdminPlugin.cs
+++ b/OpenSim/ApplicationPlugins/RemoteController/RemoteAdminPlugin.cs
@@ -47,6 +47,7 @@ using OpenSim.Framework.Servers.HttpServer;
47using OpenSim.Region.CoreModules.World.Terrain; 47using OpenSim.Region.CoreModules.World.Terrain;
48using OpenSim.Region.Framework.Interfaces; 48using OpenSim.Region.Framework.Interfaces;
49using OpenSim.Region.Framework.Scenes; 49using OpenSim.Region.Framework.Scenes;
50using OpenSim.Services.Interfaces;
50 51
51namespace OpenSim.ApplicationPlugins.RemoteController 52namespace OpenSim.ApplicationPlugins.RemoteController
52{ 53{
@@ -1421,7 +1422,7 @@ namespace OpenSim.ApplicationPlugins.RemoteController
1421 1422
1422 UICallback uic; 1423 UICallback uic;
1423 IInventoryServices iserv = m_app.CommunicationsManager.InventoryService; 1424 IInventoryServices iserv = m_app.CommunicationsManager.InventoryService;
1424 IAssetCache aserv = m_app.CommunicationsManager.AssetCache; 1425 IAssetService aserv = m_app.SceneManager.CurrentOrFirstScene.AssetService;
1425 1426
1426 doc.LoadXml(File.ReadAllText(dafn)); 1427 doc.LoadXml(File.ReadAllText(dafn));
1427 1428
@@ -1437,7 +1438,7 @@ namespace OpenSim.ApplicationPlugins.RemoteController
1437 rass.Local = Boolean.Parse(GetStringAttribute(asset,"local","")); 1438 rass.Local = Boolean.Parse(GetStringAttribute(asset,"local",""));
1438 rass.Temporary = Boolean.Parse(GetStringAttribute(asset,"temporary","")); 1439 rass.Temporary = Boolean.Parse(GetStringAttribute(asset,"temporary",""));
1439 rass.Data = Convert.FromBase64String(asset.InnerText); 1440 rass.Data = Convert.FromBase64String(asset.InnerText);
1440 aserv.AddAsset(rass); 1441 aserv.Store(rass);
1441 } 1442 }
1442 1443
1443 avatars = doc.GetElementsByTagName("Avatar"); 1444 avatars = doc.GetElementsByTagName("Avatar");
diff --git a/OpenSim/ApplicationPlugins/Rest/Inventory/Rest.cs b/OpenSim/ApplicationPlugins/Rest/Inventory/Rest.cs
index 748f20a..5d58c6a 100644
--- a/OpenSim/ApplicationPlugins/Rest/Inventory/Rest.cs
+++ b/OpenSim/ApplicationPlugins/Rest/Inventory/Rest.cs
@@ -34,6 +34,8 @@ using log4net;
34using Nini.Config; 34using Nini.Config;
35using OpenSim.Framework; 35using OpenSim.Framework;
36using OpenSim.Framework.Communications; 36using OpenSim.Framework.Communications;
37using OpenSim.Services.Interfaces;
38using IUserService = OpenSim.Framework.Communications.IUserService;
37 39
38namespace OpenSim.ApplicationPlugins.Rest.Inventory 40namespace OpenSim.ApplicationPlugins.Rest.Inventory
39{ 41{
@@ -110,9 +112,9 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
110 get { return Comms.AvatarService; } 112 get { return Comms.AvatarService; }
111 } 113 }
112 114
113 internal static IAssetCache AssetServices 115 internal static IAssetService AssetServices
114 { 116 {
115 get { return Comms.AssetCache; } 117 get { return main.SceneManager.CurrentOrFirstScene.AssetService; }
116 } 118 }
117 119
118 /// <summary> 120 /// <summary>
diff --git a/OpenSim/ApplicationPlugins/Rest/Inventory/RestAssetServices.cs b/OpenSim/ApplicationPlugins/Rest/Inventory/RestAssetServices.cs
index 77c14c6..cd2074a 100644
--- a/OpenSim/ApplicationPlugins/Rest/Inventory/RestAssetServices.cs
+++ b/OpenSim/ApplicationPlugins/Rest/Inventory/RestAssetServices.cs
@@ -190,14 +190,12 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
190 190
191 private void DoGet(AssetRequestData rdata) 191 private void DoGet(AssetRequestData rdata)
192 { 192 {
193 bool istexture = false;
194
195 Rest.Log.DebugFormat("{0} REST Asset handler, Method = <{1}> ENTRY", MsgId, rdata.method); 193 Rest.Log.DebugFormat("{0} REST Asset handler, Method = <{1}> ENTRY", MsgId, rdata.method);
196 194
197 if (rdata.Parameters.Length == 1) 195 if (rdata.Parameters.Length == 1)
198 { 196 {
199 UUID uuid = new UUID(rdata.Parameters[0]); 197 UUID uuid = new UUID(rdata.Parameters[0]);
200 AssetBase asset = Rest.AssetServices.GetAsset(uuid, istexture); 198 AssetBase asset = Rest.AssetServices.Get(uuid.ToString());
201 199
202 if (asset != null) 200 if (asset != null)
203 { 201 {
@@ -258,7 +256,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
258 } 256 }
259 257
260 UUID uuid = new UUID(rdata.Parameters[0]); 258 UUID uuid = new UUID(rdata.Parameters[0]);
261 asset = Rest.AssetServices.GetAsset(uuid, false); 259 asset = Rest.AssetServices.Get(uuid.ToString());
262 260
263 modified = (asset != null); 261 modified = (asset != null);
264 created = !modified; 262 created = !modified;
@@ -278,7 +276,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
278 MsgId, rdata.Parameters[0], asset.ID); 276 MsgId, rdata.Parameters[0], asset.ID);
279 } 277 }
280 278
281 Rest.AssetServices.AddAsset(asset); 279 Rest.AssetServices.Store(asset);
282 280
283 } 281 }
284 else 282 else
@@ -338,7 +336,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
338 } 336 }
339 337
340 UUID uuid = new UUID(xml.GetAttribute("id")); 338 UUID uuid = new UUID(xml.GetAttribute("id"));
341 AssetBase asset = Rest.AssetServices.GetAsset(uuid, false); 339 AssetBase asset = Rest.AssetServices.Get(uuid.ToString());
342 340
343 modified = (asset != null); 341 modified = (asset != null);
344 created = !modified; 342 created = !modified;
@@ -352,7 +350,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
352 asset.Temporary = Int32.Parse(xml.GetAttribute("temporary")) != 0; 350 asset.Temporary = Int32.Parse(xml.GetAttribute("temporary")) != 0;
353 asset.Data = Convert.FromBase64String(xml.ReadElementContentAsString("Asset", "")); 351 asset.Data = Convert.FromBase64String(xml.ReadElementContentAsString("Asset", ""));
354 352
355 Rest.AssetServices.AddAsset(asset); 353 Rest.AssetServices.Store(asset);
356 354
357 if (created) 355 if (created)
358 { 356 {
diff --git a/OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs b/OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs
index 5de44b6..1a330b1 100644
--- a/OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs
+++ b/OpenSim/ApplicationPlugins/Rest/Inventory/RestInventoryServices.cs
@@ -476,7 +476,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
476 { 476 {
477 Rest.Log.DebugFormat("{0} Rest asset: {1} {2} {3}", 477 Rest.Log.DebugFormat("{0} Rest asset: {1} {2} {3}",
478 MsgId, asset.ID, asset.Type, asset.Name); 478 MsgId, asset.ID, asset.Type, asset.Name);
479 Rest.AssetServices.AddAsset(asset); 479 Rest.AssetServices.Store(asset);
480 480
481 created = true; 481 created = true;
482 rdata.appendStatus(String.Format("<p> Created asset {0}, UUID {1} <p>", 482 rdata.appendStatus(String.Format("<p> Created asset {0}, UUID {1} <p>",
@@ -682,7 +682,7 @@ namespace OpenSim.ApplicationPlugins.Rest.Inventory
682 682
683 // The asset was validated during the collection process 683 // The asset was validated during the collection process
684 684
685 Rest.AssetServices.AddAsset(asset); 685 Rest.AssetServices.Store(asset);
686 686
687 created = true; 687 created = true;
688 rdata.appendStatus(String.Format("<p> Created asset {0}, UUID {1} <p>", asset.Name, asset.ID)); 688 rdata.appendStatus(String.Format("<p> Created asset {0}, UUID {1} <p>", asset.Name, asset.ID));
diff --git a/OpenSim/Client/Linden/LLClientStackModule.cs b/OpenSim/Client/Linden/LLClientStackModule.cs
index 4639db8..461c651 100644
--- a/OpenSim/Client/Linden/LLClientStackModule.cs
+++ b/OpenSim/Client/Linden/LLClientStackModule.cs
@@ -83,7 +83,7 @@ namespace OpenSim.Client.Linden
83 m_clientServer 83 m_clientServer
84 = m_clientStackManager.CreateServer(endPoint.Address, 84 = m_clientStackManager.CreateServer(endPoint.Address,
85 ref port, m_scene.RegionInfo.ProxyOffset, m_scene.RegionInfo.m_allow_alternate_ports, m_source, 85 ref port, m_scene.RegionInfo.ProxyOffset, m_scene.RegionInfo.m_allow_alternate_ports, m_source,
86 m_scene.CommsManager.AssetCache, m_scene.AuthenticateHandler); 86 m_scene.AuthenticateHandler);
87 87
88 m_clientServer.AddScene(m_scene); 88 m_clientServer.AddScene(m_scene);
89 89
diff --git a/OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs b/OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs
index 167d081..4218ad7 100644
--- a/OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs
+++ b/OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs
@@ -88,7 +88,7 @@ namespace OpenSim.Client.VWoHTTP.ClientStack
88 if (!UUID.TryParse(param, out assetID)) 88 if (!UUID.TryParse(param, out assetID))
89 return false; 89 return false;
90 90
91 AssetBase asset = m_scene.CommsManager.AssetCache.GetAsset(assetID, true); 91 AssetBase asset = m_scene.AssetService.Get(assetID.ToString());
92 92
93 if (asset == null) 93 if (asset == null)
94 return false; 94 return false;
diff --git a/OpenSim/Framework/Communications/Capabilities/Caps.cs b/OpenSim/Framework/Communications/Capabilities/Caps.cs
index 24cf0b6..27395e3 100644
--- a/OpenSim/Framework/Communications/Capabilities/Caps.cs
+++ b/OpenSim/Framework/Communications/Capabilities/Caps.cs
@@ -34,6 +34,7 @@ using log4net;
34using OpenMetaverse; 34using OpenMetaverse;
35using OpenSim.Framework.Servers; 35using OpenSim.Framework.Servers;
36using OpenSim.Framework.Servers.HttpServer; 36using OpenSim.Framework.Servers.HttpServer;
37using OpenSim.Services.Interfaces;
37 38
38// using OpenSim.Region.Framework.Interfaces; 39// using OpenSim.Region.Framework.Interfaces;
39 40
@@ -100,7 +101,7 @@ namespace OpenSim.Framework.Communications.Capabilities
100 //private string eventQueue = "0100/"; 101 //private string eventQueue = "0100/";
101 private IHttpServer m_httpListener; 102 private IHttpServer m_httpListener;
102 private UUID m_agentID; 103 private UUID m_agentID;
103 private IAssetCache m_assetCache; 104 private IAssetService m_assetCache;
104 private int m_eventQueueCount = 1; 105 private int m_eventQueueCount = 1;
105 private Queue<string> m_capsEventQueue = new Queue<string>(); 106 private Queue<string> m_capsEventQueue = new Queue<string>();
106 private bool m_dumpAssetsToFile; 107 private bool m_dumpAssetsToFile;
@@ -128,7 +129,7 @@ namespace OpenSim.Framework.Communications.Capabilities
128 public FetchInventoryDescendentsCAPS CAPSFetchInventoryDescendents = null; 129 public FetchInventoryDescendentsCAPS CAPSFetchInventoryDescendents = null;
129 public GetClientDelegate GetClient = null; 130 public GetClientDelegate GetClient = null;
130 131
131 public Caps(IAssetCache assetCache, IHttpServer httpServer, string httpListen, uint httpPort, string capsPath, 132 public Caps(IAssetService assetCache, IHttpServer httpServer, string httpListen, uint httpPort, string capsPath,
132 UUID agent, bool dumpAssetsToFile, string regionName) 133 UUID agent, bool dumpAssetsToFile, string regionName)
133 { 134 {
134 m_assetCache = assetCache; 135 m_assetCache = assetCache;
@@ -870,7 +871,7 @@ namespace OpenSim.Framework.Communications.Capabilities
870 if (AddNewAsset != null) 871 if (AddNewAsset != null)
871 AddNewAsset(asset); 872 AddNewAsset(asset);
872 else if (m_assetCache != null) 873 else if (m_assetCache != null)
873 m_assetCache.AddAsset(asset); 874 m_assetCache.Store(asset);
874 875
875 InventoryItemBase item = new InventoryItemBase(); 876 InventoryItemBase item = new InventoryItemBase();
876 item.Owner = m_agentID; 877 item.Owner = m_agentID;
diff --git a/OpenSim/Framework/Communications/Services/HGInventoryService.cs b/OpenSim/Framework/Communications/Services/HGInventoryService.cs
index 77a6177..5334a21 100644
--- a/OpenSim/Framework/Communications/Services/HGInventoryService.cs
+++ b/OpenSim/Framework/Communications/Services/HGInventoryService.cs
@@ -40,6 +40,7 @@ using Caps = OpenSim.Framework.Communications.Capabilities.Caps;
40using LLSDHelpers = OpenSim.Framework.Communications.Capabilities.LLSDHelpers; 40using LLSDHelpers = OpenSim.Framework.Communications.Capabilities.LLSDHelpers;
41using OpenSim.Framework.Servers; 41using OpenSim.Framework.Servers;
42using OpenSim.Framework.Servers.HttpServer; 42using OpenSim.Framework.Servers.HttpServer;
43using OpenSim.Services.Interfaces;
43 44
44using OpenMetaverse.StructuredData; 45using OpenMetaverse.StructuredData;
45 46
@@ -58,7 +59,7 @@ namespace OpenSim.Framework.Communications.Services
58 59
59 // These two used for local access, standalone mode 60 // These two used for local access, standalone mode
60 private UserManagerBase m_userService = null; 61 private UserManagerBase m_userService = null;
61 IAssetDataPlugin m_assetProvider = null; 62 IAssetService m_assetProvider = null;
62 63
63 // These two used for remote access 64 // These two used for remote access
64 //string m_UserServerURL = string.Empty; 65 //string m_UserServerURL = string.Empty;
@@ -77,7 +78,7 @@ namespace OpenSim.Framework.Communications.Services
77 } 78 }
78 79
79 // Constructor for standalone mode 80 // Constructor for standalone mode
80 public HGInventoryService(InventoryServiceBase invService, IAssetDataPlugin assetService, UserManagerBase userService, IHttpServer httpserver, string thisurl) 81 public HGInventoryService(InventoryServiceBase invService, IAssetService assetService, UserManagerBase userService, IHttpServer httpserver, string thisurl)
81 { 82 {
82 m_userService = userService; 83 m_userService = userService;
83 m_assetProvider = assetService; 84 m_assetProvider = assetService;
@@ -708,7 +709,7 @@ namespace OpenSim.Framework.Communications.Services
708 return m_AssetClient.SyncGetAsset(assetID, isTexture); 709 return m_AssetClient.SyncGetAsset(assetID, isTexture);
709 // local call 710 // local call
710 else 711 else
711 return m_assetProvider.FetchAsset(assetID); 712 return m_assetProvider.Get(assetID.ToString());
712 } 713 }
713 714
714 void StoreAsset(AssetBase asset) 715 void StoreAsset(AssetBase asset)
@@ -718,7 +719,7 @@ namespace OpenSim.Framework.Communications.Services
718 m_AssetClient.StoreAsset(asset); 719 m_AssetClient.StoreAsset(asset);
719 // local call 720 // local call
720 else 721 else
721 m_assetProvider.CreateAsset(asset); 722 m_assetProvider.Store(asset);
722 } 723 }
723 724
724 #endregion Local vs Remote 725 #endregion Local vs Remote
diff --git a/OpenSim/Region/Application/OpenSimBase.cs b/OpenSim/Region/Application/OpenSimBase.cs
index 53cba9f..cc1f59a 100644
--- a/OpenSim/Region/Application/OpenSimBase.cs
+++ b/OpenSim/Region/Application/OpenSimBase.cs
@@ -673,7 +673,7 @@ namespace OpenSim
673 clientServer 673 clientServer
674 = m_clientStackManager.CreateServer( 674 = m_clientStackManager.CreateServer(
675 listenIP, ref port, proxyOffset, regionInfo.m_allow_alternate_ports, configSource, 675 listenIP, ref port, proxyOffset, regionInfo.m_allow_alternate_ports, configSource,
676 m_assetCache, circuitManager); 676 circuitManager);
677 } 677 }
678 else 678 else
679 { 679 {
diff --git a/OpenSim/Region/ClientStack/ClientStackManager.cs b/OpenSim/Region/ClientStack/ClientStackManager.cs
index a7b65cb..4f36df8 100644
--- a/OpenSim/Region/ClientStack/ClientStackManager.cs
+++ b/OpenSim/Region/ClientStack/ClientStackManager.cs
@@ -86,10 +86,10 @@ namespace OpenSim.Region.ClientStack
86 /// <returns></returns> 86 /// <returns></returns>
87 public IClientNetworkServer CreateServer( 87 public IClientNetworkServer CreateServer(
88 IPAddress _listenIP, ref uint port, int proxyPortOffset, bool allow_alternate_port, 88 IPAddress _listenIP, ref uint port, int proxyPortOffset, bool allow_alternate_port,
89 IAssetCache assetCache, AgentCircuitManager authenticateClass) 89 AgentCircuitManager authenticateClass)
90 { 90 {
91 return CreateServer( 91 return CreateServer(
92 _listenIP, ref port, proxyPortOffset, allow_alternate_port, null, assetCache, authenticateClass); 92 _listenIP, ref port, proxyPortOffset, allow_alternate_port, null, authenticateClass);
93 } 93 }
94 94
95 /// <summary> 95 /// <summary>
@@ -107,7 +107,7 @@ namespace OpenSim.Region.ClientStack
107 /// <returns></returns> 107 /// <returns></returns>
108 public IClientNetworkServer CreateServer( 108 public IClientNetworkServer CreateServer(
109 IPAddress _listenIP, ref uint port, int proxyPortOffset, bool allow_alternate_port, IConfigSource configSource, 109 IPAddress _listenIP, ref uint port, int proxyPortOffset, bool allow_alternate_port, IConfigSource configSource,
110 IAssetCache assetCache, AgentCircuitManager authenticateClass) 110 AgentCircuitManager authenticateClass)
111 { 111 {
112 if (plugin != null) 112 if (plugin != null)
113 { 113 {
@@ -116,7 +116,7 @@ namespace OpenSim.Region.ClientStack
116 116
117 server.Initialise( 117 server.Initialise(
118 _listenIP, ref port, proxyPortOffset, allow_alternate_port, 118 _listenIP, ref port, proxyPortOffset, allow_alternate_port,
119 configSource, assetCache, authenticateClass); 119 configSource, authenticateClass);
120 120
121 return server; 121 return server;
122 } 122 }
diff --git a/OpenSim/Region/ClientStack/IClientNetworkServer.cs b/OpenSim/Region/ClientStack/IClientNetworkServer.cs
index f2f1614..23f639f 100644
--- a/OpenSim/Region/ClientStack/IClientNetworkServer.cs
+++ b/OpenSim/Region/ClientStack/IClientNetworkServer.cs
@@ -36,7 +36,7 @@ namespace OpenSim.Region.ClientStack
36 { 36 {
37 void Initialise( 37 void Initialise(
38 IPAddress _listenIP, ref uint port, int proxyPortOffsetParm, bool allow_alternate_port, IConfigSource configSource, 38 IPAddress _listenIP, ref uint port, int proxyPortOffsetParm, bool allow_alternate_port, IConfigSource configSource,
39 IAssetCache assetCache, AgentCircuitManager authenticateClass); 39 AgentCircuitManager authenticateClass);
40 40
41 Socket Server { get; } 41 Socket Server { get; }
42 bool HandlesRegion(Location x); 42 bool HandlesRegion(Location x);
diff --git a/OpenSim/Region/ClientStack/LindenUDP/J2KImage.cs b/OpenSim/Region/ClientStack/LindenUDP/J2KImage.cs
index aef0ada..a88fd26 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/J2KImage.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/J2KImage.cs
@@ -31,6 +31,7 @@ using OpenMetaverse;
31using OpenMetaverse.Imaging; 31using OpenMetaverse.Imaging;
32using OpenSim.Framework; 32using OpenSim.Framework;
33using OpenSim.Region.Framework.Interfaces; 33using OpenSim.Region.Framework.Interfaces;
34using OpenSim.Services.Interfaces;
34using log4net; 35using log4net;
35using System.Reflection; 36using System.Reflection;
36 37
@@ -50,7 +51,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
50 public sbyte m_requestedDiscardLevel; 51 public sbyte m_requestedDiscardLevel;
51 public UUID m_requestedUUID; 52 public UUID m_requestedUUID;
52 public IJ2KDecoder m_j2kDecodeModule; 53 public IJ2KDecoder m_j2kDecodeModule;
53 public IAssetCache m_assetCache; 54 public IAssetService m_assetCache;
54 public OpenJPEG.J2KLayerInfo[] Layers = new OpenJPEG.J2KLayerInfo[0]; 55 public OpenJPEG.J2KLayerInfo[] Layers = new OpenJPEG.J2KLayerInfo[0];
55 public AssetBase m_MissingSubstitute = null; 56 public AssetBase m_MissingSubstitute = null;
56 public bool m_decoded = false; 57 public bool m_decoded = false;
@@ -131,6 +132,12 @@ namespace OpenSim.Region.ClientStack.LindenUDP
131 RunUpdate(); 132 RunUpdate();
132 } 133 }
133 134
135 protected void AssetReceived(string id, Object sender, AssetBase asset)
136 {
137 if (asset != null)
138 AssetDataCallback(asset.FullID, asset);
139 }
140
134 private int GetPacketForBytePosition(int bytePosition) 141 private int GetPacketForBytePosition(int bytePosition)
135 { 142 {
136 return ((bytePosition - cFirstPacketSize + cImagePacketSize - 1) / cImagePacketSize) + 1; 143 return ((bytePosition - cFirstPacketSize + cImagePacketSize - 1) / cImagePacketSize) + 1;
@@ -301,7 +308,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
301 if (!m_asset_requested) 308 if (!m_asset_requested)
302 { 309 {
303 m_asset_requested = true; 310 m_asset_requested = true;
304 m_assetCache.GetAsset(m_requestedUUID, AssetDataCallback, true); 311 m_assetCache.Get(m_requestedUUID.ToString(), this, AssetReceived);
305 312
306 } 313 }
307 314
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
index 0eb08b2..7c524d9 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
@@ -43,6 +43,7 @@ using OpenSim.Framework.Communications.Cache;
43using OpenSim.Framework.Statistics; 43using OpenSim.Framework.Statistics;
44using OpenSim.Region.Framework.Interfaces; 44using OpenSim.Region.Framework.Interfaces;
45using OpenSim.Region.Framework.Scenes; 45using OpenSim.Region.Framework.Scenes;
46using OpenSim.Services.Interfaces;
46using Timer=System.Timers.Timer; 47using Timer=System.Timers.Timer;
47using Nini.Config; 48using Nini.Config;
48 49
@@ -66,7 +67,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
66 67
67 private int m_debugPacketLevel; 68 private int m_debugPacketLevel;
68 69
69 private readonly IAssetCache m_assetCache; 70 //private readonly IAssetCache m_assetCache;
70 private int m_cachedTextureSerial; 71 private int m_cachedTextureSerial;
71 private Timer m_clientPingTimer; 72 private Timer m_clientPingTimer;
72 73
@@ -141,6 +142,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
141 142
142 protected int m_packetMTU = 1400; 143 protected int m_packetMTU = 1400;
143 144
145 protected IAssetService m_assetService;
146
144 // LLClientView Only 147 // LLClientView Only
145 public delegate void BinaryGenericMessage(Object sender, string method, byte[][] args); 148 public delegate void BinaryGenericMessage(Object sender, string method, byte[][] args);
146 149
@@ -490,7 +493,10 @@ namespace OpenSim.Region.ClientStack.LindenUDP
490 InitDefaultAnimations(); 493 InitDefaultAnimations();
491 494
492 m_scene = scene; 495 m_scene = scene;
493 m_assetCache = assetCache; 496 //m_assetCache = assetCache;
497
498 m_assetService = m_scene.RequestModuleInterface<IAssetService>();
499 m_log.Debug("[XXX] m_assetService is null? " + ((m_assetService == null) ? "yes" : "no"));
494 500
495 m_networkServer = packServer; 501 m_networkServer = packServer;
496 502
@@ -543,7 +549,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
543 } 549 }
544 550
545 RegisterLocalPacketHandlers(); 551 RegisterLocalPacketHandlers();
546 m_imageManager = new LLImageManager(this, m_assetCache,Scene.RequestModuleInterface<IJ2KDecoder>()); 552 m_imageManager = new LLImageManager(this, m_assetService, Scene.RequestModuleInterface<IJ2KDecoder>());
547 } 553 }
548 554
549 public void SetDebugPacketLevel(int newDebugPacketLevel) 555 public void SetDebugPacketLevel(int newDebugPacketLevel)
@@ -6451,7 +6457,10 @@ namespace OpenSim.Region.ClientStack.LindenUDP
6451 } 6457 }
6452 } 6458 }
6453 6459
6454 m_assetCache.AddAssetRequest(this, transfer); 6460 //m_assetCache.AddAssetRequest(this, transfer);
6461
6462 MakeAssetRequest(transfer);
6463
6455 /* RequestAsset = OnRequestAsset; 6464 /* RequestAsset = OnRequestAsset;
6456 if (RequestAsset != null) 6465 if (RequestAsset != null)
6457 { 6466 {
@@ -7115,7 +7124,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
7115 AssetLandmark lm; 7124 AssetLandmark lm;
7116 if (lmid != UUID.Zero) 7125 if (lmid != UUID.Zero)
7117 { 7126 {
7118 AssetBase lma = m_assetCache.GetAsset(lmid, false); 7127 //AssetBase lma = m_assetCache.GetAsset(lmid, false);
7128 AssetBase lma = m_assetService.Get(lmid.ToString());
7119 7129
7120 if (lma == null) 7130 if (lma == null)
7121 { 7131 {
@@ -10604,6 +10614,93 @@ namespace OpenSim.Region.ClientStack.LindenUDP
10604 return ""; 10614 return "";
10605 } 10615 }
10606 10616
10617 public void MakeAssetRequest(TransferRequestPacket transferRequest)
10618 {
10619 UUID requestID = UUID.Zero;
10620 if (transferRequest.TransferInfo.SourceType == 2)
10621 {
10622 //direct asset request
10623 requestID = new UUID(transferRequest.TransferInfo.Params, 0);
10624 }
10625 else if (transferRequest.TransferInfo.SourceType == 3)
10626 {
10627 //inventory asset request
10628 requestID = new UUID(transferRequest.TransferInfo.Params, 80);
10629 //m_log.Debug("asset request " + requestID);
10630 }
10631
10632 //check to see if asset is in local cache, if not we need to request it from asset server.
10633 //m_log.Debug("asset request " + requestID);
10634
10635 m_assetService.Get(requestID.ToString(), transferRequest, AssetReceived);
10636
10637 }
10638
10639 protected void AssetReceived(string id, Object sender, AssetBase asset)
10640 {
10641 TransferRequestPacket transferRequest = (TransferRequestPacket)sender;
10642
10643 UUID requestID = UUID.Zero;
10644 byte source = 2;
10645 if (transferRequest.TransferInfo.SourceType == 2)
10646 {
10647 //direct asset request
10648 requestID = new UUID(transferRequest.TransferInfo.Params, 0);
10649 }
10650 else if (transferRequest.TransferInfo.SourceType == 3)
10651 {
10652 //inventory asset request
10653 requestID = new UUID(transferRequest.TransferInfo.Params, 80);
10654 source = 3;
10655 //m_log.Debug("asset request " + requestID);
10656 }
10657
10658 // FIXME: We never tell the client about assets which do not exist when requested by this transfer mechanism, which can't be right.
10659 if (null == asset)
10660 {
10661 //m_log.DebugFormat("[ASSET CACHE]: Asset transfer request for asset which is {0} already known to be missing. Dropping", requestID);
10662 return;
10663 }
10664
10665 // Scripts cannot be retrieved by direct request
10666 if (transferRequest.TransferInfo.SourceType == 2 && asset.Type == 10)
10667 return;
10668
10669 // The asset is known to exist and is in our cache, so add it to the AssetRequests list
10670 AssetRequestToClient req = new AssetRequestToClient();
10671 req.AssetInf = asset;
10672 req.AssetRequestSource = source;
10673 req.IsTextureRequest = false;
10674 req.NumPackets = CalculateNumPackets(asset.Data);
10675 req.Params = transferRequest.TransferInfo.Params;
10676 req.RequestAssetID = requestID;
10677 req.TransferRequestID = transferRequest.TransferInfo.TransferID;
10678
10679 SendAsset(req);
10680 }
10681
10682 /// <summary>
10683 /// Calculate the number of packets required to send the asset to the client.
10684 /// </summary>
10685 /// <param name="data"></param>
10686 /// <returns></returns>
10687 private static int CalculateNumPackets(byte[] data)
10688 {
10689 const uint m_maxPacketSize = 600;
10690 int numPackets = 1;
10691
10692 if (data.LongLength > m_maxPacketSize)
10693 {
10694 // over max number of bytes so split up file
10695 long restData = data.LongLength - m_maxPacketSize;
10696 int restPackets = (int)((restData + m_maxPacketSize - 1) / m_maxPacketSize);
10697 numPackets += restPackets;
10698 }
10699
10700 return numPackets;
10701 }
10702
10703
10607 #region IClientIPEndpoint Members 10704 #region IClientIPEndpoint Members
10608 10705
10609 public IPAddress EndPoint 10706 public IPAddress EndPoint
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLImageManager.cs b/OpenSim/Region/ClientStack/LindenUDP/LLImageManager.cs
index 1aa0c75..a2160c6 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLImageManager.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLImageManager.cs
@@ -31,6 +31,7 @@ using OpenMetaverse;
31using OpenMetaverse.Imaging; 31using OpenMetaverse.Imaging;
32using OpenSim.Framework; 32using OpenSim.Framework;
33using OpenSim.Region.Framework.Interfaces; 33using OpenSim.Region.Framework.Interfaces;
34using OpenSim.Services.Interfaces;
34using log4net; 35using log4net;
35using System.Reflection; 36using System.Reflection;
36 37
@@ -50,7 +51,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
50 private long m_lastloopprocessed = 0; 51 private long m_lastloopprocessed = 0;
51 52
52 private LLClientView m_client; //Client we're assigned to 53 private LLClientView m_client; //Client we're assigned to
53 private IAssetCache m_assetCache; //Asset Cache 54 private IAssetService m_assetCache; //Asset Cache
54 private IJ2KDecoder m_j2kDecodeModule; //Our J2K module 55 private IJ2KDecoder m_j2kDecodeModule; //Our J2K module
55 56
56 private readonly AssetBase m_missingsubstitute; //Sustitute for bad decodes 57 private readonly AssetBase m_missingsubstitute; //Sustitute for bad decodes
@@ -62,7 +63,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
62 63
63 public int m_outstandingtextures = 0; 64 public int m_outstandingtextures = 0;
64 //Constructor 65 //Constructor
65 public LLImageManager(LLClientView client, IAssetCache pAssetCache, IJ2KDecoder pJ2kDecodeModule) 66 public LLImageManager(LLClientView client, IAssetService pAssetCache, IJ2KDecoder pJ2kDecodeModule)
66 { 67 {
67 68
68 m_imagestore = new Dictionary<UUID,J2KImage>(); 69 m_imagestore = new Dictionary<UUID,J2KImage>();
@@ -71,7 +72,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
71 m_client = client; 72 m_client = client;
72 m_assetCache = pAssetCache; 73 m_assetCache = pAssetCache;
73 if (pAssetCache != null) 74 if (pAssetCache != null)
74 m_missingsubstitute = pAssetCache.GetAsset(UUID.Parse("5748decc-f629-461c-9a36-a35a221fe21f"), true); 75 m_missingsubstitute = pAssetCache.Get("5748decc-f629-461c-9a36-a35a221fe21f");
75 else 76 else
76 m_log.Error("[ClientView] - couldn't set missing image, all manner of things will probably break"); 77 m_log.Error("[ClientView] - couldn't set missing image, all manner of things will probably break");
77 m_j2kDecodeModule = pJ2kDecodeModule; 78 m_j2kDecodeModule = pJ2kDecodeModule;
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs b/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs
index e796cff..4eaaea1 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs
@@ -132,7 +132,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
132 IPAddress _listenIP, ref uint port, int proxyPortOffset, bool allow_alternate_port, IConfigSource configSource, 132 IPAddress _listenIP, ref uint port, int proxyPortOffset, bool allow_alternate_port, IConfigSource configSource,
133 IAssetCache assetCache, AgentCircuitManager authenticateClass) 133 IAssetCache assetCache, AgentCircuitManager authenticateClass)
134 { 134 {
135 Initialise(_listenIP, ref port, proxyPortOffset, allow_alternate_port, configSource, assetCache, authenticateClass); 135 Initialise(_listenIP, ref port, proxyPortOffset, allow_alternate_port, configSource, authenticateClass);
136 } 136 }
137 137
138 /// <summary> 138 /// <summary>
@@ -147,7 +147,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
147 /// <param name="circuitManager"></param> 147 /// <param name="circuitManager"></param>
148 public void Initialise( 148 public void Initialise(
149 IPAddress _listenIP, ref uint port, int proxyPortOffsetParm, bool allow_alternate_port, IConfigSource configSource, 149 IPAddress _listenIP, ref uint port, int proxyPortOffsetParm, bool allow_alternate_port, IConfigSource configSource,
150 IAssetCache assetCache, AgentCircuitManager circuitManager) 150 AgentCircuitManager circuitManager)
151 { 151 {
152 ClientStackUserSettings userSettings = new ClientStackUserSettings(); 152 ClientStackUserSettings userSettings = new ClientStackUserSettings();
153 153
@@ -165,7 +165,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP
165 listenPort = (uint) (port + proxyPortOffsetParm); 165 listenPort = (uint) (port + proxyPortOffsetParm);
166 listenIP = _listenIP; 166 listenIP = _listenIP;
167 Allow_Alternate_Port = allow_alternate_port; 167 Allow_Alternate_Port = allow_alternate_port;
168 m_assetCache = assetCache;
169 m_circuitManager = circuitManager; 168 m_circuitManager = circuitManager;
170 CreatePacketServer(userSettings); 169 CreatePacketServer(userSettings);
171 170
diff --git a/OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs b/OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs
index 02f78c7..46d39c7 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs
@@ -73,7 +73,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP.Tests
73 acm = new AgentCircuitManager(); 73 acm = new AgentCircuitManager();
74 74
75 uint port = 666; 75 uint port = 666;
76 testLLUDPServer.Initialise(null, ref port, 0, false, configSource, null, acm); 76 testLLUDPServer.Initialise(null, ref port, 0, false, configSource, acm);
77 testPacketServer = new TestLLPacketServer(testLLUDPServer, userSettings); 77 testPacketServer = new TestLLPacketServer(testLLUDPServer, userSettings);
78 testLLUDPServer.LocalScene = scene; 78 testLLUDPServer.LocalScene = scene;
79 } 79 }
diff --git a/OpenSim/Region/ClientStack/LindenUDP/Tests/PacketHandlerTests.cs b/OpenSim/Region/ClientStack/LindenUDP/Tests/PacketHandlerTests.cs
index 4ebc624..e014634 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/Tests/PacketHandlerTests.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/Tests/PacketHandlerTests.cs
@@ -98,7 +98,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP.Tests
98 acm = new AgentCircuitManager(); 98 acm = new AgentCircuitManager();
99 99
100 uint port = 666; 100 uint port = 666;
101 testLLUDPServer.Initialise(null, ref port, 0, false, configSource, null, acm); 101 testLLUDPServer.Initialise(null, ref port, 0, false, configSource, acm);
102 testPacketServer = new TestLLPacketServer(testLLUDPServer, userSettings); 102 testPacketServer = new TestLLPacketServer(testLLUDPServer, userSettings);
103 testLLUDPServer.LocalScene = scene; 103 testLLUDPServer.LocalScene = scene;
104 } 104 }
diff --git a/OpenSim/Region/CoreModules/Agent/AssetTransaction/AgentAssetsTransactions.cs b/OpenSim/Region/CoreModules/Agent/AssetTransaction/AgentAssetsTransactions.cs
index eefcfe8..94140fc 100644
--- a/OpenSim/Region/CoreModules/Agent/AssetTransaction/AgentAssetsTransactions.cs
+++ b/OpenSim/Region/CoreModules/Agent/AssetTransaction/AgentAssetsTransactions.cs
@@ -32,6 +32,7 @@ using OpenMetaverse;
32using OpenSim.Framework; 32using OpenSim.Framework;
33using OpenSim.Framework.Communications.Cache; 33using OpenSim.Framework.Communications.Cache;
34using OpenSim.Region.Framework.Scenes; 34using OpenSim.Region.Framework.Scenes;
35using OpenSim.Services.Interfaces;
35 36
36namespace OpenSim.Region.CoreModules.Agent.AssetTransaction 37namespace OpenSim.Region.CoreModules.Agent.AssetTransaction
37{ 38{
@@ -177,7 +178,7 @@ namespace OpenSim.Region.CoreModules.Agent.AssetTransaction
177 asset.Type = (sbyte)item.Type; 178 asset.Type = (sbyte)item.Type;
178 item.AssetID = asset.FullID; 179 item.AssetID = asset.FullID;
179 180
180 Manager.MyScene.CommsManager.AssetCache.AddAsset(asset); 181 Manager.MyScene.AssetService.Store(asset);
181 182
182 if (part.Inventory.UpdateInventoryItem(item)) 183 if (part.Inventory.UpdateInventoryItem(item))
183 part.GetProperties(remoteClient); 184 part.GetProperties(remoteClient);
@@ -198,9 +199,7 @@ namespace OpenSim.Region.CoreModules.Agent.AssetTransaction
198 { 199 {
199 UUID assetID = UUID.Combine(transactionID, remoteClient.SecureSessionId); 200 UUID assetID = UUID.Combine(transactionID, remoteClient.SecureSessionId);
200 201
201 AssetBase asset 202 AssetBase asset = Manager.MyScene.AssetService.Get(assetID.ToString());
202 = Manager.MyScene.CommsManager.AssetCache.GetAsset(
203 assetID, (item.AssetType == (int)AssetType.Texture ? true : false));
204 203
205 if (asset == null) 204 if (asset == null)
206 { 205 {
@@ -216,7 +215,7 @@ namespace OpenSim.Region.CoreModules.Agent.AssetTransaction
216 asset.Type = (sbyte)item.AssetType; 215 asset.Type = (sbyte)item.AssetType;
217 item.AssetID = asset.FullID; 216 item.AssetID = asset.FullID;
218 217
219 Manager.MyScene.CommsManager.AssetCache.AddAsset(asset); 218 Manager.MyScene.AssetService.Store(asset);
220 } 219 }
221 220
222 userInfo.UpdateItem(item); 221 userInfo.UpdateItem(item);
diff --git a/OpenSim/Region/CoreModules/Agent/AssetTransaction/AssetXferUploader.cs b/OpenSim/Region/CoreModules/Agent/AssetTransaction/AssetXferUploader.cs
index a8e5ae3..6044949 100644
--- a/OpenSim/Region/CoreModules/Agent/AssetTransaction/AssetXferUploader.cs
+++ b/OpenSim/Region/CoreModules/Agent/AssetTransaction/AssetXferUploader.cs
@@ -153,7 +153,7 @@ namespace OpenSim.Region.CoreModules.Agent.AssetTransaction
153 } 153 }
154 else if (m_storeLocal) 154 else if (m_storeLocal)
155 { 155 {
156 m_userTransactions.Manager.MyScene.CommsManager.AssetCache.AddAsset(m_asset); 156 m_userTransactions.Manager.MyScene.AssetService.Store(m_asset);
157 } 157 }
158 158
159 m_log.DebugFormat("[ASSET TRANSACTIONS]: Uploaded asset data for transaction {0}", TransactionID); 159 m_log.DebugFormat("[ASSET TRANSACTIONS]: Uploaded asset data for transaction {0}", TransactionID);
@@ -213,7 +213,7 @@ namespace OpenSim.Region.CoreModules.Agent.AssetTransaction
213 213
214 private void DoCreateItem(uint callbackID) 214 private void DoCreateItem(uint callbackID)
215 { 215 {
216 m_userTransactions.Manager.MyScene.CommsManager.AssetCache.AddAsset(m_asset); 216 m_userTransactions.Manager.MyScene.AssetService.Store(m_asset);
217 CachedUserInfo userInfo = 217 CachedUserInfo userInfo =
218 m_userTransactions.Manager.MyScene.CommsManager.UserProfileCacheService.GetUserDetails( 218 m_userTransactions.Manager.MyScene.CommsManager.UserProfileCacheService.GetUserDetails(
219 ourClient.AgentId); 219 ourClient.AgentId);
diff --git a/OpenSim/Region/CoreModules/Agent/Capabilities/CapabilitiesModule.cs b/OpenSim/Region/CoreModules/Agent/Capabilities/CapabilitiesModule.cs
index 39dd84f..dbd5104 100644
--- a/OpenSim/Region/CoreModules/Agent/Capabilities/CapabilitiesModule.cs
+++ b/OpenSim/Region/CoreModules/Agent/Capabilities/CapabilitiesModule.cs
@@ -86,7 +86,7 @@ namespace OpenSim.Region.CoreModules.Agent.Capabilities
86 86
87 Caps caps 87 Caps caps
88 = new Caps( 88 = new Caps(
89 m_scene.CommsManager.AssetCache, m_scene.CommsManager.HttpServer, m_scene.RegionInfo.ExternalHostName, 89 m_scene.AssetService, m_scene.CommsManager.HttpServer, m_scene.RegionInfo.ExternalHostName,
90 m_scene.CommsManager.HttpServer.Port, 90 m_scene.CommsManager.HttpServer.Port,
91 capsObjectPath, agentId, m_scene.DumpAssetsToFile, m_scene.RegionInfo.RegionName); 91 capsObjectPath, agentId, m_scene.DumpAssetsToFile, m_scene.RegionInfo.RegionName);
92 92
diff --git a/OpenSim/Region/CoreModules/Agent/TextureDownload/UserTextureDownloadService.cs b/OpenSim/Region/CoreModules/Agent/TextureDownload/UserTextureDownloadService.cs
index e4a2b21..9c8d294 100644
--- a/OpenSim/Region/CoreModules/Agent/TextureDownload/UserTextureDownloadService.cs
+++ b/OpenSim/Region/CoreModules/Agent/TextureDownload/UserTextureDownloadService.cs
@@ -25,6 +25,7 @@
25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */ 26 */
27 27
28using System;
28using System.Collections.Generic; 29using System.Collections.Generic;
29using System.Reflection; 30using System.Reflection;
30using log4net; 31using log4net;
@@ -152,7 +153,7 @@ namespace OpenSim.Region.CoreModules.Agent.TextureDownload
152 TextureSender.TextureSender requestHandler = new TextureSender.TextureSender(m_client, e.DiscardLevel, e.PacketNumber); 153 TextureSender.TextureSender requestHandler = new TextureSender.TextureSender(m_client, e.DiscardLevel, e.PacketNumber);
153 m_textureSenders.Add(e.RequestedAssetID, requestHandler); 154 m_textureSenders.Add(e.RequestedAssetID, requestHandler);
154 155
155 m_scene.CommsManager.AssetCache.GetAsset(e.RequestedAssetID, TextureCallback, true); 156 m_scene.AssetService.Get(e.RequestedAssetID.ToString(), this, TextureReceived);
156 } 157 }
157 } 158 }
158 } 159 }
@@ -168,6 +169,12 @@ namespace OpenSim.Region.CoreModules.Agent.TextureDownload
168 } 169 }
169 } 170 }
170 171
172 protected void TextureReceived(string id, Object sender, AssetBase asset)
173 {
174 if (asset != null)
175 TextureCallback(asset.FullID, asset);
176 }
177
171 /// <summary> 178 /// <summary>
172 /// The callback for the asset cache when a texture has been retrieved. This method queues the 179 /// The callback for the asset cache when a texture has been retrieved. This method queues the
173 /// texture sender for processing. 180 /// texture sender for processing.
diff --git a/OpenSim/Region/CoreModules/Asset/CoreAssetCache.cs b/OpenSim/Region/CoreModules/Asset/CoreAssetCache.cs
index c7f8c31..bc6a239 100644
--- a/OpenSim/Region/CoreModules/Asset/CoreAssetCache.cs
+++ b/OpenSim/Region/CoreModules/Asset/CoreAssetCache.cs
@@ -56,10 +56,14 @@ namespace OpenSim.Region.CoreModules.Asset
56 56
57 public void Initialise(IConfigSource source) 57 public void Initialise(IConfigSource source)
58 { 58 {
59 IConfig moduleConfig = source.Configs["Modules"]; 59 IConfig moduleConfig = source.Configs["ServiceConnectors"];
60 m_log.DebugFormat("[XXX] moduleConfig null? {0}", ((moduleConfig == null) ? "yes" : "no"));
61
60 if (moduleConfig != null) 62 if (moduleConfig != null)
61 { 63 {
62 string name = moduleConfig.GetString("AssetCaching", "CoreAssetCache"); 64 string name = moduleConfig.GetString("AssetCaching", "CoreAssetCache");
65 m_log.DebugFormat("[XXX] name = {0} (this module's name: {1}", name, Name);
66
63 if (name == Name) 67 if (name == Name)
64 { 68 {
65 IConfig assetConfig = source.Configs["AssetCache"]; 69 IConfig assetConfig = source.Configs["AssetCache"];
diff --git a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs
index b0c1d0b..ca731d5 100644
--- a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs
+++ b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs
@@ -41,6 +41,7 @@ using OpenSim.Framework.Communications.Osp;
41using OpenSim.Framework.Serialization; 41using OpenSim.Framework.Serialization;
42using OpenSim.Framework.Serialization.External; 42using OpenSim.Framework.Serialization.External;
43using OpenSim.Region.CoreModules.World.Archiver; 43using OpenSim.Region.CoreModules.World.Archiver;
44using OpenSim.Services.Interfaces;
44 45
45namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver 46namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
46{ 47{
@@ -59,24 +60,26 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
59 private Stream m_loadStream; 60 private Stream m_loadStream;
60 61
61 protected CommunicationsManager m_commsManager; 62 protected CommunicationsManager m_commsManager;
63 protected IAssetService m_assetService;
62 64
63 public InventoryArchiveReadRequest( 65 public InventoryArchiveReadRequest(
64 CachedUserInfo userInfo, string invPath, string loadPath, CommunicationsManager commsManager) 66 CachedUserInfo userInfo, string invPath, string loadPath, CommunicationsManager commsManager, IAssetService assetService)
65 : this( 67 : this(
66 userInfo, 68 userInfo,
67 invPath, 69 invPath,
68 new GZipStream(new FileStream(loadPath, FileMode.Open), CompressionMode.Decompress), 70 new GZipStream(new FileStream(loadPath, FileMode.Open), CompressionMode.Decompress),
69 commsManager) 71 commsManager, assetService)
70 { 72 {
71 } 73 }
72 74
73 public InventoryArchiveReadRequest( 75 public InventoryArchiveReadRequest(
74 CachedUserInfo userInfo, string invPath, Stream loadStream, CommunicationsManager commsManager) 76 CachedUserInfo userInfo, string invPath, Stream loadStream, CommunicationsManager commsManager, IAssetService assetService)
75 { 77 {
76 m_userInfo = userInfo; 78 m_userInfo = userInfo;
77 m_invPath = invPath; 79 m_invPath = invPath;
78 m_loadStream = loadStream; 80 m_loadStream = loadStream;
79 m_commsManager = commsManager; 81 m_commsManager = commsManager;
82 m_assetService = assetService;
80 } 83 }
81 84
82 /// <summary> 85 /// <summary>
@@ -356,7 +359,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
356 asset.Type = assetType; 359 asset.Type = assetType;
357 asset.Data = data; 360 asset.Data = data;
358 361
359 m_commsManager.AssetCache.AddAsset(asset); 362 m_assetService.Store(asset);
360 363
361 return true; 364 return true;
362 } 365 }
diff --git a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs
index fec2425..b3014ef 100644
--- a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs
+++ b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs
@@ -97,7 +97,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
97 m_userInfo = userInfo; 97 m_userInfo = userInfo;
98 m_invPath = invPath; 98 m_invPath = invPath;
99 m_saveStream = saveStream; 99 m_saveStream = saveStream;
100 m_assetGatherer = new UuidGatherer(m_module.CommsManager.AssetCache); 100 m_assetGatherer = new UuidGatherer(m_module.AssetService);
101 } 101 }
102 102
103 protected void ReceivedAllAssets(ICollection<UUID> assetsFoundUuids, ICollection<UUID> assetsNotFoundUuids) 103 protected void ReceivedAllAssets(ICollection<UUID> assetsFoundUuids, ICollection<UUID> assetsNotFoundUuids)
@@ -297,7 +297,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
297 SaveUsers(); 297 SaveUsers();
298 new AssetsRequest( 298 new AssetsRequest(
299 new AssetsArchiver(m_archiveWriter), m_assetUuids.Keys, 299 new AssetsArchiver(m_archiveWriter), m_assetUuids.Keys,
300 m_module.CommsManager.AssetCache, ReceivedAllAssets).Execute(); 300 m_module.AssetService, ReceivedAllAssets).Execute();
301 } 301 }
302 302
303 /// <summary> 303 /// <summary>
diff --git a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
index c5699c0..efef840 100644
--- a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
+++ b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
@@ -37,6 +37,7 @@ using OpenSim.Framework.Communications;
37using OpenSim.Framework.Communications.Cache; 37using OpenSim.Framework.Communications.Cache;
38using OpenSim.Region.Framework.Interfaces; 38using OpenSim.Region.Framework.Interfaces;
39using OpenSim.Region.Framework.Scenes; 39using OpenSim.Region.Framework.Scenes;
40using OpenSim.Services.Interfaces;
40 41
41namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver 42namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
42{ 43{
@@ -62,11 +63,12 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
62 /// All scenes that this module knows about 63 /// All scenes that this module knows about
63 /// </value> 64 /// </value>
64 private Dictionary<UUID, Scene> m_scenes = new Dictionary<UUID, Scene>(); 65 private Dictionary<UUID, Scene> m_scenes = new Dictionary<UUID, Scene>();
65 66 private Scene m_aScene;
66 /// <value> 67 /// <value>
67 /// The comms manager we will use for all comms requests 68 /// The comms manager we will use for all comms requests
68 /// </value> 69 /// </value>
69 protected internal CommunicationsManager CommsManager; 70 protected internal CommunicationsManager CommsManager;
71 protected internal IAssetService AssetService;
70 72
71 public void Initialise(Scene scene, IConfigSource source) 73 public void Initialise(Scene scene, IConfigSource source)
72 { 74 {
@@ -84,13 +86,18 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
84 scene.AddCommand( 86 scene.AddCommand(
85 this, "save iar", 87 this, "save iar",
86 "save iar <first> <last> <inventory path> [<archive path>]", 88 "save iar <first> <last> <inventory path> [<archive path>]",
87 "Save user inventory archive. EXPERIMENTAL, PLEASE DO NOT USE YET", HandleSaveInvConsoleCommand); 89 "Save user inventory archive. EXPERIMENTAL, PLEASE DO NOT USE YET", HandleSaveInvConsoleCommand);
90
91 m_aScene = scene;
88 } 92 }
89 93
90 m_scenes[scene.RegionInfo.RegionID] = scene; 94 m_scenes[scene.RegionInfo.RegionID] = scene;
91 } 95 }
92 96
93 public void PostInitialise() {} 97 public void PostInitialise()
98 {
99 AssetService = m_aScene.AssetService;
100 }
94 101
95 public void Close() {} 102 public void Close() {}
96 103
@@ -114,7 +121,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
114 if (userInfo != null) 121 if (userInfo != null)
115 { 122 {
116 InventoryArchiveReadRequest request = 123 InventoryArchiveReadRequest request =
117 new InventoryArchiveReadRequest(userInfo, invPath, loadStream, CommsManager); 124 new InventoryArchiveReadRequest(userInfo, invPath, loadStream, CommsManager, AssetService);
118 UpdateClientWithLoadedNodes(userInfo, request.Execute()); 125 UpdateClientWithLoadedNodes(userInfo, request.Execute());
119 } 126 }
120 } 127 }
@@ -140,7 +147,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
140 if (userInfo != null) 147 if (userInfo != null)
141 { 148 {
142 InventoryArchiveReadRequest request = 149 InventoryArchiveReadRequest request =
143 new InventoryArchiveReadRequest(userInfo, invPath, loadPath, CommsManager); 150 new InventoryArchiveReadRequest(userInfo, invPath, loadPath, CommsManager, AssetService);
144 UpdateClientWithLoadedNodes(userInfo, request.Execute()); 151 UpdateClientWithLoadedNodes(userInfo, request.Execute());
145 } 152 }
146 } 153 }
diff --git a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/Tests/InventoryArchiverTests.cs b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/Tests/InventoryArchiverTests.cs
index 34640ae..296d4c1 100644
--- a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/Tests/InventoryArchiverTests.cs
+++ b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/Tests/InventoryArchiverTests.cs
@@ -66,135 +66,135 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver.Tests
66 /// <summary> 66 /// <summary>
67 /// Test saving a V0.1 OpenSim Inventory Archive (subject to change since there is no fixed format yet). 67 /// Test saving a V0.1 OpenSim Inventory Archive (subject to change since there is no fixed format yet).
68 /// </summary> 68 /// </summary>
69 [Test] 69// [Test]
70 public void TestSaveIarV0p1() 70// public void TestSaveIarV0p1()
71 { 71// {
72 TestHelper.InMethod(); 72// TestHelper.InMethod();
73 //log4net.Config.XmlConfigurator.Configure(); 73// //log4net.Config.XmlConfigurator.Configure();
74 74
75 InventoryArchiverModule archiverModule = new InventoryArchiverModule(); 75// InventoryArchiverModule archiverModule = new InventoryArchiverModule();
76 76
77 Scene scene = SceneSetupHelpers.SetupScene(false); 77// Scene scene = SceneSetupHelpers.SetupScene(false);
78 SceneSetupHelpers.SetupSceneModules(scene, archiverModule); 78// SceneSetupHelpers.SetupSceneModules(scene, archiverModule);
79 CommunicationsManager cm = scene.CommsManager; 79// CommunicationsManager cm = scene.CommsManager;
80 80
81 // Create user 81// // Create user
82 string userFirstName = "Jock"; 82// string userFirstName = "Jock";
83 string userLastName = "Stirrup"; 83// string userLastName = "Stirrup";
84 UUID userId = UUID.Parse("00000000-0000-0000-0000-000000000020"); 84// UUID userId = UUID.Parse("00000000-0000-0000-0000-000000000020");
85 cm.UserAdminService.AddUser(userFirstName, userLastName, string.Empty, string.Empty, 1000, 1000, userId); 85// cm.UserAdminService.AddUser(userFirstName, userLastName, string.Empty, string.Empty, 1000, 1000, userId);
86 CachedUserInfo userInfo = cm.UserProfileCacheService.GetUserDetails(userId); 86// CachedUserInfo userInfo = cm.UserProfileCacheService.GetUserDetails(userId);
87 userInfo.FetchInventory(); 87// userInfo.FetchInventory();
88 88
89 // Create asset 89// // Create asset
90 SceneObjectGroup object1; 90// SceneObjectGroup object1;
91 SceneObjectPart part1; 91// SceneObjectPart part1;
92 { 92// {
93 string partName = "My Little Dog Object"; 93// string partName = "My Little Dog Object";
94 UUID ownerId = UUID.Parse("00000000-0000-0000-0000-000000000040"); 94// UUID ownerId = UUID.Parse("00000000-0000-0000-0000-000000000040");
95 PrimitiveBaseShape shape = PrimitiveBaseShape.CreateSphere(); 95// PrimitiveBaseShape shape = PrimitiveBaseShape.CreateSphere();
96 Vector3 groupPosition = new Vector3(10, 20, 30); 96// Vector3 groupPosition = new Vector3(10, 20, 30);
97 Quaternion rotationOffset = new Quaternion(20, 30, 40, 50); 97// Quaternion rotationOffset = new Quaternion(20, 30, 40, 50);
98 Vector3 offsetPosition = new Vector3(5, 10, 15); 98// Vector3 offsetPosition = new Vector3(5, 10, 15);
99 99
100 part1 100// part1
101 = new SceneObjectPart( 101// = new SceneObjectPart(
102 ownerId, shape, groupPosition, rotationOffset, offsetPosition); 102// ownerId, shape, groupPosition, rotationOffset, offsetPosition);
103 part1.Name = partName; 103// part1.Name = partName;
104 104
105 object1 = new SceneObjectGroup(part1); 105// object1 = new SceneObjectGroup(part1);
106 scene.AddNewSceneObject(object1, false); 106// scene.AddNewSceneObject(object1, false);
107 } 107// }
108 108
109 UUID asset1Id = UUID.Parse("00000000-0000-0000-0000-000000000060"); 109// UUID asset1Id = UUID.Parse("00000000-0000-0000-0000-000000000060");
110 AssetBase asset1 = new AssetBase(); 110// AssetBase asset1 = new AssetBase();
111 asset1.FullID = asset1Id; 111// asset1.FullID = asset1Id;
112 asset1.Data = Encoding.ASCII.GetBytes(SceneObjectSerializer.ToXml2Format(object1)); 112// asset1.Data = Encoding.ASCII.GetBytes(SceneObjectSerializer.ToXml2Format(object1));
113 cm.AssetCache.AddAsset(asset1); 113// scene.AssetService.Store(asset1);
114 114
115 // Create item 115// // Create item
116 UUID item1Id = UUID.Parse("00000000-0000-0000-0000-000000000080"); 116// UUID item1Id = UUID.Parse("00000000-0000-0000-0000-000000000080");
117 InventoryItemBase item1 = new InventoryItemBase(); 117// InventoryItemBase item1 = new InventoryItemBase();
118 item1.Name = "My Little Dog"; 118// item1.Name = "My Little Dog";
119 item1.AssetID = asset1.FullID; 119// item1.AssetID = asset1.FullID;
120 item1.ID = item1Id; 120// item1.ID = item1Id;
121 item1.Folder = userInfo.RootFolder.FindFolderByPath("Objects").ID; 121// item1.Folder = userInfo.RootFolder.FindFolderByPath("Objects").ID;
122 scene.AddInventoryItem(userId, item1); 122// scene.AddInventoryItem(userId, item1);
123 123
124 MemoryStream archiveWriteStream = new MemoryStream(); 124// MemoryStream archiveWriteStream = new MemoryStream();
125 archiverModule.OnInventoryArchiveSaved += SaveCompleted; 125// archiverModule.OnInventoryArchiveSaved += SaveCompleted;
126 126
127 lock (this) 127// lock (this)
128 { 128// {
129 archiverModule.ArchiveInventory(userFirstName, userLastName, "Objects", archiveWriteStream); 129// archiverModule.ArchiveInventory(userFirstName, userLastName, "Objects", archiveWriteStream);
130 AssetServerBase assetServer = (AssetServerBase)scene.CommsManager.AssetCache.AssetServer; 130// //AssetServerBase assetServer = (AssetServerBase)scene.CommsManager.AssetCache.AssetServer;
131 while (assetServer.HasWaitingRequests()) 131// //while (assetServer.HasWaitingRequests())
132 assetServer.ProcessNextRequest(); 132// // assetServer.ProcessNextRequest();
133 133
134 Monitor.Wait(this, 60000); 134// Monitor.Wait(this, 60000);
135 } 135// }
136 136
137 byte[] archive = archiveWriteStream.ToArray(); 137// byte[] archive = archiveWriteStream.ToArray();
138 MemoryStream archiveReadStream = new MemoryStream(archive); 138// MemoryStream archiveReadStream = new MemoryStream(archive);
139 TarArchiveReader tar = new TarArchiveReader(archiveReadStream); 139// TarArchiveReader tar = new TarArchiveReader(archiveReadStream);
140 140
141 InventoryFolderImpl objectsFolder = userInfo.RootFolder.FindFolderByPath("Objects"); 141// InventoryFolderImpl objectsFolder = userInfo.RootFolder.FindFolderByPath("Objects");
142 142
143 //bool gotControlFile = false; 143// //bool gotControlFile = false;
144 bool gotObject1File = false; 144// bool gotObject1File = false;
145 //bool gotObject2File = false; 145// //bool gotObject2File = false;
146 string expectedObject1FilePath = string.Format( 146// string expectedObject1FilePath = string.Format(
147 "{0}{1}/{2}_{3}.xml", 147// "{0}{1}/{2}_{3}.xml",
148 ArchiveConstants.INVENTORY_PATH, 148// ArchiveConstants.INVENTORY_PATH,
149 string.Format( 149// string.Format(
150 "Objects{0}{1}", ArchiveConstants.INVENTORY_NODE_NAME_COMPONENT_SEPARATOR, objectsFolder.ID), 150// "Objects{0}{1}", ArchiveConstants.INVENTORY_NODE_NAME_COMPONENT_SEPARATOR, objectsFolder.ID),
151 item1.Name, 151// item1.Name,
152 item1Id); 152// item1Id);
153 153
154/* 154///*
155 string expectedObject2FileName = string.Format( 155// string expectedObject2FileName = string.Format(
156 "{0}_{1:000}-{2:000}-{3:000}__{4}.xml", 156// "{0}_{1:000}-{2:000}-{3:000}__{4}.xml",
157 part2.Name, 157// part2.Name,
158 Math.Round(part2.GroupPosition.X), Math.Round(part2.GroupPosition.Y), Math.Round(part2.GroupPosition.Z), 158// Math.Round(part2.GroupPosition.X), Math.Round(part2.GroupPosition.Y), Math.Round(part2.GroupPosition.Z),
159 part2.UUID); 159// part2.UUID);
160 */ 160// */
161 161
162 string filePath; 162// string filePath;
163 TarArchiveReader.TarEntryType tarEntryType; 163// TarArchiveReader.TarEntryType tarEntryType;
164 164
165 while (tar.ReadEntry(out filePath, out tarEntryType) != null) 165// while (tar.ReadEntry(out filePath, out tarEntryType) != null)
166 { 166// {
167 Console.WriteLine("Got {0}", filePath); 167// Console.WriteLine("Got {0}", filePath);
168 168
169 /* 169// /*
170 if (ArchiveConstants.CONTROL_FILE_PATH == filePath) 170// if (ArchiveConstants.CONTROL_FILE_PATH == filePath)
171 { 171// {
172 gotControlFile = true; 172// gotControlFile = true;
173 } 173// }
174 */ 174// */
175 if (filePath.StartsWith(ArchiveConstants.INVENTORY_PATH) && filePath.EndsWith(".xml")) 175// if (filePath.StartsWith(ArchiveConstants.INVENTORY_PATH) && filePath.EndsWith(".xml"))
176 { 176// {
177 //string fileName = filePath.Remove(0, "Objects/".Length); 177// //string fileName = filePath.Remove(0, "Objects/".Length);
178 178
179 //if (fileName.StartsWith(part1.Name)) 179// //if (fileName.StartsWith(part1.Name))
180 //{ 180// //{
181 Assert.That(filePath, Is.EqualTo(expectedObject1FilePath)); 181// Assert.That(filePath, Is.EqualTo(expectedObject1FilePath));
182 gotObject1File = true; 182// gotObject1File = true;
183 //} 183// //}
184 //else if (fileName.StartsWith(part2.Name)) 184// //else if (fileName.StartsWith(part2.Name))
185 //{ 185// //{
186 // Assert.That(fileName, Is.EqualTo(expectedObject2FileName)); 186// // Assert.That(fileName, Is.EqualTo(expectedObject2FileName));
187 // gotObject2File = true; 187// // gotObject2File = true;
188 //} 188// //}
189 } 189// }
190 } 190// }
191 191
192 //Assert.That(gotControlFile, Is.True, "No control file in archive"); 192// //Assert.That(gotControlFile, Is.True, "No control file in archive");
193 Assert.That(gotObject1File, Is.True, "No item1 file in archive"); 193// Assert.That(gotObject1File, Is.True, "No item1 file in archive");
194 //Assert.That(gotObject2File, Is.True, "No object2 file in archive"); 194// //Assert.That(gotObject2File, Is.True, "No object2 file in archive");
195 195
196 // TODO: Test presence of more files and contents of files. 196// // TODO: Test presence of more files and contents of files.
197 } 197// }
198 198
199 /// <summary> 199 /// <summary>
200 /// Test loading a V0.1 OpenSim Inventory Archive (subject to change since there is no fixed format yet) where 200 /// Test loading a V0.1 OpenSim Inventory Archive (subject to change since there is no fixed format yet) where
@@ -363,7 +363,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver.Tests
363 "{0}{1}/{2}/{3}", 363 "{0}{1}/{2}/{3}",
364 ArchiveConstants.INVENTORY_PATH, folder1ArchiveName, folder2ArchiveName, itemName); 364 ArchiveConstants.INVENTORY_PATH, folder1ArchiveName, folder2ArchiveName, itemName);
365 365
366 new InventoryArchiveReadRequest(userInfo, null, (Stream)null, null) 366 new InventoryArchiveReadRequest(userInfo, null, (Stream)null, null, null)
367 .ReplicateArchivePathToUserInventory(itemArchivePath, false, userInfo.RootFolder, foldersCreated, nodesLoaded); 367 .ReplicateArchivePathToUserInventory(itemArchivePath, false, userInfo.RootFolder, foldersCreated, nodesLoaded);
368 368
369 InventoryFolderImpl folder1 = userInfo.RootFolder.FindFolderByPath("a"); 369 InventoryFolderImpl folder1 = userInfo.RootFolder.FindFolderByPath("a");
diff --git a/OpenSim/Region/CoreModules/Hypergrid/HGStandaloneInventoryModule.cs b/OpenSim/Region/CoreModules/Hypergrid/HGStandaloneInventoryModule.cs
index f9a7303..e2c15e1 100644
--- a/OpenSim/Region/CoreModules/Hypergrid/HGStandaloneInventoryModule.cs
+++ b/OpenSim/Region/CoreModules/Hypergrid/HGStandaloneInventoryModule.cs
@@ -91,8 +91,7 @@ namespace OpenSim.Region.CoreModules.Hypergrid
91 //m_inventoryService = new InventoryService(m_scene); 91 //m_inventoryService = new InventoryService(m_scene);
92 m_inventoryBase = (InventoryServiceBase)m_scene.CommsManager.SecureInventoryService; 92 m_inventoryBase = (InventoryServiceBase)m_scene.CommsManager.SecureInventoryService;
93 93
94 m_inventoryService = new HGInventoryService(m_inventoryBase, 94 m_inventoryService = new HGInventoryService(m_inventoryBase, m_scene.AssetService,
95 ((AssetServerBase)m_scene.CommsManager.AssetCache.AssetServer).AssetProviderPlugin,
96 (UserManagerBase)m_scene.CommsManager.UserAdminService, m_scene.CommsManager.HttpServer, 95 (UserManagerBase)m_scene.CommsManager.UserAdminService, m_scene.CommsManager.HttpServer,
97 m_scene.CommsManager.NetworkServersInfo.InventoryURL); 96 m_scene.CommsManager.NetworkServersInfo.InventoryURL);
98 97
diff --git a/OpenSim/Region/CoreModules/Scripting/DynamicTexture/DynamicTextureModule.cs b/OpenSim/Region/CoreModules/Scripting/DynamicTexture/DynamicTextureModule.cs
index a2d6b45..063081e 100644
--- a/OpenSim/Region/CoreModules/Scripting/DynamicTexture/DynamicTextureModule.cs
+++ b/OpenSim/Region/CoreModules/Scripting/DynamicTexture/DynamicTextureModule.cs
@@ -264,7 +264,7 @@ namespace OpenSim.Region.CoreModules.Scripting.DynamicTexture
264 if (BlendWithOldTexture) 264 if (BlendWithOldTexture)
265 { 265 {
266 UUID lastTextureID = part.Shape.Textures.DefaultTexture.TextureID; 266 UUID lastTextureID = part.Shape.Textures.DefaultTexture.TextureID;
267 oldAsset = scene.CommsManager.AssetCache.GetAsset(lastTextureID, true); 267 oldAsset = scene.AssetService.Get(lastTextureID.ToString());
268 if (oldAsset != null) 268 if (oldAsset != null)
269 { 269 {
270 assetData = BlendTextures(data, oldAsset.Data, SetNewFrontAlpha, FrontAlpha); 270 assetData = BlendTextures(data, oldAsset.Data, SetNewFrontAlpha, FrontAlpha);
@@ -290,7 +290,7 @@ namespace OpenSim.Region.CoreModules.Scripting.DynamicTexture
290 asset.Description = "dynamic image"; 290 asset.Description = "dynamic image";
291 asset.Local = false; 291 asset.Local = false;
292 asset.Temporary = true; 292 asset.Temporary = true;
293 scene.CommsManager.AssetCache.AddAsset(asset); 293 scene.AssetService.Store(asset);
294 294
295 LastAssetID = asset.FullID; 295 LastAssetID = asset.FullID;
296 296
@@ -315,7 +315,6 @@ namespace OpenSim.Region.CoreModules.Scripting.DynamicTexture
315 part.Shape.Textures = tmptex; 315 part.Shape.Textures = tmptex;
316 part.ScheduleFullUpdate(); 316 part.ScheduleFullUpdate();
317 317
318 scene.CommsManager.AssetCache.ExpireAsset(oldID);
319 } 318 }
320 319
321 private byte[] BlendTextures(byte[] frontImage, byte[] backImage, bool setNewAlpha, byte newAlpha) 320 private byte[] BlendTextures(byte[] frontImage, byte[] backImage, bool setNewAlpha, byte newAlpha)
diff --git a/OpenSim/Region/CoreModules/ServiceConnectors/Asset/HGAssetBroker.cs b/OpenSim/Region/CoreModules/ServiceConnectors/Asset/HGAssetBroker.cs
index 37589fa..d537d7b 100644
--- a/OpenSim/Region/CoreModules/ServiceConnectors/Asset/HGAssetBroker.cs
+++ b/OpenSim/Region/CoreModules/ServiceConnectors/Asset/HGAssetBroker.cs
@@ -58,7 +58,7 @@ namespace OpenSim.Region.CoreModules.ServiceConnectors.Asset
58 58
59 public void Initialise(IConfigSource source) 59 public void Initialise(IConfigSource source)
60 { 60 {
61 IConfig moduleConfig = source.Configs["Modules"]; 61 IConfig moduleConfig = source.Configs["ServiceConnectors"];
62 if (moduleConfig != null) 62 if (moduleConfig != null)
63 { 63 {
64 string name = moduleConfig.GetString("AssetServices", ""); 64 string name = moduleConfig.GetString("AssetServices", "");
diff --git a/OpenSim/Region/CoreModules/ServiceConnectors/Asset/LocalAssetServiceConnector.cs b/OpenSim/Region/CoreModules/ServiceConnectors/Asset/LocalAssetServiceConnector.cs
index 19a41ec..11c857f 100644
--- a/OpenSim/Region/CoreModules/ServiceConnectors/Asset/LocalAssetServiceConnector.cs
+++ b/OpenSim/Region/CoreModules/ServiceConnectors/Asset/LocalAssetServiceConnector.cs
@@ -58,7 +58,7 @@ namespace OpenSim.Region.CoreModules.ServiceConnectors.Asset
58 58
59 public void Initialise(IConfigSource source) 59 public void Initialise(IConfigSource source)
60 { 60 {
61 IConfig moduleConfig = source.Configs["Modules"]; 61 IConfig moduleConfig = source.Configs["ServiceConnectors"];
62 if (moduleConfig != null) 62 if (moduleConfig != null)
63 { 63 {
64 string name = moduleConfig.GetString("AssetServices", ""); 64 string name = moduleConfig.GetString("AssetServices", "");
diff --git a/OpenSim/Region/CoreModules/ServiceConnectors/Asset/RemoteAssetServiceConnector.cs b/OpenSim/Region/CoreModules/ServiceConnectors/Asset/RemoteAssetServiceConnector.cs
index ec982e5..5bbd181 100644
--- a/OpenSim/Region/CoreModules/ServiceConnectors/Asset/RemoteAssetServiceConnector.cs
+++ b/OpenSim/Region/CoreModules/ServiceConnectors/Asset/RemoteAssetServiceConnector.cs
@@ -55,7 +55,7 @@ namespace OpenSim.Region.CoreModules.ServiceConnectors.Asset
55 55
56 public override void Initialise(IConfigSource source) 56 public override void Initialise(IConfigSource source)
57 { 57 {
58 IConfig moduleConfig = source.Configs["Modules"]; 58 IConfig moduleConfig = source.Configs["ServiceConnectors"];
59 if (moduleConfig != null) 59 if (moduleConfig != null)
60 { 60 {
61 string name = moduleConfig.GetString("AssetServices", ""); 61 string name = moduleConfig.GetString("AssetServices", "");
diff --git a/OpenSim/Region/CoreModules/ServiceConnectors/User/LocalUserServiceConnector.cs b/OpenSim/Region/CoreModules/ServiceConnectors/User/LocalUserServiceConnector.cs
index 37286bd..c34ade9 100644
--- a/OpenSim/Region/CoreModules/ServiceConnectors/User/LocalUserServiceConnector.cs
+++ b/OpenSim/Region/CoreModules/ServiceConnectors/User/LocalUserServiceConnector.cs
@@ -53,7 +53,7 @@ namespace OpenSim.Region.CoreModules.ServiceConnectors.User
53 53
54 public void Initialise(IConfigSource source) 54 public void Initialise(IConfigSource source)
55 { 55 {
56 IConfig moduleConfig = source.Configs["Modules"]; 56 IConfig moduleConfig = source.Configs["ServiceConnectors"];
57 if (moduleConfig != null) 57 if (moduleConfig != null)
58 { 58 {
59 string name = moduleConfig.GetString("UserServices", ""); 59 string name = moduleConfig.GetString("UserServices", "");
diff --git a/OpenSim/Region/CoreModules/ServiceConnectors/User/RemoteUserServiceConnector.cs b/OpenSim/Region/CoreModules/ServiceConnectors/User/RemoteUserServiceConnector.cs
index e56aac5..fcfc4fa 100644
--- a/OpenSim/Region/CoreModules/ServiceConnectors/User/RemoteUserServiceConnector.cs
+++ b/OpenSim/Region/CoreModules/ServiceConnectors/User/RemoteUserServiceConnector.cs
@@ -43,7 +43,7 @@ namespace OpenSim.Region.CoreModules.ServiceConnectors.User
43 43
44 public void Initialise(IConfigSource source) 44 public void Initialise(IConfigSource source)
45 { 45 {
46 IConfig moduleConfig = source.Configs["Modules"]; 46 IConfig moduleConfig = source.Configs["ServiceConnectors"];
47 if (moduleConfig != null) 47 if (moduleConfig != null)
48 { 48 {
49 string name = moduleConfig.GetString("UserServices", ""); 49 string name = moduleConfig.GetString("UserServices", "");
diff --git a/OpenSim/Region/CoreModules/World/Archiver/ArchiveReadRequest.cs b/OpenSim/Region/CoreModules/World/Archiver/ArchiveReadRequest.cs
index bf844ad..a5ceb19 100644
--- a/OpenSim/Region/CoreModules/World/Archiver/ArchiveReadRequest.cs
+++ b/OpenSim/Region/CoreModules/World/Archiver/ArchiveReadRequest.cs
@@ -310,7 +310,7 @@ namespace OpenSim.Region.CoreModules.World.Archiver
310 asset.Type = assetType; 310 asset.Type = assetType;
311 asset.Data = data; 311 asset.Data = data;
312 312
313 m_scene.CommsManager.AssetCache.AddAsset(asset); 313 m_scene.AssetService.Store(asset);
314 314
315 /** 315 /**
316 * Create layers on decode for image assets. This is likely to significantly increase the time to load archives so 316 * Create layers on decode for image assets. This is likely to significantly increase the time to load archives so
diff --git a/OpenSim/Region/CoreModules/World/Archiver/ArchiveWriteRequestPreparation.cs b/OpenSim/Region/CoreModules/World/Archiver/ArchiveWriteRequestPreparation.cs
index 0a882eb..f121374 100644
--- a/OpenSim/Region/CoreModules/World/Archiver/ArchiveWriteRequestPreparation.cs
+++ b/OpenSim/Region/CoreModules/World/Archiver/ArchiveWriteRequestPreparation.cs
@@ -101,7 +101,7 @@ namespace OpenSim.Region.CoreModules.World.Archiver
101 } 101 }
102 } 102 }
103 103
104 UuidGatherer assetGatherer = new UuidGatherer(m_scene.CommsManager.AssetCache); 104 UuidGatherer assetGatherer = new UuidGatherer(m_scene.AssetService);
105 105
106 foreach (SceneObjectGroup sceneObject in sceneObjects) 106 foreach (SceneObjectGroup sceneObject in sceneObjects)
107 { 107 {
@@ -141,7 +141,7 @@ namespace OpenSim.Region.CoreModules.World.Archiver
141 141
142 new AssetsRequest( 142 new AssetsRequest(
143 new AssetsArchiver(archiveWriter), assetUuids.Keys, 143 new AssetsArchiver(archiveWriter), assetUuids.Keys,
144 m_scene.CommsManager.AssetCache, awre.ReceivedAllAssets).Execute(); 144 m_scene.AssetService, awre.ReceivedAllAssets).Execute();
145 } 145 }
146 } 146 }
147} 147}
diff --git a/OpenSim/Region/CoreModules/World/Archiver/AssetsRequest.cs b/OpenSim/Region/CoreModules/World/Archiver/AssetsRequest.cs
index d806a9c..6cd52ab 100644
--- a/OpenSim/Region/CoreModules/World/Archiver/AssetsRequest.cs
+++ b/OpenSim/Region/CoreModules/World/Archiver/AssetsRequest.cs
@@ -33,6 +33,7 @@ using log4net;
33using OpenMetaverse; 33using OpenMetaverse;
34using OpenSim.Framework; 34using OpenSim.Framework;
35using OpenSim.Framework.Serialization; 35using OpenSim.Framework.Serialization;
36using OpenSim.Services.Interfaces;
36 37
37namespace OpenSim.Region.CoreModules.World.Archiver 38namespace OpenSim.Region.CoreModules.World.Archiver
38{ 39{
@@ -71,13 +72,13 @@ namespace OpenSim.Region.CoreModules.World.Archiver
71 /// <value> 72 /// <value>
72 /// Asset cache used to request the assets 73 /// Asset cache used to request the assets
73 /// </value> 74 /// </value>
74 protected IAssetCache m_assetCache; 75 protected IAssetService m_assetCache;
75 76
76 protected AssetsArchiver m_assetsArchiver; 77 protected AssetsArchiver m_assetsArchiver;
77 78
78 protected internal AssetsRequest( 79 protected internal AssetsRequest(
79 AssetsArchiver assetsArchiver, ICollection<UUID> uuids, 80 AssetsArchiver assetsArchiver, ICollection<UUID> uuids,
80 IAssetCache assetCache, AssetsRequestCallback assetsRequestCallback) 81 IAssetService assetCache, AssetsRequestCallback assetsRequestCallback)
81 { 82 {
82 m_assetsArchiver = assetsArchiver; 83 m_assetsArchiver = assetsArchiver;
83 m_uuids = uuids; 84 m_uuids = uuids;
@@ -96,7 +97,15 @@ namespace OpenSim.Region.CoreModules.World.Archiver
96 97
97 foreach (UUID uuid in m_uuids) 98 foreach (UUID uuid in m_uuids)
98 { 99 {
99 m_assetCache.GetAsset(uuid, AssetRequestCallback, true); 100 m_assetCache.Get(uuid.ToString(), this, AssetReceived);
101 }
102 }
103
104 protected void AssetReceived(string id, object sender, AssetBase asset)
105 {
106 if (asset != null)
107 {
108 AssetRequestCallback(asset.FullID, asset);
100 } 109 }
101 } 110 }
102 111
@@ -110,10 +119,7 @@ namespace OpenSim.Region.CoreModules.World.Archiver
110 //m_log.DebugFormat("[ARCHIVER]: Received callback for asset {0}", assetID); 119 //m_log.DebugFormat("[ARCHIVER]: Received callback for asset {0}", assetID);
111 120
112 if (asset != null) 121 if (asset != null)
113 { 122 {
114 // Make sure that we don't run out of memory by hogging assets in the cache
115 m_assetCache.ExpireAsset(assetID);
116
117 m_foundAssetUuids.Add(assetID); 123 m_foundAssetUuids.Add(assetID);
118 m_assetsArchiver.WriteAsset(asset); 124 m_assetsArchiver.WriteAsset(asset);
119 } 125 }
diff --git a/OpenSim/Region/CoreModules/World/Archiver/Tests/ArchiverTests.cs b/OpenSim/Region/CoreModules/World/Archiver/Tests/ArchiverTests.cs
index 2012ea8..2ba94f7 100644
--- a/OpenSim/Region/CoreModules/World/Archiver/Tests/ArchiverTests.cs
+++ b/OpenSim/Region/CoreModules/World/Archiver/Tests/ArchiverTests.cs
@@ -74,129 +74,129 @@ namespace OpenSim.Region.CoreModules.World.Archiver.Tests
74 } 74 }
75 } 75 }
76 76
77 /// <summary> 77 ///// <summary>
78 /// Test saving a V0.2 OpenSim Region Archive. 78 ///// Test saving a V0.2 OpenSim Region Archive.
79 /// </summary> 79 ///// </summary>
80 [Test] 80 //[Test]
81 public void TestSaveOarV0p2() 81 //public void TestSaveOarV0p2()
82 { 82 //{
83 TestHelper.InMethod(); 83 // TestHelper.InMethod();
84 //log4net.Config.XmlConfigurator.Configure(); 84 // //log4net.Config.XmlConfigurator.Configure();
85 85
86 ArchiverModule archiverModule = new ArchiverModule(); 86 // ArchiverModule archiverModule = new ArchiverModule();
87 SerialiserModule serialiserModule = new SerialiserModule(); 87 // SerialiserModule serialiserModule = new SerialiserModule();
88 TerrainModule terrainModule = new TerrainModule(); 88 // TerrainModule terrainModule = new TerrainModule();
89 89
90 Scene scene = SceneSetupHelpers.SetupScene(false); 90 // Scene scene = SceneSetupHelpers.SetupScene(false);
91 SceneSetupHelpers.SetupSceneModules(scene, archiverModule, serialiserModule, terrainModule); 91 // SceneSetupHelpers.SetupSceneModules(scene, archiverModule, serialiserModule, terrainModule);
92 92
93 SceneObjectPart part1; 93 // SceneObjectPart part1;
94 94
95 // Create and add prim 1 95 // // Create and add prim 1
96 { 96 // {
97 string partName = "My Little Pony"; 97 // string partName = "My Little Pony";
98 UUID ownerId = UUID.Parse("00000000-0000-0000-0000-000000000015"); 98 // UUID ownerId = UUID.Parse("00000000-0000-0000-0000-000000000015");
99 PrimitiveBaseShape shape = PrimitiveBaseShape.CreateSphere(); 99 // PrimitiveBaseShape shape = PrimitiveBaseShape.CreateSphere();
100 Vector3 groupPosition = new Vector3(10, 20, 30); 100 // Vector3 groupPosition = new Vector3(10, 20, 30);
101 Quaternion rotationOffset = new Quaternion(20, 30, 40, 50); 101 // Quaternion rotationOffset = new Quaternion(20, 30, 40, 50);
102 Vector3 offsetPosition = new Vector3(5, 10, 15); 102 // Vector3 offsetPosition = new Vector3(5, 10, 15);
103 103
104 part1 104 // part1
105 = new SceneObjectPart( 105 // = new SceneObjectPart(
106 ownerId, shape, groupPosition, rotationOffset, offsetPosition); 106 // ownerId, shape, groupPosition, rotationOffset, offsetPosition);
107 part1.Name = partName; 107 // part1.Name = partName;
108 108
109 scene.AddNewSceneObject(new SceneObjectGroup(part1), false); 109 // scene.AddNewSceneObject(new SceneObjectGroup(part1), false);
110 } 110 // }
111 111
112 SceneObjectPart part2; 112 // SceneObjectPart part2;
113 113
114 // Create and add prim 2 114 // // Create and add prim 2
115 { 115 // {
116 string partName = "Action Man"; 116 // string partName = "Action Man";
117 UUID ownerId = UUID.Parse("00000000-0000-0000-0000-000000000016"); 117 // UUID ownerId = UUID.Parse("00000000-0000-0000-0000-000000000016");
118 PrimitiveBaseShape shape = PrimitiveBaseShape.CreateCylinder(); 118 // PrimitiveBaseShape shape = PrimitiveBaseShape.CreateCylinder();
119 Vector3 groupPosition = new Vector3(90, 80, 70); 119 // Vector3 groupPosition = new Vector3(90, 80, 70);
120 Quaternion rotationOffset = new Quaternion(60, 70, 80, 90); 120 // Quaternion rotationOffset = new Quaternion(60, 70, 80, 90);
121 Vector3 offsetPosition = new Vector3(20, 25, 30); 121 // Vector3 offsetPosition = new Vector3(20, 25, 30);
122 122
123 part2 123 // part2
124 = new SceneObjectPart( 124 // = new SceneObjectPart(
125 ownerId, shape, groupPosition, rotationOffset, offsetPosition); 125 // ownerId, shape, groupPosition, rotationOffset, offsetPosition);
126 part2.Name = partName; 126 // part2.Name = partName;
127 127
128 scene.AddNewSceneObject(new SceneObjectGroup(part2), false); 128 // scene.AddNewSceneObject(new SceneObjectGroup(part2), false);
129 } 129 // }
130 130
131 MemoryStream archiveWriteStream = new MemoryStream(); 131 // MemoryStream archiveWriteStream = new MemoryStream();
132 scene.EventManager.OnOarFileSaved += SaveCompleted; 132 // scene.EventManager.OnOarFileSaved += SaveCompleted;
133 133
134 Guid requestId = new Guid("00000000-0000-0000-0000-808080808080"); 134 // Guid requestId = new Guid("00000000-0000-0000-0000-808080808080");
135 135
136 lock (this) 136 // lock (this)
137 { 137 // {
138 archiverModule.ArchiveRegion(archiveWriteStream, requestId); 138 // archiverModule.ArchiveRegion(archiveWriteStream, requestId);
139 AssetServerBase assetServer = (AssetServerBase)scene.CommsManager.AssetCache.AssetServer; 139 // //AssetServerBase assetServer = (AssetServerBase)scene.CommsManager.AssetCache.AssetServer;
140 while (assetServer.HasWaitingRequests()) 140 // //while (assetServer.HasWaitingRequests())
141 assetServer.ProcessNextRequest(); 141 // // assetServer.ProcessNextRequest();
142 142
143 Monitor.Wait(this, 60000); 143 // Monitor.Wait(this, 60000);
144 } 144 // }
145 145
146 Assert.That(m_lastRequestId, Is.EqualTo(requestId)); 146 // Assert.That(m_lastRequestId, Is.EqualTo(requestId));
147 147
148 byte[] archive = archiveWriteStream.ToArray(); 148 // byte[] archive = archiveWriteStream.ToArray();
149 MemoryStream archiveReadStream = new MemoryStream(archive); 149 // MemoryStream archiveReadStream = new MemoryStream(archive);
150 TarArchiveReader tar = new TarArchiveReader(archiveReadStream); 150 // TarArchiveReader tar = new TarArchiveReader(archiveReadStream);
151 151
152 bool gotControlFile = false; 152 // bool gotControlFile = false;
153 bool gotObject1File = false; 153 // bool gotObject1File = false;
154 bool gotObject2File = false; 154 // bool gotObject2File = false;
155 string expectedObject1FileName = string.Format( 155 // string expectedObject1FileName = string.Format(
156 "{0}_{1:000}-{2:000}-{3:000}__{4}.xml", 156 // "{0}_{1:000}-{2:000}-{3:000}__{4}.xml",
157 part1.Name, 157 // part1.Name,
158 Math.Round(part1.GroupPosition.X), Math.Round(part1.GroupPosition.Y), Math.Round(part1.GroupPosition.Z), 158 // Math.Round(part1.GroupPosition.X), Math.Round(part1.GroupPosition.Y), Math.Round(part1.GroupPosition.Z),
159 part1.UUID); 159 // part1.UUID);
160 string expectedObject2FileName = string.Format( 160 // string expectedObject2FileName = string.Format(
161 "{0}_{1:000}-{2:000}-{3:000}__{4}.xml", 161 // "{0}_{1:000}-{2:000}-{3:000}__{4}.xml",
162 part2.Name, 162 // part2.Name,
163 Math.Round(part2.GroupPosition.X), Math.Round(part2.GroupPosition.Y), Math.Round(part2.GroupPosition.Z), 163 // Math.Round(part2.GroupPosition.X), Math.Round(part2.GroupPosition.Y), Math.Round(part2.GroupPosition.Z),
164 part2.UUID); 164 // part2.UUID);
165 165
166 string filePath; 166 // string filePath;
167 TarArchiveReader.TarEntryType tarEntryType; 167 // TarArchiveReader.TarEntryType tarEntryType;
168 168
169 while (tar.ReadEntry(out filePath, out tarEntryType) != null) 169 // while (tar.ReadEntry(out filePath, out tarEntryType) != null)
170 { 170 // {
171 if (ArchiveConstants.CONTROL_FILE_PATH == filePath) 171 // if (ArchiveConstants.CONTROL_FILE_PATH == filePath)
172 { 172 // {
173 gotControlFile = true; 173 // gotControlFile = true;
174 } 174 // }
175 else if (filePath.StartsWith(ArchiveConstants.OBJECTS_PATH)) 175 // else if (filePath.StartsWith(ArchiveConstants.OBJECTS_PATH))
176 { 176 // {
177 string fileName = filePath.Remove(0, ArchiveConstants.OBJECTS_PATH.Length); 177 // string fileName = filePath.Remove(0, ArchiveConstants.OBJECTS_PATH.Length);
178 178
179 if (fileName.StartsWith(part1.Name)) 179 // if (fileName.StartsWith(part1.Name))
180 { 180 // {
181 Assert.That(fileName, Is.EqualTo(expectedObject1FileName)); 181 // Assert.That(fileName, Is.EqualTo(expectedObject1FileName));
182 gotObject1File = true; 182 // gotObject1File = true;
183 } 183 // }
184 else if (fileName.StartsWith(part2.Name)) 184 // else if (fileName.StartsWith(part2.Name))
185 { 185 // {
186 Assert.That(fileName, Is.EqualTo(expectedObject2FileName)); 186 // Assert.That(fileName, Is.EqualTo(expectedObject2FileName));
187 gotObject2File = true; 187 // gotObject2File = true;
188 } 188 // }
189 } 189 // }
190 } 190 // }
191 191
192 Assert.That(gotControlFile, Is.True, "No control file in archive"); 192 // Assert.That(gotControlFile, Is.True, "No control file in archive");
193 Assert.That(gotObject1File, Is.True, "No object1 file in archive"); 193 // Assert.That(gotObject1File, Is.True, "No object1 file in archive");
194 Assert.That(gotObject2File, Is.True, "No object2 file in archive"); 194 // Assert.That(gotObject2File, Is.True, "No object2 file in archive");
195 195
196 // TODO: Test presence of more files and contents of files. 196 // // TODO: Test presence of more files and contents of files.
197 // Temporary 197 // // Temporary
198 Console.WriteLine("Successfully completed {0}", MethodBase.GetCurrentMethod()); 198 // Console.WriteLine("Successfully completed {0}", MethodBase.GetCurrentMethod());
199 } 199 //}
200 200
201 /// <summary> 201 /// <summary>
202 /// Test loading a V0.2 OpenSim Region Archive. 202 /// Test loading a V0.2 OpenSim Region Archive.
diff --git a/OpenSim/Region/CoreModules/World/WorldMap/TexturedMapTileRenderer.cs b/OpenSim/Region/CoreModules/World/WorldMap/TexturedMapTileRenderer.cs
index 1ab8e26..8671b54 100644
--- a/OpenSim/Region/CoreModules/World/WorldMap/TexturedMapTileRenderer.cs
+++ b/OpenSim/Region/CoreModules/World/WorldMap/TexturedMapTileRenderer.cs
@@ -170,7 +170,7 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
170 // will wait anyway) 170 // will wait anyway)
171 private Bitmap fetchTexture(UUID id) 171 private Bitmap fetchTexture(UUID id)
172 { 172 {
173 AssetBase asset = m_scene.CommsManager.AssetCache.GetAsset(id, true); 173 AssetBase asset = m_scene.AssetService.Get(id.ToString());
174 m_log.DebugFormat("Fetched texture {0}, found: {1}", id, asset != null); 174 m_log.DebugFormat("Fetched texture {0}, found: {1}", id, asset != null);
175 if (asset == null) return null; 175 if (asset == null) return null;
176 176
diff --git a/OpenSim/Region/CoreModules/World/WorldMap/WorldMapModule.cs b/OpenSim/Region/CoreModules/World/WorldMap/WorldMapModule.cs
index 30f35d0..a2bbb3e 100644
--- a/OpenSim/Region/CoreModules/World/WorldMap/WorldMapModule.cs
+++ b/OpenSim/Region/CoreModules/World/WorldMap/WorldMapModule.cs
@@ -774,7 +774,7 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
774 imgstream = new MemoryStream(); 774 imgstream = new MemoryStream();
775 775
776 // non-async because we know we have the asset immediately. 776 // non-async because we know we have the asset immediately.
777 AssetBase mapasset = m_scene.CommsManager.AssetCache.GetAsset(m_scene.RegionInfo.lastMapUUID, true); 777 AssetBase mapasset = m_scene.AssetService.Get(m_scene.RegionInfo.lastMapUUID.ToString());
778 778
779 // Decode image to System.Drawing.Image 779 // Decode image to System.Drawing.Image
780 if (OpenJPEG.DecodeToImage(mapasset.Data, out managedImage, out image)) 780 if (OpenJPEG.DecodeToImage(mapasset.Data, out managedImage, out image))
@@ -872,7 +872,7 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
872 872
873 foreach (MapBlockData mapBlock in mapBlocks) 873 foreach (MapBlockData mapBlock in mapBlocks)
874 { 874 {
875 AssetBase texAsset = m_scene.CommsManager.AssetCache.GetAsset(mapBlock.MapImageId, true); 875 AssetBase texAsset = m_scene.AssetService.Get(mapBlock.MapImageId.ToString());
876 876
877 if (texAsset != null) 877 if (texAsset != null)
878 { 878 {
@@ -880,7 +880,7 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
880 } 880 }
881 else 881 else
882 { 882 {
883 texAsset = m_scene.CommsManager.AssetCache.GetAsset(mapBlock.MapImageId, true); 883 texAsset = m_scene.AssetService.Get(mapBlock.MapImageId.ToString());
884 if (texAsset != null) 884 if (texAsset != null)
885 { 885 {
886 textures.Add(texAsset); 886 textures.Add(texAsset);
@@ -1029,7 +1029,7 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
1029 1029
1030 asset.Type = 0; 1030 asset.Type = 0;
1031 asset.Temporary = temporary; 1031 asset.Temporary = temporary;
1032 m_scene.CommsManager.AssetCache.AddAsset(asset); 1032 m_scene.AssetService.Store(asset);
1033 } 1033 }
1034 1034
1035 private void MakeRootAgent(ScenePresence avatar) 1035 private void MakeRootAgent(ScenePresence avatar)
diff --git a/OpenSim/Region/Framework/Scenes/Scene.Inventory.cs b/OpenSim/Region/Framework/Scenes/Scene.Inventory.cs
index 1dcdc06..0694576 100644
--- a/OpenSim/Region/Framework/Scenes/Scene.Inventory.cs
+++ b/OpenSim/Region/Framework/Scenes/Scene.Inventory.cs
@@ -193,7 +193,7 @@ namespace OpenSim.Region.Framework.Scenes
193 193
194 AssetBase asset = 194 AssetBase asset =
195 CreateAsset(item.Name, item.Description, (sbyte)item.AssetType, data); 195 CreateAsset(item.Name, item.Description, (sbyte)item.AssetType, data);
196 CommsManager.AssetCache.AddAsset(asset); 196 AssetService.Store(asset);
197 197
198 item.AssetID = asset.FullID; 198 item.AssetID = asset.FullID;
199 userInfo.UpdateItem(item); 199 userInfo.UpdateItem(item);
@@ -279,7 +279,7 @@ namespace OpenSim.Region.Framework.Scenes
279 } 279 }
280 280
281 AssetBase asset = CreateAsset(item.Name, item.Description, (sbyte)AssetType.LSLText, data); 281 AssetBase asset = CreateAsset(item.Name, item.Description, (sbyte)AssetType.LSLText, data);
282 CommsManager.AssetCache.AddAsset(asset); 282 AssetService.Store(asset);
283 283
284 if (isScriptRunning) 284 if (isScriptRunning)
285 { 285 {
@@ -688,9 +688,7 @@ namespace OpenSim.Region.Framework.Scenes
688 } 688 }
689 } 689 }
690 690
691 AssetBase asset 691 AssetBase asset = AssetService.Get(item.AssetID.ToString());
692 = CommsManager.AssetCache.GetAsset(
693 item.AssetID, (item.AssetType == (int)AssetType.Texture ? true : false));
694 692
695 if (asset != null) 693 if (asset != null)
696 { 694 {
@@ -911,7 +909,7 @@ namespace OpenSim.Region.Framework.Scenes
911 } 909 }
912 910
913 AssetBase asset = CreateAsset(name, description, assetType, data); 911 AssetBase asset = CreateAsset(name, description, assetType, data);
914 CommsManager.AssetCache.AddAsset(asset); 912 AssetService.Store(asset);
915 913
916 CreateNewInventoryItem(remoteClient, folderID, asset.Name, 0, callbackID, asset, invType, nextOwnerMask, creationDate); 914 CreateNewInventoryItem(remoteClient, folderID, asset.Name, 0, callbackID, asset, invType, nextOwnerMask, creationDate);
917 } 915 }
@@ -1538,7 +1536,7 @@ namespace OpenSim.Region.Framework.Scenes
1538 return; 1536 return;
1539 1537
1540 AssetBase asset = CreateAsset(itemBase.Name, itemBase.Description, (sbyte)itemBase.AssetType, Encoding.ASCII.GetBytes("default\n{\n state_entry()\n {\n llSay(0, \"Script running\");\n }\n}")); 1538 AssetBase asset = CreateAsset(itemBase.Name, itemBase.Description, (sbyte)itemBase.AssetType, Encoding.ASCII.GetBytes("default\n{\n state_entry()\n {\n llSay(0, \"Script running\");\n }\n}"));
1541 CommsManager.AssetCache.AddAsset(asset); 1539 AssetService.Store(asset);
1542 1540
1543 TaskInventoryItem taskItem = new TaskInventoryItem(); 1541 TaskInventoryItem taskItem = new TaskInventoryItem();
1544 1542
@@ -1959,7 +1957,7 @@ namespace OpenSim.Region.Framework.Scenes
1959 objectGroup.GetPartDescription(objectGroup.RootPart.LocalId), 1957 objectGroup.GetPartDescription(objectGroup.RootPart.LocalId),
1960 (sbyte)AssetType.Object, 1958 (sbyte)AssetType.Object,
1961 Utils.StringToBytes(sceneObjectXml)); 1959 Utils.StringToBytes(sceneObjectXml));
1962 CommsManager.AssetCache.AddAsset(asset); 1960 AssetService.Store(asset);
1963 assetID = asset.FullID; 1961 assetID = asset.FullID;
1964 1962
1965 if (DeRezAction.SaveToExistingUserInventoryItem == action) 1963 if (DeRezAction.SaveToExistingUserInventoryItem == action)
@@ -2085,7 +2083,7 @@ namespace OpenSim.Region.Framework.Scenes
2085 objectGroup.GetPartDescription(objectGroup.LocalId), 2083 objectGroup.GetPartDescription(objectGroup.LocalId),
2086 (sbyte)AssetType.Object, 2084 (sbyte)AssetType.Object,
2087 Utils.StringToBytes(sceneObjectXml)); 2085 Utils.StringToBytes(sceneObjectXml));
2088 CommsManager.AssetCache.AddAsset(asset); 2086 AssetService.Store(asset);
2089 2087
2090 item.AssetID = asset.FullID; 2088 item.AssetID = asset.FullID;
2091 item.Description = asset.Description; 2089 item.Description = asset.Description;
@@ -2123,7 +2121,7 @@ namespace OpenSim.Region.Framework.Scenes
2123 grp.GetPartDescription(grp.LocalId), 2121 grp.GetPartDescription(grp.LocalId),
2124 (sbyte)AssetType.Object, 2122 (sbyte)AssetType.Object,
2125 Utils.StringToBytes(sceneObjectXml)); 2123 Utils.StringToBytes(sceneObjectXml));
2126 CommsManager.AssetCache.AddAsset(asset); 2124 AssetService.Store(asset);
2127 2125
2128 InventoryItemBase item = new InventoryItemBase(); 2126 InventoryItemBase item = new InventoryItemBase();
2129 item.CreatorId = grp.RootPart.CreatorID.ToString(); 2127 item.CreatorId = grp.RootPart.CreatorID.ToString();
@@ -2247,7 +2245,7 @@ namespace OpenSim.Region.Framework.Scenes
2247 2245
2248 if (item != null) 2246 if (item != null)
2249 { 2247 {
2250 AssetBase rezAsset = CommsManager.AssetCache.GetAsset(item.AssetID, false); 2248 AssetBase rezAsset = AssetService.Get(item.AssetID.ToString());
2251 2249
2252 if (rezAsset != null) 2250 if (rezAsset != null)
2253 { 2251 {
@@ -2416,7 +2414,7 @@ namespace OpenSim.Region.Framework.Scenes
2416 { 2414 {
2417 UUID ownerID = item.OwnerID; 2415 UUID ownerID = item.OwnerID;
2418 2416
2419 AssetBase rezAsset = CommsManager.AssetCache.GetAsset(item.AssetID, false); 2417 AssetBase rezAsset = AssetService.Get(item.AssetID.ToString());
2420 2418
2421 if (rezAsset != null) 2419 if (rezAsset != null)
2422 { 2420 {
diff --git a/OpenSim/Region/Framework/Scenes/Scene.cs b/OpenSim/Region/Framework/Scenes/Scene.cs
index 733c062..a650ec5 100644
--- a/OpenSim/Region/Framework/Scenes/Scene.cs
+++ b/OpenSim/Region/Framework/Scenes/Scene.cs
@@ -3465,7 +3465,7 @@ namespace OpenSim.Region.Framework.Scenes
3465 group.GetPartDescription(localID), 3465 group.GetPartDescription(localID),
3466 (sbyte)AssetType.Object, 3466 (sbyte)AssetType.Object,
3467 Utils.StringToBytes(sceneObjectXml)); 3467 Utils.StringToBytes(sceneObjectXml));
3468 CommsManager.AssetCache.AddAsset(asset); 3468 AssetService.Store(asset);
3469 3469
3470 InventoryItemBase item = new InventoryItemBase(); 3470 InventoryItemBase item = new InventoryItemBase();
3471 item.CreatorId = part.CreatorID.ToString(); 3471 item.CreatorId = part.CreatorID.ToString();
diff --git a/OpenSim/Region/Framework/Scenes/SceneManager.cs b/OpenSim/Region/Framework/Scenes/SceneManager.cs
index 80634c0..e59675e 100644
--- a/OpenSim/Region/Framework/Scenes/SceneManager.cs
+++ b/OpenSim/Region/Framework/Scenes/SceneManager.cs
@@ -649,7 +649,7 @@ namespace OpenSim.Region.Framework.Scenes
649 { 649 {
650 for (int i=0;i<arrassets.Length;i++) 650 for (int i=0;i<arrassets.Length;i++)
651 { 651 {
652 AssetBase ab = sn.CommsManager.AssetCache.GetAsset(arrassets[i], true); 652 AssetBase ab = sn.AssetService.Get(arrassets[i].ToString());
653 if (ab != null && ab.Data != null) 653 if (ab != null && ab.Data != null)
654 { 654 {
655 j2kdecode.syncdecode(arrassets[i], ab.Data); 655 j2kdecode.syncdecode(arrassets[i], ab.Data);
diff --git a/OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs b/OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs
index 8a06fd1..e0a50a1 100644
--- a/OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs
+++ b/OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs
@@ -2967,8 +2967,8 @@ namespace OpenSim.Region.Framework.Scenes
2967 { 2967 {
2968 if (part.Shape.SculptEntry && part.Shape.SculptTexture != UUID.Zero) 2968 if (part.Shape.SculptEntry && part.Shape.SculptTexture != UUID.Zero)
2969 { 2969 {
2970 m_scene.CommsManager.AssetCache.GetAsset( 2970 m_scene.AssetService.Get(
2971 part.Shape.SculptTexture, part.SculptTextureCallback, true); 2971 part.Shape.SculptTexture.ToString(), part, AssetReceived);
2972 } 2972 }
2973 } 2973 }
2974 } 2974 }
@@ -2976,6 +2976,16 @@ namespace OpenSim.Region.Framework.Scenes
2976 } 2976 }
2977 } 2977 }
2978 2978
2979 protected void AssetReceived(string id, Object sender, AssetBase asset)
2980 {
2981 if (asset != null)
2982 {
2983 SceneObjectPart sop = (SceneObjectPart)sender;
2984 if (sop != null)
2985 sop.SculptTextureCallback(asset.FullID, asset);
2986 }
2987 }
2988
2979 /// <summary> 2989 /// <summary>
2980 /// Set the user group to which this scene object belongs. 2990 /// Set the user group to which this scene object belongs.
2981 /// </summary> 2991 /// </summary>
diff --git a/OpenSim/Region/Framework/Scenes/SceneObjectPart.cs b/OpenSim/Region/Framework/Scenes/SceneObjectPart.cs
index 6b5883e..9a455ae 100644
--- a/OpenSim/Region/Framework/Scenes/SceneObjectPart.cs
+++ b/OpenSim/Region/Framework/Scenes/SceneObjectPart.cs
@@ -1414,8 +1414,7 @@ if (m_shape != null) {
1414 { 1414 {
1415 if (dupe.m_shape.SculptEntry && dupe.m_shape.SculptTexture != UUID.Zero) 1415 if (dupe.m_shape.SculptEntry && dupe.m_shape.SculptTexture != UUID.Zero)
1416 { 1416 {
1417 m_parentGroup.Scene.CommsManager.AssetCache.GetAsset( 1417 m_parentGroup.Scene.AssetService.Get(dupe.m_shape.SculptTexture.ToString(), dupe, AssetReceived);
1418 dupe.m_shape.SculptTexture, dupe.SculptTextureCallback, true);
1419 } 1418 }
1420 1419
1421 bool UsePhysics = ((dupe.ObjectFlags & (uint)PrimFlags.Physics) != 0); 1420 bool UsePhysics = ((dupe.ObjectFlags & (uint)PrimFlags.Physics) != 0);
@@ -1425,6 +1424,16 @@ if (m_shape != null) {
1425 return dupe; 1424 return dupe;
1426 } 1425 }
1427 1426
1427 protected void AssetReceived(string id, Object sender, AssetBase asset)
1428 {
1429 if (asset != null)
1430 {
1431 SceneObjectPart sop = (SceneObjectPart)sender;
1432 if (sop != null)
1433 sop.SculptTextureCallback(asset.FullID, asset);
1434 }
1435 }
1436
1428 public static SceneObjectPart Create() 1437 public static SceneObjectPart Create()
1429 { 1438 {
1430 SceneObjectPart part = new SceneObjectPart(); 1439 SceneObjectPart part = new SceneObjectPart();
@@ -3147,8 +3156,7 @@ if (m_shape != null) {
3147 { 3156 {
3148 if (m_shape.SculptEntry && m_shape.SculptTexture != UUID.Zero) 3157 if (m_shape.SculptEntry && m_shape.SculptTexture != UUID.Zero)
3149 { 3158 {
3150 m_parentGroup.Scene.CommsManager.AssetCache.GetAsset( 3159 m_parentGroup.Scene.AssetService.Get(m_shape.SculptTexture.ToString(), this, AssetReceived);
3151 m_shape.SculptTexture, SculptTextureCallback, true);
3152 } 3160 }
3153 } 3161 }
3154 3162
diff --git a/OpenSim/Region/Framework/Scenes/SceneObjectPartInventory.cs b/OpenSim/Region/Framework/Scenes/SceneObjectPartInventory.cs
index d03fec2..713cc0e 100644
--- a/OpenSim/Region/Framework/Scenes/SceneObjectPartInventory.cs
+++ b/OpenSim/Region/Framework/Scenes/SceneObjectPartInventory.cs
@@ -252,9 +252,8 @@ namespace OpenSim.Region.Framework.Scenes
252 m_part.ScheduleFullUpdate(); 252 m_part.ScheduleFullUpdate();
253 return; 253 return;
254 } 254 }
255 IAssetCache cache = m_part.ParentGroup.Scene.CommsManager.AssetCache;
256 255
257 cache.GetAsset(item.AssetID, delegate(UUID assetID, AssetBase asset) 256 m_part.ParentGroup.Scene.AssetService.Get(item.AssetID.ToString(), this, delegate(string id, object sender, AssetBase asset)
258 { 257 {
259 if (null == asset) 258 if (null == asset)
260 { 259 {
@@ -275,7 +274,7 @@ namespace OpenSim.Region.Framework.Scenes
275 m_part.ParentGroup.AddActiveScriptCount(1); 274 m_part.ParentGroup.AddActiveScriptCount(1);
276 m_part.ScheduleFullUpdate(); 275 m_part.ScheduleFullUpdate();
277 } 276 }
278 }, false); 277 });
279 } 278 }
280 } 279 }
281 280
diff --git a/OpenSim/Region/Framework/Scenes/ScenePresence.cs b/OpenSim/Region/Framework/Scenes/ScenePresence.cs
index 8950942..3b1f668 100644
--- a/OpenSim/Region/Framework/Scenes/ScenePresence.cs
+++ b/OpenSim/Region/Framework/Scenes/ScenePresence.cs
@@ -1979,7 +1979,7 @@ namespace OpenSim.Region.Framework.Scenes
1979 //BinBVHAnimation bbvhanim = new BinBVHAnimation(Animasset.Data); 1979 //BinBVHAnimation bbvhanim = new BinBVHAnimation(Animasset.Data);
1980 1980
1981 1981
1982 m_scene.CommsManager.AssetCache.AddAsset(Animasset); 1982 m_scene.AssetService.Store(Animasset);
1983 AddAnimation(Animasset.FullID, UUID); 1983 AddAnimation(Animasset.FullID, UUID);
1984 return anim; 1984 return anim;
1985 } 1985 }
diff --git a/OpenSim/Region/Framework/Scenes/Tests/SceneObjectBasicTests.cs b/OpenSim/Region/Framework/Scenes/Tests/SceneObjectBasicTests.cs
index 8a17ee7..895ee19 100644
--- a/OpenSim/Region/Framework/Scenes/Tests/SceneObjectBasicTests.cs
+++ b/OpenSim/Region/Framework/Scenes/Tests/SceneObjectBasicTests.cs
@@ -112,37 +112,37 @@ namespace OpenSim.Region.Framework.Scenes.Tests
112 /// <summary> 112 /// <summary>
113 /// Test deleting an object asynchronously to user inventory. 113 /// Test deleting an object asynchronously to user inventory.
114 /// </summary> 114 /// </summary>
115 [Test] 115 //[Test]
116 public void TestDeleteSceneObjectAsyncToUserInventory() 116 //public void TestDeleteSceneObjectAsyncToUserInventory()
117 { 117 //{
118 TestHelper.InMethod(); 118 // TestHelper.InMethod();
119 //log4net.Config.XmlConfigurator.Configure(); 119 // //log4net.Config.XmlConfigurator.Configure();
120 120
121 UUID agentId = UUID.Parse("00000000-0000-0000-0000-000000000001"); 121 // UUID agentId = UUID.Parse("00000000-0000-0000-0000-000000000001");
122 string myObjectName = "Fred"; 122 // string myObjectName = "Fred";
123 123
124 TestScene scene = SceneSetupHelpers.SetupScene(); 124 // TestScene scene = SceneSetupHelpers.SetupScene();
125 SceneObjectPart part = SceneSetupHelpers.AddSceneObject(scene, myObjectName); 125 // SceneObjectPart part = SceneSetupHelpers.AddSceneObject(scene, myObjectName);
126 126
127 Assert.That( 127 // Assert.That(
128 scene.CommsManager.UserAdminService.AddUser( 128 // scene.CommsManager.UserAdminService.AddUser(
129 "Bob", "Hoskins", "test", "test@test.com", 1000, 1000, agentId), 129 // "Bob", "Hoskins", "test", "test@test.com", 1000, 1000, agentId),
130 Is.EqualTo(agentId)); 130 // Is.EqualTo(agentId));
131 131
132 IClientAPI client = SceneSetupHelpers.AddRootAgent(scene, agentId); 132 // IClientAPI client = SceneSetupHelpers.AddRootAgent(scene, agentId);
133 133
134 CachedUserInfo userInfo = scene.CommsManager.UserProfileCacheService.GetUserDetails(agentId); 134 // CachedUserInfo userInfo = scene.CommsManager.UserProfileCacheService.GetUserDetails(agentId);
135 Assert.That(userInfo, Is.Not.Null); 135 // Assert.That(userInfo, Is.Not.Null);
136 Assert.That(userInfo.RootFolder, Is.Not.Null); 136 // Assert.That(userInfo.RootFolder, Is.Not.Null);
137 137
138 SceneSetupHelpers.DeleteSceneObjectAsync(scene, part, DeRezAction.Take, userInfo.RootFolder.ID, client); 138 // SceneSetupHelpers.DeleteSceneObjectAsync(scene, part, DeRezAction.Take, userInfo.RootFolder.ID, client);
139 139
140 // Check that we now have the taken part in our inventory 140 // // Check that we now have the taken part in our inventory
141 Assert.That(myObjectName, Is.EqualTo(userInfo.RootFolder.FindItemByPath(myObjectName).Name)); 141 // Assert.That(myObjectName, Is.EqualTo(userInfo.RootFolder.FindItemByPath(myObjectName).Name));
142 142
143 // Check that the taken part has actually disappeared 143 // // Check that the taken part has actually disappeared
144 SceneObjectPart retrievedPart = scene.GetSceneObjectPart(part.LocalId); 144 // SceneObjectPart retrievedPart = scene.GetSceneObjectPart(part.LocalId);
145 Assert.That(retrievedPart, Is.Null); 145 // Assert.That(retrievedPart, Is.Null);
146 } 146 //}
147 } 147 }
148} 148}
diff --git a/OpenSim/Region/Framework/Scenes/UuidGatherer.cs b/OpenSim/Region/Framework/Scenes/UuidGatherer.cs
index 600295f..5eb42f7 100644
--- a/OpenSim/Region/Framework/Scenes/UuidGatherer.cs
+++ b/OpenSim/Region/Framework/Scenes/UuidGatherer.cs
@@ -34,6 +34,7 @@ using log4net;
34using OpenMetaverse; 34using OpenMetaverse;
35using OpenSim.Framework; 35using OpenSim.Framework;
36using OpenSim.Region.Framework.Scenes.Serialization; 36using OpenSim.Region.Framework.Scenes.Serialization;
37using OpenSim.Services.Interfaces;
37 38
38namespace OpenSim.Region.Framework.Scenes 39namespace OpenSim.Region.Framework.Scenes
39{ 40{
@@ -52,7 +53,7 @@ namespace OpenSim.Region.Framework.Scenes
52 /// <summary> 53 /// <summary>
53 /// Asset cache used for gathering assets 54 /// Asset cache used for gathering assets
54 /// </summary> 55 /// </summary>
55 protected IAssetCache m_assetCache; 56 protected IAssetService m_assetCache;
56 57
57 /// <summary> 58 /// <summary>
58 /// Used as a temporary store of an asset which represents an object. This can be a null if no appropriate 59 /// Used as a temporary store of an asset which represents an object. This can be a null if no appropriate
@@ -65,7 +66,7 @@ namespace OpenSim.Region.Framework.Scenes
65 /// </summary> 66 /// </summary>
66 protected bool m_waitingForObjectAsset; 67 protected bool m_waitingForObjectAsset;
67 68
68 public UuidGatherer(IAssetCache assetCache) 69 public UuidGatherer(IAssetService assetCache)
69 { 70 {
70 m_assetCache = assetCache; 71 m_assetCache = assetCache;
71 } 72 }
@@ -174,6 +175,12 @@ namespace OpenSim.Region.Framework.Scenes
174 } 175 }
175 } 176 }
176 177
178 protected void AssetReceived(string id, Object sender, AssetBase asset)
179 {
180 if (asset != null)
181 AssetRequestCallback(asset.FullID, asset);
182 }
183
177 /// <summary> 184 /// <summary>
178 /// Get an asset synchronously, potentially using an asynchronous callback. If the 185 /// Get an asset synchronously, potentially using an asynchronous callback. If the
179 /// asynchronous callback is used, we will wait for it to complete. 186 /// asynchronous callback is used, we will wait for it to complete.
@@ -183,7 +190,7 @@ namespace OpenSim.Region.Framework.Scenes
183 protected AssetBase GetAsset(UUID uuid) 190 protected AssetBase GetAsset(UUID uuid)
184 { 191 {
185 m_waitingForObjectAsset = true; 192 m_waitingForObjectAsset = true;
186 m_assetCache.GetAsset(uuid, AssetRequestCallback, true); 193 m_assetCache.Get(uuid.ToString(), this, AssetReceived);
187 194
188 // The asset cache callback can either 195 // The asset cache callback can either
189 // 196 //
diff --git a/OpenSim/Region/OptionalModules/Scripting/Minimodule/Graphics.cs b/OpenSim/Region/OptionalModules/Scripting/Minimodule/Graphics.cs
index 0b937c1..963cab5 100644
--- a/OpenSim/Region/OptionalModules/Scripting/Minimodule/Graphics.cs
+++ b/OpenSim/Region/OptionalModules/Scripting/Minimodule/Graphics.cs
@@ -57,14 +57,14 @@ namespace OpenSim.Region.OptionalModules.Scripting.Minimodule
57 asset.Description = "MRM Image"; 57 asset.Description = "MRM Image";
58 asset.Local = false; 58 asset.Local = false;
59 asset.Temporary = temporary; 59 asset.Temporary = temporary;
60 m_scene.CommsManager.AssetCache.AddAsset(asset); 60 m_scene.AssetService.Store(asset);
61 61
62 return asset.FullID; 62 return asset.FullID;
63 } 63 }
64 64
65 public Bitmap LoadBitmap(UUID assetID) 65 public Bitmap LoadBitmap(UUID assetID)
66 { 66 {
67 AssetBase bmp = m_scene.CommsManager.AssetCache.GetAsset(assetID, true); 67 AssetBase bmp = m_scene.AssetService.Get(assetID.ToString());
68 ManagedImage outimg; 68 ManagedImage outimg;
69 Image img; 69 Image img;
70 OpenJPEG.DecodeToImage(bmp.Data, out outimg, out img); 70 OpenJPEG.DecodeToImage(bmp.Data, out outimg, out img);
diff --git a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
index 9020ff9..d4fc2d1 100644
--- a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
+++ b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
@@ -3782,8 +3782,8 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
3782 World.RegionInfo.RegionLocY * Constants.RegionSize, 3782 World.RegionInfo.RegionLocY * Constants.RegionSize,
3783 0); 3783 0);
3784 3784
3785 World.CommsManager.AssetCache.GetAsset(item.AssetID, 3785 World.AssetService.Get(item.AssetID.ToString(), this,
3786 delegate(UUID i, AssetBase a) 3786 delegate(string i, object sender, AssetBase a)
3787 { 3787 {
3788 AssetLandmark lm = new AssetLandmark(a); 3788 AssetLandmark lm = new AssetLandmark(a);
3789 3789
@@ -3795,7 +3795,7 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
3795 AsyncCommands. 3795 AsyncCommands.
3796 DataserverPlugin.DataserverReply(i.ToString(), 3796 DataserverPlugin.DataserverReply(i.ToString(),
3797 reply); 3797 reply);
3798 }, false); 3798 });
3799 3799
3800 // ScriptSleep(1000); 3800 // ScriptSleep(1000);
3801 return tid.ToString(); 3801 return tid.ToString();
@@ -9311,7 +9311,13 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
9311 public delegate void AssetRequestCallback(UUID assetID, AssetBase asset); 9311 public delegate void AssetRequestCallback(UUID assetID, AssetBase asset);
9312 private void WithNotecard(UUID assetID, AssetRequestCallback cb) 9312 private void WithNotecard(UUID assetID, AssetRequestCallback cb)
9313 { 9313 {
9314 World.CommsManager.AssetCache.GetAsset(assetID, delegate(UUID i, AssetBase a) { cb(i, a); }, false); 9314 World.AssetService.Get(assetID.ToString(), this,
9315 delegate(string i, object sender, AssetBase a)
9316 {
9317 UUID uuid = UUID.Zero;
9318 UUID.TryParse(i, out uuid);
9319 cb(uuid, a);
9320 });
9315 } 9321 }
9316 9322
9317 public LSL_String llGetNumberOfNotecardLines(string name) 9323 public LSL_String llGetNumberOfNotecardLines(string name)
diff --git a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs
index e5c59aa..fbae9c8 100644
--- a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs
+++ b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/OSSL_Api.cs
@@ -1341,7 +1341,7 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
1341 + textLength.ToString() + "\n" + notecardData + "}\n"; 1341 + textLength.ToString() + "\n" + notecardData + "}\n";
1342 1342
1343 asset.Data = Encoding.ASCII.GetBytes(notecardData); 1343 asset.Data = Encoding.ASCII.GetBytes(notecardData);
1344 World.CommsManager.AssetCache.AddAsset(asset); 1344 World.AssetService.Store(asset);
1345 1345
1346 // Create Task Entry 1346 // Create Task Entry
1347 TaskInventoryItem taskItem=new TaskInventoryItem(); 1347 TaskInventoryItem taskItem=new TaskInventoryItem();
@@ -1402,7 +1402,7 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
1402 1402
1403 if (!NotecardCache.IsCached(assetID)) 1403 if (!NotecardCache.IsCached(assetID))
1404 { 1404 {
1405 AssetBase a = World.CommsManager.AssetCache.GetAsset(assetID, false); 1405 AssetBase a = World.AssetService.Get(assetID.ToString());
1406 if (a != null) 1406 if (a != null)
1407 { 1407 {
1408 System.Text.ASCIIEncoding enc = new System.Text.ASCIIEncoding(); 1408 System.Text.ASCIIEncoding enc = new System.Text.ASCIIEncoding();
@@ -1455,7 +1455,7 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
1455 1455
1456 if (!NotecardCache.IsCached(assetID)) 1456 if (!NotecardCache.IsCached(assetID))
1457 { 1457 {
1458 AssetBase a = World.CommsManager.AssetCache.GetAsset(assetID, false); 1458 AssetBase a = World.AssetService.Get(assetID.ToString());
1459 if (a != null) 1459 if (a != null)
1460 { 1460 {
1461 System.Text.ASCIIEncoding enc = new System.Text.ASCIIEncoding(); 1461 System.Text.ASCIIEncoding enc = new System.Text.ASCIIEncoding();
@@ -1512,7 +1512,7 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
1512 1512
1513 if (!NotecardCache.IsCached(assetID)) 1513 if (!NotecardCache.IsCached(assetID))
1514 { 1514 {
1515 AssetBase a = World.CommsManager.AssetCache.GetAsset(assetID, false); 1515 AssetBase a = World.AssetService.Get(assetID.ToString());
1516 if (a != null) 1516 if (a != null)
1517 { 1517 {
1518 System.Text.ASCIIEncoding enc = new System.Text.ASCIIEncoding(); 1518 System.Text.ASCIIEncoding enc = new System.Text.ASCIIEncoding();
diff --git a/OpenSim/Services/AssetService/HGAssetService.cs b/OpenSim/Services/AssetService/HGAssetService.cs
index 7415427..87e42fe 100644
--- a/OpenSim/Services/AssetService/HGAssetService.cs
+++ b/OpenSim/Services/AssetService/HGAssetService.cs
@@ -42,7 +42,7 @@ namespace OpenSim.Region.CoreModules.ServiceConnectors.Asset
42 42
43 public HGAssetService(IConfigSource source) 43 public HGAssetService(IConfigSource source)
44 { 44 {
45 IConfig moduleConfig = source.Configs["Modules"]; 45 IConfig moduleConfig = source.Configs["ServiceConnectors"];
46 if (moduleConfig != null) 46 if (moduleConfig != null)
47 { 47 {
48 string name = moduleConfig.GetString("AssetServices", ""); 48 string name = moduleConfig.GetString("AssetServices", "");
diff --git a/OpenSim/Region/CoreModules/Framework/Services/RegionAssetService.cs b/OpenSim/SimulatorServices/RegionAssetService.cs
index e738560..9a2cbb9 100644
--- a/OpenSim/Region/CoreModules/Framework/Services/RegionAssetService.cs
+++ b/OpenSim/SimulatorServices/RegionAssetService.cs
@@ -1,138 +1,123 @@
1/* 1/*
2 * Copyright (c) Contributors, http://opensimulator.org/ 2 * Copyright (c) Contributors, http://opensimulator.org/
3 * See CONTRIBUTORS.TXT for a full list of copyright holders. 3 * See CONTRIBUTORS.TXT for a full list of copyright holders.
4 * 4 *
5 * Redistribution and use in source and binary forms, with or without 5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met: 6 * modification, are permitted provided that the following conditions are met:
7 * * Redistributions of source code must retain the above copyright 7 * * Redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer. 8 * notice, this list of conditions and the following disclaimer.
9 * * Redistributions in binary form must reproduce the above copyright 9 * * Redistributions in binary form must reproduce the above copyright
10 * notice, this list of conditions and the following disclaimer in the 10 * notice, this list of conditions and the following disclaimer in the
11 * documentation and/or other materials provided with the distribution. 11 * documentation and/or other materials provided with the distribution.
12 * * Neither the name of the OpenSim Project nor the 12 * * Neither the name of the OpenSim Project nor the
13 * names of its contributors may be used to endorse or promote products 13 * names of its contributors may be used to endorse or promote products
14 * derived from this software without specific prior written permission. 14 * derived from this software without specific prior written permission.
15 * 15 *
16 * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 16 * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
17 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 17 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 18 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
19 * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 19 * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
20 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 20 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
21 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 21 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
22 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 22 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
23 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 23 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */ 26 */
27 27
28using System.Reflection; 28using System.Reflection;
29using log4net; 29using log4net;
30using Nini.Config; 30using Nini.Config;
31using OpenMetaverse; 31using OpenSim.Framework;
32using OpenSim.Data; 32using OpenSim.Framework.Servers.HttpServer;
33using OpenSim.Framework; 33using OpenSim.Region.Framework.Scenes;
34using OpenSim.Framework.Communications; 34using OpenSim.Region.Framework.Interfaces;
35using OpenSim.Framework.Communications.Cache; 35using OpenSim.Servers.AssetServer.Handlers;
36using OpenSim.Framework.Servers; 36
37using OpenSim.Framework.Servers.HttpServer; 37namespace OpenSim.Region.SimulatorServices
38using OpenSim.Region.Framework.Interfaces; 38{
39using OpenSim.Region.Framework.Scenes; 39 public class RegionAssetService : IRegionModule
40 40 {
41namespace OpenSim.Region.CoreModules.Framework.Services 41 private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
42{ 42 private static bool initialized = false;
43 public class RegionAssetService : IRegionModule 43 private static bool enabled = false;
44 { 44
45 private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); 45 private bool m_gridMode = false;
46 private static bool initialized = false; 46 Scene m_scene;
47 private static bool enabled = false; 47
48 48 #region IRegionModule interface
49 private bool m_gridMode = false; 49
50 Scene m_scene; 50 public void Initialise(Scene scene, IConfigSource config)
51 51 {
52 #region IRegionModule interface 52 if (!initialized)
53 53 {
54 public void Initialise(Scene scene, IConfigSource config) 54 initialized = true;
55 { 55 m_scene = scene;
56 if (!initialized) 56
57 { 57 // This module is only on for standalones in hypergrid mode
58 initialized = true; 58 enabled = ((!config.Configs["Startup"].GetBoolean("gridmode", true)) &&
59 m_scene = scene; 59 config.Configs["Startup"].GetBoolean("hypergrid", true)) ||
60 60 ((config.Configs["MXP"] != null) && config.Configs["MXP"].GetBoolean("Enabled", true));
61 // This module is only on for standalones in hypergrid mode 61 m_gridMode = config.Configs["Startup"].GetBoolean("gridmode", true);
62 enabled = ((!config.Configs["Startup"].GetBoolean("gridmode", true)) && 62 }
63 config.Configs["Startup"].GetBoolean("hypergrid", true)) || 63 }
64 ((config.Configs["MXP"] != null) && config.Configs["MXP"].GetBoolean("Enabled", true)); 64
65 m_gridMode = config.Configs["Startup"].GetBoolean("gridmode", true); 65 public void PostInitialise()
66 } 66 {
67 } 67 if (enabled)
68 68 {
69 public void PostInitialise() 69 m_log.Info("[RegionAssetService]: Starting...");
70 { 70
71 if (enabled) 71 new AssetService(m_scene,m_gridMode);
72 { 72 }
73 m_log.Info("[RegionAssetService]: Starting..."); 73 }
74 74
75 new AssetService(m_scene,m_gridMode); 75 public void Close()
76 } 76 {
77 } 77 }
78 78
79 public void Close() 79 public string Name
80 { 80 {
81 } 81 get { return "RegionAssetService"; }
82 82 }
83 public string Name 83
84 { 84 public bool IsSharedModule
85 get { return "RegionAssetService"; } 85 {
86 } 86 get { return true; }
87 87 }
88 public bool IsSharedModule 88
89 { 89 #endregion
90 get { return true; } 90
91 } 91 }
92 92
93 #endregion 93 public class AssetService
94 94 {
95 } 95 private bool m_doLookup = false;
96 96 private bool m_gridMode = false;
97 public class AssetService 97
98 { 98 public bool DoLookup
99// private IUserService m_userService; 99 {
100 private bool m_doLookup = false; 100 get { return m_doLookup; }
101 private bool m_gridMode = false; 101 set { m_doLookup = value; }
102 102 }
103 public bool DoLookup 103// private static readonly ILog m_log
104 { 104// = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
105 get { return m_doLookup; } 105
106 set { m_doLookup = value; } 106 public AssetService(Scene m_scene, bool gridMode)
107 } 107 {
108// private static readonly ILog m_log 108 m_gridMode = gridMode;
109// = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); 109 AddHttpHandlers(m_scene);
110 110 }
111 public AssetService(Scene m_scene, bool gridMode) 111
112 { 112 protected void AddHttpHandlers(Scene m_scene)
113 m_gridMode = gridMode; 113 {
114 AddHttpHandlers(m_scene); 114 IHttpServer httpServer = m_scene.CommsManager.HttpServer;
115// m_userService = m_scene.CommsManager.UserService; 115
116 } 116 httpServer.AddStreamHandler(new AssetServerGetHandler(m_scene.AssetService));
117 117 httpServer.AddStreamHandler(new AssetServerPostHandler(m_scene.AssetService));
118 protected void AddHttpHandlers(Scene m_scene) 118 httpServer.AddStreamHandler(new AssetServerDeleteHandler(m_scene.AssetService));
119 { 119
120 IAssetDataPlugin m_assetProvider 120
121 = ((AssetServerBase)m_scene.CommsManager.AssetCache.AssetServer).AssetProviderPlugin; 121 }
122 122 }
123 IHttpServer httpServer = m_scene.CommsManager.HttpServer; 123}
124
125 if (m_gridMode)
126 {
127 httpServer.AddStreamHandler(new CachedGetAssetStreamHandler(m_scene.CommsManager.AssetCache));
128 }
129 else
130 {
131 httpServer.AddStreamHandler(new GetAssetStreamHandler(m_assetProvider));
132 }
133
134 httpServer.AddStreamHandler(new PostAssetStreamHandler(m_assetProvider));
135
136 }
137 }
138}
diff --git a/OpenSim/Tests/Common/Setup/SceneSetupHelpers.cs b/OpenSim/Tests/Common/Setup/SceneSetupHelpers.cs
index 8527886..5eb8e0f 100644
--- a/OpenSim/Tests/Common/Setup/SceneSetupHelpers.cs
+++ b/OpenSim/Tests/Common/Setup/SceneSetupHelpers.cs
@@ -40,6 +40,8 @@ using OpenSim.Region.Framework.Interfaces;
40using OpenSim.Region.Framework.Scenes; 40using OpenSim.Region.Framework.Scenes;
41using OpenSim.Region.CoreModules.Agent.Capabilities; 41using OpenSim.Region.CoreModules.Agent.Capabilities;
42using OpenSim.Region.CoreModules.Avatar.Gods; 42using OpenSim.Region.CoreModules.Avatar.Gods;
43using OpenSim.Region.CoreModules.ServiceConnectors.Asset;
44using OpenSim.Services.Interfaces;
43using OpenSim.Tests.Common.Mock; 45using OpenSim.Tests.Common.Mock;
44 46
45namespace OpenSim.Tests.Common.Setup 47namespace OpenSim.Tests.Common.Setup
@@ -122,6 +124,18 @@ namespace OpenSim.Tests.Common.Setup
122 IRegionModule godsModule = new GodsModule(); 124 IRegionModule godsModule = new GodsModule();
123 godsModule.Initialise(testScene, new IniConfigSource()); 125 godsModule.Initialise(testScene, new IniConfigSource());
124 testScene.AddModule(godsModule.Name, godsModule); 126 testScene.AddModule(godsModule.Name, godsModule);
127
128 ISharedRegionModule assetService = new LocalAssetServicesConnector();
129 IniConfigSource config = new IniConfigSource();
130 config.AddConfig("ServiceConnectors");
131 config.AddConfig("AssetService");
132 config.Configs["ServiceConnectors"].Set("AssetServices", "LocalAssetServicesConnector");
133 config.Configs["AssetService"].Set("LocalServiceModule", "OpenSim.Services.AssetService.dll:AssetService");
134 config.Configs["AssetService"].Set("StorageProvider", "OpenSim.Data.Null.dll");
135 assetService.Initialise(config);
136 assetService.AddRegion(testScene);
137 assetService.RegionLoaded(testScene);
138 //testScene.RegisterModuleInterface<IAssetService>((IAssetService)assetService);
125 139
126 testScene.SetModuleInterfaces(); 140 testScene.SetModuleInterfaces();
127 141
generated by cgit v1.1 at 2024-11-09 07:44:13 +0000