Mercurial Hosting > luan

comparison src/org/eclipse/jetty/server/nio/SelectChannelConnector.java @ 964:768414c16e10

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove SelectSet
author Franklin Schmidt <fschmidt@gmail.com>
date Fri, 14 Oct 2016 01:03:47 -0600
parents fc521d2f098e
children 0d20943cfea2
comparison
equal deleted inserted replaced
963:4b6216fa9cec 964:768414c16e10
57 private final SelectorManager _manager = new ConnectorSelectorManager(); 57 private final SelectorManager _manager = new ConnectorSelectorManager();
58 58
59 public SelectChannelConnector(Server server,int port) 59 public SelectChannelConnector(Server server,int port)
60 { 60 {
61 super(server,port); 61 super(server,port);
62 _manager.setMaxIdleTime(getMaxIdleTime());
63 addBean(_manager,true); 62 addBean(_manager,true);
64 } 63 }
65 64
66 @Override 65 @Override
67 public final void accept() throws IOException 66 public final void accept() throws IOException
89 } 88 }
90 89
91 @Override 90 @Override
92 protected synchronized void doStart() throws Exception 91 protected synchronized void doStart() throws Exception
93 { 92 {
94 // _manager.setMaxIdleTime(getMaxIdleTime());
95 _manager.setLowResourcesConnections(0);
96
97 if (_acceptChannel == null) 93 if (_acceptChannel == null)
98 { 94 {
99 // Create a new server socket 95 // Create a new server socket
100 _acceptChannel = ServerSocketChannel.open(); 96 _acceptChannel = ServerSocketChannel.open();
101 // Set to blocking mode 97 // Set to blocking mode
118 } 114 }
119 115
120 116
121 private final class ConnectorSelectorManager extends SelectorManager 117 private final class ConnectorSelectorManager extends SelectorManager
122 { 118 {
119 ConnectorSelectorManager() {
120 super(_maxIdleTime);
121 }
122
123 @Override 123 @Override
124 public void execute(Runnable task) 124 public void execute(Runnable task)
125 { 125 {
126 server.threadPool.execute(task); 126 server.threadPool.execute(task);
127 } 127 }