kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject kafka git commit: DelayedOperationTest.testRequestExpiry transient failure; reviewed by Neha Narkhede
Date Mon, 20 Apr 2015 16:56:05 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk ed11e177d -> 6b964461a


DelayedOperationTest.testRequestExpiry transient failure; reviewed by Neha Narkhede


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6b964461
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6b964461
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6b964461

Branch: refs/heads/trunk
Commit: 6b964461af23e604a1f7f96b24194c276efebe96
Parents: ed11e17
Author: Rajini Sivaram <rajinisivaram@googlemail.com>
Authored: Mon Apr 20 09:55:51 2015 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Mon Apr 20 09:56:03 2015 -0700

----------------------------------------------------------------------
 core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/6b964461/core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala b/core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala
index 9186c90..f3ab3f4 100644
--- a/core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala
+++ b/core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala
@@ -55,9 +55,9 @@ class DelayedOperationTest extends JUnit3Suite {
   @Test
   def testRequestExpiry() {
     val expiration = 20L
+    val start = System.currentTimeMillis
     val r1 = new MockDelayedOperation(expiration)
     val r2 = new MockDelayedOperation(200000L)
-    val start = System.currentTimeMillis
     assertFalse("r1 not satisfied and hence watched", purgatory.tryCompleteElseWatch(r1,
Array("test1")))
     assertFalse("r2 not satisfied and hence watched", purgatory.tryCompleteElseWatch(r2,
Array("test2")))
     r1.awaitExpiration()


Mime
View raw message