Skip to content

Commit

Permalink
Rename variable
Browse files Browse the repository at this point in the history
Signed-off-by: Stanislav Yuzvinsky <[email protected]>
  • Loading branch information
syuzvinsky committed Apr 8, 2024
1 parent be49213 commit 041457d
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions src/applications/bmqtool/m_bmqtool_application.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -770,7 +770,7 @@ void Application::onMessageEvent(const bmqa::MessageEvent& event)
d_fileLogger.writeAckMessage(message);

if (d_numExpectedAcks != 0 &&
d_numExpectedAcks == ++d_numPostedAcknowledged) {
d_numExpectedAcks == ++d_numAcknowledged) {
BALL_LOG_INFO << "All posted messages have been acknowledged";
d_shutdownSemaphore_p->post();
}
Expand Down Expand Up @@ -1133,7 +1133,7 @@ Application::Application(Parameters* parameters,
, d_autoReadInProgress(false)
, d_autoReadActivity(false)
, d_numExpectedAcks(0)
, d_numPostedAcknowledged(0)
, d_numAcknowledged(0)
{
// NOTHING
}
Expand Down Expand Up @@ -1200,7 +1200,7 @@ int Application::run()
if (bmqt::QueueFlagsUtil::isWriter(d_parameters_p->queueFlags())) {
d_numExpectedAcks = d_parameters_p->eventsCount() *
d_parameters_p->eventSize();
d_numPostedAcknowledged = 0;
d_numAcknowledged = 0;

// Start the thread
rc = bslmt::ThreadUtil::create(
Expand Down
2 changes: 1 addition & 1 deletion src/applications/bmqtool/m_bmqtool_application.h
Original file line number Diff line number Diff line change
Expand Up @@ -174,7 +174,7 @@ class Application : public bmqa::SessionEventHandler {
// messages, after which the shutdown semaphore will
// be posted.

bsl::uint64_t d_numPostedAcknowledged;
bsl::uint64_t d_numAcknowledged;
// Auto-produce mode only. The number of acknowledged
// messages. When the value of this field becomes equal
// to d_numExpectedAcks, the shutdown semaphore will be
Expand Down

0 comments on commit 041457d

Please sign in to comment.