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

Added protocol field to netty packet header

Browse Source
This commit is contained in:
Collin Smith 2020-06-19 15:01:01 -07:00
parent 510342e232
commit 101cc92be4
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
core/gen/com/riiablo/net/packet/netty/Header.java
View File

@ -14,25 +14,29 @@ public final class Header extends Table {
public void __init(int _i, ByteBuffer _bb) { bb_pos = _i; bb = _bb; vtable_start = bb_pos - bb.getInt(bb_pos); vtable_size = bb.getShort(vtable_start); } public void __init(int _i, ByteBuffer _bb) { bb_pos = _i; bb = _bb; vtable_start = bb_pos - bb.getInt(bb_pos); vtable_size = bb.getShort(vtable_start); }
public Header __assign(int _i, ByteBuffer _bb) { __init(_i, _bb); return this; } public Header __assign(int _i, ByteBuffer _bb) { __init(_i, _bb); return this; }
public int sequence() { int o = __offset(4); return o != 0 ? bb.getShort(o + bb_pos) & 0xFFFF : 0; } public int protocol() { int o = __offset(4); return o != 0 ? bb.get(o + bb_pos) & 0xFF : 0; }
public int ack() { int o = __offset(6); return o != 0 ? bb.getShort(o + bb_pos) & 0xFFFF : 0; } public int sequence() { int o = __offset(6); return o != 0 ? bb.getShort(o + bb_pos) & 0xFFFF : 0; }
public int ackBits() { int o = __offset(8); return o != 0 ? bb.getInt(o + bb_pos) : 0; } public int ack() { int o = __offset(8); return o != 0 ? bb.getShort(o + bb_pos) & 0xFFFF : 0; }
public int ackBits() { int o = __offset(10); return o != 0 ? bb.getInt(o + bb_pos) : 0; }
public static int createHeader(FlatBufferBuilder builder, public static int createHeader(FlatBufferBuilder builder,
int protocol,
int sequence, int sequence,
int ack, int ack,
int ack_bits) { int ack_bits) {
builder.startObject(3); builder.startObject(4);
Header.addAckBits(builder, ack_bits); Header.addAckBits(builder, ack_bits);
Header.addAck(builder, ack); Header.addAck(builder, ack);
Header.addSequence(builder, sequence); Header.addSequence(builder, sequence);
Header.addProtocol(builder, protocol);
return Header.endHeader(builder); return Header.endHeader(builder);
} }
public static void startHeader(FlatBufferBuilder builder) { builder.startObject(3); } public static void startHeader(FlatBufferBuilder builder) { builder.startObject(4); }
public static void addSequence(FlatBufferBuilder builder, int sequence) { builder.addShort(0, (short)sequence, (short)0); } public static void addProtocol(FlatBufferBuilder builder, int protocol) { builder.addByte(0, (byte)protocol, (byte)0); }
public static void addAck(FlatBufferBuilder builder, int ack) { builder.addShort(1, (short)ack, (short)0); } public static void addSequence(FlatBufferBuilder builder, int sequence) { builder.addShort(1, (short)sequence, (short)0); }
public static void addAckBits(FlatBufferBuilder builder, int ackBits) { builder.addInt(2, ackBits, 0); } public static void addAck(FlatBufferBuilder builder, int ack) { builder.addShort(2, (short)ack, (short)0); }
public static void addAckBits(FlatBufferBuilder builder, int ackBits) { builder.addInt(3, ackBits, 0); }
public static int endHeader(FlatBufferBuilder builder) { public static int endHeader(FlatBufferBuilder builder) {
int o = builder.endObject(); int o = builder.endObject();
return o; return o;

1
core/src/com/riiablo/net/netty/Netty.fbs
View File

@ -3,6 +3,7 @@ include "Packets.fbs";
namespace com.riiablo.net.packet.netty; namespace com.riiablo.net.packet.netty;
table Header { table Header {
protocol:uint8;
sequence:uint16; sequence:uint16;
ack:uint16; ack:uint16;
ack_bits:int32; ack_bits:int32;