comparison src/org/eclipse/jetty/server/nio/BlockingChannelConnector.java @ 967:8a8dc0b1742f

remove getConnection()
author Franklin Schmidt <fschmidt@gmail.com>
date Fri, 14 Oct 2016 02:30:48 -0600
parents 866f2e801618
children 0d20943cfea2
comparison
equal deleted inserted replaced
966:2ac9e57ccae6 967:8a8dc0b1742f
150 { 150 {
151 super(channel,BlockingChannelConnector.this._maxIdleTime); 151 super(channel,BlockingChannelConnector.this._maxIdleTime);
152 _connection = new BlockingHttpConnection(BlockingChannelConnector.this,this,server); 152 _connection = new BlockingHttpConnection(BlockingChannelConnector.this,this,server);
153 } 153 }
154 154
155 /* ------------------------------------------------------------ */
156 /** Get the connection.
157 * @return the connection
158 */
159 public Connection getConnection()
160 {
161 return _connection;
162 }
163
164 /* ------------------------------------------------------------ */
165 public void setConnection(Connection connection) 155 public void setConnection(Connection connection)
166 { 156 {
167 _connection=connection; 157 _connection=connection;
168 } 158 }
169 159
170 /* ------------------------------------------------------------ */
171 public void checkIdleTimestamp(long now) 160 public void checkIdleTimestamp(long now)
172 { 161 {
173 if (_idleTimestamp!=0 && _timeout>0 && now>(_idleTimestamp+_timeout)) 162 if (_idleTimestamp!=0 && _timeout>0 && now>(_idleTimestamp+_timeout))
174 { 163 {
175 idleExpired(); 164 idleExpired();
176 } 165 }
177 } 166 }
178 167
179 /* ------------------------------------------------------------ */
180 protected void idleExpired() 168 protected void idleExpired()
181 { 169 {
182 try 170 try
183 { 171 {
184 super.close(); 172 super.close();
187 { 175 {
188 LOG.trace("",e); 176 LOG.trace("",e);
189 } 177 }
190 } 178 }
191 179
192 /* ------------------------------------------------------------ */
193 void dispatch() throws IOException 180 void dispatch() throws IOException
194 { 181 {
195 try { 182 try {
196 server.threadPool.execute(this); 183 server.threadPool.execute(this);
197 } catch(RejectedExecutionException e) { 184 } catch(RejectedExecutionException e) {