*/
protected boolean setSocketOptions(SocketChannel socket) {
// Process the connection
- int step = 1;
try {
//disable blocking, APR style, we are gonna be polling it
socket.configureBlocking(false);
NioChannel channel = nioChannels.poll();
if ( channel == null ) {
- // 2: SSL setup
- step = 2;
-
+ // SSL setup
if (sslContext != null) {
SSLEngine engine = createSSLEngine();
int appbufsize = engine.getSession().getApplicationBufferSize();
socketProperties.getDirectBuffer());
channel = new SecureNioChannel(socket, engine, bufhandler, selectorPool);
} else {
+ // normal tcp setup
NioBufferHandler bufhandler = new NioBufferHandler(socketProperties.getAppReadBufSize(),
socketProperties.getAppWriteBufSize(),
socketProperties.getDirectBuffer());
channel = new NioChannel(socket, bufhandler);
}
- } else {
-
+ } else {
channel.setIOChannel(socket);
if ( channel instanceof SecureNioChannel ) {
SSLEngine engine = createSSLEngine();
}
}
getPoller0().register(channel);
-
} catch (Throwable t) {
try {
log.error("",t);