Mercurial Hosting > luan

comparison src/org/eclipse/jetty/io/nio/SelectChannelEndPoint.java @ 952:669769bcdf5c

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
simplify AsyncEndPoint
author Franklin Schmidt <fschmidt@gmail.com>
date Wed, 12 Oct 2016 19:47:45 -0600
parents a778413aefc0
children 7db4a488fc82
comparison
equal deleted inserted replaced
951:e542a9cc75ef 952:669769bcdf5c
228 } 228 }
229 else 229 else
230 _checkIdle=false; 230 _checkIdle=false;
231 } 231 }
232 232
233 public boolean isCheckForIdle() 233 private boolean isCheckForIdle()
234 { 234 {
235 return _checkIdle; 235 return _checkIdle;
236 } 236 }
237 237
238 protected void notIdle() 238 protected void notIdle()
266 }); 266 });
267 } 267 }
268 } 268 }
269 } 269 }
270 270
271 public void onIdleExpired(long idleForMs) 271 private void onIdleExpired(long idleForMs)
272 { 272 {
273 try 273 try
274 { 274 {
275 synchronized (this) 275 synchronized (this)
276 { 276 {
437 _writeBlocked=false; 437 _writeBlocked=false;
438 setCheckForIdle(check); 438 setCheckForIdle(check);
439 } 439 }
440 } 440 }
441 return true; 441 return true;
442 }
443
444 /* ------------------------------------------------------------ */
445 /**
446 * @see org.eclipse.jetty.io.AsyncEndPoint#scheduleWrite()
447 */
448 public void scheduleWrite()
449 {
450 if (_writable)
451 LOG.debug("Required scheduleWrite {}",this);
452
453 _writable=false;
454 updateKey();
455 }
456
457 /* ------------------------------------------------------------ */
458 public boolean isWritable()
459 {
460 return _writable;
461 } 442 }
462 443
463 /* ------------------------------------------------------------ */ 444 /* ------------------------------------------------------------ */
464 public boolean hasProgressed() 445 public boolean hasProgressed()
465 { 446 {