@Override
        public void run() {
            try {
                if (stopping) {
                    return;
                }
                socket = channelType.accept(serverSocket, socketFactory);
                socket.setEnabledProtocols(protocols);
                socket.setEnabledCipherSuites(cipherSuites);

                socket.startHandshake();

                inputStream = socket.getInputStream();
                outputStream = socket.getOutputStream();

                if (stopping) {
                    return;
                }
                processFuture = executor.submit(new ProcessTask());
            } catch (IOException e) {
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }
A {@link MessageProcessor} that simply echos back the received message to the client.
benchmark-base/src/main/java/org/conscrypt/ServerEndpoint.java