Mercurial Hosting > luan

comparison src/org/eclipse/jetty/server/AsyncContinuation.java @ 924:5c9cb5d00512

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove isContinuation()
author Franklin Schmidt <fschmidt@gmail.com>
date Sun, 09 Oct 2016 18:21:39 -0600
parents 52d8b5c29d8e
children 720a98fb0253
comparison
equal deleted inserted replaced
923:52d8b5c29d8e 924:5c9cb5d00512
84 private boolean _initial; 84 private boolean _initial;
85 private volatile boolean _responseWrapped; 85 private volatile boolean _responseWrapped;
86 private long _timeoutMs=DEFAULT_TIMEOUT; 86 private long _timeoutMs=DEFAULT_TIMEOUT;
87 private AsyncEventState _event; 87 private AsyncEventState _event;
88 private volatile long _expireAt; 88 private volatile long _expireAt;
89 private volatile boolean _continuation;
90 89
91 /* ------------------------------------------------------------ */ 90 /* ------------------------------------------------------------ */
92 protected AsyncContinuation() 91 protected AsyncContinuation()
93 { 92 {
94 _state=__IDLE; 93 _state=__IDLE;
187 { 186 {
188 synchronized(this) 187 synchronized(this)
189 { 188 {
190 return _initial; 189 return _initial;
191 } 190 }
192 }
193
194 public boolean isContinuation()
195 {
196 return _continuation;
197 } 191 }
198 192
199 /* ------------------------------------------------------------ */ 193 /* ------------------------------------------------------------ */
200 /* (non-Javadoc) 194 /* (non-Javadoc)
201 * @see javax.servlet.ServletRequest#isSuspended() 195 * @see javax.servlet.ServletRequest#isSuspended()
269 */ 263 */
270 protected boolean handling() 264 protected boolean handling()
271 { 265 {
272 synchronized (this) 266 synchronized (this)
273 { 267 {
274 _continuation=false;
275
276 switch(_state) 268 switch(_state)
277 { 269 {
278 case __IDLE: 270 case __IDLE:
279 _initial=true; 271 _initial=true;
280 _state=__DISPATCHED; 272 _state=__DISPATCHED;
548 ((AsyncEndPoint)endp).cancelTimeout(event._timeout); 540 ((AsyncEndPoint)endp).cancelTimeout(event._timeout);
549 } 541 }
550 } 542 }
551 } 543 }
552 544
553 /* ------------------------------------------------------------ */
554 boolean isUncompleted() 545 boolean isUncompleted()
555 { 546 {
556 synchronized (this) 547 synchronized (this)
557 { 548 {
558 return _state==__UNCOMPLETED; 549 return _state==__UNCOMPLETED;
559 } 550 }
560 } 551 }
561 552
562 /* ------------------------------------------------------------ */
563 public boolean isComplete() 553 public boolean isComplete()
564 { 554 {
565 synchronized (this) 555 synchronized (this)
566 { 556 {
567 return _state==__COMPLETED; 557 return _state==__COMPLETED;
568 } 558 }
569 } 559 }
570 560
571 561
572 /* ------------------------------------------------------------ */
573 public boolean isAsync() 562 public boolean isAsync()
574 { 563 {
575 synchronized (this) 564 synchronized (this)
576 { 565 {
577 switch(_state) 566 switch(_state)