From fefe0ff3d9ceaaefccb494ef13a5a98cc0131070 Mon Sep 17 00:00:00 2001 From: Mike Mazur Date: Wed, 28 Jan 2009 01:56:04 +0000 Subject: Removing contents of ThirdParty/3Di. The load balancer can now be found at http://forge.opensimulator.org/gf/project/loadbalancer/ config key: svn.rmdir --- ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs | 1094 -------------------- .../LoadBalancer/Resources/LoadBalancer.addin.xml | 12 - ThirdParty/3Di/LoadBalancer/TcpClient.cs | 225 ---- ThirdParty/3Di/LoadBalancer/TcpServer.cs | 219 ---- 4 files changed, 1550 deletions(-) delete mode 100644 ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs delete mode 100644 ThirdParty/3Di/LoadBalancer/Resources/LoadBalancer.addin.xml delete mode 100644 ThirdParty/3Di/LoadBalancer/TcpClient.cs delete mode 100644 ThirdParty/3Di/LoadBalancer/TcpServer.cs (limited to 'ThirdParty/3Di/LoadBalancer') diff --git a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs deleted file mode 100644 index b3b66da..0000000 --- a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs +++ /dev/null @@ -1,1094 +0,0 @@ -/* - * Copyright (c) Contributors, http://opensimulator.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.IO; -using System.Net; -using System.Reflection; -using System.Threading; -using OpenMetaverse; -using OpenMetaverse.Packets; -using log4net; -using Mono.Addins; -using Nwc.XmlRpc; -using OpenSim.Framework; -using OpenSim.Framework.Servers; -using OpenSim.Region.ClientStack; -using OpenSim.Region.ClientStack.LindenUDP; -using OpenSim.Region.Environment.Scenes; - -// TODO: remove LindenUDP dependency - -namespace OpenSim.ApplicationPlugins.LoadBalancer -{ - public class LoadBalancerPlugin : IApplicationPlugin - { - private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); - - private BaseHttpServer commandServer; - private bool[] isLocalNeighbour; - private bool isSplit; - private TcpServer mTcpServer; - private readonly object padlock = new object(); - - private int proxyOffset; - private string proxyURL; - private List regionData; - private int[] regionPortList; - private SceneManager sceneManager; - private string[] sceneURL; - private string serializeDir; - private OpenSimBase simMain; - private TcpClient[] tcpClientList; - private List m_clientServers; - - #region IApplicationPlugin Members - // TODO: required by IPlugin, but likely not at all right - string m_name = "LoadBalancer"; - string m_version = "0.1"; - - public string Version { get { return m_version; } } - public string Name { get { return m_name; } } - - public void Initialise() - { - m_log.Info("[BALANCER]: " + Name + " cannot be default-initialized!"); - throw new PluginNotInitialisedException (Name); - } - - public void Initialise(OpenSimBase openSim) - { - m_log.Info("[BALANCER]: " + "Entering Initialize()"); - - proxyURL = openSim.ConfigSource.Source.Configs["Network"].GetString("proxy_url", ""); - if (proxyURL.Length == 0) return; - - StartTcpServer(); - - LLClientView.SynchronizeClient = SynchronizePackets; - AsynchronousSocketListener.PacketHandler = SynchronizePacketRecieve; - - sceneManager = openSim.SceneManager; - m_clientServers = openSim.ClientServers; - regionData = openSim.RegionData; - simMain = openSim; - commandServer = openSim.HttpServer; - - proxyOffset = Int32.Parse(openSim.ConfigSource.Source.Configs["Network"].GetString("proxy_offset", "0")); - serializeDir = openSim.ConfigSource.Source.Configs["Network"].GetString("serialize_dir", "/tmp/"); - - commandServer.AddXmlRPCHandler("SerializeRegion", SerializeRegion); - commandServer.AddXmlRPCHandler("DeserializeRegion_Move", DeserializeRegion_Move); - commandServer.AddXmlRPCHandler("DeserializeRegion_Clone", DeserializeRegion_Clone); - commandServer.AddXmlRPCHandler("TerminateRegion", TerminateRegion); - - commandServer.AddXmlRPCHandler("SplitRegion", SplitRegion); - commandServer.AddXmlRPCHandler("MergeRegions", MergeRegions); - commandServer.AddXmlRPCHandler("UpdatePhysics", UpdatePhysics); - commandServer.AddXmlRPCHandler("GetStatus", GetStatus); - - m_log.Info("[BALANCER] " + "Exiting Initialize()"); - } - - public void Dispose() - { - } - - #endregion - - private void StartTcpServer() - { - Thread server_thread = new Thread(new ThreadStart( - delegate - { - mTcpServer = new TcpServer(10001); - mTcpServer.start(); - })); - server_thread.Start(); - } - - private XmlRpcResponse GetStatus(XmlRpcRequest request) - { - XmlRpcResponse response = new XmlRpcResponse(); - try - { - m_log.Info("[BALANCER] " + "Entering RegionStatus()"); - - int src_port = Convert.ToInt32(request.Params[0]); - Scene scene; - // try to get the scene object - RegionInfo src_region = SearchRegionFromPortNum(src_port); - if (sceneManager.TryGetScene(src_region.RegionID, out scene) == false) - { - m_log.Error("[BALANCER] " + "The Scene is not found"); - return response; - } - // serialization of client's informations - List presences = scene.GetScenePresences(); - int get_scene_presence = presences.Count; - int get_scene_presence_filter = 0; - foreach (ScenePresence pre in presences) - { - IClientAPI client = pre.ControllingClient; - //if (pre.MovementFlag!=0 && client.PacketProcessingEnabled==true) - if (client.IsActive) - { - get_scene_presence_filter++; - } - } - List avatars = scene.GetAvatars(); - int get_avatar = avatars.Count; - int get_avatar_filter = 0; - string avatar_names = ""; - foreach (ScenePresence pre in avatars) - { - IClientAPI client = pre.ControllingClient; - //if (pre.MovementFlag!=0 && client.PacketProcessingEnabled==true) - if (client.IsActive) - { - get_avatar_filter++; - avatar_names += pre.Firstname + " " + pre.Lastname + "; "; - } - } - - Hashtable responseData = new Hashtable(); - responseData["get_scene_presence_filter"] = get_scene_presence_filter; - responseData["get_scene_presence"] = get_scene_presence; - responseData["get_avatar_filter"] = get_avatar_filter; - responseData["get_avatar"] = get_avatar; - responseData["avatar_names"] = avatar_names; - response.Value = responseData; - - m_log.Info("[BALANCER] " + "Exiting RegionStatus()"); - } - catch (Exception e) - { - m_log.Error("[BALANCER] " + e); - m_log.Error("[BALANCER] " + e.StackTrace); - } - return response; - } - - private XmlRpcResponse SerializeRegion(XmlRpcRequest request) - { - try - { - m_log.Info("[BALANCER] " + "Entering SerializeRegion()"); - - string src_url = (string) request.Params[0]; - int src_port = (int) request.Params[1]; - - SerializeRegion(src_url, src_port); - - m_log.Info("[BALANCER] " + "Exiting SerializeRegion()"); - } - catch (Exception e) - { - m_log.Error("[BALANCER] " + e); - m_log.Error("[BALANCER] " + e.StackTrace); - } - - return new XmlRpcResponse(); - } - - private XmlRpcResponse DeserializeRegion_Move(XmlRpcRequest request) - { - try - { - m_log.Info("[BALANCER] " + "Entering DeserializeRegion_Move()"); - - string src_url = (string) request.Params[0]; - int src_port = (int) request.Params[1]; - string dst_url = (string) request.Params[2]; - int dst_port = (int) request.Params[3]; - - DeserializeRegion_Move(src_port, dst_port, src_url, dst_url); - - m_log.Info("[BALANCER] " + "Exiting DeserializeRegion_Move()"); - } - catch (Exception e) - { - m_log.Error("[BALANCER] " + e); - m_log.Error("[BALANCER] " + e.StackTrace); - } - - return new XmlRpcResponse(); - } - - private XmlRpcResponse DeserializeRegion_Clone(XmlRpcRequest request) - { - try - { - m_log.Info("[BALANCER] " + "Entering DeserializeRegion_Clone()"); - - string src_url = (string) request.Params[0]; - int src_port = (int) request.Params[1]; - string dst_url = (string) request.Params[2]; - int dst_port = (int) request.Params[3]; - - DeserializeRegion_Clone(src_port, dst_port, src_url, dst_url); - - m_log.Info("[BALANCER] " + "Exiting DeserializeRegion_Clone()"); - } - catch (Exception e) - { - m_log.Error("[BALANCER] " + e); - m_log.Error("[BALANCER] " + e.StackTrace); - throw; - } - - return new XmlRpcResponse(); - } - - private XmlRpcResponse TerminateRegion(XmlRpcRequest request) - { - try - { - m_log.Info("[BALANCER] " + "Entering TerminateRegion()"); - - int src_port = (int) request.Params[0]; - - // backgroud - WaitCallback callback = TerminateRegion; - ThreadPool.QueueUserWorkItem(callback, src_port); - - m_log.Info("[BALANCER] " + "Exiting TerminateRegion()"); - } - catch (Exception e) - { - m_log.Error("[BALANCER] " + e); - m_log.Error("[BALANCER] " + e.StackTrace); - } - - return new XmlRpcResponse(); - } - - // internal functions - - private void SerializeRegion(string src_url, int src_port) - { - //------------------------------------------ - // Processing of origin region - //------------------------------------------ - - // search origin region - RegionInfo src_region = SearchRegionFromPortNum(src_port); - - if (src_region == null) - { - m_log.Error("[BALANCER] " + "Region not found"); - return; - } - - Util.XmlRpcCommand(src_region.proxyUrl, "BlockClientMessages", src_url, src_port + proxyOffset); - - // serialization of origin region's data - SerializeRegion(src_region, serializeDir); - } - - private void DeserializeRegion_Move(int src_port, int dst_port, string src_url, string dst_url) - { - //------------------------------------------ - // Processing of destination region - //------------------------------------------ - - // import the source region's data - RegionInfo dst_region = DeserializeRegion(dst_port, serializeDir); - - Util.XmlRpcCommand(dst_region.proxyUrl, "ChangeRegion", src_port + proxyOffset, src_url, dst_port + proxyOffset, dst_url); - Util.XmlRpcCommand(dst_region.proxyUrl, "UnblockClientMessages", dst_url, dst_port + proxyOffset); - } - - private void DeserializeRegion_Clone(int src_port, int dst_port, string src_url, string dst_url) - { - //------------------------------------------ - // Processing of destination region - //------------------------------------------ - - // import the source region's data - RegionInfo dst_region = DeserializeRegion(dst_port, serializeDir); - - // Decide who is in charge for each section - int[] port = new int[] {src_port, dst_port}; - string[] url = new string[] {"http://" + src_url + ":" + commandServer.Port, "http://" + dst_url + ":" + commandServer.Port}; - for (int i = 0; i < 2; i++) Util.XmlRpcCommand(url[i], "SplitRegion", i, 2, port[0], port[1], url[0], url[1]); - - // Enable the proxy - Util.XmlRpcCommand(dst_region.proxyUrl, "AddRegion", src_port + proxyOffset, src_url, dst_port + proxyOffset, dst_url); - Util.XmlRpcCommand(dst_region.proxyUrl, "UnblockClientMessages", dst_url, dst_port + proxyOffset); - } - - private void TerminateRegion(object param) - { - int src_port = (int) param; - - //------------------------------------------ - // Processing of remove region - //------------------------------------------ - - // search origin region - RegionInfo src_region = SearchRegionFromPortNum(src_port); - - if (src_region == null) - { - m_log.Error("[BALANCER] " + "Region not found"); - return; - } - - isSplit = false; - - // remove client resources - RemoveAllClientResource(src_region); - // remove old region - RemoveRegion(src_region.RegionID, src_region.InternalEndPoint.Port); - - m_log.Info("[BALANCER] " + "Region terminated"); - } - - private RegionInfo SearchRegionFromPortNum(int portnum) - { - RegionInfo result = null; - - foreach (RegionInfo rinfo in regionData) - { - if (rinfo.InternalEndPoint.Port == portnum) - { -// m_log.Info("BALANCER", -// "Region found. Internal Port = {0}, Handle={1}", -// rinfo.InternalEndPoint.Port, rinfo.RegionHandle); - result = rinfo; - break; - } - } - - return result; - } - - private IClientNetworkServer SearchClientServerFromPortNum(int portnum) - { - return m_clientServers.Find( - delegate(IClientNetworkServer server) - { -// ReSharper disable PossibleNullReferenceException - return (portnum + proxyOffset == ((IPEndPoint) server.Server.LocalEndPoint).Port); -// ReSharper restore PossibleNullReferenceException - } - ); - } - - private void SerializeRegion(RegionInfo src_region, string export_dir) - { - Scene scene; - int i = 0; - - // try to get the scene object - if (sceneManager.TryGetScene(src_region.RegionID, out scene) == false) - { - m_log.Error("[BALANCER] " + "The Scene is not found"); - return; - } - - // create export directory - DirectoryInfo dirinfo = new DirectoryInfo(export_dir); - if (!dirinfo.Exists) - { - dirinfo.Create(); - } - - // serialization of client's informations - List presences = scene.GetScenePresences(); - - foreach (ScenePresence pre in presences) - { - SerializeClient(i, scene, pre, export_dir); - i++; - } - - // serialization of region data - SerializableRegionInfo dst_region = new SerializableRegionInfo(src_region); - - string filename = export_dir + "RegionInfo_" + src_region.RegionID + ".bin"; - Util.SerializeToFile(filename, dst_region); - - // backup current scene's entities - //scene.Backup(); - - m_log.InfoFormat("[BALANCER] " + "region serialization completed [{0}]", - src_region.RegionID.ToString()); - } - - private static void SerializeClient(int idx, IScene scene, EntityBase pre, string export_dir) - { - string filename; - IClientAPI controller; - - m_log.InfoFormat("[BALANCER] " + "agent id : {0}", pre.UUID); - - uint[] circuits = scene.ClientManager.GetAllCircuits(pre.UUID); - - foreach (uint code in circuits) - { - m_log.InfoFormat("[BALANCER] " + "circuit code : {0}", code); - - if (scene.ClientManager.TryGetClient(code, out controller)) - { - ClientInfo info = controller.GetClientInfo(); - - filename = export_dir + "ClientInfo-" + String.Format("{0:0000}", idx) + "_" + controller.CircuitCode + ".bin"; - - Util.SerializeToFile(filename, info); - - m_log.InfoFormat("[BALANCER] " + "client info serialized [filename={0}]", filename); - } - } - - //filename = export_dir + "Presence_" + controller.AgentId.ToString() + ".bin"; - filename = export_dir + "Presence_" + String.Format("{0:0000}", idx) + ".bin"; - - Util.SerializeToFile(filename, pre); - - m_log.InfoFormat("[BALANCER] " + "scene presence serialized [filename={0}]", filename); - } - - private RegionInfo DeserializeRegion(int dst_port, string import_dir) - { - RegionInfo dst_region = null; - - try - { - // deserialization of region data - string[] files = Directory.GetFiles(import_dir, "RegionInfo_*.bin"); - - foreach (string filename in files) - { - m_log.InfoFormat("[BALANCER] RegionInfo filename = [{0}]", filename); - - dst_region = new RegionInfo((SerializableRegionInfo) Util.DeserializeFromFile(filename)); - - m_log.InfoFormat("[BALANCER] " + "RegionID = [{0}]", dst_region.RegionID.ToString()); - m_log.InfoFormat("[BALANCER] " + "RegionHandle = [{0}]", dst_region.RegionHandle); - m_log.InfoFormat("[BALANCER] " + "ProxyUrl = [{0}]", dst_region.proxyUrl); - m_log.InfoFormat("[BALANCER] " + "OriginRegionID = [{0}]", dst_region.originRegionID.ToString()); - - CreateCloneRegion(dst_region, dst_port, true); - - File.Delete(filename); - - m_log.InfoFormat("[BALANCER] " + "region deserialized [{0}]", dst_region.RegionID); - } - - if (dst_region != null) - { - // deserialization of client data - DeserializeClient(dst_region, import_dir); - - m_log.InfoFormat("[BALANCER] " + "region deserialization completed [{0}]", - dst_region.ToString()); - } - } - catch (Exception e) - { - m_log.Error("[BALANCER] " + e); - m_log.Error("[BALANCER] " + e.StackTrace); - throw; - } - - return dst_region; - } - - private void DeserializeClient(SimpleRegionInfo dst_region, string import_dir) - { - ScenePresence sp; - ClientInfo data; - Scene scene; - IClientAPI controller; - - if (sceneManager.TryGetScene(dst_region.RegionID, out scene)) - { - IClientNetworkServer clientserv = SearchClientServerFromPortNum(scene.RegionInfo.InternalEndPoint.Port); - - // restore the scene presence - for (int i = 0;; i++) - { - string filename = import_dir + "Presence_" + String.Format("{0:0000}", i) + ".bin"; - - if (!File.Exists(filename)) - { - break; - } - - sp = (ScenePresence) Util.DeserializeFromFile(filename); - Console.WriteLine("agent id = {0}", sp.UUID); - - scene.m_restorePresences.Add(sp.UUID, sp); - File.Delete(filename); - - m_log.InfoFormat("[BALANCER] " + "scene presence deserialized [{0}]", sp.UUID); - - // restore the ClientView - - string[] files = Directory.GetFiles(import_dir, "ClientInfo-" + String.Format("{0:0000}", i) + "_*.bin"); - - foreach (string fname in files) - { - int start = fname.IndexOf('_'); - int end = fname.LastIndexOf('.'); - uint circuit_code = uint.Parse(fname.Substring(start + 1, end - start - 1)); - m_log.InfoFormat("[BALANCER] " + "client circuit code = {0}", circuit_code); - - data = (ClientInfo) Util.DeserializeFromFile(fname); - - AgentCircuitData agentdata = new AgentCircuitData(data.agentcircuit); - scene.AuthenticateHandler.AddNewCircuit(circuit_code, agentdata); - - // TODO: This needs to be abstracted and converted into IClientNetworkServer - if (clientserv is LLUDPServer) - { - ((LLUDPServer) clientserv).RestoreClient(agentdata, data.userEP, data.proxyEP); - } - - // waiting for the scene-presense restored - lock (scene.m_restorePresences) - { - Monitor.Wait(scene.m_restorePresences, 3000); - } - - if (scene.ClientManager.TryGetClient(circuit_code, out controller)) - { - m_log.InfoFormat("[BALANCER] " + "get client [{0}]", circuit_code); - controller.SetClientInfo(data); - } - - File.Delete(fname); - - m_log.InfoFormat("[BALANCER] " + "client info deserialized [{0}]", circuit_code); - } - - // backup new scene's entities - //scene.Backup(); - } - } - } - - private void CreateCloneRegion(RegionInfo dst_region, int dst_port, bool createID_flag) - { - if (createID_flag) - { - dst_region.RegionID = UUID.Random(); - } - - // change RegionInfo (memory only) - dst_region.InternalEndPoint.Port = dst_port; - dst_region.ExternalHostName = proxyURL.Split(new char[] {'/', ':'})[3]; - - // Create new region - simMain.CreateRegion(dst_region, false); - } - - private void RemoveRegion(UUID regionID, int port) - { - Scene killScene; - if (sceneManager.TryGetScene(regionID, out killScene)) - { - Console.WriteLine("scene found."); - - if ((sceneManager.CurrentScene != null) - && (sceneManager.CurrentScene.RegionInfo.RegionID == killScene.RegionInfo.RegionID)) - { - sceneManager.TrySetCurrentScene(".."); - } - - m_log.Info("Removing region : " + killScene.RegionInfo.RegionName); - regionData.Remove(killScene.RegionInfo); - sceneManager.CloseScene(killScene); - } - - // Shutting down the UDP server - IClientNetworkServer clientsvr = SearchClientServerFromPortNum(port); - - if (clientsvr != null) - { - clientsvr.Server.Close(); - m_clientServers.Remove(clientsvr); - } - } - - private void RemoveAllClientResource(SimpleRegionInfo src_region) - { - Scene scene; - IClientAPI controller; - - // try to get the scene object - if (sceneManager.TryGetScene(src_region.RegionID, out scene) == false) - { - m_log.Error("[BALANCER] " + "The Scene is not found"); - return; - } - - // serialization of client's informations - List presences = scene.GetScenePresences(); - - // remove all scene presences - foreach (ScenePresence pre in presences) - { - uint[] circuits = scene.ClientManager.GetAllCircuits(pre.UUID); - - foreach (uint code in circuits) - { - m_log.InfoFormat("[BALANCER] " + "circuit code : {0}", code); - - if (scene.ClientManager.TryGetClient(code, out controller)) - { - // stopping clientview thread - if ((controller).IsActive) - { - controller.Stop(); - (controller).IsActive = false; - } - // teminateing clientview thread - controller.Terminate(); - m_log.Info("[BALANCER] " + "client thread stopped"); - } - } - - // remove scene presence - scene.RemoveClient(pre.UUID); - } - } - - /* - * This section implements scene splitting and synchronization - */ - - private XmlRpcResponse SplitRegion(XmlRpcRequest request) - { - try - { - int myID = (int) request.Params[0]; - int numRegions = (int) request.Params[1]; - regionPortList = new int[numRegions]; - sceneURL = new string[numRegions]; - tcpClientList = new TcpClient[numRegions]; - - for (int i = 0; i < numRegions; i++) - { - regionPortList[i] = (int) request.Params[i + 2]; - sceneURL[i] = (string) request.Params[i + 2 + numRegions]; - } - - for (int i = 0; i < numRegions; i++) - { - string hostname = sceneURL[i].Split(new char[] {'/', ':'})[3]; - m_log.InfoFormat("[SPLITSCENE] " + "creating tcp client host:{0}", hostname); - tcpClientList[i] = new TcpClient(hostname, 10001); - } - - bool isMaster = (myID == 0); - - isLocalNeighbour = new bool[numRegions]; - for (int i = 0; i < numRegions; i++) isLocalNeighbour[i] = (sceneURL[i] == sceneURL[myID]); - - RegionInfo region = SearchRegionFromPortNum(regionPortList[myID]); - - //Console.WriteLine("\n === SplitRegion {0}\n", region.RegionID); - - Scene scene; - if (sceneManager.TryGetScene(region.RegionID, out scene)) - { - // Disable event updates, backups etc in the slave(s) - scene.Region_Status = isMaster ? RegionStatus.Up : RegionStatus.SlaveScene; - - //Console.WriteLine("=== SplitRegion {0}: Scene found, status {1}", region.RegionID, scene.Region_Status); - - // Disabling half of the avatars in master, and the other half in slave - - int i = 0; - - List circuits = scene.ClientManager.GetAllCircuitCodes(); - circuits.Sort(); - - foreach (uint code in circuits) - { - m_log.InfoFormat("[BALANCER] " + "circuit code : {0}", code); - - IClientAPI controller; - if (scene.ClientManager.TryGetClient(code, out controller)) - { - // Divide the presences evenly over the set of subscenes - LLClientView client = (LLClientView) controller; - client.IsActive = (((i + myID) % sceneURL.Length) == 0); - - m_log.InfoFormat("[SPLITSCENE] === SplitRegion {0}: SP.PacketEnabled {1}", region.RegionID, client.IsActive); - - if (!client.IsActive) - { - // stopping clientview thread - client.Stop(); - } - - ++i; - } - } - - scene.splitID = myID; - scene.SynchronizeScene = SynchronizeScenes; - isSplit = true; - } - else - { - m_log.Error("[SPLITSCENE] " + String.Format("Scene not found {0}", region.RegionID)); - } - } - catch (Exception e) - { - m_log.Error("[SPLITSCENE] " + e); - m_log.Error("[SPLITSCENE] " + e.StackTrace); - } - - return new XmlRpcResponse(); - } - - private XmlRpcResponse MergeRegions(XmlRpcRequest request) - { - // This should only be called for the master scene - try - { - m_log.Info("[BALANCER] " + "Entering MergeRegions()"); - - string src_url = (string) request.Params[0]; - int src_port = (int) request.Params[1]; - - RegionInfo region = SearchRegionFromPortNum(src_port); - - Util.XmlRpcCommand(region.proxyUrl, "BlockClientMessages", src_url, src_port + proxyOffset); - - Scene scene; - if (sceneManager.TryGetScene(region.RegionID, out scene)) - { - isSplit = false; - - scene.SynchronizeScene = null; - scene.Region_Status = RegionStatus.Up; - - List presences = scene.GetScenePresences(); - foreach (ScenePresence pre in presences) - { - LLClientView client = (LLClientView) pre.ControllingClient; - if (!client.IsActive) - { - client.Restart(); - client.IsActive = true; - } - } - } - - // Delete the slave scenes - for (int i = 1; i < sceneURL.Length; i++) - { - string url = (sceneURL[i].Split('/')[2]).Split(':')[0]; // get URL part from EP - Util.XmlRpcCommand(region.proxyUrl, "DeleteRegion", regionPortList[i] + proxyOffset, url); - Thread.Sleep(1000); - Util.XmlRpcCommand(sceneURL[i], "TerminateRegion", regionPortList[i]); // TODO: need + proxyOffset? - } - - Util.XmlRpcCommand(region.proxyUrl, "UnblockClientMessages", src_url, src_port + proxyOffset); - } - catch (Exception e) - { - m_log.Error("[BALANCER] " + e); - m_log.Error("[BALANCER] " + e.StackTrace); - throw; - } - - return new XmlRpcResponse(); - } - - private XmlRpcResponse UpdatePhysics(XmlRpcRequest request) - { - // this callback receives physic scene updates from the other sub-scenes (in split mode) - - int regionPort = (int) request.Params[0]; - UUID scenePresenceID = new UUID((byte[]) request.Params[1], 0); - Vector3 position = new Vector3((byte[]) request.Params[2], 0); - Vector3 velocity = new Vector3((byte[]) request.Params[3], 0); - bool flying = (bool) request.Params[4]; - - LocalUpdatePhysics(regionPort, scenePresenceID, position, velocity, flying); - - return new XmlRpcResponse(); - } - - private void LocalUpdatePhysics(int regionPort, UUID scenePresenceID, Vector3 position, Vector3 velocity, bool flying) - { - //m_log.Info("[SPLITSCENE] "+String.Format("UpdatePhysics called {0}", regionID)); - - //m_log.Info("[SPLITSCENE] "+"LocalUpdatePhysics [region port:{0}, client:{1}, position:{2}, velocity:{3}, flying:{4}]", - // regionPort, scenePresenceID.ToString(), position.ToString(), - // velocity.ToString(), flying); - - RegionInfo region = SearchRegionFromPortNum(regionPort); - - // Find and update the scene precense - Scene scene; - if (sceneManager.TryGetScene(region.RegionID, out scene)) - { - ScenePresence pre = scene.GetScenePresences().Find(delegate(ScenePresence x) { return x.UUID == scenePresenceID; }); - - if (pre == null) - { - m_log.ErrorFormat("[SPLITSCENE] [LocalUpdatePhysics] ScenePresence is missing... ({0})", scenePresenceID.ToString()); - return; - } - -// m_log.Info("[SPLITSCENE] "+"LocalUpdatePhysics [region:{0}, client:{1}]", -// regionID.ToString(), pre.ToString()); - - pre.AbsolutePosition = position; // will set PhysicsActor.Position - pre.Velocity = velocity; // will set PhysicsActor.Velocity - pre.PhysicsActor.Flying = flying; - } - } - - private void SynchronizeScenes(Scene scene) - { - if (!isSplit) - { - return; - } - - lock (padlock) - { - // Callback activated after a physics scene update -// int i = 0; - List presences = scene.GetScenePresences(); - foreach (ScenePresence pre in presences) - { - LLClientView client = (LLClientView) pre.ControllingClient; - - // Because data changes by the physics simulation when the client doesn't move, - // if MovementFlag is false, It is necessary to synchronize. - //if (pre.MovementFlag!=0 && client.PacketProcessingEnabled==true) - if (client.IsActive) - { - //m_log.Info("[SPLITSCENE] "+String.Format("Client moving in {0} {1}", scene.RegionInfo.RegionID, pre.AbsolutePosition)); - - for (int i = 0; i < sceneURL.Length; i++) - { - if (i == scene.splitID) - { - continue; - } - - if (isLocalNeighbour[i]) - { - //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Local) [region:{0}=>{1}, client:{2}]", - // scene.RegionInfo.RegionID, regionPortList[i], pre.ToString()); - LocalUpdatePhysics(regionPortList[i], pre.UUID, pre.AbsolutePosition, pre.Velocity, pre.PhysicsActor.Flying); - } - else - { - //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Remote) [region port:{0}, client:{1}, position:{2}, velocity:{3}, flying:{4}]", - // regionPortList[i], pre.ToString(), pre.AbsolutePosition.ToString(), - // pre.Velocity.ToString(), pre.PhysicsActor.Flying); - - - Util.XmlRpcCommand(sceneURL[i], "UpdatePhysics", - regionPortList[i], pre.UUID.GetBytes(), - pre.AbsolutePosition.GetBytes(), pre.Velocity.GetBytes(), - pre.PhysicsActor.Flying); - -/* - byte[] buff = new byte[12+12+1]; - - Buffer.BlockCopy(pre.AbsolutePosition.GetBytes(), 0, buff, 0, 12); - Buffer.BlockCopy(pre.Velocity.GetBytes(), 0, buff, 12, 12); - buff[24] = (byte)((pre.PhysicsActor.Flying)?1:0); - - // create header - InternalPacketHeader header = new InternalPacketHeader(); - - header.type = 1; - header.throttlePacketType = 0; - header.numbytes = buff.Length; - header.agent_id = pre.UUID.Guid; - header.region_port = regionPortList[i]; - - //Send - tcpClientList[i].send(header, buff); -*/ - } - } - } -// ++i; - } - } - } - - public bool SynchronizePackets(IScene scene, Packet packet, UUID agentID, ThrottleOutPacketType throttlePacketType) - { - if (!isSplit) - { - return false; - } - - Scene localScene = (Scene) scene; - - for (int i = 0; i < sceneURL.Length; i++) - { - if (i == localScene.splitID) - { - continue; - } - - if (isLocalNeighbour[i]) - { - //m_log.Info("[SPLITSCENE] "+"Synchronize Packet (Local) [type:{0}, client:{1}]", - // packet.Type.ToString(), agentID.ToString()); - LocalUpdatePacket(regionPortList[i], agentID, packet, throttlePacketType); - } - else - { - //m_log.Info("[SPLITSCENE] "+"Synchronize Packet (Remote) [type:{0}, client:{1}]", - // packet.Type.ToString(), agentID.ToString()); - // to bytes - byte[] buff = packet.ToBytes(); - - // create header - InternalPacketHeader header = new InternalPacketHeader(); - - header.type = 0; - header.throttlePacketType = (int) throttlePacketType; - header.numbytes = buff.Length; - header.agent_id = agentID.Guid; - header.region_port = regionPortList[i]; - - //Send - tcpClientList[i].send(header, buff); - - PacketPool.Instance.ReturnPacket(packet); - } - } - - return true; - } - - private void LocalUpdatePacket(int regionPort, UUID agentID, Packet packet, ThrottleOutPacketType throttlePacketType) - { - Scene scene; - - RegionInfo region = SearchRegionFromPortNum(regionPort); - -// m_log.Info("[SPLITSCENE] "+"LocalUpdatePacket [region port:{0}, client:{1}, packet type:{2}]", -// regionPort, agentID.ToString(), packet.GetType().ToString()); - - if (sceneManager.TryGetScene(region.RegionID, out scene)) - { - ScenePresence pre = scene.GetScenePresences().Find(delegate(ScenePresence x) { return x.UUID == agentID; }); - - if (pre == null) - { - m_log.ErrorFormat("[SPLITSCENE] [LocalUpdatePacket] ScenePresence is missing... ({0})", agentID.ToString()); - return; - } - if (pre.ControllingClient is LLClientView) - { - if (((LLClientView)pre.ControllingClient).IsActive) - { - ((LLClientView)pre.ControllingClient).OutPacket(packet, throttlePacketType); - } - else - { - PacketPool.Instance.ReturnPacket(packet); - } - } - else - { - PacketPool.Instance.ReturnPacket(packet); - } - } - } - - public void SynchronizePacketRecieve(InternalPacketHeader header, byte[] buff) - { -// m_log.Info("[SPLITSCENE] "+"entering SynchronizePacketRecieve[type={0}]", header.type); - - if (!isSplit) - { - return; - } - - switch (header.type) - { - case 0: - - byte[] zero = new byte[3000]; - - // deserialize packet - int packetEnd = buff.Length - 1; -// packetEnd = buff.Length; - - try - { - //m_log.Info("[SPLITSCENE] "+"PacketPool.Instance : {0}", (PacketPool.Instance == null)?"null":"not null"); - //m_log.Info("[SPLITSCENE] "+"buff length={0}", buff.Length); - - Packet packet = PacketPool.Instance.GetPacket(buff, ref packetEnd, zero); - - LocalUpdatePacket(header.region_port, new UUID(header.agent_id), - packet, (ThrottleOutPacketType) header.throttlePacketType); - } - catch (Exception e) - { - m_log.Error("[SPLITSCENE] " + e); - m_log.Error("[SPLITSCENE] " + e.StackTrace); - } - - break; - - case 1: - - int regionPort = header.region_port; - UUID scenePresenceID = new UUID(header.agent_id); - Vector3 position = new Vector3(buff, 0); - Vector3 velocity = new Vector3(buff, 12); - bool flying = ((buff[24] == 1) ? true : false); - - LocalUpdatePhysics(regionPort, scenePresenceID, position, velocity, flying); - - break; - - default: - m_log.Info("[SPLITSCENE] " + "Invalid type"); - break; - } - -// m_log.Info("[SPLITSCENE] "+"exiting SynchronizePacketRecieve"); - } - } -} diff --git a/ThirdParty/3Di/LoadBalancer/Resources/LoadBalancer.addin.xml b/ThirdParty/3Di/LoadBalancer/Resources/LoadBalancer.addin.xml deleted file mode 100644 index ac6ac15..0000000 --- a/ThirdParty/3Di/LoadBalancer/Resources/LoadBalancer.addin.xml +++ /dev/null @@ -1,12 +0,0 @@ - - - - - - - - - - - - diff --git a/ThirdParty/3Di/LoadBalancer/TcpClient.cs b/ThirdParty/3Di/LoadBalancer/TcpClient.cs deleted file mode 100644 index 1acba24..0000000 --- a/ThirdParty/3Di/LoadBalancer/TcpClient.cs +++ /dev/null @@ -1,225 +0,0 @@ -/* - * Copyright (c) Contributors, http://opensimulator.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.IO; -using System.Net; -using System.Net.Sockets; -using System.Threading; - -namespace OpenSim.ApplicationPlugins.LoadBalancer -{ - public class AsynchronousClient - { - private static ManualResetEvent connectDone = new ManualResetEvent(false); - private static ManualResetEvent sendDone = new ManualResetEvent(false); - - public static Socket StartClient(string hostname, int port) - { - try - { - IPHostEntry ipHostInfo = Dns.GetHostEntry(hostname); - IPAddress ipAddress = ipHostInfo.AddressList[0]; - IPEndPoint remoteEP = new IPEndPoint(ipAddress, port); - - Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); - client.BeginConnect(remoteEP, new AsyncCallback(ConnectCallback), client); - connectDone.WaitOne(); - /* - Send(client,"This is a test"); - sendDone.WaitOne(); - Receive(client); - receiveDone.WaitOne(); - client.Shutdown(SocketShutdown.Both); - client.Close(); - */ - return client; - } - catch (Exception e) - { - Console.WriteLine(e.ToString()); - throw new Exception("socket error !!"); - } - } - - private static void ConnectCallback(IAsyncResult ar) - { - try - { - Socket client = (Socket) ar.AsyncState; - client.EndConnect(ar); - Console.WriteLine("Socket connected to {0}", client.RemoteEndPoint.ToString()); - connectDone.Set(); - } - catch (Exception e) - { - Console.WriteLine(e.ToString()); - } - } - - public static void Send(Socket client, byte[] byteData) - { - client.BeginSend(byteData, 0, byteData.Length, 0, new AsyncCallback(SendCallback), client); - } - - private static void SendCallback(IAsyncResult ar) - { - try - { - Socket client = (Socket) ar.AsyncState; - int bytesSent = client.EndSend(ar); - if (bytesSent > 0) - { - //Console.WriteLine("Sent {0} bytes to server.", bytesSent); - } - sendDone.Set(); - } - catch (Exception e) - { - Console.WriteLine(e.ToString()); - } - } - } - - public class InternalPacketHeader - { - public Guid agent_id; - private byte[] buffer = new byte[32]; - public int numbytes; - public int region_port; - public int throttlePacketType; - public int type; - - public void FromBytes(byte[] bytes) - { - MemoryStream memstr = new MemoryStream(bytes); - memstr.Seek(0, SeekOrigin.Begin); - BinaryReader binread = new BinaryReader(memstr); - - type = binread.ReadInt32(); - throttlePacketType = binread.ReadInt32(); - numbytes = binread.ReadInt32(); - agent_id = new Guid(binread.ReadBytes(16)); - region_port = binread.ReadInt32(); - - binread.Close(); - } - - public byte[] ToBytes() - { - int i = 0; - buffer[i++] = (byte) (type % 256); - buffer[i++] = (byte) ((type >> 8) % 256); - buffer[i++] = (byte) ((type >> 16) % 256); - buffer[i++] = (byte) ((type >> 24) % 256); - - buffer[i++] = (byte) (throttlePacketType % 256); - buffer[i++] = (byte) ((throttlePacketType >> 8) % 256); - buffer[i++] = (byte) ((throttlePacketType >> 16) % 256); - buffer[i++] = (byte) ((throttlePacketType >> 24) % 256); - - buffer[i++] = (byte) (numbytes % 256); - buffer[i++] = (byte) ((numbytes >> 8) % 256); - buffer[i++] = (byte) ((numbytes >> 16) % 256); - buffer[i++] = (byte) ((numbytes >> 24) % 256); - - // no endian care - Buffer.BlockCopy(agent_id.ToByteArray(), 0, buffer, i, 16); - i += 16; - - buffer[i++] = (byte) (region_port % 256); - buffer[i++] = (byte) ((region_port >> 8) % 256); - buffer[i++] = (byte) ((region_port >> 16) % 256); - buffer[i++] = (byte) ((region_port >> 24) % 256); - - return buffer; - } - } - - public class TcpClient - { - public static int internalPacketHeaderSize = 4 * 4 + 16 * 1; - private Socket mConnection; - - private string mHostname; - private int mPort; - - public TcpClient(string hostname, int port) - { - mHostname = hostname; - mPort = port; - mConnection = null; - } - - public void connect() - { - mConnection = AsynchronousClient.StartClient(mHostname, mPort); - } - -/* - public void receive() - { - if (mConnection == null) - { - throw new Exception("client not initialized"); - } - try - { - AsynchronousClient.Receive(this.mConnection); - } - catch (Exception e) - { - Console.WriteLine(e.ToString()); - mConnection = null; - } - } -*/ - - public void send(InternalPacketHeader header, byte[] packet) - { - lock (this) - { - if (mConnection == null) - { -// throw new Exception("client not initialized"); - connect(); - } - - AsynchronousClient.Send(mConnection, header.ToBytes()); - -/* -for (int i = 0; i < 10; i++) -{ - Console.Write(packet[i] + " "); -} -Console.WriteLine(""); -*/ - AsynchronousClient.Send(mConnection, packet); - } - } - } -} \ No newline at end of file diff --git a/ThirdParty/3Di/LoadBalancer/TcpServer.cs b/ThirdParty/3Di/LoadBalancer/TcpServer.cs deleted file mode 100644 index 376c0a5..0000000 --- a/ThirdParty/3Di/LoadBalancer/TcpServer.cs +++ /dev/null @@ -1,219 +0,0 @@ -/* - * Copyright (c) Contributors, http://opensimulator.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.IO; -using System.Net; -using System.Net.Sockets; -using System.Threading; - -namespace OpenSim.ApplicationPlugins.LoadBalancer -{ - public class StateObject - { - public const int BufferSize = 2048; - public byte[] buffer = new byte[BufferSize]; - public InternalPacketHeader header = null; - public MemoryStream ms_ptr = new MemoryStream(); - public Socket workSocket = null; - } - - public class AsynchronousSocketListener - { - public static ManualResetEvent allDone = new ManualResetEvent(false); - public static string data = null; - - #region KIRYU - - #region Delegates - - public delegate void PacketRecieveHandler(InternalPacketHeader header, byte[] buff); - - #endregion - - public static PacketRecieveHandler PacketHandler = null; - - #endregion - - public AsynchronousSocketListener() - { - } - - public static void StartListening(int port) - { - IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName()); - IPAddress ipAddress = ipHostInfo.AddressList[0]; - IPEndPoint localEndPoint = new IPEndPoint(ipAddress, port); - - Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); - try - { - listener.Bind(localEndPoint); - listener.Listen(100); - while (true) - { - allDone.Reset(); - listener.BeginAccept(new AsyncCallback(AcceptCallback), listener); - allDone.WaitOne(); - } - } - catch (Exception e) - { - Console.WriteLine(e.ToString()); - } - /* - Console.WriteLine("\nPress ENTER to continue..."); - Console.Read(); - */ - } - - public static void AcceptCallback(IAsyncResult ar) - { - allDone.Set(); - Socket listener = (Socket) ar.AsyncState; - Socket handler = listener.EndAccept(ar); - StateObject state = new StateObject(); - state.workSocket = handler; - handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReadCallback), state); - } - - public static void ReadCallback(IAsyncResult ar) - { - StateObject state = (StateObject) ar.AsyncState; - Socket handler = state.workSocket; - - try - { - int bytesRead = handler.EndReceive(ar); - - //MainLog.Instance.Verbose("TCPSERVER", "Received packet [{0}]", bytesRead); - - if (bytesRead > 0) - { - state.ms_ptr.Write(state.buffer, 0, bytesRead); - } - else - { - //MainLog.Instance.Verbose("TCPSERVER", "Connection terminated"); - return; - } - - long rest_size = state.ms_ptr.Length; - long current_pos = 0; - while (rest_size > TcpClient.internalPacketHeaderSize) - { - if ((state.header == null) && (rest_size >= TcpClient.internalPacketHeaderSize)) - { - //MainLog.Instance.Verbose("TCPSERVER", "Processing header"); - - // reading header - state.header = new InternalPacketHeader(); - - byte[] headerbytes = new byte[TcpClient.internalPacketHeaderSize]; - state.ms_ptr.Position = current_pos; - state.ms_ptr.Read(headerbytes, 0, TcpClient.internalPacketHeaderSize); - state.ms_ptr.Seek(0, SeekOrigin.End); - state.header.FromBytes(headerbytes); - } - - if ((state.header != null) && (rest_size >= state.header.numbytes + TcpClient.internalPacketHeaderSize)) - { - //MainLog.Instance.Verbose("TCPSERVER", "Processing body"); - - // reading body - byte[] packet = new byte[state.header.numbytes]; - state.ms_ptr.Position = current_pos + TcpClient.internalPacketHeaderSize; - state.ms_ptr.Read(packet, 0, state.header.numbytes); - -/* - for (int i=0; i