started to refactor startup code and to move udp server code out to its own class (currently not being used though) so that a single instance can handle multiple regions (each will need to be listening on a separate udp port)

author: MW 2007-05-16 12:44:58 +0000
committer: MW 2007-05-16 12:44:58 +0000
commit: 3d93d390485075345442b9b5ea35eed88a9cab49 (patch)
tree: a51cdb72cd310ae3f579650886836ddc0211d986 /OpenSim.RegionServer/SimClient.PacketHandlers.cs
parent: made QueItem a nested class in SimClient. (diff)
download: opensim-SC_OLD-3d93d390485075345442b9b5ea35eed88a9cab49.zip
opensim-SC_OLD-3d93d390485075345442b9b5ea35eed88a9cab49.tar.gz
opensim-SC_OLD-3d93d390485075345442b9b5ea35eed88a9cab49.tar.bz2
opensim-SC_OLD-3d93d390485075345442b9b5ea35eed88a9cab49.tar.xz
1 files changed, 156 insertions, 0 deletions
diff --git a/OpenSim.RegionServer/SimClient.PacketHandlers.cs b/OpenSim.RegionServer/SimClient.PacketHandlers.cs
new file mode 100644
index 0000000..5007a60
--- /dev/null
+++ b/OpenSim.RegionServer/SimClient.PacketHandlers.cs
@@ -0,0 +1,156 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using libsecondlife;
+using libsecondlife.Packets;
+using Nwc.XmlRpc;
+using System.Net;
+using System.Net.Sockets;
+using System.IO;
+using System.Threading;
+using System.Timers;
+using OpenSim.Framework.Interfaces;
+using OpenSim.Framework.Types;
+using OpenSim.Framework.Inventory;
+using OpenSim.Framework.Utilities;
+using OpenSim.world;
+using OpenSim.Assets;
+namespace OpenSim
+{
+    public partial class SimClient
+    {
+        protected virtual bool Logout(SimClient simClient, Packet packet)
+        {
+            OpenSim.Framework.Console.MainConsole.Instance.WriteLine(OpenSim.Framework.Console.LogPriority.LOW, "OpenSimClient.cs:ProcessInPacket() - Got a logout request");
+            //send reply to let the client logout
+            LogoutReplyPacket logReply = new LogoutReplyPacket();
+            logReply.AgentData.AgentID = this.AgentID;
+            logReply.AgentData.SessionID = this.SessionID;
+            logReply.InventoryData = new LogoutReplyPacket.InventoryDataBlock[1];
+            logReply.InventoryData[0] = new LogoutReplyPacket.InventoryDataBlock();
+            logReply.InventoryData[0].ItemID = LLUUID.Zero;
+            OutPacket(logReply);
+            //tell all clients to kill our object
+            KillObjectPacket kill = new KillObjectPacket();
+            kill.ObjectData = new KillObjectPacket.ObjectDataBlock[1];
+            kill.ObjectData[0] = new KillObjectPacket.ObjectDataBlock();
+            kill.ObjectData[0].ID = this.ClientAvatar.localid;
+            foreach (SimClient client in m_clientThreads.Values)
+            {
+                client.OutPacket(kill);
+            }
+            if (this.m_userServer != null)
+            {
+                this.m_inventoryCache.ClientLeaving(this.AgentID, this.m_userServer);
+            }
+            else
+            {
+                this.m_inventoryCache.ClientLeaving(this.AgentID, null);
+            }
+            m_gridServer.LogoutSession(this.SessionID, this.AgentID, this.CircuitCode);
+            /*lock (m_world.Entities)
+            {
+                m_world.Entities.Remove(this.AgentID);
+            }*/
+            m_world.RemoveViewerAgent(this);
+            //need to do other cleaning up here too
+            m_clientThreads.Remove(this.CircuitCode);
+            m_application.RemoveClientCircuit(this.CircuitCode);
+            this.ClientThread.Abort();
+            return true;
+        }
+        protected bool AgentTextureCached(SimClient simclient, Packet packet)
+        {
+            // Console.WriteLine(packet.ToString());
+            AgentCachedTexturePacket chechedtex = (AgentCachedTexturePacket)packet;
+            AgentCachedTextureResponsePacket cachedresp = new AgentCachedTextureResponsePacket();
+            cachedresp.AgentData.AgentID = this.AgentID;
+            cachedresp.AgentData.SessionID = this.SessionID;
+            cachedresp.AgentData.SerialNum = this.cachedtextureserial;
+            this.cachedtextureserial++;
+            cachedresp.WearableData = new AgentCachedTextureResponsePacket.WearableDataBlock[chechedtex.WearableData.Length];
+            for (int i = 0; i < chechedtex.WearableData.Length; i++)
+            {
+                cachedresp.WearableData[i] = new AgentCachedTextureResponsePacket.WearableDataBlock();
+                cachedresp.WearableData[i].TextureIndex = chechedtex.WearableData[i].TextureIndex;
+                cachedresp.WearableData[i].TextureID = LLUUID.Zero;
+                cachedresp.WearableData[i].HostName = new byte[0];
+            }
+            this.OutPacket(cachedresp);
+            return true;
+        }
+        protected bool MultipleObjUpdate(SimClient simClient, Packet packet)
+        {
+            MultipleObjectUpdatePacket multipleupdate = (MultipleObjectUpdatePacket)packet;
+            for (int i = 0; i < multipleupdate.ObjectData.Length; i++)
+            {
+                if (multipleupdate.ObjectData[i].Type == 9) //change position
+                {
+                    libsecondlife.LLVector3 pos = new LLVector3(multipleupdate.ObjectData[i].Data, 0);
+                    foreach (Entity ent in m_world.Entities.Values)
+                    {
+                        if (ent.localid == multipleupdate.ObjectData[i].ObjectLocalID)
+                        {
+                            ((OpenSim.world.Primitive)ent).UpdatePosition(pos);
+                        }
+                    }
+                    //should update stored position of the prim
+                }
+                else if (multipleupdate.ObjectData[i].Type == 10)//rotation
+                {
+                    libsecondlife.LLQuaternion rot = new LLQuaternion(multipleupdate.ObjectData[i].Data, 0, true);
+                    foreach (Entity ent in m_world.Entities.Values)
+                    {
+                        if (ent.localid == multipleupdate.ObjectData[i].ObjectLocalID)
+                        {
+                            ent.rotation = new Axiom.MathLib.Quaternion(rot.W, rot.X, rot.Y, rot.Z);
+                            ((OpenSim.world.Primitive)ent).UpdateFlag = true;
+                        }
+                    }
+                }
+                else if (multipleupdate.ObjectData[i].Type == 13)//scale
+                {
+                    libsecondlife.LLVector3 scale = new LLVector3(multipleupdate.ObjectData[i].Data, 12);
+                    foreach (Entity ent in m_world.Entities.Values)
+                    {
+                        if (ent.localid == multipleupdate.ObjectData[i].ObjectLocalID)
+                        {
+                            ((OpenSim.world.Primitive)ent).Scale = scale;
+                        }
+                    }
+                }
+            }
+            return true;
+        }
+        public void RequestMapLayer() //should be getting the map layer from the grid server
+        {
+            //send a layer covering the 800,800 - 1200,1200 area (should be covering the requested area)
+            MapLayerReplyPacket mapReply = new MapLayerReplyPacket();
+            mapReply.AgentData.AgentID = this.AgentID;
+            mapReply.AgentData.Flags = 0;
+            mapReply.LayerData = new MapLayerReplyPacket.LayerDataBlock[1];
+            mapReply.LayerData[0] = new MapLayerReplyPacket.LayerDataBlock();
+            mapReply.LayerData[0].Bottom = 800;
+            mapReply.LayerData[0].Left = 800;
+            mapReply.LayerData[0].Top = 1200;
+            mapReply.LayerData[0].Right = 1200;
+            mapReply.LayerData[0].ImageID = new LLUUID("00000000-0000-0000-9999-000000000006");
+            this.OutPacket(mapReply);
+        }
+        public void RequestMapBlock(int minX, int minY, int maxX, int maxY)
+        {
+            //check if our own map was requested
+            this.m_world.RequestMapBlock(this, minX, minY, maxX, maxY);
+            //now should get other regions maps from gridserver
+        }
+    }
+}
author	MW	2007-05-16 12:44:58 +0000
committer	MW	2007-05-16 12:44:58 +0000
commit	3d93d390485075345442b9b5ea35eed88a9cab49 (patch)
tree	a51cdb72cd310ae3f579650886836ddc0211d986 /OpenSim.RegionServer/SimClient.PacketHandlers.cs
parent	made QueItem a nested class in SimClient. (diff)
download	opensim-SC_OLD-3d93d390485075345442b9b5ea35eed88a9cab49.zip opensim-SC_OLD-3d93d390485075345442b9b5ea35eed88a9cab49.tar.gz opensim-SC_OLD-3d93d390485075345442b9b5ea35eed88a9cab49.tar.bz2 opensim-SC_OLD-3d93d390485075345442b9b5ea35eed88a9cab49.tar.xz

diff --git a/OpenSim.RegionServer/SimClient.PacketHandlers.cs b/OpenSim.RegionServer/SimClient.PacketHandlers.cs new file mode 100644 index 0000000..5007a60 --- /dev/null +++ b/OpenSim.RegionServer/SimClient.PacketHandlers.cs
@@ -0,0 +1,156 @@
	1	using System;
	2	using System.Collections;
	3	using System.Collections.Generic;
	4	using libsecondlife;
	5	using libsecondlife.Packets;
	6	using Nwc.XmlRpc;
	7	using System.Net;
	8	using System.Net.Sockets;
	9	using System.IO;
	10	using System.Threading;
	11	using System.Timers;
	12	using OpenSim.Framework.Interfaces;
	13	using OpenSim.Framework.Types;
	14	using OpenSim.Framework.Inventory;
	15	using OpenSim.Framework.Utilities;
	16	using OpenSim.world;
	17	using OpenSim.Assets;
	18
	19	namespace OpenSim
	20	{
	21	public partial class SimClient
	22	{
	23	protected virtual bool Logout(SimClient simClient, Packet packet)
	24	{
	25	OpenSim.Framework.Console.MainConsole.Instance.WriteLine(OpenSim.Framework.Console.LogPriority.LOW, "OpenSimClient.cs:ProcessInPacket() - Got a logout request");
	26	//send reply to let the client logout
	27	LogoutReplyPacket logReply = new LogoutReplyPacket();
	28	logReply.AgentData.AgentID = this.AgentID;
	29	logReply.AgentData.SessionID = this.SessionID;
	30	logReply.InventoryData = new LogoutReplyPacket.InventoryDataBlock[1];
	31	logReply.InventoryData[0] = new LogoutReplyPacket.InventoryDataBlock();
	32	logReply.InventoryData[0].ItemID = LLUUID.Zero;
	33	OutPacket(logReply);
	34	//tell all clients to kill our object
	35	KillObjectPacket kill = new KillObjectPacket();
	36	kill.ObjectData = new KillObjectPacket.ObjectDataBlock[1];
	37	kill.ObjectData[0] = new KillObjectPacket.ObjectDataBlock();
	38	kill.ObjectData[0].ID = this.ClientAvatar.localid;
	39	foreach (SimClient client in m_clientThreads.Values)
	40	{
	41	client.OutPacket(kill);
	42	}
	43	if (this.m_userServer != null)
	44	{
	45	this.m_inventoryCache.ClientLeaving(this.AgentID, this.m_userServer);
	46	}
	47	else
	48	{
	49	this.m_inventoryCache.ClientLeaving(this.AgentID, null);
	50	}
	51
	52	m_gridServer.LogoutSession(this.SessionID, this.AgentID, this.CircuitCode);
	53	/*lock (m_world.Entities)
	54	{
	55	m_world.Entities.Remove(this.AgentID);
	56	}*/
	57	m_world.RemoveViewerAgent(this);
	58	//need to do other cleaning up here too
	59	m_clientThreads.Remove(this.CircuitCode);
	60	m_application.RemoveClientCircuit(this.CircuitCode);
	61	this.ClientThread.Abort();
	62	return true;
	63	}
	64
	65	protected bool AgentTextureCached(SimClient simclient, Packet packet)
	66	{
	67	// Console.WriteLine(packet.ToString());
	68	AgentCachedTexturePacket chechedtex = (AgentCachedTexturePacket)packet;
	69	AgentCachedTextureResponsePacket cachedresp = new AgentCachedTextureResponsePacket();
	70	cachedresp.AgentData.AgentID = this.AgentID;
	71	cachedresp.AgentData.SessionID = this.SessionID;
	72	cachedresp.AgentData.SerialNum = this.cachedtextureserial;
	73	this.cachedtextureserial++;
	74	cachedresp.WearableData = new AgentCachedTextureResponsePacket.WearableDataBlock[chechedtex.WearableData.Length];
	75	for (int i = 0; i < chechedtex.WearableData.Length; i++)
	76	{
	77	cachedresp.WearableData[i] = new AgentCachedTextureResponsePacket.WearableDataBlock();
	78	cachedresp.WearableData[i].TextureIndex = chechedtex.WearableData[i].TextureIndex;
	79	cachedresp.WearableData[i].TextureID = LLUUID.Zero;
	80	cachedresp.WearableData[i].HostName = new byte[0];
	81	}
	82	this.OutPacket(cachedresp);
	83	return true;
	84	}
	85
	86	protected bool MultipleObjUpdate(SimClient simClient, Packet packet)
	87	{
	88	MultipleObjectUpdatePacket multipleupdate = (MultipleObjectUpdatePacket)packet;
	89	for (int i = 0; i < multipleupdate.ObjectData.Length; i++)
	90	{
	91	if (multipleupdate.ObjectData[i].Type == 9) //change position
	92	{
	93	libsecondlife.LLVector3 pos = new LLVector3(multipleupdate.ObjectData[i].Data, 0);
	94	foreach (Entity ent in m_world.Entities.Values)
	95	{
	96	if (ent.localid == multipleupdate.ObjectData[i].ObjectLocalID)
	97	{
	98	((OpenSim.world.Primitive)ent).UpdatePosition(pos);
	99
	100	}
	101	}
	102	//should update stored position of the prim
	103	}
	104	else if (multipleupdate.ObjectData[i].Type == 10)//rotation
	105	{
	106	libsecondlife.LLQuaternion rot = new LLQuaternion(multipleupdate.ObjectData[i].Data, 0, true);
	107	foreach (Entity ent in m_world.Entities.Values)
	108	{
	109	if (ent.localid == multipleupdate.ObjectData[i].ObjectLocalID)
	110	{
	111	ent.rotation = new Axiom.MathLib.Quaternion(rot.W, rot.X, rot.Y, rot.Z);
	112	((OpenSim.world.Primitive)ent).UpdateFlag = true;
	113	}
	114	}
	115	}
	116	else if (multipleupdate.ObjectData[i].Type == 13)//scale
	117	{
	118
	119	libsecondlife.LLVector3 scale = new LLVector3(multipleupdate.ObjectData[i].Data, 12);
	120	foreach (Entity ent in m_world.Entities.Values)
	121	{
	122	if (ent.localid == multipleupdate.ObjectData[i].ObjectLocalID)
	123	{
	124	((OpenSim.world.Primitive)ent).Scale = scale;
	125	}
	126	}
	127	}
	128	}
	129	return true;
	130	}
	131
	132	public void RequestMapLayer() //should be getting the map layer from the grid server
	133	{
	134	//send a layer covering the 800,800 - 1200,1200 area (should be covering the requested area)
	135	MapLayerReplyPacket mapReply = new MapLayerReplyPacket();
	136	mapReply.AgentData.AgentID = this.AgentID;
	137	mapReply.AgentData.Flags = 0;
	138	mapReply.LayerData = new MapLayerReplyPacket.LayerDataBlock[1];
	139	mapReply.LayerData[0] = new MapLayerReplyPacket.LayerDataBlock();
	140	mapReply.LayerData[0].Bottom = 800;
	141	mapReply.LayerData[0].Left = 800;
	142	mapReply.LayerData[0].Top = 1200;
	143	mapReply.LayerData[0].Right = 1200;
	144	mapReply.LayerData[0].ImageID = new LLUUID("00000000-0000-0000-9999-000000000006");
	145	this.OutPacket(mapReply);
	146	}
	147
	148	public void RequestMapBlock(int minX, int minY, int maxX, int maxY)
	149	{
	150	//check if our own map was requested
	151	this.m_world.RequestMapBlock(this, minX, minY, maxX, maxY);
	152
	153	//now should get other regions maps from gridserver
	154	}
	155	}
	156	}