Code polish
This commit is contained in:
parent
682a069c19
commit
353164fac5
|
@ -610,7 +610,7 @@ class ConnectionImpl extends ChannelInboundHandlerAdapter implements Connection_
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
this.logger.info("Closed remote {} connection [{}]",
|
this.logger.info("Closed {} connection [{}]",
|
||||||
type,
|
type,
|
||||||
EndPoint.getHostDetails(channel.remoteAddress()));
|
EndPoint.getHostDetails(channel.remoteAddress()));
|
||||||
}
|
}
|
||||||
|
|
|
@ -146,7 +146,8 @@ class KryoExtra extends Kryo {
|
||||||
// read the object from the buffer.
|
// read the object from the buffer.
|
||||||
readerBuff.setBuffer(buffer);
|
readerBuff.setBuffer(buffer);
|
||||||
|
|
||||||
return readClassAndObject(readerBuff); // this properly sets the readerIndex, but only if it's the correct buffer
|
// this properly sets the readerIndex, but only if it's the correct buffer
|
||||||
|
return readClassAndObject(readerBuff);
|
||||||
}
|
}
|
||||||
|
|
||||||
////////////////
|
////////////////
|
||||||
|
@ -467,16 +468,6 @@ class KryoExtra extends Kryo {
|
||||||
return read(connection, reader);
|
return read(connection, reader);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Override
|
|
||||||
protected
|
|
||||||
void finalize() throws Throwable {
|
|
||||||
readerBuff.getByteBuf().release();
|
|
||||||
writerBuff.getByteBuf().release();
|
|
||||||
|
|
||||||
super.finalize();
|
|
||||||
}
|
|
||||||
|
|
||||||
public
|
public
|
||||||
NetworkSerializationManager getSerializationManager() {
|
NetworkSerializationManager getSerializationManager() {
|
||||||
return serializationManager;
|
return serializationManager;
|
||||||
|
|
Loading…
Reference in New Issue
Block a user