aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Region/GridInterfaces/Local/LocalAssetServer.cs
diff options
context:
space:
mode:
Diffstat (limited to 'OpenSim/Region/GridInterfaces/Local/LocalAssetServer.cs')
-rw-r--r--OpenSim/Region/GridInterfaces/Local/LocalAssetServer.cs312
1 files changed, 312 insertions, 0 deletions
diff --git a/OpenSim/Region/GridInterfaces/Local/LocalAssetServer.cs b/OpenSim/Region/GridInterfaces/Local/LocalAssetServer.cs
new file mode 100644
index 0000000..95d03f1
--- /dev/null
+++ b/OpenSim/Region/GridInterfaces/Local/LocalAssetServer.cs
@@ -0,0 +1,312 @@
1/*
2* Copyright (c) Contributors, http://www.openmetaverse.org/
3* See CONTRIBUTORS.TXT for a full list of copyright holders.
4*
5* Redistribution and use in source and binary forms, with or without
6* modification, are permitted provided that the following conditions are met:
7* * Redistributions of source code must retain the above copyright
8* notice, this list of conditions and the following disclaimer.
9* * Redistributions in binary form must reproduce the above copyright
10* notice, this list of conditions and the following disclaimer in the
11* documentation and/or other materials provided with the distribution.
12* * Neither the name of the OpenSim Project nor the
13* names of its contributors may be used to endorse or promote products
14* derived from this software without specific prior written permission.
15*
16* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
17* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
19* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
20* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
21* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
22* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
23* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
25* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26*
27*/
28using System;
29using System.Collections.Generic;
30using System.Text;
31using System.Threading;
32using System.IO;
33using OpenSim.Framework.Interfaces;
34using OpenSim.Framework.Types;
35using OpenSim.Framework.Utilities;
36using OpenSim.Framework.Console;
37using libsecondlife;
38using Db4objects.Db4o;
39using Db4objects.Db4o.Query;
40
41namespace OpenSim.Region.GridInterfaces.Local
42{
43 public class LocalAssetPlugin : IAssetPlugin
44 {
45 public LocalAssetPlugin()
46 {
47
48 }
49
50 public IAssetServer GetAssetServer()
51 {
52 return (new LocalAssetServer());
53 }
54 }
55
56 public class LocalAssetServer : IAssetServer
57 {
58 private IAssetReceiver _receiver;
59 private BlockingQueue<ARequest> _assetRequests;
60 private IObjectContainer db;
61 private Thread _localAssetServerThread;
62
63 public LocalAssetServer()
64 {
65 bool yapfile;
66 this._assetRequests = new BlockingQueue<ARequest>();
67 yapfile = System.IO.File.Exists("assets.yap");
68
69 OpenSim.Framework.Console.MainLog.Instance.Verbose( "Local Asset Server class created");
70 try
71 {
72 db = Db4oFactory.OpenFile("assets.yap");
73 OpenSim.Framework.Console.MainLog.Instance.Verbose( "Db4 Asset database creation");
74 }
75 catch (Exception e)
76 {
77 db.Close();
78 OpenSim.Framework.Console.MainLog.Instance.WriteLine(LogPriority.MEDIUM, "Db4 Asset server :Constructor - Exception occured");
79 OpenSim.Framework.Console.MainLog.Instance.Warn(e.ToString());
80 }
81 if (!yapfile)
82 {
83 this.SetUpAssetDatabase();
84 }
85 this._localAssetServerThread = new Thread(new ThreadStart(RunRequests));
86 this._localAssetServerThread.IsBackground = true;
87 this._localAssetServerThread.Start();
88
89 }
90
91 public void SetReceiver(IAssetReceiver receiver)
92 {
93 this._receiver = receiver;
94 }
95
96 public void RequestAsset(LLUUID assetID, bool isTexture)
97 {
98 ARequest req = new ARequest();
99 req.AssetID = assetID;
100 req.IsTexture = isTexture;
101 this._assetRequests.Enqueue(req);
102 }
103
104 public void UpdateAsset(AssetBase asset)
105 {
106
107 }
108
109 public void UploadNewAsset(AssetBase asset)
110 {
111 AssetStorage store = new AssetStorage();
112 store.Data = asset.Data;
113 store.Name = asset.Name;
114 store.UUID = asset.FullID;
115 db.Set(store);
116 db.Commit();
117 }
118
119 public void SetServerInfo(string ServerUrl, string ServerKey)
120 {
121
122 }
123 public void Close()
124 {
125 if (db != null)
126 {
127 OpenSim.Framework.Console.MainLog.Instance.Verbose( "Closing local asset server database");
128 db.Close();
129 }
130 }
131
132 private void RunRequests()
133 {
134 while (true)
135 {
136 byte[] idata = null;
137 bool found = false;
138 AssetStorage foundAsset = null;
139 ARequest req = this._assetRequests.Dequeue();
140 IObjectSet result = db.Query(new AssetUUIDQuery(req.AssetID));
141 if (result.Count > 0)
142 {
143 foundAsset = (AssetStorage)result.Next();
144 found = true;
145 }
146
147 AssetBase asset = new AssetBase();
148 if (found)
149 {
150 asset.FullID = foundAsset.UUID;
151 asset.Type = foundAsset.Type;
152 asset.InvType = foundAsset.Type;
153 asset.Name = foundAsset.Name;
154 idata = foundAsset.Data;
155 }
156 else
157 {
158 asset.FullID = LLUUID.Zero;
159 }
160 asset.Data = idata;
161 _receiver.AssetReceived(asset, req.IsTexture);
162 }
163
164 }
165
166 private void SetUpAssetDatabase()
167 {
168 try
169 {
170
171 OpenSim.Framework.Console.MainLog.Instance.Verbose( "Setting up asset database");
172
173 AssetBase Image = new AssetBase();
174 Image.FullID = new LLUUID("00000000-0000-0000-9999-000000000001");
175 Image.Name = "Bricks";
176 this.LoadAsset(Image, true, "bricks.jp2");
177 AssetStorage store = new AssetStorage();
178 store.Data = Image.Data;
179 store.Name = Image.Name;
180 store.UUID = Image.FullID;
181 db.Set(store);
182 db.Commit();
183
184 Image = new AssetBase();
185 Image.FullID = new LLUUID("00000000-0000-0000-9999-000000000002");
186 Image.Name = "Plywood";
187 this.LoadAsset(Image, true, "plywood.jp2");
188 store = new AssetStorage();
189 store.Data = Image.Data;
190 store.Name = Image.Name;
191 store.UUID = Image.FullID;
192 db.Set(store);
193 db.Commit();
194
195 Image = new AssetBase();
196 Image.FullID = new LLUUID("00000000-0000-0000-9999-000000000003");
197 Image.Name = "Rocks";
198 this.LoadAsset(Image, true, "rocks.jp2");
199 store = new AssetStorage();
200 store.Data = Image.Data;
201 store.Name = Image.Name;
202 store.UUID = Image.FullID;
203 db.Set(store);
204 db.Commit();
205
206 Image = new AssetBase();
207 Image.FullID = new LLUUID("00000000-0000-0000-9999-000000000004");
208 Image.Name = "Granite";
209 this.LoadAsset(Image, true, "granite.jp2");
210 store = new AssetStorage();
211 store.Data = Image.Data;
212 store.Name = Image.Name;
213 store.UUID = Image.FullID;
214 db.Set(store);
215 db.Commit();
216
217 Image = new AssetBase();
218 Image.FullID = new LLUUID("00000000-0000-0000-9999-000000000005");
219 Image.Name = "Hardwood";
220 this.LoadAsset(Image, true, "hardwood.jp2");
221 store = new AssetStorage();
222 store.Data = Image.Data;
223 store.Name = Image.Name;
224 store.UUID = Image.FullID;
225 db.Set(store);
226 db.Commit();
227
228 Image = new AssetBase();
229 Image.FullID = new LLUUID("00000000-0000-0000-5005-000000000005");
230 Image.Name = "Prim Base Texture";
231 this.LoadAsset(Image, true, "plywood.jp2");
232 store = new AssetStorage();
233 store.Data = Image.Data;
234 store.Name = Image.Name;
235 store.UUID = Image.FullID;
236 db.Set(store);
237 db.Commit();
238
239 Image = new AssetBase();
240 Image.FullID = new LLUUID("00000000-0000-0000-9999-000000000006");
241 Image.Name = "Map Base Texture";
242 this.LoadAsset(Image, true, "map_base.jp2");
243 store = new AssetStorage();
244 store.Data = Image.Data;
245 store.Name = Image.Name;
246 store.UUID = Image.FullID;
247 db.Set(store);
248 db.Commit();
249
250 Image = new AssetBase();
251 Image.FullID = new LLUUID("00000000-0000-0000-9999-000000000007");
252 Image.Name = "Map Texture";
253 this.LoadAsset(Image, true, "map1.jp2");
254 store = new AssetStorage();
255 store.Data = Image.Data;
256 store.Name = Image.Name;
257 store.UUID = Image.FullID;
258 db.Set(store);
259 db.Commit();
260
261 Image = new AssetBase();
262 Image.FullID = new LLUUID("66c41e39-38f9-f75a-024e-585989bfab73");
263 Image.Name = "Shape";
264 this.LoadAsset(Image, false, "base_shape.dat");
265 store = new AssetStorage();
266 store.Data = Image.Data;
267 store.Name = Image.Name;
268 store.UUID = Image.FullID;
269 db.Set(store);
270 db.Commit();
271 }
272 catch (Exception e)
273 {
274 Console.WriteLine(e.Message);
275 }
276
277 }
278
279 private void LoadAsset(AssetBase info, bool image, string filename)
280 {
281 //should request Asset from storage manager
282 //but for now read from file
283
284 string dataPath = Path.Combine(System.AppDomain.CurrentDomain.BaseDirectory, "assets"); //+ folder;
285 string fileName = Path.Combine(dataPath, filename);
286 FileInfo fInfo = new FileInfo(fileName);
287 long numBytes = fInfo.Length;
288 FileStream fStream = new FileStream(fileName, FileMode.Open, FileAccess.Read);
289 byte[] idata = new byte[numBytes];
290 BinaryReader br = new BinaryReader(fStream);
291 idata = br.ReadBytes((int)numBytes);
292 br.Close();
293 fStream.Close();
294 info.Data = idata;
295 //info.loaded=true;
296 }
297 }
298 public class AssetUUIDQuery : Predicate
299 {
300 private LLUUID _findID;
301
302 public AssetUUIDQuery(LLUUID find)
303 {
304 _findID = find;
305 }
306 public bool Match(AssetStorage asset)
307 {
308 return (asset.UUID == _findID);
309 }
310 }
311
312}
generated by cgit v1.1 at 2024-11-10 14:45:59 +0000