mirrors/riiablo
1
0
Fork 0
mirror of https://github.com/collinsmith/riiablo.git synced 2025-03-02 21:53:21 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added time field

Browse Source
This commit is contained in:
Collin Smith 2020-06-23 20:33:05 -07:00
parent 24eb6f1c9b
commit c268d69ff9
2 changed files with 4 additions and 6 deletions
server/netty/src/com/riiablo/net/reliable
PacketData.javaReliablePacketController.java

4
server/netty/src/com/riiablo/net/reliable/PacketData.java
View File

@ -1,4 +0,0 @@
package com.riiablo.net.reliable;
public interface PacketData {
}

6
server/netty/src/com/riiablo/net/reliable/ReliablePacketController.java
View File

@ -23,6 +23,8 @@ public class ReliablePacketController {
private final SequenceBuffer<ReceivedPacketData> receivedPackets; private final SequenceBuffer<ReceivedPacketData> receivedPackets;
private final SequenceBuffer<FragmentReassemblyData> fragmentReassembly; private final SequenceBuffer<FragmentReassemblyData> fragmentReassembly;
private long time;
public ReliablePacketController(ReliableConfiguration config, MessageChannel channel) { public ReliablePacketController(ReliableConfiguration config, MessageChannel channel) {
this.config = config; this.config = config;
this.channel = channel; this.channel = channel;
@ -45,7 +47,7 @@ public class ReliablePacketController {
} }
public void update(long time) { public void update(long time) {
this.time = time;
} }
public void sendAck(int channelId, DatagramChannel ch) { public void sendAck(int channelId, DatagramChannel ch) {
@ -70,7 +72,7 @@ public class ReliablePacketController {
} }
SentPacketData sentPacketData = sentPackets.insert(sequence); SentPacketData sentPacketData = sentPackets.insert(sequence);
// sentPacketData.time = this.time; sentPacketData.time = this.time;
// sentPacketData.packetSize = // sentPacketData.packetSize =
sentPacketData.acked = false; sentPacketData.acked = false;