OpenSim
/
OpenSimMirror
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Think I've recovered my deleted files, so hopefully it works now.

afrisby
MW 2007-07-22 13:31:08 +00:00
parent 70fa302042
commit 276011a0a1
7 changed files with 1356 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

561
OpenSim/Framework/Communications/Cache/AssetCache.cs Normal file
View File

@ -0,0 +1,561 @@
/*
* Copyright (c) Contributors, http://www.openmetaverse.org/
* See CONTRIBUTORS.TXT for a full list of copyright holders.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* * Neither the name of the OpenSim Project nor the
* names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*/
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.Reflection;
using System.Threading;
using libsecondlife;
using libsecondlife.Packets;
using OpenSim.Framework.Interfaces;
using OpenSim.Framework.Servers;
using OpenSim.Framework.Types;
using OpenSim.Framework.Utilities;
namespace OpenSim.Framework.Communications.Caches
{
public delegate void DownloadComplete(AssetCache.TextureSender sender);
public class AssetCache : IAssetReceiver
{
// Fields
private Thread _assetCacheThread;
private IAssetServer _assetServer;
public List<AssetRequest> AssetRequests;
public Dictionary<LLUUID, AssetInfo> Assets;
public Dictionary<LLUUID, AssetRequest> RequestedAssets;
public Dictionary<LLUUID, AssetRequest> RequestedTextures;
public Dictionary<LLUUID, TextureSender> SendingTextures;
private LLUUID[] textureList;
public List<AssetRequest> TextureRequests;
public Dictionary<LLUUID, TextureImage> Textures;
// Methods
public AssetCache(IAssetServer assetServer)
{
this.AssetRequests = new List<AssetRequest>();
this.TextureRequests = new List<AssetRequest>();
this.RequestedAssets = new Dictionary<LLUUID, AssetRequest>();
this.RequestedTextures = new Dictionary<LLUUID, AssetRequest>();
this.SendingTextures = new Dictionary<LLUUID, TextureSender>();
this.textureList = new LLUUID[5];
Console.WriteLine("Creating Asset cache");
this._assetServer = assetServer;
this._assetServer.SetReceiver(this);
this.Assets = new Dictionary<LLUUID, AssetInfo>();
this.Textures = new Dictionary<LLUUID, TextureImage>();
this._assetCacheThread = new Thread(new ThreadStart(this.RunAssetManager));
this._assetCacheThread.IsBackground = true;
this._assetCacheThread.Start();
}
public AssetCache(string assetServerDLLName, string assetServerURL, string assetServerKey)
{
this.AssetRequests = new List<AssetRequest>();
this.TextureRequests = new List<AssetRequest>();
this.RequestedAssets = new Dictionary<LLUUID, AssetRequest>();
this.RequestedTextures = new Dictionary<LLUUID, AssetRequest>();
this.SendingTextures = new Dictionary<LLUUID, TextureSender>();
this.textureList = new LLUUID[5];
Console.WriteLine("Creating Asset cache");
this._assetServer = this.LoadAssetDll(assetServerDLLName);
this._assetServer.SetServerInfo(assetServerURL, assetServerKey);
this._assetServer.SetReceiver(this);
this.Assets = new Dictionary<LLUUID, AssetInfo>();
this.Textures = new Dictionary<LLUUID, TextureImage>();
this._assetCacheThread = new Thread(new ThreadStart(this.RunAssetManager));
this._assetCacheThread.IsBackground = true;
this._assetCacheThread.Start();
}
public void AddAsset(AssetBase asset)
{
if (asset.Type == 0)
{
if (!this.Textures.ContainsKey(asset.FullID))
{
TextureImage image = new TextureImage(asset);
this.Textures.Add(image.FullID, image);
this._assetServer.UploadNewAsset(asset);
}
}
else if (!this.Assets.ContainsKey(asset.FullID))
{
AssetInfo info = new AssetInfo(asset);
this.Assets.Add(info.FullID, info);
this._assetServer.UploadNewAsset(asset);
}
}
public void AddAssetRequest(IClientAPI userInfo, TransferRequestPacket transferRequest)
{
LLUUID assetID = new LLUUID(transferRequest.TransferInfo.Params, 0);
if (!this.Assets.ContainsKey(assetID))
{
if (!this.RequestedAssets.ContainsKey(assetID))
{
AssetRequest request = new AssetRequest();
request.RequestUser = userInfo;
request.RequestAssetID = assetID;
request.TransferRequestID = transferRequest.TransferInfo.TransferID;
this.RequestedAssets.Add(assetID, request);
this._assetServer.RequestAsset(assetID, false);
}
}
else
{
AssetInfo info = this.Assets[assetID];
AssetRequest request2 = new AssetRequest();
request2.RequestUser = userInfo;
request2.RequestAssetID = assetID;
request2.TransferRequestID = transferRequest.TransferInfo.TransferID;
request2.AssetInf = info;
if (info.Data.LongLength > 600)
{
request2.NumPackets = 1 + (((info.Data.Length - 600) + 0x3e7) / 0x3e8);
}
else
{
request2.NumPackets = 1;
}
this.AssetRequests.Add(request2);
}
}
public void AddTextureRequest(IClientAPI userInfo, LLUUID imageID)
{
if (!this.Textures.ContainsKey(imageID))
{
if (!this.RequestedTextures.ContainsKey(imageID))
{
AssetRequest request = new AssetRequest();
request.RequestUser = userInfo;
request.RequestAssetID = imageID;
request.IsTextureRequest = true;
this.RequestedTextures.Add(imageID, request);
this._assetServer.RequestAsset(imageID, true);
}
}
else
{
TextureImage image = this.Textures[imageID];
AssetRequest request2 = new AssetRequest();
request2.RequestUser = userInfo;
request2.RequestAssetID = imageID;
request2.IsTextureRequest = true;
request2.ImageInfo = image;
if (image.Data.LongLength > 600)
{
request2.NumPackets = 1 + (((image.Data.Length - 600) + 0x3e7) / 0x3e8);
}
else
{
request2.NumPackets = 1;
}
this.TextureRequests.Add(request2);
}
}
public void AssetNotFound(AssetBase asset)
{
}
public void AssetReceived(AssetBase asset, bool IsTexture)
{
if (asset.FullID != LLUUID.Zero)
{
if (IsTexture)
{
TextureImage image = new TextureImage(asset);
this.Textures.Add(image.FullID, image);
if (this.RequestedTextures.ContainsKey(image.FullID))
{
AssetRequest request = this.RequestedTextures[image.FullID];
request.ImageInfo = image;
if (image.Data.LongLength > 600)
{
request.NumPackets = 1 + (((image.Data.Length - 600) + 0x3e7) / 0x3e8);
}
else
{
request.NumPackets = 1;
}
this.RequestedTextures.Remove(image.FullID);
this.TextureRequests.Add(request);
}
}
else
{
AssetInfo info = new AssetInfo(asset);
this.Assets.Add(info.FullID, info);
if (this.RequestedAssets.ContainsKey(info.FullID))
{
AssetRequest request2 = this.RequestedAssets[info.FullID];
request2.AssetInf = info;
if (info.Data.LongLength > 600)
{
request2.NumPackets = 1 + (((info.Data.Length - 600) + 0x3e7) / 0x3e8);
}
else
{
request2.NumPackets = 1;
}
this.RequestedAssets.Remove(info.FullID);
this.AssetRequests.Add(request2);
}
}
}
}
public AssetInfo CloneAsset(LLUUID newOwner, AssetInfo sourceAsset)
{
AssetInfo info = new AssetInfo();
info.Data = new byte[sourceAsset.Data.Length];
Array.Copy(sourceAsset.Data, info.Data, sourceAsset.Data.Length);
info.FullID = LLUUID.Random();
info.Type = sourceAsset.Type;
info.InvType = sourceAsset.InvType;
return info;
}
public TextureImage CloneImage(LLUUID newOwner, TextureImage source)
{
TextureImage image = new TextureImage();
image.Data = new byte[source.Data.Length];
Array.Copy(source.Data, image.Data, source.Data.Length);
image.FullID = LLUUID.Random();
image.Name = source.Name;
return image;
}
public AssetBase[] CreateNewInventorySet(LLUUID agentID)
{
AssetBase[] baseArray = new AssetBase[this.textureList.Length];
for (int i = 0; i < this.textureList.Length; i++)
{
if (this.Textures.ContainsKey(this.textureList[i]))
{
baseArray[i] = this.CloneImage(agentID, this.Textures[this.textureList[i]]);
TextureImage asset = new TextureImage(baseArray[i]);
this.Textures.Add(asset.FullID, asset);
this._assetServer.UploadNewAsset(asset);
}
}
return baseArray;
}
public AssetBase GetAsset(LLUUID assetID)
{
AssetBase base2 = null;
if (this.Textures.ContainsKey(assetID))
{
return this.Textures[assetID];
}
if (this.Assets.ContainsKey(assetID))
{
base2 = this.Assets[assetID];
}
return base2;
}
private IAssetServer LoadAssetDll(string dllName)
{
Assembly assembly = Assembly.LoadFrom(dllName);
IAssetServer assetServer = null;
foreach (Type type in assembly.GetTypes())
{
if (type.IsPublic && !type.IsAbstract)
{
if (type.GetInterface("IAssetPlugin", true) != null)
{
assetServer = ((IAssetPlugin)Activator.CreateInstance(assembly.GetType(type.ToString()))).GetAssetServer();
break;
}
}
}
assembly = null;
return assetServer;
}
public void LoadDefaultTextureSet()
{
this.textureList[0] = new LLUUID("00000000-0000-0000-9999-000000000001");
this.textureList[1] = new LLUUID("00000000-0000-0000-9999-000000000002");
this.textureList[2] = new LLUUID("00000000-0000-0000-9999-000000000003");
this.textureList[3] = new LLUUID("00000000-0000-0000-9999-000000000004");
this.textureList[4] = new LLUUID("00000000-0000-0000-9999-000000000005");
for (int i = 0; i < this.textureList.Length; i++)
{
this._assetServer.RequestAsset(this.textureList[i], true);
}
}
private void ProcessAssetQueue()
{
if (this.AssetRequests.Count != 0)
{
int num;
if (this.AssetRequests.Count < 5)
{
num = this.AssetRequests.Count;
}
else
{
num = 5;
}
for (int i = 0; i < num; i++)
{
AssetRequest request = this.AssetRequests[i];
TransferInfoPacket newPack = new TransferInfoPacket();
newPack.TransferInfo.ChannelType = 2;
newPack.TransferInfo.Status = 0;
newPack.TransferInfo.TargetType = 0;
newPack.TransferInfo.Params = request.RequestAssetID.GetBytes();
newPack.TransferInfo.Size = request.AssetInf.Data.Length;
newPack.TransferInfo.TransferID = request.TransferRequestID;
request.RequestUser.OutPacket(newPack);
if (request.NumPackets == 1)
{
TransferPacketPacket packet2 = new TransferPacketPacket();
packet2.TransferData.Packet = 0;
packet2.TransferData.ChannelType = 2;
packet2.TransferData.TransferID = request.TransferRequestID;
packet2.TransferData.Data = request.AssetInf.Data;
packet2.TransferData.Status = 1;
request.RequestUser.OutPacket(packet2);
}
else
{
TransferPacketPacket packet3 = new TransferPacketPacket();
packet3.TransferData.Packet = 0;
packet3.TransferData.ChannelType = 2;
packet3.TransferData.TransferID = request.TransferRequestID;
byte[] destinationArray = new byte[0x3e8];
Array.Copy(request.AssetInf.Data, destinationArray, 0x3e8);
packet3.TransferData.Data = destinationArray;
packet3.TransferData.Status = 0;
request.RequestUser.OutPacket(packet3);
packet3 = new TransferPacketPacket();
packet3.TransferData.Packet = 1;
packet3.TransferData.ChannelType = 2;
packet3.TransferData.TransferID = request.TransferRequestID;
byte[] buffer2 = new byte[request.AssetInf.Data.Length - 0x3e8];
Array.Copy(request.AssetInf.Data, 0x3e8, buffer2, 0, buffer2.Length);
packet3.TransferData.Data = buffer2;
packet3.TransferData.Status = 1;
request.RequestUser.OutPacket(packet3);
}
}
for (int j = 0; j < num; j++)
{
this.AssetRequests.RemoveAt(0);
}
}
}
private void ProcessTextureQueue()
{
if (this.TextureRequests.Count != 0)
{
int num = this.TextureRequests.Count;
for (int i = 0; i < num; i++)
{
AssetRequest req = this.TextureRequests[i];
if (!this.SendingTextures.ContainsKey(req.ImageInfo.FullID))
{
TextureSender sender = new TextureSender(req);
sender.OnComplete += new DownloadComplete(this.TextureSent);
lock (this.SendingTextures)
{
this.SendingTextures.Add(req.ImageInfo.FullID, sender);
}
}
}
this.TextureRequests.Clear();
}
}
public void RunAssetManager()
{
Label_0000:
try
{
this.ProcessAssetQueue();
this.ProcessTextureQueue();
Thread.Sleep(500);
goto Label_0000;
}
catch (Exception exception)
{
Console.WriteLine(exception.Message);
goto Label_0000;
}
}
public void TextureSent(TextureSender sender)
{
if (this.SendingTextures.ContainsKey(sender.request.ImageInfo.FullID))
{
lock (this.SendingTextures)
{
this.SendingTextures.Remove(sender.request.ImageInfo.FullID);
}
}
}
// Nested Types
public class AssetInfo : AssetBase
{
// Methods
public AssetInfo()
{
}
public AssetInfo(AssetBase aBase)
{
base.Data = aBase.Data;
base.FullID = aBase.FullID;
base.Type = aBase.Type;
base.InvType = aBase.InvType;
base.Name = aBase.Name;
base.Description = aBase.Description;
}
}
public class AssetRequest
{
// Fields
public AssetCache.AssetInfo AssetInf;
public long DataPointer;
public AssetCache.TextureImage ImageInfo;
public bool IsTextureRequest;
public int NumPackets;
public int PacketCounter;
public LLUUID RequestAssetID;
public IClientAPI RequestUser;
public LLUUID TransferRequestID;
}
public class TextureImage : AssetBase
{
// Methods
public TextureImage()
{
}
public TextureImage(AssetBase aBase)
{
base.Data = aBase.Data;
base.FullID = aBase.FullID;
base.Type = aBase.Type;
base.InvType = aBase.InvType;
base.Name = aBase.Name;
base.Description = aBase.Description;
}
}
public class TextureSender
{
// Fields
private Thread m_thread;
public AssetCache.AssetRequest request;
// Events
public event DownloadComplete OnComplete;
// Methods
public TextureSender(AssetCache.AssetRequest req)
{
this.request = req;
this.m_thread = new Thread(new ThreadStart(this.SendTexture));
this.m_thread.IsBackground = true;
this.m_thread.Start();
}
public void SendPacket()
{
AssetCache.AssetRequest request = this.request;
if (request.PacketCounter == 0)
{
if (request.NumPackets == 1)
{
ImageDataPacket newPack = new ImageDataPacket();
newPack.ImageID.Packets = 1;
newPack.ImageID.ID = request.ImageInfo.FullID;
newPack.ImageID.Size = (uint)request.ImageInfo.Data.Length;
newPack.ImageData.Data = request.ImageInfo.Data;
newPack.ImageID.Codec = 2;
request.RequestUser.OutPacket(newPack);
request.PacketCounter++;
}
else
{
ImageDataPacket packet2 = new ImageDataPacket();
packet2.ImageID.Packets = (ushort)request.NumPackets;
packet2.ImageID.ID = request.ImageInfo.FullID;
packet2.ImageID.Size = (uint)request.ImageInfo.Data.Length;
packet2.ImageData.Data = new byte[600];
Array.Copy(request.ImageInfo.Data, 0, packet2.ImageData.Data, 0, 600);
packet2.ImageID.Codec = 2;
request.RequestUser.OutPacket(packet2);
request.PacketCounter++;
}
}
else
{
ImagePacketPacket packet3 = new ImagePacketPacket();
packet3.ImageID.Packet = (ushort)request.PacketCounter;
packet3.ImageID.ID = request.ImageInfo.FullID;
int length = (request.ImageInfo.Data.Length - 600) - (0x3e8 * (request.PacketCounter - 1));
if (length > 0x3e8)
{
length = 0x3e8;
}
packet3.ImageData.Data = new byte[length];
Array.Copy(request.ImageInfo.Data, 600 + (0x3e8 * (request.PacketCounter - 1)), packet3.ImageData.Data, 0, length);
request.RequestUser.OutPacket(packet3);
request.PacketCounter++;
}
}
public void SendTexture()
{
while (this.request.PacketCounter != this.request.NumPackets)
{
this.SendPacket();
Thread.Sleep(500);
}
if (this.OnComplete != null)
{
this.OnComplete(this);
}
}
}
}
}

81
OpenSim/Framework/Communications/Cache/AssetTransactionManager.cs Normal file
View File

@ -0,0 +1,81 @@
/*
* Copyright (c) Contributors, http://www.openmetaverse.org/
* See CONTRIBUTORS.TXT for a full list of copyright holders.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* * Neither the name of the OpenSim Project nor the
* names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*/
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.IO;
using libsecondlife;
using OpenSim.Framework.Interfaces;
using OpenSim.Framework.Types;
using OpenSim.Framework.Utilities;
using OpenSim.Framework.Data;
namespace OpenSim.Framework.Communications.Caches
{
public class AssetTransactionManager
{
// Fields
public Dictionary<LLUUID, AgentAssetTransactions> AgentTransactions = new Dictionary<LLUUID, AgentAssetTransactions>();
// Methods
public AgentAssetTransactions AddUser(LLUUID userID)
{
if (!this.AgentTransactions.ContainsKey(userID))
{
AgentAssetTransactions transactions = new AgentAssetTransactions(userID);
this.AgentTransactions.Add(userID, transactions);
return transactions;
}
return null;
}
public AgentAssetTransactions GetUserTransActions(LLUUID userID)
{
if (this.AgentTransactions.ContainsKey(userID))
{
return this.AgentTransactions[userID];
}
return null;
}
public void HandleInventoryFromTransaction()
{
}
public void HandleUDPUploadRequest()
{
}
public void HandleXfer(IClientAPI remoteClient, uint xferID, uint packetID, byte[] data)
{
}
}
}

275
OpenSim/Framework/Communications/Cache/AssetTransactions.cs Normal file
View File

@ -0,0 +1,275 @@
/*
* Copyright (c) Contributors, http://www.openmetaverse.org/
* See CONTRIBUTORS.TXT for a full list of copyright holders.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* * Neither the name of the OpenSim Project nor the
* names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*/
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.IO;
using libsecondlife;
using libsecondlife.Packets;
using OpenSim.Framework.Interfaces;
using OpenSim.Framework.Types;
using OpenSim.Framework.Utilities;
using OpenSim.Region.Capabilities;
using OpenSim.Framework.Servers;
namespace OpenSim.Framework.Communications.Caches
{
public class AgentAssetTransactions
{
// Fields
public List<AssetCapsUploader> CapsUploaders = new List<AssetCapsUploader>();
public List<NoteCardCapsUpdate> NotecardUpdaters = new List<NoteCardCapsUpdate>();
public LLUUID UserID;
public Dictionary<LLUUID, AssetXferUploader> XferUploaders = new Dictionary<LLUUID, AssetXferUploader>();
// Methods
public AgentAssetTransactions(LLUUID agentID)
{
this.UserID = agentID;
}
public AssetCapsUploader RequestCapsUploader()
{
AssetCapsUploader uploader = new AssetCapsUploader();
this.CapsUploaders.Add(uploader);
return uploader;
}
public NoteCardCapsUpdate RequestNoteCardUpdater()
{
NoteCardCapsUpdate update = new NoteCardCapsUpdate();
this.NotecardUpdaters.Add(update);
return update;
}
public AssetXferUploader RequestXferUploader(LLUUID transactionID)
{
AssetXferUploader uploader = new AssetXferUploader();
this.XferUploaders.Add(transactionID, uploader);
return uploader;
}
// Nested Types
public class AssetCapsUploader
{
// Fields
private BaseHttpServer httpListener;
private LLUUID inventoryItemID;
private string m_assetDescription = "";
private string m_assetName = "";
private LLUUID m_folderID;
private LLUUID newAssetID;
private bool SaveImages;
private string uploaderPath = "";
// Events
public event UpLoadedTexture OnUpLoad;
// Methods
public void Initialise(string assetName, string assetDescription, LLUUID assetID, LLUUID inventoryItem, LLUUID folderID, string path, BaseHttpServer httpServer)
{
this.m_assetName = assetName;
this.m_assetDescription = assetDescription;
this.m_folderID = folderID;
this.newAssetID = assetID;
this.inventoryItemID = inventoryItem;
this.uploaderPath = path;
this.httpListener = httpServer;
}
private void SaveImageToFile(string filename, byte[] data)
{
FileStream output = File.Create(filename);
BinaryWriter writer = new BinaryWriter(output);
writer.Write(data);
writer.Close();
output.Close();
}
public string uploaderCaps(byte[] data, string path, string param)
{
LLUUID inventoryItemID = this.inventoryItemID;
string text = "";
LLSDAssetUploadComplete complete = new LLSDAssetUploadComplete();
complete.new_asset = this.newAssetID.ToStringHyphenated();
complete.new_inventory_item = inventoryItemID;
complete.state = "complete";
text = LLSDHelpers.SerialiseLLSDReply(complete);
this.httpListener.RemoveStreamHandler("POST", this.uploaderPath);
if (this.SaveImages)
{
this.SaveImageToFile(this.m_assetName + ".jp2", data);
}
if (this.OnUpLoad != null)
{
this.OnUpLoad(this.m_assetName, this.newAssetID, inventoryItemID, data);
}
return text;
}
}
public class AssetXferUploader
{
// Fields
public bool AddToInventory;
public AssetBase Asset;
public LLUUID InventFolder = LLUUID.Zero;
private IClientAPI ourClient;
public LLUUID TransactionID = LLUUID.Zero;
public bool UploadComplete;
public uint XferID;
// Methods
public void HandleXferPacket(uint xferID, uint packetID, byte[] data)
{
if (this.XferID == xferID)
{
if (this.Asset.Data.Length > 1)
{
byte[] destinationArray = new byte[this.Asset.Data.Length + data.Length];
Array.Copy(this.Asset.Data, 0, destinationArray, 0, this.Asset.Data.Length);
Array.Copy(data, 0, destinationArray, this.Asset.Data.Length, data.Length);
this.Asset.Data = destinationArray;
}
else
{
byte[] buffer2 = new byte[data.Length - 4];
Array.Copy(data, 4, buffer2, 0, data.Length - 4);
this.Asset.Data = buffer2;
}
ConfirmXferPacketPacket newPack = new ConfirmXferPacketPacket();
newPack.XferID.ID = xferID;
newPack.XferID.Packet = packetID;
this.ourClient.OutPacket(newPack);
if ((packetID & 0x80000000) != 0)
{
this.SendCompleteMessage();
}
}
}
public void Initialise(IClientAPI remoteClient, LLUUID assetID, LLUUID transaction, sbyte type, byte[] data)
{
this.ourClient = remoteClient;
this.Asset = new AssetBase();
this.Asset.FullID = assetID;
this.Asset.InvType = type;
this.Asset.Type = type;
this.Asset.Data = data;
this.Asset.Name = "blank";
this.Asset.Description = "empty";
this.TransactionID = transaction;
if (this.Asset.Data.Length > 2)
{
this.SendCompleteMessage();
}
else
{
this.ReqestStartXfer();
}
}
protected void ReqestStartXfer()
{
this.UploadComplete = false;
this.XferID = Util.GetNextXferID();
RequestXferPacket newPack = new RequestXferPacket();
newPack.XferID.ID = this.XferID;
newPack.XferID.VFileType = this.Asset.Type;
newPack.XferID.VFileID = this.Asset.FullID;
newPack.XferID.FilePath = 0;
newPack.XferID.Filename = new byte[0];
this.ourClient.OutPacket(newPack);
}
protected void SendCompleteMessage()
{
this.UploadComplete = true;
AssetUploadCompletePacket newPack = new AssetUploadCompletePacket();
newPack.AssetBlock.Type = this.Asset.Type;
newPack.AssetBlock.Success = true;
newPack.AssetBlock.UUID = this.Asset.FullID;
this.ourClient.OutPacket(newPack);
}
}
public class NoteCardCapsUpdate
{
// Fields
private BaseHttpServer httpListener;
private LLUUID inventoryItemID;
private string m_assetName = "";
private LLUUID newAssetID;
private bool SaveImages;
private string uploaderPath = "";
// Events
public event UpLoadedTexture OnUpLoad;
// Methods
public void Initialise(LLUUID inventoryItem, string path, BaseHttpServer httpServer)
{
this.inventoryItemID = inventoryItem;
this.uploaderPath = path;
this.httpListener = httpServer;
this.newAssetID = LLUUID.Random();
}
private void SaveImageToFile(string filename, byte[] data)
{
FileStream output = File.Create(filename);
BinaryWriter writer = new BinaryWriter(output);
writer.Write(data);
writer.Close();
output.Close();
}
public string uploaderCaps(byte[] data, string path, string param)
{
LLUUID inventoryItemID = this.inventoryItemID;
string text = "";
LLSDAssetUploadComplete complete = new LLSDAssetUploadComplete();
complete.new_asset = this.newAssetID.ToStringHyphenated();
complete.new_inventory_item = inventoryItemID;
complete.state = "complete";
text = LLSDHelpers.SerialiseLLSDReply(complete);
this.httpListener.RemoveStreamHandler("POST", this.uploaderPath);
if (this.SaveImages)
{
this.SaveImageToFile(this.m_assetName + "notecard.txt", data);
}
if (this.OnUpLoad != null)
{
this.OnUpLoad(this.m_assetName, this.newAssetID, inventoryItemID, data);
}
return text;
}
}
}
}

94
OpenSim/Framework/Communications/Cache/CachedUserInfo.cs Normal file
View File

@ -0,0 +1,94 @@
/*
* Copyright (c) Contributors, http://www.openmetaverse.org/
* See CONTRIBUTORS.TXT for a full list of copyright holders.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* * Neither the name of the OpenSim Project nor the
* names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*/
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.IO;
using libsecondlife;
using OpenSim.Framework.Interfaces;
using OpenSim.Framework.Types;
using OpenSim.Framework.Data;
using OpenSim.Framework.Utilities;
namespace OpenSim.Framework.Communications.Caches
{
public class CachedUserInfo
{
// Fields
public InventoryFolder RootFolder;
public UserProfileData UserProfile;
// Methods
public void FolderReceive(LLUUID userID, InventoryFolder folderInfo)
{
if (userID == this.UserProfile.UUID)
{
if (this.RootFolder == null)
{
if (folderInfo.parentID == LLUUID.Zero)
{
this.RootFolder = folderInfo;
}
}
else if (this.RootFolder.folderID == folderInfo.parentID)
{
this.RootFolder.SubFolders.Add(folderInfo.folderID, folderInfo);
}
else
{
InventoryFolder folder = this.RootFolder.HasSubFolder(folderInfo.parentID);
if (folder != null)
{
folder.SubFolders.Add(folderInfo.folderID, folderInfo);
}
}
}
}
public void ItemReceive(LLUUID userID, InventoryItemBase itemInfo)
{
if ((userID == this.UserProfile.UUID) && (this.RootFolder != null))
{
if (itemInfo.parentFolderID == this.RootFolder.folderID)
{
this.RootFolder.Items.Add(itemInfo.inventoryID, itemInfo);
}
else
{
InventoryFolder folder = this.RootFolder.HasSubFolder(itemInfo.parentFolderID);
if (folder != null)
{
folder.Items.Add(itemInfo.inventoryID, itemInfo);
}
}
}
}
}
}

109
OpenSim/Framework/Communications/Cache/InventoryFolder.cs Normal file
View File

@ -0,0 +1,109 @@
/*
* Copyright (c) Contributors, http://www.openmetaverse.org/
* See CONTRIBUTORS.TXT for a full list of copyright holders.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* * Neither the name of the OpenSim Project nor the
* names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*/
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.IO;
using libsecondlife;
using OpenSim.Framework.Interfaces;
using OpenSim.Framework.Data;
using OpenSim.Framework.Types;
using OpenSim.Framework.Utilities;
namespace OpenSim.Framework.Communications.Caches
{
public class InventoryFolder : InventoryFolderBase
{
// Fields
public Dictionary<LLUUID, InventoryItemBase> Items = new Dictionary<LLUUID, InventoryItemBase>();
public Dictionary<LLUUID, InventoryFolder> SubFolders = new Dictionary<LLUUID, InventoryFolder>();
// Methods
public InventoryFolder CreateNewSubFolder(LLUUID folderID, string folderName, ushort type)
{
InventoryFolder subFold = new InventoryFolder();
subFold.name = folderName;
subFold.folderID = folderID;
subFold.type = type;
subFold.parentID = this.folderID;
subFold.agentID = this.agentID;
this.SubFolders.Add(subFold.folderID, subFold);
return subFold;
}
public InventoryItemBase HasItem(LLUUID itemID)
{
InventoryItemBase base2 = null;
if (this.Items.ContainsKey(itemID))
{
return this.Items[itemID];
}
foreach (InventoryFolder folder in this.SubFolders.Values)
{
base2 = folder.HasItem(itemID);
if (base2 != null)
{
break;
}
}
return base2;
}
public InventoryFolder HasSubFolder(LLUUID folderID)
{
InventoryFolder returnFolder = null;
if (this.SubFolders.ContainsKey(folderID))
{
returnFolder = this.SubFolders[folderID];
}
else
{
foreach (InventoryFolder folder in this.SubFolders.Values)
{
returnFolder = folder.HasSubFolder(folderID);
if (returnFolder != null)
{
break;
}
}
}
return returnFolder;
}
public List<InventoryItemBase> RequestListOfItems()
{
List<InventoryItemBase> itemList = new List<InventoryItemBase>();
foreach (InventoryItemBase item in this.Items.Values)
{
itemList.Add(item);
}
return itemList;
}
}
}

170
OpenSim/Framework/Communications/Cache/UserProfileCache.cs Normal file
View File

@ -0,0 +1,170 @@
/*
* Copyright (c) Contributors, http://www.openmetaverse.org/
* See CONTRIBUTORS.TXT for a full list of copyright holders.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* * Neither the name of the OpenSim Project nor the
* names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*/
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.IO;
using libsecondlife;
using OpenSim.Framework.Interfaces;
using OpenSim.Framework.Types;
using OpenSim.Framework.Utilities;
using OpenSim.Framework.Data;
namespace OpenSim.Framework.Communications.Caches
{
public class UserProfileCache
{
// Fields
private CommunicationsManager m_parent;
public Dictionary<LLUUID, CachedUserInfo> UserProfiles = new Dictionary<LLUUID, CachedUserInfo>();
// Methods
public UserProfileCache(CommunicationsManager parent)
{
this.m_parent = parent;
}
public void AddNewUser(LLUUID userID)
{
if (!this.UserProfiles.ContainsKey(userID))
{
CachedUserInfo userInfo = new CachedUserInfo();
userInfo.UserProfile = this.RequestUserProfileForUser(userID);
if (userInfo.UserProfile != null)
{
this.RequestInventoryForUser(userID, userInfo);
this.UserProfiles.Add(userID, userInfo);
}
else
{
Console.WriteLine("UserProfileCache.cs: user profile for user not found");
}
}
}
public void AddNewUser(string firstName, string lastName)
{
}
public CachedUserInfo GetUserDetails(LLUUID userID)
{
if (this.UserProfiles.ContainsKey(userID))
{
return this.UserProfiles[userID];
}
return null;
}
public void HandleCreateInventoryFolder(IClientAPI remoteClient, LLUUID folderID, ushort folderType, string folderName, LLUUID parentID)
{
if (this.UserProfiles.ContainsKey(remoteClient.AgentId))
{
CachedUserInfo info = this.UserProfiles[remoteClient.AgentId];
if (info.RootFolder.folderID == parentID)
{
info.RootFolder.CreateNewSubFolder(folderID, folderName, folderType);
}
else
{
InventoryFolder folder = info.RootFolder.HasSubFolder(parentID);
if (folder != null)
{
folder.CreateNewSubFolder(folderID, folderName, folderType);
}
}
}
}
public void HandleFecthInventoryDescendents(IClientAPI remoteClient, LLUUID folderID, LLUUID ownerID, bool fetchFolders, bool fetchItems, int sortOrder)
{
if (this.UserProfiles.ContainsKey(remoteClient.AgentId))
{
CachedUserInfo info = this.UserProfiles[remoteClient.AgentId];
if (info.RootFolder.folderID == folderID)
{
if (fetchItems)
{
remoteClient.SendInventoryFolderDetails(remoteClient.AgentId, folderID, info.RootFolder.RequestListOfItems());
}
}
else
{
InventoryFolder folder = info.RootFolder.HasSubFolder(folderID);
if ((folder != null) && fetchItems)
{
remoteClient.SendInventoryFolderDetails(remoteClient.AgentId, folderID, folder.RequestListOfItems());
}
}
}
}
public void HandleFetchInventory(IClientAPI remoteClient, LLUUID itemID, LLUUID ownerID)
{
if (this.UserProfiles.ContainsKey(remoteClient.AgentId))
{
InventoryItemBase item = this.UserProfiles[remoteClient.AgentId].RootFolder.HasItem(itemID);
if (item != null)
{
remoteClient.SendInventoryItemDetails(ownerID, item);
}
}
}
private void RequestInventoryForUser(LLUUID userID, CachedUserInfo userInfo)
{
InventoryFolder folderInfo = new InventoryFolder();
folderInfo.agentID = userID;
folderInfo.folderID = userInfo.UserProfile.rootInventoryFolderID;
folderInfo.name = "My Inventory";
folderInfo.parentID = LLUUID.Zero;
folderInfo.type = 8;
folderInfo.version = 1;
userInfo.FolderReceive(userID, folderInfo);
}
private UserProfileData RequestUserProfileForUser(LLUUID userID)
{
return this.m_parent.UserServer.GetUserProfile(userID);
}
private void UpdateInventoryToServer(LLUUID userID)
{
}
private void UpdateUserProfileToServer(LLUUID userID)
{
}
public void UserLogOut(LLUUID userID)
{
}
}
}

66
OpenSim/Region/Physics/BulletXPlugin/OpenSim.Region.Physics.BulletXPlugin.csproj Normal file
View File

@ -0,0 +1,66 @@
<?xml version="1.0" encoding="utf-8"?>
<Project DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<PropertyGroup>
<Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
<Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
<ProductVersion>8.0.50727</ProductVersion>
<SchemaVersion>2.0</SchemaVersion>
<ProjectGuid>{2D3DE8E4-9202-46A4-857B-3579B70E8356}</ProjectGuid>
<OutputType>Library</OutputType>
<AppDesignerFolder>Properties</AppDesignerFolder>
<RootNamespace>OpenSim.Region.Physics.BulletXPlugin</RootNamespace>
<AssemblyName>OpenSim.Region.Physics.BulletXPlugin</AssemblyName>
<StartupObject>
</StartupObject>
</PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
<DebugSymbols>true</DebugSymbols>
<DebugType>full</DebugType>
<Optimize>false</Optimize>
<OutputPath>bin\Debug\</OutputPath>
<DefineConstants>DEBUG;TRACE</DefineConstants>
<ErrorReport>prompt</ErrorReport>
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
<DebugType>pdbonly</DebugType>
<Optimize>true</Optimize>
<OutputPath>..\..\..\..\bin\Physics\</OutputPath>
<DefineConstants>TRACE</DefineConstants>
<ErrorReport>prompt</ErrorReport>
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
<!-- To modify your build process, add your task inside one of the targets below and uncomment it.
Other similar extension points exist, see Microsoft.Common.targets.
<Target Name="BeforeBuild">
</Target>
<Target Name="AfterBuild">
</Target>
-->
<ItemGroup>
<Compile Include="AssemblyInfo.cs" />
<Compile Include="BulletXPlugin.cs" />
</ItemGroup>
<ItemGroup>
<Reference Include="Axiom.MathLib.dll">
<HintPath>..\..\..\..\bin\Axiom.MathLib.dll</HintPath>
<Private>False</Private>
</Reference>
<Reference Include="Modified.XnaDevRu.BulletX, Version=2.50.149.21894, Culture=neutral, processorArchitecture=x86">
<SpecificVersion>False</SpecificVersion>
<HintPath>..\..\..\..\bin\Modified.XnaDevRu.BulletX.dll</HintPath>
</Reference>
<Reference Include="MonoXnaCompactMaths, Version=0.0.0.0, Culture=neutral, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
<HintPath>..\..\..\..\bin\MonoXnaCompactMaths.dll</HintPath>
</Reference>
<Reference Include="OpenSim.Region.Physics.Manager, Version=1.0.2741.37128, Culture=neutral, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
<HintPath>..\..\..\..\bin\OpenSim.Region.Physics.Manager.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Data" />
<Reference Include="System.Xml" />
</ItemGroup>
</Project>