mirrors/riiablo
1
0
Fork 0
mirror of https://github.com/collinsmith/riiablo.git synced 2025-07-04 15:27:30 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Created PacketSender abstraction to send Flatbuffer data using any protocol

Browse Source
This commit is contained in:
Collin Smith
2020-06-24 12:19:31 -07:00
parent 919281e814
commit 2f066cbd0f
2 changed files with 17 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/netty/src/com/riiablo/net/PacketSender.java Normal file
View File

@ -0,0 +1,8 @@
package com.riiablo.net;
import java.nio.ByteBuffer;
public interface PacketSender<T> {
void sendMessage(ByteBuffer bb);
void sendMessage(T qos, ByteBuffer bb);
}

10
server/netty/src/com/riiablo/net/reliable/ReliableEndpoint.java
View File

@ -10,12 +10,13 @@ import java.nio.ByteBuffer;
import org.apache.commons.lang3.Validate; import org.apache.commons.lang3.Validate;
import com.riiablo.net.PacketProcessor; import com.riiablo.net.PacketProcessor;
import com.riiablo.net.PacketSender;
import com.riiablo.net.reliable.channel.ReliableMessageChannel; import com.riiablo.net.reliable.channel.ReliableMessageChannel;
import com.riiablo.net.reliable.channel.UnreliableMessageChannel; import com.riiablo.net.reliable.channel.UnreliableMessageChannel;
import com.riiablo.net.reliable.channel.UnreliableOrderedMessageChannel; import com.riiablo.net.reliable.channel.UnreliableOrderedMessageChannel;
import com.riiablo.util.EnumIntMap; import com.riiablo.util.EnumIntMap;
public class ReliableEndpoint implements MessageChannel.PacketTransceiver { public class ReliableEndpoint implements PacketSender<QoS>, MessageChannel.PacketTransceiver {
private static final String TAG = "ReliableEndpoint"; private static final String TAG = "ReliableEndpoint";
private static final boolean DEBUG = true; private static final boolean DEBUG = true;
@ -62,6 +63,13 @@ public class ReliableEndpoint implements MessageChannel.PacketTransceiver {
for (MessageChannel mc : channels) if (mc != null) mc.update(delta, channel); for (MessageChannel mc : channels) if (mc != null) mc.update(delta, channel);
} }
@Override
public void sendMessage(ByteBuffer bb) {
if (DEBUG_SEND) Log.debug(TAG, "sendMessage (auto)");
sendMessage(QoS.Reliable, bb);
}
@Override
public void sendMessage(QoS qos, ByteBuffer bb) { public void sendMessage(QoS qos, ByteBuffer bb) {
if (DEBUG_SEND) Log.debug(TAG, "sendMessage"); if (DEBUG_SEND) Log.debug(TAG, "sendMessage");
if (DEBUG_QOS) Log.debug(TAG, "sending message with %s QoS (0x%02x)", qos, qos.ordinal()); if (DEBUG_QOS) Log.debug(TAG, "sending message with %s QoS (0x%02x)", qos, qos.ordinal());