comparison src/org/eclipse/jetty/server/nio/SelectChannelConnector.java @ 950:a778413aefc0

add SaneSelector
author Franklin Schmidt <fschmidt@gmail.com>
date Wed, 12 Oct 2016 14:37:56 -0600
parents f5aefdc4a81a
children 669769bcdf5c
comparison
equal deleted inserted replaced
949:e9088af3787f 950:a778413aefc0
70 { 70 {
71 ServerSocketChannel server = _acceptChannel; 71 ServerSocketChannel server = _acceptChannel;
72 72
73 if (server!=null && server.isOpen() && _manager.isStarted()) 73 if (server!=null && server.isOpen() && _manager.isStarted())
74 { 74 {
75 SocketChannel channel = server.accept(); 75 final SocketChannel channel = server.accept();
76 channel.configureBlocking(false); 76 channel.configureBlocking(false);
77 Socket socket = channel.socket(); 77 Socket socket = channel.socket();
78 configure(socket); 78 configure(socket);
79 _manager.register(channel); 79 this.server.threadPool.execute(new Runnable(){public void run(){
80 _manager.register(channel);
81 }});
80 } 82 }
81 } 83 }
82 84
83 @Override 85 @Override
84 public void customize(EndPoint endpoint, Request request) throws IOException 86 public void customize(EndPoint endpoint, Request request) throws IOException