Add SessionReader and SessionWriter worker threads for session #198
+1
-1
@@ -68,7 +68,7 @@ public class SessionManager {
|
||||
try {
|
||||
handle.session().getTransport().close();
|
||||
} catch (IOException e) {
|
||||
logger.trace("Unexpected exception while closing transport", e);
|
||||
logger.error("Unexpected exception while closing transport", e);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
+2
-2
@@ -42,11 +42,11 @@ public class SessionReader implements Runnable {
|
||||
eventBus.publish(new DisconnectEvent(session.getId()));
|
||||
break;
|
||||
} catch (TokenizerException | ProtocolParserException e) {
|
||||
logger.trace("Error occured while parsing request", e);
|
||||
logger.error("Error occured while parsing request", e);
|
||||
|
||||
// TODO: Send error response to client
|
||||
} catch (IOException e) {
|
||||
logger.trace("Unexpected exception while reading from transport", e);
|
||||
logger.error("Unexpected exception while reading from transport", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
+2
-2
@@ -28,9 +28,9 @@ public class SessionWriter implements Runnable {
|
||||
RawPacket packet = new RawPacket(response.requestId(), response.payload());
|
||||
transport.write(packet);
|
||||
} catch (IOException e) {
|
||||
logger.trace("Unexpected exception while writing to transport", e);
|
||||
logger.error("Unexpected exception while writing to transport", e);
|
||||
} catch (InterruptedException e) {
|
||||
logger.trace("Thread got interrupted", e);
|
||||
logger.warn("Thread got interrupted", e);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user