diff options
Diffstat (limited to 'ThirdParty/3Di/LoadBalancer')
-rw-r--r-- | ThirdParty/3Di/LoadBalancer/TcpClient.cs | 30 |
1 files changed, 12 insertions, 18 deletions
diff --git a/ThirdParty/3Di/LoadBalancer/TcpClient.cs b/ThirdParty/3Di/LoadBalancer/TcpClient.cs index ddd40cc..c794def 100644 --- a/ThirdParty/3Di/LoadBalancer/TcpClient.cs +++ b/ThirdParty/3Di/LoadBalancer/TcpClient.cs | |||
@@ -26,6 +26,7 @@ | |||
26 | */ | 26 | */ |
27 | 27 | ||
28 | using System; | 28 | using System; |
29 | using System.IO; | ||
29 | using System.Net; | 30 | using System.Net; |
30 | using System.Net.Sockets; | 31 | using System.Net.Sockets; |
31 | using System.Threading; | 32 | using System.Threading; |
@@ -115,24 +116,17 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
115 | 116 | ||
116 | public void FromBytes(byte[] bytes) | 117 | public void FromBytes(byte[] bytes) |
117 | { | 118 | { |
118 | int i = 0; // offset | 119 | MemoryStream memstr = new MemoryStream(bytes); |
119 | try | 120 | memstr.Seek(0, SeekOrigin.Begin); |
120 | { | 121 | BinaryReader binread = new BinaryReader(memstr); |
121 | type = (int) (bytes[i++] + (bytes[i++] << 8) + (bytes[i++] << 16) + (bytes[i++] << 24)); | 122 | |
122 | throttlePacketType = (int) (bytes[i++] + (bytes[i++] << 8) + (bytes[i++] << 16) + (bytes[i++] << 24)); | 123 | type = binread.ReadInt32(); |
123 | numbytes = (int) (bytes[i++] + (bytes[i++] << 8) + (bytes[i++] << 16) + (bytes[i++] << 24)); | 124 | throttlePacketType = binread.ReadInt32(); |
124 | agent_id = new Guid( | 125 | numbytes = binread.ReadInt32(); |
125 | bytes[i++] | (bytes[i++] << 8) | (bytes[i++] << 16) | bytes[i++] << 24, | 126 | agent_id = new Guid(binread.ReadBytes(16)); |
126 | (short) (bytes[i++] | (bytes[i++] << 8)), | 127 | region_port = binread.ReadInt32(); |
127 | (short) (bytes[i++] | (bytes[i++] << 8)), | 128 | |
128 | bytes[i++], bytes[i++], bytes[i++], bytes[i++], | 129 | binread.Close(); |
129 | bytes[i++], bytes[i++], bytes[i++], bytes[i++]); | ||
130 | region_port = (int) (bytes[i++] + (bytes[i++] << 8) + (bytes[i++] << 16) + (bytes[i++] << 24)); | ||
131 | } | ||
132 | catch (Exception) | ||
133 | { | ||
134 | throw new Exception("bad format!!!"); | ||
135 | } | ||
136 | } | 130 | } |
137 | 131 | ||
138 | public byte[] ToBytes() | 132 | public byte[] ToBytes() |