Skip to content

Commit f3d8662

Browse files
committed
Update trickle down test
Signed-off-by: Derek Riley <derek.riley@swirldslabs.com>
1 parent 49f9bdb commit f3d8662

File tree

1 file changed

+14
-2
lines changed
  • hedera-node/test-clients/src/main/java/com/hedera/services/bdd/suites/blocknode

1 file changed

+14
-2
lines changed

hedera-node/test-clients/src/main/java/com/hedera/services/bdd/suites/blocknode/BlockNodeSuite.java

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -439,8 +439,20 @@ final Stream<DynamicTest> node0StreamingBlockNodeConnectionDropsTrickle() {
439439
String.format(
440440
"/localhost:%s/CLOSED] Connection state transitioned from CLOSING to CLOSED.",
441441
portNumbers.get(3)))),
442-
doingContextual(
443-
spec -> LockSupport.parkNanos(Duration.ofSeconds(20).toNanos())));
442+
doingContextual(spec -> connectionDropTime.set(Instant.now())),
443+
blockNode(3).startImmediately(), // Pri 3
444+
blockNode(1).shutDownImmediately(), // Pri 1
445+
sourcingContextual(spec -> assertBlockNodeCommsLogContainsTimeframe(
446+
byNodeId(0),
447+
connectionDropTime::get,
448+
Duration.ofMinutes(1),
449+
Duration.ofSeconds(45),
450+
String.format(
451+
"/localhost:%s/PENDING] Connection state transitioned from UNINITIALIZED to PENDING.",
452+
portNumbers.get(3)),
453+
String.format(
454+
"/localhost:%s/ACTIVE] Connection state transitioned from PENDING to ACTIVE.",
455+
portNumbers.get(3)))));
444456
}
445457

446458
@HapiTest

0 commit comments

Comments
 (0)