diff options
author | MW | 2007-06-27 15:28:52 +0000 |
---|---|---|
committer | MW | 2007-06-27 15:28:52 +0000 |
commit | 646bbbc84b8010e0dacbeed5342cdb045f46cc49 (patch) | |
tree | 770b34d19855363c3c113ab9a0af9a56d821d887 /OpenSim/Region/Caches | |
download | opensim-SC_OLD-646bbbc84b8010e0dacbeed5342cdb045f46cc49.zip opensim-SC_OLD-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.gz opensim-SC_OLD-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.bz2 opensim-SC_OLD-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.xz |
Some work on restructuring the namespaces / project names. Note this doesn't compile yet as not all the code has been changed to use the new namespaces. Am committing it now for feedback on the namespaces.
Diffstat (limited to 'OpenSim/Region/Caches')
-rw-r--r-- | OpenSim/Region/Caches/AssetCache.cs | 670 | ||||
-rw-r--r-- | OpenSim/Region/Caches/OpenSim.Region.Caches.csproj | 97 | ||||
-rw-r--r-- | OpenSim/Region/Caches/OpenSim.Region.Caches.csproj.user | 12 | ||||
-rw-r--r-- | OpenSim/Region/Caches/Properties/AssemblyInfo.cs | 35 |
4 files changed, 814 insertions, 0 deletions
diff --git a/OpenSim/Region/Caches/AssetCache.cs b/OpenSim/Region/Caches/AssetCache.cs new file mode 100644 index 0000000..d0cc370 --- /dev/null +++ b/OpenSim/Region/Caches/AssetCache.cs | |||
@@ -0,0 +1,670 @@ | |||
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 | */ | ||
28 | |||
29 | using System; | ||
30 | using System.Collections.Generic; | ||
31 | using System.Threading; | ||
32 | using System.Reflection; | ||
33 | using libsecondlife; | ||
34 | using libsecondlife.Packets; | ||
35 | using OpenSim.Framework.Interfaces; | ||
36 | using OpenSim.Framework.Types; | ||
37 | using OpenSim.Framework.Utilities; | ||
38 | |||
39 | namespace OpenSim.Caches | ||
40 | { | ||
41 | public delegate void DownloadComplete(AssetCache.TextureSender sender); | ||
42 | |||
43 | /// <summary> | ||
44 | /// Manages local cache of assets and their sending to viewers. | ||
45 | /// </summary> | ||
46 | public class AssetCache : IAssetReceiver | ||
47 | { | ||
48 | public Dictionary<libsecondlife.LLUUID, AssetInfo> Assets; | ||
49 | public Dictionary<libsecondlife.LLUUID, TextureImage> Textures; | ||
50 | |||
51 | public List<AssetRequest> AssetRequests = new List<AssetRequest>(); //assets ready to be sent to viewers | ||
52 | public List<AssetRequest> TextureRequests = new List<AssetRequest>(); //textures ready to be sent | ||
53 | |||
54 | public Dictionary<LLUUID, AssetRequest> RequestedAssets = new Dictionary<LLUUID, AssetRequest>(); //Assets requested from the asset server | ||
55 | public Dictionary<LLUUID, AssetRequest> RequestedTextures = new Dictionary<LLUUID, AssetRequest>(); //Textures requested from the asset server | ||
56 | |||
57 | public Dictionary<LLUUID, TextureSender> SendingTextures = new Dictionary<LLUUID, TextureSender>(); | ||
58 | private IAssetServer _assetServer; | ||
59 | private Thread _assetCacheThread; | ||
60 | private LLUUID[] textureList = new LLUUID[5]; | ||
61 | |||
62 | /// <summary> | ||
63 | /// | ||
64 | /// </summary> | ||
65 | public AssetCache(IAssetServer assetServer) | ||
66 | { | ||
67 | Console.WriteLine("Creating Asset cache"); | ||
68 | _assetServer = assetServer; | ||
69 | _assetServer.SetReceiver(this); | ||
70 | Assets = new Dictionary<libsecondlife.LLUUID, AssetInfo>(); | ||
71 | Textures = new Dictionary<libsecondlife.LLUUID, TextureImage>(); | ||
72 | this._assetCacheThread = new Thread(new ThreadStart(RunAssetManager)); | ||
73 | this._assetCacheThread.IsBackground = true; | ||
74 | this._assetCacheThread.Start(); | ||
75 | |||
76 | } | ||
77 | |||
78 | public AssetCache(string assetServerDLLName, string assetServerURL, string assetServerKey) | ||
79 | { | ||
80 | Console.WriteLine("Creating Asset cache"); | ||
81 | _assetServer = this.LoadAssetDll(assetServerDLLName); | ||
82 | _assetServer.SetServerInfo(assetServerURL, assetServerKey); | ||
83 | _assetServer.SetReceiver(this); | ||
84 | Assets = new Dictionary<libsecondlife.LLUUID, AssetInfo>(); | ||
85 | Textures = new Dictionary<libsecondlife.LLUUID, TextureImage>(); | ||
86 | this._assetCacheThread = new Thread(new ThreadStart(RunAssetManager)); | ||
87 | this._assetCacheThread.IsBackground = true; | ||
88 | this._assetCacheThread.Start(); | ||
89 | |||
90 | } | ||
91 | |||
92 | /// <summary> | ||
93 | /// | ||
94 | /// </summary> | ||
95 | public void RunAssetManager() | ||
96 | { | ||
97 | while (true) | ||
98 | { | ||
99 | try | ||
100 | { | ||
101 | //Console.WriteLine("Asset cache loop"); | ||
102 | this.ProcessAssetQueue(); | ||
103 | this.ProcessTextureQueue(); | ||
104 | Thread.Sleep(500); | ||
105 | } | ||
106 | catch (Exception e) | ||
107 | { | ||
108 | Console.WriteLine(e.Message); | ||
109 | } | ||
110 | } | ||
111 | } | ||
112 | |||
113 | public void LoadDefaultTextureSet() | ||
114 | { | ||
115 | //hack: so we can give each user a set of textures | ||
116 | textureList[0] = new LLUUID("00000000-0000-0000-9999-000000000001"); | ||
117 | textureList[1] = new LLUUID("00000000-0000-0000-9999-000000000002"); | ||
118 | textureList[2] = new LLUUID("00000000-0000-0000-9999-000000000003"); | ||
119 | textureList[3] = new LLUUID("00000000-0000-0000-9999-000000000004"); | ||
120 | textureList[4] = new LLUUID("00000000-0000-0000-9999-000000000005"); | ||
121 | |||
122 | for (int i = 0; i < textureList.Length; i++) | ||
123 | { | ||
124 | this._assetServer.RequestAsset(textureList[i], true); | ||
125 | } | ||
126 | |||
127 | } | ||
128 | |||
129 | public AssetBase[] CreateNewInventorySet(LLUUID agentID) | ||
130 | { | ||
131 | AssetBase[] inventorySet = new AssetBase[this.textureList.Length]; | ||
132 | for (int i = 0; i < textureList.Length; i++) | ||
133 | { | ||
134 | if (this.Textures.ContainsKey(textureList[i])) | ||
135 | { | ||
136 | inventorySet[i] = this.CloneImage(agentID, this.Textures[textureList[i]]); | ||
137 | TextureImage image = new TextureImage(inventorySet[i]); | ||
138 | this.Textures.Add(image.FullID, image); | ||
139 | this._assetServer.UploadNewAsset(image); //save the asset to the asset server | ||
140 | } | ||
141 | } | ||
142 | return inventorySet; | ||
143 | } | ||
144 | |||
145 | public AssetBase GetAsset(LLUUID assetID) | ||
146 | { | ||
147 | AssetBase asset = null; | ||
148 | if (this.Textures.ContainsKey(assetID)) | ||
149 | { | ||
150 | asset = this.Textures[assetID]; | ||
151 | } | ||
152 | else if (this.Assets.ContainsKey(assetID)) | ||
153 | { | ||
154 | asset = this.Assets[assetID]; | ||
155 | } | ||
156 | return asset; | ||
157 | } | ||
158 | |||
159 | public void AddAsset(AssetBase asset) | ||
160 | { | ||
161 | // Console.WriteLine("adding asset " + asset.FullID.ToStringHyphenated()); | ||
162 | if (asset.Type == 0) | ||
163 | { | ||
164 | //Console.WriteLine("which is a texture"); | ||
165 | if (!this.Textures.ContainsKey(asset.FullID)) | ||
166 | { //texture | ||
167 | TextureImage textur = new TextureImage(asset); | ||
168 | this.Textures.Add(textur.FullID, textur); | ||
169 | this._assetServer.UploadNewAsset(asset); | ||
170 | } | ||
171 | } | ||
172 | else | ||
173 | { | ||
174 | if (!this.Assets.ContainsKey(asset.FullID)) | ||
175 | { | ||
176 | AssetInfo assetInf = new AssetInfo(asset); | ||
177 | this.Assets.Add(assetInf.FullID, assetInf); | ||
178 | this._assetServer.UploadNewAsset(asset); | ||
179 | } | ||
180 | } | ||
181 | } | ||
182 | |||
183 | /// <summary> | ||
184 | /// | ||
185 | /// </summary> | ||
186 | private void ProcessTextureQueue() | ||
187 | { | ||
188 | if (this.TextureRequests.Count == 0) | ||
189 | { | ||
190 | //no requests waiting | ||
191 | return; | ||
192 | } | ||
193 | int num; | ||
194 | num = this.TextureRequests.Count; | ||
195 | |||
196 | AssetRequest req; | ||
197 | for (int i = 0; i < num; i++) | ||
198 | { | ||
199 | req = (AssetRequest)this.TextureRequests[i]; | ||
200 | if (!this.SendingTextures.ContainsKey(req.ImageInfo.FullID)) | ||
201 | { | ||
202 | TextureSender sender = new TextureSender(req); | ||
203 | sender.OnComplete += this.TextureSent; | ||
204 | lock (this.SendingTextures) | ||
205 | { | ||
206 | this.SendingTextures.Add(req.ImageInfo.FullID, sender); | ||
207 | } | ||
208 | } | ||
209 | |||
210 | } | ||
211 | |||
212 | this.TextureRequests.Clear(); | ||
213 | } | ||
214 | |||
215 | /// <summary> | ||
216 | /// Event handler, called by a TextureSender object to say that texture has been sent | ||
217 | /// </summary> | ||
218 | /// <param name="sender"></param> | ||
219 | public void TextureSent(AssetCache.TextureSender sender) | ||
220 | { | ||
221 | if (this.SendingTextures.ContainsKey(sender.request.ImageInfo.FullID)) | ||
222 | { | ||
223 | lock (this.SendingTextures) | ||
224 | { | ||
225 | this.SendingTextures.Remove(sender.request.ImageInfo.FullID); | ||
226 | } | ||
227 | } | ||
228 | } | ||
229 | |||
230 | public void AssetReceived(AssetBase asset, bool IsTexture) | ||
231 | { | ||
232 | if (asset.FullID != LLUUID.Zero) // if it is set to zero then the asset wasn't found by the server | ||
233 | { | ||
234 | //check if it is a texture or not | ||
235 | //then add to the correct cache list | ||
236 | //then check for waiting requests for this asset/texture (in the Requested lists) | ||
237 | //and move those requests into the Requests list. | ||
238 | if (IsTexture) | ||
239 | { | ||
240 | TextureImage image = new TextureImage(asset); | ||
241 | this.Textures.Add(image.FullID, image); | ||
242 | if (this.RequestedTextures.ContainsKey(image.FullID)) | ||
243 | { | ||
244 | AssetRequest req = this.RequestedTextures[image.FullID]; | ||
245 | req.ImageInfo = image; | ||
246 | if (image.Data.LongLength > 600) | ||
247 | { | ||
248 | //over 600 bytes so split up file | ||
249 | req.NumPackets = 1 + (int)(image.Data.Length - 600 + 999) / 1000; | ||
250 | } | ||
251 | else | ||
252 | { | ||
253 | req.NumPackets = 1; | ||
254 | } | ||
255 | this.RequestedTextures.Remove(image.FullID); | ||
256 | this.TextureRequests.Add(req); | ||
257 | } | ||
258 | } | ||
259 | else | ||
260 | { | ||
261 | AssetInfo assetInf = new AssetInfo(asset); | ||
262 | this.Assets.Add(assetInf.FullID, assetInf); | ||
263 | if (this.RequestedAssets.ContainsKey(assetInf.FullID)) | ||
264 | { | ||
265 | AssetRequest req = this.RequestedAssets[assetInf.FullID]; | ||
266 | req.AssetInf = assetInf; | ||
267 | if (assetInf.Data.LongLength > 600) | ||
268 | { | ||
269 | //over 600 bytes so split up file | ||
270 | req.NumPackets = 1 + (int)(assetInf.Data.Length - 600 + 999) / 1000; | ||
271 | } | ||
272 | else | ||
273 | { | ||
274 | req.NumPackets = 1; | ||
275 | } | ||
276 | this.RequestedAssets.Remove(assetInf.FullID); | ||
277 | this.AssetRequests.Add(req); | ||
278 | } | ||
279 | } | ||
280 | } | ||
281 | } | ||
282 | |||
283 | public void AssetNotFound(AssetBase asset) | ||
284 | { | ||
285 | //the asset server had no knowledge of requested asset | ||
286 | |||
287 | } | ||
288 | |||
289 | #region Assets | ||
290 | /// <summary> | ||
291 | /// | ||
292 | /// </summary> | ||
293 | /// <param name="userInfo"></param> | ||
294 | /// <param name="transferRequest"></param> | ||
295 | public void AddAssetRequest(IClientAPI userInfo, TransferRequestPacket transferRequest) | ||
296 | { | ||
297 | LLUUID requestID = new LLUUID(transferRequest.TransferInfo.Params, 0); | ||
298 | //check to see if asset is in local cache, if not we need to request it from asset server. | ||
299 | |||
300 | if (!this.Assets.ContainsKey(requestID)) | ||
301 | { | ||
302 | //not found asset | ||
303 | // so request from asset server | ||
304 | if (!this.RequestedAssets.ContainsKey(requestID)) | ||
305 | { | ||
306 | AssetRequest request = new AssetRequest(); | ||
307 | request.RequestUser = userInfo; | ||
308 | request.RequestAssetID = requestID; | ||
309 | request.TransferRequestID = transferRequest.TransferInfo.TransferID; | ||
310 | this.RequestedAssets.Add(requestID, request); | ||
311 | this._assetServer.RequestAsset(requestID, false); | ||
312 | } | ||
313 | return; | ||
314 | } | ||
315 | //it is in our cache | ||
316 | AssetInfo asset = this.Assets[requestID]; | ||
317 | |||
318 | //work out how many packets it should be sent in | ||
319 | // and add to the AssetRequests list | ||
320 | AssetRequest req = new AssetRequest(); | ||
321 | req.RequestUser = userInfo; | ||
322 | req.RequestAssetID = requestID; | ||
323 | req.TransferRequestID = transferRequest.TransferInfo.TransferID; | ||
324 | req.AssetInf = asset; | ||
325 | |||
326 | if (asset.Data.LongLength > 600) | ||
327 | { | ||
328 | //over 600 bytes so split up file | ||
329 | req.NumPackets = 1 + (int)(asset.Data.Length - 600 + 999) / 1000; | ||
330 | } | ||
331 | else | ||
332 | { | ||
333 | req.NumPackets = 1; | ||
334 | } | ||
335 | |||
336 | this.AssetRequests.Add(req); | ||
337 | } | ||
338 | |||
339 | /// <summary> | ||
340 | /// | ||
341 | /// </summary> | ||
342 | private void ProcessAssetQueue() | ||
343 | { | ||
344 | if (this.AssetRequests.Count == 0) | ||
345 | { | ||
346 | //no requests waiting | ||
347 | return; | ||
348 | } | ||
349 | int num; | ||
350 | |||
351 | if (this.AssetRequests.Count < 5) | ||
352 | { | ||
353 | //lower than 5 so do all of them | ||
354 | num = this.AssetRequests.Count; | ||
355 | } | ||
356 | else | ||
357 | { | ||
358 | num = 5; | ||
359 | } | ||
360 | AssetRequest req; | ||
361 | for (int i = 0; i < num; i++) | ||
362 | { | ||
363 | req = (AssetRequest)this.AssetRequests[i]; | ||
364 | |||
365 | TransferInfoPacket Transfer = new TransferInfoPacket(); | ||
366 | Transfer.TransferInfo.ChannelType = 2; | ||
367 | Transfer.TransferInfo.Status = 0; | ||
368 | Transfer.TransferInfo.TargetType = 0; | ||
369 | Transfer.TransferInfo.Params = req.RequestAssetID.GetBytes(); | ||
370 | Transfer.TransferInfo.Size = (int)req.AssetInf.Data.Length; | ||
371 | Transfer.TransferInfo.TransferID = req.TransferRequestID; | ||
372 | req.RequestUser.OutPacket(Transfer); | ||
373 | |||
374 | if (req.NumPackets == 1) | ||
375 | { | ||
376 | TransferPacketPacket TransferPacket = new TransferPacketPacket(); | ||
377 | TransferPacket.TransferData.Packet = 0; | ||
378 | TransferPacket.TransferData.ChannelType = 2; | ||
379 | TransferPacket.TransferData.TransferID = req.TransferRequestID; | ||
380 | TransferPacket.TransferData.Data = req.AssetInf.Data; | ||
381 | TransferPacket.TransferData.Status = 1; | ||
382 | req.RequestUser.OutPacket(TransferPacket); | ||
383 | } | ||
384 | else | ||
385 | { | ||
386 | //more than one packet so split file up , for now it can't be bigger than 2000 bytes | ||
387 | TransferPacketPacket TransferPacket = new TransferPacketPacket(); | ||
388 | TransferPacket.TransferData.Packet = 0; | ||
389 | TransferPacket.TransferData.ChannelType = 2; | ||
390 | TransferPacket.TransferData.TransferID = req.TransferRequestID; | ||
391 | byte[] chunk = new byte[1000]; | ||
392 | Array.Copy(req.AssetInf.Data, chunk, 1000); | ||
393 | TransferPacket.TransferData.Data = chunk; | ||
394 | TransferPacket.TransferData.Status = 0; | ||
395 | req.RequestUser.OutPacket(TransferPacket); | ||
396 | |||
397 | TransferPacket = new TransferPacketPacket(); | ||
398 | TransferPacket.TransferData.Packet = 1; | ||
399 | TransferPacket.TransferData.ChannelType = 2; | ||
400 | TransferPacket.TransferData.TransferID = req.TransferRequestID; | ||
401 | byte[] chunk1 = new byte[(req.AssetInf.Data.Length - 1000)]; | ||
402 | Array.Copy(req.AssetInf.Data, 1000, chunk1, 0, chunk1.Length); | ||
403 | TransferPacket.TransferData.Data = chunk1; | ||
404 | TransferPacket.TransferData.Status = 1; | ||
405 | req.RequestUser.OutPacket(TransferPacket); | ||
406 | } | ||
407 | |||
408 | } | ||
409 | |||
410 | //remove requests that have been completed | ||
411 | for (int i = 0; i < num; i++) | ||
412 | { | ||
413 | this.AssetRequests.RemoveAt(0); | ||
414 | } | ||
415 | |||
416 | } | ||
417 | |||
418 | public AssetInfo CloneAsset(LLUUID newOwner, AssetInfo sourceAsset) | ||
419 | { | ||
420 | AssetInfo newAsset = new AssetInfo(); | ||
421 | newAsset.Data = new byte[sourceAsset.Data.Length]; | ||
422 | Array.Copy(sourceAsset.Data, newAsset.Data, sourceAsset.Data.Length); | ||
423 | newAsset.FullID = LLUUID.Random(); | ||
424 | newAsset.Type = sourceAsset.Type; | ||
425 | newAsset.InvType = sourceAsset.InvType; | ||
426 | return (newAsset); | ||
427 | } | ||
428 | #endregion | ||
429 | |||
430 | #region Textures | ||
431 | /// <summary> | ||
432 | /// | ||
433 | /// </summary> | ||
434 | /// <param name="userInfo"></param> | ||
435 | /// <param name="imageID"></param> | ||
436 | public void AddTextureRequest(IClientAPI userInfo, LLUUID imageID) | ||
437 | { | ||
438 | //Console.WriteLine("texture request for " + imageID.ToStringHyphenated()); | ||
439 | //check to see if texture is in local cache, if not request from asset server | ||
440 | if (!this.Textures.ContainsKey(imageID)) | ||
441 | { | ||
442 | if (!this.RequestedTextures.ContainsKey(imageID)) | ||
443 | { | ||
444 | //not is cache so request from asset server | ||
445 | AssetRequest request = new AssetRequest(); | ||
446 | request.RequestUser = userInfo; | ||
447 | request.RequestAssetID = imageID; | ||
448 | request.IsTextureRequest = true; | ||
449 | this.RequestedTextures.Add(imageID, request); | ||
450 | this._assetServer.RequestAsset(imageID, true); | ||
451 | } | ||
452 | return; | ||
453 | } | ||
454 | |||
455 | //Console.WriteLine("texture already in cache"); | ||
456 | TextureImage imag = this.Textures[imageID]; | ||
457 | AssetRequest req = new AssetRequest(); | ||
458 | req.RequestUser = userInfo; | ||
459 | req.RequestAssetID = imageID; | ||
460 | req.IsTextureRequest = true; | ||
461 | req.ImageInfo = imag; | ||
462 | |||
463 | if (imag.Data.LongLength > 600) | ||
464 | { | ||
465 | //over 600 bytes so split up file | ||
466 | req.NumPackets = 1 + (int)(imag.Data.Length - 600 + 999) / 1000; | ||
467 | } | ||
468 | else | ||
469 | { | ||
470 | req.NumPackets = 1; | ||
471 | } | ||
472 | this.TextureRequests.Add(req); | ||
473 | } | ||
474 | |||
475 | public TextureImage CloneImage(LLUUID newOwner, TextureImage source) | ||
476 | { | ||
477 | TextureImage newImage = new TextureImage(); | ||
478 | newImage.Data = new byte[source.Data.Length]; | ||
479 | Array.Copy(source.Data, newImage.Data, source.Data.Length); | ||
480 | //newImage.filename = source.filename; | ||
481 | newImage.FullID = LLUUID.Random(); | ||
482 | newImage.Name = source.Name; | ||
483 | return (newImage); | ||
484 | } | ||
485 | #endregion | ||
486 | |||
487 | private IAssetServer LoadAssetDll(string dllName) | ||
488 | { | ||
489 | Assembly pluginAssembly = Assembly.LoadFrom(dllName); | ||
490 | IAssetServer server = null; | ||
491 | |||
492 | foreach (Type pluginType in pluginAssembly.GetTypes()) | ||
493 | { | ||
494 | if (pluginType.IsPublic) | ||
495 | { | ||
496 | if (!pluginType.IsAbstract) | ||
497 | { | ||
498 | Type typeInterface = pluginType.GetInterface("IAssetPlugin", true); | ||
499 | |||
500 | if (typeInterface != null) | ||
501 | { | ||
502 | IAssetPlugin plug = (IAssetPlugin)Activator.CreateInstance(pluginAssembly.GetType(pluginType.ToString())); | ||
503 | server = plug.GetAssetServer(); | ||
504 | break; | ||
505 | } | ||
506 | |||
507 | typeInterface = null; | ||
508 | } | ||
509 | } | ||
510 | } | ||
511 | pluginAssembly = null; | ||
512 | return server; | ||
513 | } | ||
514 | |||
515 | public class AssetRequest | ||
516 | { | ||
517 | public IClientAPI RequestUser; | ||
518 | public LLUUID RequestAssetID; | ||
519 | public AssetInfo AssetInf; | ||
520 | public TextureImage ImageInfo; | ||
521 | public LLUUID TransferRequestID; | ||
522 | public long DataPointer = 0; | ||
523 | public int NumPackets = 0; | ||
524 | public int PacketCounter = 0; | ||
525 | public bool IsTextureRequest; | ||
526 | //public bool AssetInCache; | ||
527 | //public int TimeRequested; | ||
528 | |||
529 | public AssetRequest() | ||
530 | { | ||
531 | |||
532 | } | ||
533 | } | ||
534 | |||
535 | public class AssetInfo : AssetBase | ||
536 | { | ||
537 | public AssetInfo() | ||
538 | { | ||
539 | |||
540 | } | ||
541 | |||
542 | public AssetInfo(AssetBase aBase) | ||
543 | { | ||
544 | Data = aBase.Data; | ||
545 | FullID = aBase.FullID; | ||
546 | Type = aBase.Type; | ||
547 | InvType = aBase.InvType; | ||
548 | Name = aBase.Name; | ||
549 | Description = aBase.Description; | ||
550 | } | ||
551 | } | ||
552 | |||
553 | public class TextureImage : AssetBase | ||
554 | { | ||
555 | public TextureImage() | ||
556 | { | ||
557 | |||
558 | } | ||
559 | |||
560 | public TextureImage(AssetBase aBase) | ||
561 | { | ||
562 | Data = aBase.Data; | ||
563 | FullID = aBase.FullID; | ||
564 | Type = aBase.Type; | ||
565 | InvType = aBase.InvType; | ||
566 | Name = aBase.Name; | ||
567 | Description = aBase.Description; | ||
568 | } | ||
569 | } | ||
570 | |||
571 | public class TextureSender | ||
572 | { | ||
573 | public AssetRequest request; | ||
574 | public event DownloadComplete OnComplete; | ||
575 | Thread m_thread; | ||
576 | public TextureSender(AssetRequest req) | ||
577 | { | ||
578 | request = req; | ||
579 | //Console.WriteLine("creating worker thread for texture " + req.ImageInfo.FullID.ToStringHyphenated()); | ||
580 | //Console.WriteLine("texture data length is " + req.ImageInfo.Data.Length); | ||
581 | // Console.WriteLine("in " + req.NumPackets + " packets"); | ||
582 | //ThreadPool.QueueUserWorkItem(new WaitCallback(SendTexture), new object()); | ||
583 | |||
584 | //need some sort of custom threadpool here, as using the .net one, overloads it and stops the handling of incoming packets etc | ||
585 | //but don't really want to create a thread for every texture download | ||
586 | m_thread = new Thread(new ThreadStart(SendTexture)); | ||
587 | m_thread.IsBackground = true; | ||
588 | m_thread.Start(); | ||
589 | } | ||
590 | |||
591 | public void SendTexture() | ||
592 | { | ||
593 | //Console.WriteLine("starting to send sending texture " + request.ImageInfo.FullID.ToStringHyphenated()); | ||
594 | while (request.PacketCounter != request.NumPackets) | ||
595 | { | ||
596 | SendPacket(); | ||
597 | Thread.Sleep(500); | ||
598 | } | ||
599 | |||
600 | //Console.WriteLine("finished sending texture " + request.ImageInfo.FullID.ToStringHyphenated()); | ||
601 | if (OnComplete != null) | ||
602 | { | ||
603 | OnComplete(this); | ||
604 | } | ||
605 | } | ||
606 | |||
607 | public void SendPacket() | ||
608 | { | ||
609 | AssetRequest req = request; | ||
610 | // Console.WriteLine("sending " + req.ImageInfo.FullID); | ||
611 | |||
612 | // if (req.ImageInfo.FullID == new LLUUID("00000000-0000-0000-5005-000000000005")) | ||
613 | if (req.PacketCounter == 0) | ||
614 | { | ||
615 | //first time for this request so send imagedata packet | ||
616 | if (req.NumPackets == 1) | ||
617 | { | ||
618 | //only one packet so send whole file | ||
619 | ImageDataPacket im = new ImageDataPacket(); | ||
620 | im.ImageID.Packets = 1; | ||
621 | im.ImageID.ID = req.ImageInfo.FullID; | ||
622 | im.ImageID.Size = (uint)req.ImageInfo.Data.Length; | ||
623 | im.ImageData.Data = req.ImageInfo.Data; | ||
624 | im.ImageID.Codec = 2; | ||
625 | req.RequestUser.OutPacket(im); | ||
626 | req.PacketCounter++; | ||
627 | //req.ImageInfo.l= time; | ||
628 | //System.Console.WriteLine("sent texture: " + req.ImageInfo.FullID); | ||
629 | // Console.WriteLine("sending packet 1 for " + req.ImageInfo.FullID.ToStringHyphenated()); | ||
630 | } | ||
631 | else | ||
632 | { | ||
633 | //more than one packet so split file up | ||
634 | ImageDataPacket im = new ImageDataPacket(); | ||
635 | im.ImageID.Packets = (ushort)req.NumPackets; | ||
636 | im.ImageID.ID = req.ImageInfo.FullID; | ||
637 | im.ImageID.Size = (uint)req.ImageInfo.Data.Length; | ||
638 | im.ImageData.Data = new byte[600]; | ||
639 | Array.Copy(req.ImageInfo.Data, 0, im.ImageData.Data, 0, 600); | ||
640 | im.ImageID.Codec = 2; | ||
641 | req.RequestUser.OutPacket(im); | ||
642 | req.PacketCounter++; | ||
643 | //req.ImageInfo.last_used = time; | ||
644 | //System.Console.WriteLine("sent first packet of texture: | ||
645 | // Console.WriteLine("sending packet 1 for " + req.ImageInfo.FullID.ToStringHyphenated()); | ||
646 | } | ||
647 | } | ||
648 | else | ||
649 | { | ||
650 | //Console.WriteLine("sending packet" + req.PacketCounter + "for " + req.ImageInfo.FullID.ToStringHyphenated()); | ||
651 | //send imagepacket | ||
652 | //more than one packet so split file up | ||
653 | ImagePacketPacket im = new ImagePacketPacket(); | ||
654 | im.ImageID.Packet = (ushort)req.PacketCounter; | ||
655 | im.ImageID.ID = req.ImageInfo.FullID; | ||
656 | int size = req.ImageInfo.Data.Length - 600 - 1000 * (req.PacketCounter - 1); | ||
657 | if (size > 1000) size = 1000; | ||
658 | im.ImageData.Data = new byte[size]; | ||
659 | Array.Copy(req.ImageInfo.Data, 600 + 1000 * (req.PacketCounter - 1), im.ImageData.Data, 0, size); | ||
660 | req.RequestUser.OutPacket(im); | ||
661 | req.PacketCounter++; | ||
662 | //req.ImageInfo.last_used = time; | ||
663 | //System.Console.WriteLine("sent a packet of texture: "+req.image_info.FullID); | ||
664 | } | ||
665 | |||
666 | } | ||
667 | } | ||
668 | } | ||
669 | } | ||
670 | |||
diff --git a/OpenSim/Region/Caches/OpenSim.Region.Caches.csproj b/OpenSim/Region/Caches/OpenSim.Region.Caches.csproj new file mode 100644 index 0000000..4a73d08 --- /dev/null +++ b/OpenSim/Region/Caches/OpenSim.Region.Caches.csproj | |||
@@ -0,0 +1,97 @@ | |||
1 | <Project DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> | ||
2 | <PropertyGroup> | ||
3 | <ProjectType>Local</ProjectType> | ||
4 | <ProductVersion>8.0.50727</ProductVersion> | ||
5 | <SchemaVersion>2.0</SchemaVersion> | ||
6 | <ProjectGuid>{61FCCDB3-0000-0000-0000-000000000000}</ProjectGuid> | ||
7 | <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> | ||
8 | <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> | ||
9 | <ApplicationIcon></ApplicationIcon> | ||
10 | <AssemblyKeyContainerName> | ||
11 | </AssemblyKeyContainerName> | ||
12 | <AssemblyName>OpenSim.Region.Caches</AssemblyName> | ||
13 | <DefaultClientScript>JScript</DefaultClientScript> | ||
14 | <DefaultHTMLPageLayout>Grid</DefaultHTMLPageLayout> | ||
15 | <DefaultTargetSchema>IE50</DefaultTargetSchema> | ||
16 | <DelaySign>false</DelaySign> | ||
17 | <OutputType>Library</OutputType> | ||
18 | <AppDesignerFolder></AppDesignerFolder> | ||
19 | <RootNamespace>OpenSim.Region.Caches</RootNamespace> | ||
20 | <StartupObject></StartupObject> | ||
21 | <FileUpgradeFlags> | ||
22 | </FileUpgradeFlags> | ||
23 | </PropertyGroup> | ||
24 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' "> | ||
25 | <AllowUnsafeBlocks>False</AllowUnsafeBlocks> | ||
26 | <BaseAddress>285212672</BaseAddress> | ||
27 | <CheckForOverflowUnderflow>False</CheckForOverflowUnderflow> | ||
28 | <ConfigurationOverrideFile> | ||
29 | </ConfigurationOverrideFile> | ||
30 | <DefineConstants>TRACE;DEBUG</DefineConstants> | ||
31 | <DocumentationFile></DocumentationFile> | ||
32 | <DebugSymbols>True</DebugSymbols> | ||
33 | <FileAlignment>4096</FileAlignment> | ||
34 | <Optimize>False</Optimize> | ||
35 | <OutputPath>..\..\..\bin\</OutputPath> | ||
36 | <RegisterForComInterop>False</RegisterForComInterop> | ||
37 | <RemoveIntegerChecks>False</RemoveIntegerChecks> | ||
38 | <TreatWarningsAsErrors>False</TreatWarningsAsErrors> | ||
39 | <WarningLevel>4</WarningLevel> | ||
40 | <NoWarn></NoWarn> | ||
41 | </PropertyGroup> | ||
42 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' "> | ||
43 | <AllowUnsafeBlocks>False</AllowUnsafeBlocks> | ||
44 | <BaseAddress>285212672</BaseAddress> | ||
45 | <CheckForOverflowUnderflow>False</CheckForOverflowUnderflow> | ||
46 | <ConfigurationOverrideFile> | ||
47 | </ConfigurationOverrideFile> | ||
48 | <DefineConstants>TRACE</DefineConstants> | ||
49 | <DocumentationFile></DocumentationFile> | ||
50 | <DebugSymbols>False</DebugSymbols> | ||
51 | <FileAlignment>4096</FileAlignment> | ||
52 | <Optimize>True</Optimize> | ||
53 | <OutputPath>..\..\..\bin\</OutputPath> | ||
54 | <RegisterForComInterop>False</RegisterForComInterop> | ||
55 | <RemoveIntegerChecks>False</RemoveIntegerChecks> | ||
56 | <TreatWarningsAsErrors>False</TreatWarningsAsErrors> | ||
57 | <WarningLevel>4</WarningLevel> | ||
58 | <NoWarn></NoWarn> | ||
59 | </PropertyGroup> | ||
60 | <ItemGroup> | ||
61 | <Reference Include="libsecondlife.dll" > | ||
62 | <HintPath>..\..\..\bin\libsecondlife.dll</HintPath> | ||
63 | <Private>False</Private> | ||
64 | </Reference> | ||
65 | <Reference Include="System" > | ||
66 | <HintPath>System.dll</HintPath> | ||
67 | <Private>False</Private> | ||
68 | </Reference> | ||
69 | <Reference Include="System.Xml" > | ||
70 | <HintPath>System.Xml.dll</HintPath> | ||
71 | <Private>False</Private> | ||
72 | </Reference> | ||
73 | </ItemGroup> | ||
74 | <ItemGroup> | ||
75 | <ProjectReference Include="..\..\Framework\General\OpenSim.Framework.csproj"> | ||
76 | <Name>OpenSim.Framework</Name> | ||
77 | <Project>{8ACA2445-0000-0000-0000-000000000000}</Project> | ||
78 | <Package>{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}</Package> | ||
79 | <Private>False</Private> | ||
80 | </ProjectReference> | ||
81 | </ItemGroup> | ||
82 | <ItemGroup> | ||
83 | <Compile Include="AssetCache.cs"> | ||
84 | <SubType>Code</SubType> | ||
85 | </Compile> | ||
86 | <Compile Include="Properties\AssemblyInfo.cs"> | ||
87 | <SubType>Code</SubType> | ||
88 | </Compile> | ||
89 | </ItemGroup> | ||
90 | <Import Project="$(MSBuildBinPath)\Microsoft.CSHARP.Targets" /> | ||
91 | <PropertyGroup> | ||
92 | <PreBuildEvent> | ||
93 | </PreBuildEvent> | ||
94 | <PostBuildEvent> | ||
95 | </PostBuildEvent> | ||
96 | </PropertyGroup> | ||
97 | </Project> | ||
diff --git a/OpenSim/Region/Caches/OpenSim.Region.Caches.csproj.user b/OpenSim/Region/Caches/OpenSim.Region.Caches.csproj.user new file mode 100644 index 0000000..6841907 --- /dev/null +++ b/OpenSim/Region/Caches/OpenSim.Region.Caches.csproj.user | |||
@@ -0,0 +1,12 @@ | |||
1 | <Project xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> | ||
2 | <PropertyGroup> | ||
3 | <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> | ||
4 | <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> | ||
5 | <ReferencePath>C:\New Folder\second-life-viewer\opensim-dailys2\opensim15-06\NameSpaceChanges\bin\</ReferencePath> | ||
6 | <LastOpenVersion>8.0.50727</LastOpenVersion> | ||
7 | <ProjectView>ProjectFiles</ProjectView> | ||
8 | <ProjectTrust>0</ProjectTrust> | ||
9 | </PropertyGroup> | ||
10 | <PropertyGroup Condition = " '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' " /> | ||
11 | <PropertyGroup Condition = " '$(Configuration)|$(Platform)' == 'Release|AnyCPU' " /> | ||
12 | </Project> | ||
diff --git a/OpenSim/Region/Caches/Properties/AssemblyInfo.cs b/OpenSim/Region/Caches/Properties/AssemblyInfo.cs new file mode 100644 index 0000000..00f5dfe --- /dev/null +++ b/OpenSim/Region/Caches/Properties/AssemblyInfo.cs | |||
@@ -0,0 +1,35 @@ | |||
1 | using System.Reflection; | ||
2 | using System.Runtime.CompilerServices; | ||
3 | using System.Runtime.InteropServices; | ||
4 | |||
5 | // General Information about an assembly is controlled through the following | ||
6 | // set of attributes. Change these attribute values to modify the information | ||
7 | // associated with an assembly. | ||
8 | [assembly: AssemblyTitle("OpenSim.Caches")] | ||
9 | [assembly: AssemblyDescription("")] | ||
10 | [assembly: AssemblyConfiguration("")] | ||
11 | [assembly: AssemblyCompany("")] | ||
12 | [assembly: AssemblyProduct("OpenSim.Caches")] | ||
13 | [assembly: AssemblyCopyright("Copyright © 2007")] | ||
14 | [assembly: AssemblyTrademark("")] | ||
15 | [assembly: AssemblyCulture("")] | ||
16 | |||
17 | // Setting ComVisible to false makes the types in this assembly not visible | ||
18 | // to COM components. If you need to access a type in this assembly from | ||
19 | // COM, set the ComVisible attribute to true on that type. | ||
20 | [assembly: ComVisible(false)] | ||
21 | |||
22 | // The following GUID is for the ID of the typelib if this project is exposed to COM | ||
23 | [assembly: Guid("2b15ddbf-0341-49a6-85c0-cece268a4518")] | ||
24 | |||
25 | // Version information for an assembly consists of the following four values: | ||
26 | // | ||
27 | // Major Version | ||
28 | // Minor Version | ||
29 | // Build Number | ||
30 | // Revision | ||
31 | // | ||
32 | // You can specify all the values or you can default the Revision and Build Numbers | ||
33 | // by using the '*' as shown below: | ||
34 | [assembly: AssemblyVersion("1.0.0.0")] | ||
35 | [assembly: AssemblyFileVersion("1.0.0.0")] | ||