Imported branch

author: gareth 2007-03-07 18:49:20 +0000
committer: gareth 2007-03-07 18:49:20 +0000
commit: 16476f06b867adf01fa0d17c6761f4a862fc17ad (patch)
tree: c3a1147578ae33d269812adfe8de5ece8c62d586 /ConvertToPlugins/src/LocalServers/LocalGridServers/LocalGrid.cs
parent: Deleted old trunk code (diff)
download: opensim-SC_OLD-16476f06b867adf01fa0d17c6761f4a862fc17ad.zip
opensim-SC_OLD-16476f06b867adf01fa0d17c6761f4a862fc17ad.tar.gz
opensim-SC_OLD-16476f06b867adf01fa0d17c6761f4a862fc17ad.tar.bz2
opensim-SC_OLD-16476f06b867adf01fa0d17c6761f4a862fc17ad.tar.xz
1 files changed, 205 insertions, 0 deletions
diff --git a/ConvertToPlugins/src/LocalServers/LocalGridServers/LocalGrid.cs b/ConvertToPlugins/src/LocalServers/LocalGridServers/LocalGrid.cs
new file mode 100644
index 0000000..5adce27
--- /dev/null
+++ b/ConvertToPlugins/src/LocalServers/LocalGridServers/LocalGrid.cs
@@ -0,0 +1,205 @@
+/*
+* Copyright (c) OpenSim project, http://sim.opensecondlife.org/
+*
+* 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 <organization> 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 <copyright holder> ``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 <copyright holder> BE LIABLE FOR ANY
+* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+* 
+*/
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using OpenSim.GridServers;
+using libsecondlife;
+namespace LocalGridServers
+{
+        /// <summary>
+        /// 
+        /// </summary>
+        /// 
+        public class LocalGridPlugin : IGridPlugin
+        {
+                public LocalGridPlugin()
+                {
+                        
+                }
+                
+                public IGridServer GetGridServer()
+                {
+                        return(new LocalGridServer());
+                }
+        }
+        
+        public class LocalAssetPlugin : IAssetPlugin
+        {
+                public LocalAssetPlugin()
+                {
+                        
+                }
+                
+                public IAssetServer GetAssetServer()
+                {
+                        return(new LocalAssetServer());
+                }
+        }
+        
+        public class LocalAssetServer : IAssetServer
+        {
+                private IAssetReceiver _receiver;
+                private BlockingQueue<ARequest> _assetRequests;
+                
+                public LocalAssetServer()
+                {
+                        this._assetRequests = new BlockingQueue<ARequest>();
+                        ServerConsole.MainConsole.Instance.WriteLine("Local Asset Server class created");
+                }
+                
+                public void SetReceiver(IAssetReceiver receiver)
+                {
+                        this._receiver = receiver;
+                }
+                
+                public void RequestAsset(LLUUID assetID, bool isTexture)
+                {
+                        ARequest req = new ARequest();
+                        req.AssetID = assetID;
+                        req.IsTexture = isTexture;
+                        //this._assetRequests.Enqueue(req);
+                }
+                
+                public void UpdateAsset(AssetBase asset)
+                {
+                        
+                }
+                
+                public void UploadNewAsset(AssetBase asset)
+                {
+                        
+                }
+                
+                public void SetServerInfo(string ServerUrl, string ServerKey)
+                {
+                        
+                }
+                
+                private void RunRequests()
+                {
+                        while(true)
+                        {
+                                
+                        }
+                }
+        }
+        
+        public class LocalGridServer :IGridServer
+        {
+                public List<Login> Sessions = new List<Login>();  
+                
+                public LocalGridServer()
+                {
+                        Sessions = new List<Login>();
+                        ServerConsole.MainConsole.Instance.WriteLine("Local Grid Server class created");
+                }
+                
+                public bool RequestConnection()
+                {
+                        return true;
+                }
+                public AuthenticateResponse AuthenticateSession(LLUUID sessionID, LLUUID agentID, uint circuitCode)
+                {
+                        //we are running local
+                        AuthenticateResponse user = new AuthenticateResponse();
+                        
+                        lock(this.Sessions)
+                        {
+                                
+                                for(int i = 0; i < Sessions.Count; i++)
+                                {
+                                        if((Sessions[i].Agent == agentID) && (Sessions[i].Session == sessionID))
+                                        {
+                                                user.Authorised = true;
+                                                user.LoginInfo = Sessions[i];
+                                        }
+                                }
+                        }
+                        return(user);
+                }
+                
+                public bool LogoutSession(LLUUID sessionID, LLUUID agentID, uint circuitCode)
+                {
+                        return(true);
+                }
+                
+                public UUIDBlock RequestUUIDBlock()
+                {
+                        UUIDBlock uuidBlock = new UUIDBlock();
+                        return(uuidBlock);
+                }
+                
+                public void RequestNeighbours()
+                {
+                        return;
+                }
+                
+                public void SetServerInfo(string ServerUrl, string ServerKey)
+                {
+                        
+                }
+                /// <summary>
+                /// used by the local login server to inform us of new sessions
+                /// </summary>
+                /// <param name="session"></param>
+                public void AddNewSession(Login session)
+                {
+                        lock(this.Sessions)
+                        {
+                                this.Sessions.Add(session);
+                        }
+                }
+        }
+        
+        public class BlockingQueue< T > {
+                private Queue< T > _queue = new Queue< T >();
+                private object _queueSync = new object();
+                public void Enqueue(T value)
+                {
+                        lock(_queueSync)
+                        {
+                                _queue.Enqueue(value);
+                                Monitor.Pulse(_queueSync);
+                        }
+                }
+                public T Dequeue()
+                {
+                        lock(_queueSync)
+                        {
+                                if( _queue.Count < 1)
+                                        Monitor.Wait(_queueSync);
+                                return _queue.Dequeue();
+                        }
+                }
+        }
+}
author	gareth	2007-03-07 18:49:20 +0000
committer	gareth	2007-03-07 18:49:20 +0000
commit	16476f06b867adf01fa0d17c6761f4a862fc17ad (patch)
tree	c3a1147578ae33d269812adfe8de5ece8c62d586 /ConvertToPlugins/src/LocalServers/LocalGridServers/LocalGrid.cs
parent	Deleted old trunk code (diff)
download	opensim-SC_OLD-16476f06b867adf01fa0d17c6761f4a862fc17ad.zip opensim-SC_OLD-16476f06b867adf01fa0d17c6761f4a862fc17ad.tar.gz opensim-SC_OLD-16476f06b867adf01fa0d17c6761f4a862fc17ad.tar.bz2 opensim-SC_OLD-16476f06b867adf01fa0d17c6761f4a862fc17ad.tar.xz

diff --git a/ConvertToPlugins/src/LocalServers/LocalGridServers/LocalGrid.cs b/ConvertToPlugins/src/LocalServers/LocalGridServers/LocalGrid.cs new file mode 100644 index 0000000..5adce27 --- /dev/null +++ b/ConvertToPlugins/src/LocalServers/LocalGridServers/LocalGrid.cs
@@ -0,0 +1,205 @@
	1	/*
	2	* Copyright (c) OpenSim project, http://sim.opensecondlife.org/
	3	*
	4	* Redistribution and use in source and binary forms, with or without
	5	* modification, are permitted provided that the following conditions are met:
	6	* * Redistributions of source code must retain the above copyright
	7	* notice, this list of conditions and the following disclaimer.
	8	* * Redistributions in binary form must reproduce the above copyright
	9	* notice, this list of conditions and the following disclaimer in the
	10	* documentation and/or other materials provided with the distribution.
	11	* * Neither the name of the <organization> nor the
	12	* names of its contributors may be used to endorse or promote products
	13	* derived from this software without specific prior written permission.
	14	*
	15	* THIS SOFTWARE IS PROVIDED BY <copyright holder> ``AS IS'' AND ANY
	16	* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
	17	* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
	18	* DISCLAIMED. IN NO EVENT SHALL <copyright holder> BE LIABLE FOR ANY
	19	* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
	20	* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
	21	* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
	22	* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
	23	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
	24	* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
	25	*
	26	*/
	27	using System;
	28	using System.Collections.Generic;
	29	using System.Threading;
	30	using OpenSim.GridServers;
	31	using libsecondlife;
	32
	33	namespace LocalGridServers
	34	{
	35	/// <summary>
	36	///
	37	/// </summary>
	38	///
	39	public class LocalGridPlugin : IGridPlugin
	40	{
	41	public LocalGridPlugin()
	42	{
	43
	44	}
	45
	46	public IGridServer GetGridServer()
	47	{
	48	return(new LocalGridServer());
	49	}
	50	}
	51
	52	public class LocalAssetPlugin : IAssetPlugin
	53	{
	54	public LocalAssetPlugin()
	55	{
	56
	57	}
	58
	59	public IAssetServer GetAssetServer()
	60	{
	61	return(new LocalAssetServer());
	62	}
	63	}
	64
	65	public class LocalAssetServer : IAssetServer
	66	{
	67	private IAssetReceiver _receiver;
	68	private BlockingQueue<ARequest> _assetRequests;
	69
	70	public LocalAssetServer()
	71	{
	72	this._assetRequests = new BlockingQueue<ARequest>();
	73	ServerConsole.MainConsole.Instance.WriteLine("Local Asset Server class created");
	74	}
	75
	76	public void SetReceiver(IAssetReceiver receiver)
	77	{
	78	this._receiver = receiver;
	79	}
	80
	81	public void RequestAsset(LLUUID assetID, bool isTexture)
	82	{
	83	ARequest req = new ARequest();
	84	req.AssetID = assetID;
	85	req.IsTexture = isTexture;
	86	//this._assetRequests.Enqueue(req);
	87	}
	88
	89	public void UpdateAsset(AssetBase asset)
	90	{
	91
	92	}
	93
	94	public void UploadNewAsset(AssetBase asset)
	95	{
	96
	97	}
	98
	99	public void SetServerInfo(string ServerUrl, string ServerKey)
	100	{
	101
	102	}
	103
	104	private void RunRequests()
	105	{
	106	while(true)
	107	{
	108
	109	}
	110	}
	111	}
	112
	113	public class LocalGridServer :IGridServer
	114	{
	115	public List<Login> Sessions = new List<Login>();
	116
	117	public LocalGridServer()
	118	{
	119	Sessions = new List<Login>();
	120	ServerConsole.MainConsole.Instance.WriteLine("Local Grid Server class created");
	121	}
	122
	123	public bool RequestConnection()
	124	{
	125	return true;
	126	}
	127	public AuthenticateResponse AuthenticateSession(LLUUID sessionID, LLUUID agentID, uint circuitCode)
	128	{
	129	//we are running local
	130	AuthenticateResponse user = new AuthenticateResponse();
	131
	132	lock(this.Sessions)
	133	{
	134
	135	for(int i = 0; i < Sessions.Count; i++)
	136	{
	137	if((Sessions[i].Agent == agentID) && (Sessions[i].Session == sessionID))
	138	{
	139	user.Authorised = true;
	140	user.LoginInfo = Sessions[i];
	141	}
	142	}
	143	}
	144	return(user);
	145	}
	146
	147	public bool LogoutSession(LLUUID sessionID, LLUUID agentID, uint circuitCode)
	148	{
	149	return(true);
	150	}
	151
	152	public UUIDBlock RequestUUIDBlock()
	153	{
	154	UUIDBlock uuidBlock = new UUIDBlock();
	155	return(uuidBlock);
	156	}
	157
	158	public void RequestNeighbours()
	159	{
	160	return;
	161	}
	162
	163	public void SetServerInfo(string ServerUrl, string ServerKey)
	164	{
	165
	166	}
	167	/// <summary>
	168	/// used by the local login server to inform us of new sessions
	169	/// </summary>
	170	/// <param name="session"></param>
	171	public void AddNewSession(Login session)
	172	{
	173	lock(this.Sessions)
	174	{
	175	this.Sessions.Add(session);
	176	}
	177	}
	178	}
	179
	180	public class BlockingQueue< T > {
	181	private Queue< T > _queue = new Queue< T >();
	182	private object _queueSync = new object();
	183
	184	public void Enqueue(T value)
	185	{
	186	lock(_queueSync)
	187	{
	188	_queue.Enqueue(value);
	189	Monitor.Pulse(_queueSync);
	190	}
	191	}
	192
	193	public T Dequeue()
	194	{
	195	lock(_queueSync)
	196	{
	197	if( _queue.Count < 1)
	198	Monitor.Wait(_queueSync);
	199
	200	return _queue.Dequeue();
	201	}
	202	}
	203	}
	204
	205	}