diff --git a/scripts/net/Peer.cs b/scripts/net/Peer.cs index baefb6d..a69e682 100644 --- a/scripts/net/Peer.cs +++ b/scripts/net/Peer.cs @@ -42,7 +42,6 @@ namespace Network { LastConnectionSended = to.ID; } PacketPeer.PutPacket(packetBuffer.ByteBuffer); - GD.print("Putting stuff to " + to.Address + ":" + to.Port); } public bool StartListening(int port, string address = "*") { diff --git a/scripts/net/syncing/ConnectionHandler.cs b/scripts/net/syncing/ConnectionHandler.cs index 8947340..c23137b 100644 --- a/scripts/net/syncing/ConnectionHandler.cs +++ b/scripts/net/syncing/ConnectionHandler.cs @@ -27,14 +27,18 @@ namespace Network.Syncing { Connection = connection; } - public void SerializeAndSendQueues() { + public void SerializeAndSendQueues(int UnreliableSyncID) { PacketBuffer Buffer = PacketBuffer.WithSignature(); + SyncPkt Sync = new SyncPkt(); + Sync.Reliable = false; + Sync.ID = UnreliableSyncID; Sync.Serialize(Buffer); // Add Queues + GD.print("Sending sync-" + Sync.ID); Peer.SendBuffer(Buffer, Connection); } diff --git a/scripts/net/syncing/PacketDistributor.cs b/scripts/net/syncing/PacketDistributor.cs index 2d30e7c..9a3cd3f 100644 --- a/scripts/net/syncing/PacketDistributor.cs +++ b/scripts/net/syncing/PacketDistributor.cs @@ -23,12 +23,14 @@ namespace Network.Syncing { } public void Update(float delta) { + //GD.print("Update! + " + delta); TimeSinceLastSync += delta; if (TimeSinceLastSync > Interval) { TimeSinceLastSync = 0; foreach (ConnectionHandler Handler in HandlerList) { - Handler.SerializeAndSendQueues(); + GD.print("Sending to " + Handler.Connection.Name); + Handler.SerializeAndSendQueues(UnreliableIDCounter++); } } }