mirrors/riiablo
1
0
Fork 0
mirror of https://github.com/collinsmith/riiablo.git synced 2025-01-19 16:57:20 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Filled in some of anonymous PacketHandler within Main to process some packet types

Browse Source
This commit is contained in:
Collin Smith 2020-06-17 21:54:08 -07:00
parent 02a6cd4b56
commit fc66d120d7
2 changed files with 28 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
server/netty/src/com/riiablo/server/netty/Main.java
View File

@ -26,9 +26,12 @@ import com.badlogic.gdx.backends.headless.HeadlessApplicationConfiguration;
import com.riiablo.Riiablo;
import com.riiablo.codec.Animation;
import com.riiablo.net.packet.netty.Connection;
import com.riiablo.net.packet.netty.Disconnect;
import com.riiablo.net.packet.netty.Header;
import com.riiablo.net.packet.netty.Netty;
import com.riiablo.net.packet.netty.NettyData;
import com.riiablo.net.packet.netty.Ping;
public class Main extends ApplicationAdapter {
private static final String TAG = "Server";
@ -75,11 +78,35 @@ public class Main extends ApplicationAdapter {
protected void initChannel(DatagramChannel ch) {
ch.pipeline()
.addLast(new PacketHandler() {
final String TAG = "abstract PacketHandler";
final String TAG = "PacketHandler$1";
@Override
protected void processPacket(ChannelHandlerContext ctx, Netty netty) {
Gdx.app.debug(TAG, "Processing packet...");
byte dataType = netty.dataType();
if (0 <= dataType && dataType < NettyData.names.length) {
Gdx.app.debug(TAG, "dataType=" + NettyData.name(dataType));
}
switch (dataType) {
case NettyData.Connection: {
Connection packet = (Connection) netty.data(new Connection());
break;
}
case NettyData.Disconnect: {
Disconnect packet = (Disconnect) netty.data(new Disconnect());
break;
}
case NettyData.Ping: {
Ping ping = (Ping) netty.data(new Ping());
break;
}
default:
if (0 <= dataType && dataType < NettyData.names.length) {
Gdx.app.error(TAG, "Ignoring packet /w data type " + dataType + " (" + NettyData.name(dataType) + ")");
} else {
Gdx.app.error(TAG, "Ignoring packet /w data type " + dataType);
}
}
}
})
;

2
server/netty/src/com/riiablo/server/netty/PacketHandler.java
View File

@ -13,7 +13,6 @@ import com.badlogic.gdx.Gdx;
import com.riiablo.net.packet.netty.Header;
import com.riiablo.net.packet.netty.Netty;
import com.riiablo.net.packet.netty.NettyData;
public abstract class PacketHandler implements ChannelInboundHandler {
private static final String TAG = "PacketHandler";
@ -35,7 +34,6 @@ public abstract class PacketHandler implements ChannelInboundHandler {
try {
ByteBuffer buffer = in.nioBuffer();
Packet packet = Packet.obtain(0, buffer);
Gdx.app.log(TAG, " " + NettyData.name(packet.data.dataType()));
processHeader(ctx, packet.data.header());
processPacket(ctx, packet.data);
} finally {