Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
marc-adaptive committed Aug 30, 2024
1 parent 02bab7c commit d9c1014
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1020,15 +1020,14 @@ private void connectPersistingSessions()

@Test(timeout = TEST_TIMEOUT_IN_MS)
public void shouldSupportFollowerSessionLogonWithoutSequenceResetOnDisconnectBeforeLibraryLogonResponse()
throws IOException
throws IOException
{
launch(this::nothing);

final List<SessionInfo> noSessionContext = acceptingEngine.allSessions();
assertEquals(0, noSessionContext.size());

final SessionWriter sessionWriter = createFollowerSession(
TEST_TIMEOUT_IN_MS, testSystem, acceptingLibrary, INITIATOR_ID, ACCEPTOR_ID);
final SessionWriter sessionWriter = createFollowerSession(TEST_TIMEOUT_IN_MS);
final SessionReplyStatus requestSessionReply = requestSession(acceptingLibrary, sessionWriter.id(), testSystem);
assertEquals(SessionReplyStatus.OK, requestSessionReply);

Expand All @@ -1055,8 +1054,10 @@ public void shouldSupportFollowerSessionLogonWithoutSequenceResetOnDisconnectBef
}

final List<LibraryInfo> allLibraryInfo = libraryReply.resultIfPresent();
for (final LibraryInfo libraryInfo : allLibraryInfo) {
if (libraryInfo.libraryId() == acceptingLibrary.libraryId()) {
for (final LibraryInfo libraryInfo : allLibraryInfo)
{
if (libraryInfo.libraryId() == acceptingLibrary.libraryId())
{
return libraryInfo.sessions().isEmpty();
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -709,13 +709,13 @@ static void awaitIndexerCaughtUp(
}

static void assertEngineSubscriptionCaughtUpToLibraryPublication(
final TestSystem testSystem,
final String aeronDirectoryName,
final FixEngine engine,
final FixLibrary library)
final TestSystem testSystem,
final String aeronDirectoryName,
final FixEngine engine,
final FixLibrary library)
{
final EngineStreamInfo engineStreamInfo =
testSystem.awaitCompletedReply(FixEngineInternals.engineStreamInfo(engine)).resultIfPresent();
testSystem.awaitCompletedReply(FixEngineInternals.engineStreamInfo(engine)).resultIfPresent();

final LibraryStreamInfo libraryStreamInfo = FixLibraryInternals.libraryStreamInfo(library);

Expand Down

0 comments on commit d9c1014

Please sign in to comment.