{
const string TestData = "pwerowerower";
- using (UdpBroadcaster caster = new UdpBroadcaster(4777))
- using (UdpBroadcastListener listener = new UdpBroadcastListener(4777))
+ using (UdpBroadcaster caster = new UdpBroadcaster(47777))
+ using (UdpBroadcastListener listener = new UdpBroadcastListener(47777))
{
listener.StartListen();
[TestMethod]
public void Test()
{
- sbyte s = -1;
- Assert.AreEqual(255, (byte)s);
- byte b = 255;
- Assert.AreEqual(-1, (sbyte)b);
+ string dataStr = "4 0 5 32 0 0 0 6 0 1 5";
+ byte[] data = dataStr.Split(' ').Select(b => byte.Parse(b)).ToArray();
+ MessageReader readerParent1 = MessageReader.Get(data);
+ while (readerParent1.Position < readerParent1.Length)
+ {
+ var readerParent = readerParent1.ReadMessage(); // Loop of InnerNetClient
+ while (readerParent.Position < readerParent.Length)
+ {
+
+ Console.WriteLine($"{readerParent.Tag} = {readerParent.Length}");
+ switch (readerParent.Tag)
+ {
+ case 1:
+ {
+ int gameIdConfirm = readerParent.ReadInt32();
+ break;
+ }
+ case 5:
+ {
+ int gameIdConfirm = readerParent.ReadInt32();
+ HandleGameData(readerParent);
+ break;
+ }
+ case 6:
+ {
+ int gameIdConfirm = readerParent.ReadInt32();
+ int targetId = readerParent.ReadPackedInt32(); // Skip target id
+ HandleGameData(readerParent);
+ }
+ break;
+ }
+ }
+ }
+ }
+
+ private static void HandleGameData(MessageReader readerParent)
+ {
+ while (readerParent.Position < readerParent.Length)
+ {
+ var reader = readerParent.ReadMessage();
+
+ switch (reader.Tag)
+ {
+ case 4:
+ {
+ Console.WriteLine($"\t{reader.Tag} = SpawnId: {reader.ReadPackedUInt32()}");
+ Console.WriteLine($"\t{reader.Tag} = OwnerId: {reader.ReadPackedInt32()}");
+ Console.WriteLine($"\t{reader.Tag} = Flags: {reader.ReadByte()}");
+ var numChildren = reader.ReadPackedInt32();
+ Console.WriteLine($"\t{reader.Tag} = NumChildren: {numChildren}");
+ for (int i = 0; i < numChildren; ++i)
+ {
+ Console.WriteLine($"\t{reader.Tag} = NetId: {reader.ReadPackedUInt32()}");
+ var datam = reader.ReadMessage();
+ Console.WriteLine($"\t{reader.Tag} = Data: {string.Join(" ", datam.ReadBytes(datam.Length))}");
+ }
+ break;
+ }
+ default:
+ {
+ Console.WriteLine($"\t{reader.Tag} = {string.Join(" ", reader.ReadBytes(reader.Length))}");
+ }
+ break;
+ }
+
+ Console.WriteLine();
+ }
}
}
}
\ No newline at end of file
[TestClass]
public class MessageWriterTests
{
+
+ [TestMethod]
+ public void CancelMessages()
+ {
+ var msg = new MessageWriter(128);
+
+ msg.StartMessage(1);
+ msg.Write(32);
+
+ msg.StartMessage(2);
+ msg.Write(2);
+ msg.CancelMessage();
+
+ Assert.AreEqual(7, msg.Length);
+ Assert.IsFalse(msg.HasBytes(7));
+
+ msg.CancelMessage();
+
+ Assert.AreEqual(0, msg.Length);
+ Assert.IsFalse(msg.HasBytes(1));
+ }
+
+ [TestMethod]
+ public void HasBytes()
+ {
+ var msg = new MessageWriter(128);
+
+ msg.StartMessage(1);
+ msg.Write(32);
+
+ msg.StartMessage(2);
+ msg.Write(2);
+ msg.EndMessage();
+
+ // Assert.AreEqual(7, msg.Length);
+ Assert.IsTrue(msg.HasBytes(7));
+ }
+
[TestMethod]
public void WriteProperInt()
{
public void CancelMessage()
{
this.Position = this.messageStarts.Pop();
+ this.Length = this.Position;
}
public void Clear(SendOption sendOption)
private List<BroadcastPacket> packets = new List<BroadcastPacket>();
+ public bool Running { get; private set; }
+
///
public UdpBroadcastListener(int port)
{
///
public void StartListen()
{
- if (this.socket == null) return;
+ if (this.Running) return;
+ this.Running = true;
try
{
}
}
- ///
- public void HandleData(IAsyncResult result)
+ private void HandleData(IAsyncResult result)
{
+ this.Running = false;
+
int numBytes;
EndPoint endpt = new IPEndPoint(IPAddress.Any, 0);
try
return;
}
- if (numBytes < 2) return;
- if (buffer[0] != 4 || buffer[1] != 2) return;
+ if (numBytes < 2
+ || buffer[0] != 4 || buffer[1] != 2)
+ {
+ this.StartListen();
+ return;
+ }
IPEndPoint ipEnd = (IPEndPoint)endpt;
string data = ASCIIEncoding.ASCII.GetString(buffer, 2, numBytes - 2);
keepAliveTimer = new Timer(
(o) =>
{
- Trace.WriteLine("Keepalive packet sent.");
- SendHello(null, null);
+ try
+ {
+ SendHello(null, null);
+ Trace.WriteLine("Keepalive packet sent.");
+ }
+ catch
+ {
+ Trace.WriteLine("Keepalive packet failed to send.");
+ DisposeKeepAliveTimer();
+ }
},
null,
keepAliveInterval,
/// <param name="ackCallback">The callback to make once the packet has been acknowledged.</param>
void ReliableSend(byte sendOption, byte[] data, int offset, int length, Action ackCallback = null)
{
+ //Inform keepalive not to send for a while
+ ResetKeepAliveTimer();
+
byte[] bytes = new byte[length + 3];
//Add message type
byte[] buffer = new byte[msg.Length];
Buffer.BlockCopy(msg.Buffer, 0, buffer, 0, msg.Length);
- //Inform keepalive not to send for a while
- ResetKeepAliveTimer();
-
switch (msg.SendOption)
{
case SendOption.Reliable:
+ // Inform keepalive not to send for a while
+ ResetKeepAliveTimer();
AttachReliableID(buffer, 1, buffer.Length);
WriteBytesToConnection(buffer, buffer.Length);
Statistics.LogReliableSend(buffer.Length - 3, buffer.Length);
if (State != ConnectionState.Connected)
throw new InvalidOperationException("Could not send data as this Connection is not connected. Did you disconnect?");
-
- //Inform keepalive not to send for a while
- ResetKeepAliveTimer();
-
switch (sendOption)
{
//Handle reliable header and hellos
/// <returns>The bytes that should actually be sent.</returns>
protected void HandleSend(byte[] data, byte sendOption, Action ackCallback = null)
{
- //Inform keepalive not to send for a while
- ResetKeepAliveTimer();
-
switch (sendOption)
{
//Handle reliable header and hellos
protected internal void HandleReceive(byte[] buffer)
{
InvokeDataReceivedRaw(buffer);
-
- //Inform keepalive not to send for a while
- ResetKeepAliveTimer();
-
+
switch (buffer[0])
{
//Handle reliable receives
/// <inheritdoc />
protected override void Dispose(bool disposing)
{
+ lock (connections)
+ {
+ foreach (var kvp in this.connections)
+ {
+ if (kvp.Value.State == ConnectionState.Connected)
+ {
+ try
+ {
+ kvp.Value.SendDisconnect();
+ }
+ catch { }
+ }
+ }
+
+ connections.Clear();
+ }
+
if (listener != null)
{
listener.Close();
projects / rhonda / impostor.hazel.git / commitdiff