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

Added sendDisconnectPacket function to D2GS TestClient

Browse Source
This commit is contained in:
Collin Smith
2020-06-27 17:06:03 -07:00
parent 26173a8fd1
commit 88b8e7a096
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
server/netty/src/com/riiablo/server/d2gs/TestClient.java
View File

@ -26,6 +26,7 @@ import com.riiablo.net.EndpointedChannelHandler;
import com.riiablo.net.PacketProcessor; import com.riiablo.net.PacketProcessor;
import com.riiablo.net.UnicastEndpoint; import com.riiablo.net.UnicastEndpoint;
import com.riiablo.net.packet.netty.Connection; import com.riiablo.net.packet.netty.Connection;
import com.riiablo.net.packet.netty.Disconnect;
import com.riiablo.net.packet.netty.Netty; import com.riiablo.net.packet.netty.Netty;
import com.riiablo.net.packet.netty.NettyData; import com.riiablo.net.packet.netty.NettyData;
import com.riiablo.net.reliable.QoS; import com.riiablo.net.reliable.QoS;
@ -70,6 +71,7 @@ public class TestClient extends ApplicationAdapter implements PacketProcessor {
ChannelFuture f = b.connect("localhost", Main.PORT).sync(); ChannelFuture f = b.connect("localhost", Main.PORT).sync();
sendConnectionPacket(); sendConnectionPacket();
sendConnectionPacket(); sendConnectionPacket();
sendDisconnectPacket();
} catch (Throwable t) { } catch (Throwable t) {
Gdx.app.error(TAG, t.getMessage(), t); Gdx.app.error(TAG, t.getMessage(), t);
Gdx.app.exit(); Gdx.app.exit();
@ -91,6 +93,19 @@ public class TestClient extends ApplicationAdapter implements PacketProcessor {
endpoint.sendMessage(QoS.Unreliable, builder.dataBuffer()); endpoint.sendMessage(QoS.Unreliable, builder.dataBuffer());
} }
private void sendDisconnectPacket() {
SocketAddress remoteAddress = endpoint.channel().remoteAddress();
Gdx.app.log(TAG, "Sending Disconnect packet to " + remoteAddress);
FlatBufferBuilder builder = new FlatBufferBuilder();
Disconnect.startDisconnect(builder);
int dataOffset = Disconnect.endDisconnect(builder);
int offset = Netty.createNetty(builder, 0L, NettyData.Disconnect, dataOffset);
Netty.finishSizePrefixedNettyBuffer(builder, offset);
endpoint.sendMessage(QoS.Unreliable, builder.dataBuffer());
}
@Override @Override
public void render() { public void render() {
endpoint.update(Gdx.graphics.getDeltaTime()); endpoint.update(Gdx.graphics.getDeltaTime());