Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fixing another indeterminism around index update
Browse files Browse the repository at this point in the history
lucianoviana committed Oct 21, 2024
1 parent 0c000a6 commit 0dff61c
Showing 1 changed file with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -601,6 +601,10 @@ public void shouldSupportLogonBasedSequenceNumberResetWithMessagesSentBeforeLogo
testSystem.awaitMessageOf(otfAcceptor, EXECUTION_REPORT_MESSAGE_AS_STR,
msg -> msg.messageSequenceNumber() == seqNum2 && msg.sequenceIndex() == 1);

// to ensure the indexes are processed before resend request is received - which would mean a gapfill
// responded rather than a replay msg
awaitIndexerCaughtUp(testSystem, mediaDriver.mediaDriver().aeronDirectoryName(), engine, library);

connection.sendResendRequest(2, 2);
testSystem.awaitBlocking(
() -> assertEquals(Side.SELL, connection.readResentExecutionReport(2).sideAsEnum()));

0 comments on commit 0dff61c

Please sign in to comment.