Skip to content

Commit 69145fe

Browse files
authored
Test[bmqimp] Fix reauthentication timer race in AuthenticatedChannelFactory (#1216)
Signed-off-by: Christopher Beard <cbeard9@bloomberg.net>
1 parent 38b5c77 commit 69145fe

1 file changed

Lines changed: 2 additions & 5 deletions

File tree

src/groups/bmq/bmqimp/bmqimp_authenticatedchannelfactory.cpp

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,11 @@
1818

1919
#include <bmqscm_version.h>
2020
// BMQ
21+
#include <bmqio_channelutil.h>
2122
#include <bmqp_ctrlmsg_messages.h>
2223
#include <bmqp_event.h>
2324
#include <bmqp_protocol.h>
2425
#include <bmqp_schemaeventbuilder.h>
25-
#include <bmqsys_time.h>
26-
27-
#include <bmqio_channelutil.h>
2826
#include <bmqt_authncredential.h>
2927
#include <bmqu_blob.h>
3028
#include <bmqu_memoutstream.h>
@@ -401,8 +399,7 @@ bool AuthenticatedChannelFactory::processAuthenticationEvent(
401399
// Pending events will be cancelled when Application stops.
402400
d_config.d_scheduler_p->scheduleEvent(
403401
&d_reauthenticationTimeoutHandle,
404-
bsls::TimeInterval(bmqsys::Time::nowMonotonicClock())
405-
.addMilliseconds(intervalMs),
402+
d_config.d_scheduler_p->now().addMilliseconds(intervalMs),
406403
bdlf::BindUtil::bind(bmqu::WeakMemFnUtil::weakMemFn(
407404
&AuthenticatedChannelFactory::sendRequest,
408405
d_self.acquireWeak()),

0 commit comments

Comments
 (0)