From e90e292909166f7b38c2a3c90c0df522a8c85846 Mon Sep 17 00:00:00 2001 From: Constantine Date: Tue, 16 May 2023 10:52:33 +0300 Subject: [PATCH 1/2] npe #790 --- .../corundumstudio/socketio/transport/PollingTransport.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/corundumstudio/socketio/transport/PollingTransport.java b/src/main/java/com/corundumstudio/socketio/transport/PollingTransport.java index 031551858..8be81993e 100644 --- a/src/main/java/com/corundumstudio/socketio/transport/PollingTransport.java +++ b/src/main/java/com/corundumstudio/socketio/transport/PollingTransport.java @@ -98,7 +98,9 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception } else { // first connection ClientHead client = ctx.channel().attr(ClientHead.CLIENT).get(); - handleMessage(req, client.getSessionId(), queryDecoder, ctx); + if (client != null) { + handleMessage(req, client.getSessionId(), queryDecoder, ctx); + } } } finally { req.release(); From 42ceb8820df9d4c9a203f0ed8a11f41d33a69734 Mon Sep 17 00:00:00 2001 From: Constantine Date: Tue, 16 May 2023 10:55:37 +0300 Subject: [PATCH 2/2] npe like #790 --- .../corundumstudio/socketio/transport/WebSocketTransport.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java b/src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java index 619cd0664..618efd41c 100644 --- a/src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java +++ b/src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java @@ -115,7 +115,9 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception } else { ClientHead client = ctx.channel().attr(ClientHead.CLIENT).get(); // first connection - handshake(ctx, client.getSessionId(), path, req); + if (client != null) { + handshake(ctx, client.getSessionId(), path, req); + } } } finally { req.release();