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

Refactored name scheme

Browse Source
This commit is contained in:
Collin Smith
2020-06-17 21:16:04 -07:00
parent a2000a6162
commit ef94883dd7
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
server/netty/src/com/riiablo/server/netty/Client.java
View File

@ -5,7 +5,6 @@ import com.google.flatbuffers.FlatBufferBuilder;
import io.netty.bootstrap.Bootstrap; import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled; import io.netty.buffer.Unpooled;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.channel.ChannelInboundHandlerAdapter;
@ -55,15 +54,15 @@ public class Client extends ApplicationAdapter {
protected void initChannel(DatagramChannel ch) { protected void initChannel(DatagramChannel ch) {
ReliableInboundHandler in = new ReliableInboundHandler(); ReliableInboundHandler in = new ReliableInboundHandler();
ReliableOutboundHandler out = new ReliableOutboundHandler(); ReliableOutboundHandler out = new ReliableOutboundHandler();
final EchoClientHandler echo = new EchoClientHandler(); final ClientHandler client = new ClientHandler();
ch.pipeline() ch.pipeline()
.addLast(in) .addLast(in)
.addLast(echo) .addLast(client)
.addLast(out) .addLast(out)
.addLast(new ChannelInboundHandlerAdapter() { .addLast(new ChannelInboundHandlerAdapter() {
@Override @Override
public void channelActive(ChannelHandlerContext ctx) throws Exception { public void channelActive(ChannelHandlerContext ctx) throws Exception {
echo.init(ctx.channel()); client.init(ctx);
ctx.pipeline().remove(this); ctx.pipeline().remove(this);
} }
}) })
@ -80,13 +79,13 @@ public class Client extends ApplicationAdapter {
} }
} }
public static class EchoClientHandler extends SimpleChannelInboundHandler<DatagramPacket> { public static class ClientHandler extends SimpleChannelInboundHandler<DatagramPacket> {
EchoClientHandler() { ClientHandler() {
super(false); super(false);
} }
void init(Channel ch) { void init(ChannelHandlerContext ctx) {
InetSocketAddress remoteAddress = (InetSocketAddress) ch.remoteAddress(); InetSocketAddress remoteAddress = (InetSocketAddress) ctx.channel().remoteAddress();
Gdx.app.log(TAG, "Connecting to " + remoteAddress.getHostString() + ":" + remoteAddress.getPort()); Gdx.app.log(TAG, "Connecting to " + remoteAddress.getHostString() + ":" + remoteAddress.getPort());
FlatBufferBuilder builder = new FlatBufferBuilder(); FlatBufferBuilder builder = new FlatBufferBuilder();
@ -99,7 +98,7 @@ public class Client extends ApplicationAdapter {
sanity(builder.dataBuffer()); sanity(builder.dataBuffer());
ByteBuf byteBuf = Unpooled.wrappedBuffer(builder.dataBuffer()); ByteBuf byteBuf = Unpooled.wrappedBuffer(builder.dataBuffer());
ch.writeAndFlush(byteBuf); ctx.writeAndFlush(byteBuf);
} }
@Override @Override