raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

fix tabs; remove debugging log line

Browse source
This commit is contained in:
Garrick Evans 2011-02-12 10:01:29 -08:00
parent a274c5f0b9
commit 0fe4d8c6ee
1 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-http/src/main/scala/akka/http/JettyContinuation.scala
View file

@ -52,7 +52,7 @@ trait JettyContinuation extends ContinuationListener with akka.util.Logging
Some(continuation)
}
//
//
// the timeout was reset and the continuation was resumed
// this happens when used with getAsyncContinuation
//
@ -64,10 +64,10 @@ trait JettyContinuation extends ContinuationListener with akka.util.Logging
None
}
//
//
// the timeout was reset and the continuation is still suspended
// this happens when used with startAsync
//
// this happens when used with startAsync
//
case (false, true, false) => {
continuation.setTimeout(continuation.getAttribute(TimeoutAttribute).asInstanceOf[Long])
@ -79,7 +79,7 @@ trait JettyContinuation extends ContinuationListener with akka.util.Logging
// unexpected continution state(s) - log and do nothing
//
case _ => {
log.slf4j.warn("Received continuation in unexpected state: "+continuation.isInitial+" "+continuation.isSuspended+" "+continuation.isExpired+" "+continuation.isResumed)
log.slf4j.warn("Received continuation in unexpected state: "+continuation.isInitial+" "+continuation.isSuspended+" "+continuation.isExpired+" "+continuation.isResumed)
//continuation.cancel
None
}
@ -94,7 +94,6 @@ trait JettyContinuation extends ContinuationListener with akka.util.Logging
def timeout(ms:Long):Boolean = _continuation match {
case None => false
case Some(continuation) =>
log.slf4j.info("reseting timeout...")
continuation.setAttribute(TimeoutAttribute, ms)
continuation.resume
true