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()
|