Skip to content

Commit

Permalink
changing order of polling in frame doWork
Browse files Browse the repository at this point in the history
  • Loading branch information
lucianoviana committed Oct 3, 2024
1 parent 233da17 commit 5277bdd
Showing 1 changed file with 5 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -385,16 +385,19 @@ public int doWork() throws Exception

checkOutboundTimestampSender(timeInNs);

return retryManager.attemptSteps() +
final int i = retryManager.attemptSteps() +
sendOutboundMessages() +
sendReplayMessages() +
pollEndPoints() +
pollNewConnections(timeInMs) +
pollLibraries(timeInMs) +
gatewaySessions.pollSessions(timeInMs, timeInNs) +
fixSenderEndPoints.poll(timeInMs) +
adminCommands.drain(onAdminCommand) +
checkDutyCycle(timeInMs);

final int j = adminCommands.drain(onAdminCommand);

return i + j;
}

private void checkOutboundTimestampSender(final long timeInNs)
Expand Down

0 comments on commit 5277bdd

Please sign in to comment.