Browse Source

Code cleanup

master
Nikita 9 years ago
parent
commit
2878ec4aef
  1. 2
      src/main/java/com/corundumstudio/socketio/handler/AuthorizeHandler.java
  2. 2
      src/main/java/com/corundumstudio/socketio/handler/ClientHead.java

2
src/main/java/com/corundumstudio/socketio/handler/AuthorizeHandler.java

@ -95,7 +95,7 @@ public class AuthorizeHandler extends ChannelInboundHandlerAdapter implements Di
@Override
public void run() {
ctx.channel().close();
log.debug("Client with ip {} opens channel but not sended any data! Channel closed!", ctx.channel().remoteAddress());
log.debug("Client with ip {} opened channel but doesn't send any data! Channel closed!", ctx.channel().remoteAddress());
}
}, configuration.getFirstDataTimeout(), TimeUnit.MILLISECONDS);
super.channelActive(ctx);

2
src/main/java/com/corundumstudio/socketio/handler/ClientHead.java

@ -59,7 +59,7 @@ public class ClientHead {
private final AtomicBoolean disconnected = new AtomicBoolean();
private final Map<Namespace, NamespaceClient> namespaceClients = PlatformDependent.newConcurrentHashMap();
private final Map<Transport, TransportState> channels = new HashMap<Transport, TransportState>();
private final Map<Transport, TransportState> channels = new HashMap<Transport, TransportState>(2);
private final HandshakeData handshakeData;
private final UUID sessionId;

Loading…
Cancel
Save