mirrors/riiablo
1
0
Fork 0
mirror of https://github.com/collinsmith/riiablo.git synced 2025-07-13 09:17:52 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Filled in UnreliableOrderedMessageChannel

Browse Source
This commit is contained in:
Collin Smith
2020-06-23 21:45:06 -07:00
parent 53a1a6f117
commit 1426b87534
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
server/netty/src/com/riiablo/net/reliable/channel/UnreliableOrderedMessageChannel.java
View File

@ -7,7 +7,9 @@ import io.netty.channel.socket.DatagramPacket;
import com.riiablo.net.reliable.Log; import com.riiablo.net.reliable.Log;
import com.riiablo.net.reliable.MessageChannel; import com.riiablo.net.reliable.MessageChannel;
import com.riiablo.net.reliable.Packet;
import com.riiablo.net.reliable.ReliableConfiguration; import com.riiablo.net.reliable.ReliableConfiguration;
import com.riiablo.net.reliable.ReliableUtils;
public class UnreliableOrderedMessageChannel extends MessageChannel { public class UnreliableOrderedMessageChannel extends MessageChannel {
private static final String TAG = "UnreliableOrderedMessageChannel"; private static final String TAG = "UnreliableOrderedMessageChannel";
@ -16,18 +18,21 @@ public class UnreliableOrderedMessageChannel extends MessageChannel {
private static final boolean DEBUG_SEND = DEBUG && true; private static final boolean DEBUG_SEND = DEBUG && true;
private static final boolean DEBUG_RECEIVE = DEBUG && true; private static final boolean DEBUG_RECEIVE = DEBUG && true;
private int nextSequence = 0;
public UnreliableOrderedMessageChannel(PacketTransceiver packetTransceiver) { public UnreliableOrderedMessageChannel(PacketTransceiver packetTransceiver) {
super(new ReliableConfiguration(), packetTransceiver); super(new ReliableConfiguration(), packetTransceiver);
} }
@Override @Override
public void reset() { public void reset() {
nextSequence = 0;
packetController.reset();
} }
@Override @Override
public void update(long time, DatagramChannel ch) { public void update(long time, DatagramChannel ch) {
packetController.update(time);
} }
@Override @Override
@ -44,11 +49,14 @@ public class UnreliableOrderedMessageChannel extends MessageChannel {
@Override @Override
public void onPacketTransmitted(ByteBuf bb) { public void onPacketTransmitted(ByteBuf bb) {
packetTransceiver.sendPacket(bb);
} }
@Override @Override
public void onPacketProcessed(int sequence, ByteBuf bb) { public void onPacketProcessed(int sequence, ByteBuf bb) {
if (sequence == nextSequence || ReliableUtils.sequenceGreaterThan(sequence, nextSequence)) {
nextSequence = (sequence + 1) & Packet.USHORT_MAX_VALUE;
packetTransceiver.receivePacket(bb);
}
} }
} }