Mercurial Hosting > luan

comparison src/org/eclipse/jetty/server/nio/SelectChannelConnector.java @ 948:f5aefdc4a81a

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
simplify SelectChannelConnector
author Franklin Schmidt <fschmidt@gmail.com>
date Tue, 11 Oct 2016 22:16:29 -0600
parents 0541b6034003
children a778413aefc0
comparison
equal deleted inserted replaced
947:64f3d8dae31d 948:f5aefdc4a81a
98 98
99 @Override 99 @Override
100 protected synchronized void doStart() throws Exception 100 protected synchronized void doStart() throws Exception
101 { 101 {
102 _manager.setSelectSets(getAcceptors()); 102 _manager.setSelectSets(getAcceptors());
103 _manager.setMaxIdleTime(getMaxIdleTime()); 103 // _manager.setMaxIdleTime(getMaxIdleTime());
104 _manager.setLowResourcesConnections(0); 104 _manager.setLowResourcesConnections(0);
105 105
106 if (_acceptChannel == null) 106 if (_acceptChannel == null)
107 { 107 {
108 // Create a new server socket 108 // Create a new server socket
119 } 119 }
120 120
121 super.doStart(); 121 super.doStart();
122 } 122 }
123 123
124 protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey key) throws IOException
125 {
126 SelectChannelEndPoint endp= new SelectChannelEndPoint(channel,selectSet,key, SelectChannelConnector.this._maxIdleTime);
127 endp.setConnection(selectSet.getManager().newConnection(channel,endp, key.attachment()));
128 return endp;
129 }
130
131 protected void endPointClosed(SelectChannelEndPoint endpoint)
132 {
133 endpoint.getConnection().onClose();
134 }
135
136 protected AsyncConnection newConnection(SocketChannel channel,final AsyncEndPoint endpoint) 124 protected AsyncConnection newConnection(SocketChannel channel,final AsyncEndPoint endpoint)
137 { 125 {
138 return new AsyncHttpConnection(SelectChannelConnector.this,endpoint,server); 126 return new AsyncHttpConnection(SelectChannelConnector.this,endpoint,server);
139 } 127 }
140 128
146 { 134 {
147 server.threadPool.execute(task); 135 server.threadPool.execute(task);
148 } 136 }
149 137
150 @Override 138 @Override
151 protected void endPointClosed(final SelectChannelEndPoint endpoint)
152 {
153 SelectChannelConnector.this.endPointClosed(endpoint);
154 }
155
156 @Override
157 public AsyncConnection newConnection(SocketChannel channel,AsyncEndPoint endpoint, Object attachment) 139 public AsyncConnection newConnection(SocketChannel channel,AsyncEndPoint endpoint, Object attachment)
158 { 140 {
159 return SelectChannelConnector.this.newConnection(channel,endpoint); 141 return SelectChannelConnector.this.newConnection(channel,endpoint);
160 } 142 }
161
162 @Override
163 protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey sKey) throws IOException
164 {
165 return SelectChannelConnector.this.newEndPoint(channel,selectSet,sKey);
166 }
167 } 143 }
168 } 144 }