Remove code rendered unnecessary in the netty 4 upgrade.

This commit is contained in:
Major-
2014-01-26 21:59:38 +00:00
parent 97c23d5ed8
commit d3ab7919bb
3 changed files with 18 additions and 23 deletions
@@ -13,8 +13,7 @@ import java.util.List;
public final class JagGrabRequestDecoder extends MessageToMessageDecoder<String> {
@Override
protected void decode(ChannelHandlerContext ctx, String msg, List<Object> out) {
String request = (String) msg;
protected void decode(ChannelHandlerContext ctx, String request, List<Object> out) {
if (request.startsWith("JAGGRAB /")) {
String filePath = request.substring(8).trim();
out.add(new JagGrabRequest(filePath));
@@ -89,11 +89,11 @@ public final class LoginDecoder extends StatefulFrameDecoder<LoginDecoderState>
usernameHash = buffer.readUnsignedByte();
serverSeed = random.nextLong();
ByteBuf resp = ctx.alloc().buffer(17);
resp.writeByte(LoginConstants.STATUS_EXCHANGE_DATA);
resp.writeLong(0);
resp.writeLong(serverSeed);
ctx.channel().writeAndFlush(resp);
ByteBuf response = ctx.alloc().buffer(17);
response.writeByte(LoginConstants.STATUS_EXCHANGE_DATA);
response.writeLong(0);
response.writeLong(serverSeed);
ctx.channel().writeAndFlush(response);
setState(LoginDecoderState.LOGIN_HEADER);
}
@@ -16,24 +16,20 @@ import org.apollo.fs.FileDescriptor;
public final class UpdateEncoder extends MessageToMessageEncoder<OnDemandResponse> {
@Override
protected void encode(ChannelHandlerContext ctx, OnDemandResponse msg, List<Object> out) {
if (msg instanceof OnDemandResponse) {
OnDemandResponse response = (OnDemandResponse) msg;
protected void encode(ChannelHandlerContext ctx, OnDemandResponse response, List<Object> out) {
FileDescriptor descriptor = response.getFileDescriptor();
int fileSize = response.getFileSize();
int chunkId = response.getChunkId();
ByteBuf chunkData = response.getChunkData();
FileDescriptor descriptor = response.getFileDescriptor();
int fileSize = response.getFileSize();
int chunkId = response.getChunkId();
ByteBuf chunkData = response.getChunkData();
ByteBuf buffer = ctx.alloc().buffer(6 + chunkData.readableBytes());
buffer.writeByte(descriptor.getType() - 1);
buffer.writeShort(descriptor.getFile());
buffer.writeShort(fileSize);
buffer.writeByte(chunkId);
buffer.writeBytes(chunkData);
ByteBuf buffer = ctx.alloc().buffer(6 + chunkData.readableBytes());
buffer.writeByte(descriptor.getType() - 1);
buffer.writeShort(descriptor.getFile());
buffer.writeShort(fileSize);
buffer.writeByte(chunkId);
buffer.writeBytes(chunkData);
out.add(buffer);
}
out.add(buffer);
}
}