- SocketThread.start(ss.accept(), clientAddress, sesssionId.incrementAndGet(),authProvider);
- } catch (IOException e) {
- logger.error("Exception occurred during socket thread initialization {}",e);
+ acceptedSocket = serverSocket.accept();
+ } catch (final IOException e) {
+ if (up == false) {
+ logger.trace("Exiting server thread", e);
+ } else {
+ logger.warn("Exception occurred during socket.accept", e);
+ }
+ }
+ if (acceptedSocket != null) {
+ try {
+ final Handshaker task = new Handshaker(acceptedSocket, localAddress, sessionIdCounter.incrementAndGet(), getAuthProvider(), bossGroup, pem);
+ handshakeExecutor.submit(task);
+ } catch (final IOException e) {
+ logger.warn("Cannot set PEMHostKey, closing connection", e);
+ closeSocket(acceptedSocket);
+ } catch (final IllegalStateException e) {
+ logger.warn("Cannot accept connection, closing", e);
+ closeSocket(acceptedSocket);
+ }