diff options
author | Jason Carey <jcarey@argv.me> | 2018-05-22 18:18:45 -0400 |
---|---|---|
committer | Jason Carey <jcarey@argv.me> | 2018-06-08 15:08:52 -0400 |
commit | afe78b2fd058c09a754653bf024744ee97392bc4 (patch) | |
tree | 2422581b55a32d5ad134d198b58413d9c360a99e /src/mongo/executor/connection_pool_test_fixture.cpp | |
parent | 2baf303830538053d3bfedaa99fec0c4b5e83cd8 (diff) | |
download | mongo-afe78b2fd058c09a754653bf024744ee97392bc4.tar.gz |
SERVER-35179 Make NiTL actually refresh
Diffstat (limited to 'src/mongo/executor/connection_pool_test_fixture.cpp')
-rw-r--r-- | src/mongo/executor/connection_pool_test_fixture.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/executor/connection_pool_test_fixture.cpp b/src/mongo/executor/connection_pool_test_fixture.cpp index 1d42d0445d1..560f184a025 100644 --- a/src/mongo/executor/connection_pool_test_fixture.cpp +++ b/src/mongo/executor/connection_pool_test_fixture.cpp @@ -122,6 +122,7 @@ void ConnectionImpl::pushSetup(PushSetupCallback status) { _pushSetupQueue.pop_front(); auto cb = connPtr->_setupCallback; + connPtr->indicateUsed(); cb(connPtr, callback()); } } @@ -145,6 +146,7 @@ void ConnectionImpl::pushRefresh(PushRefreshCallback status) { _pushRefreshQueue.pop_front(); auto cb = connPtr->_refreshCallback; + connPtr->indicateUsed(); cb(connPtr, callback()); } } @@ -189,6 +191,7 @@ void ConnectionImpl::setup(Milliseconds timeout, SetupCallback cb) { _pushSetupQueue.pop_front(); auto refreshCb = connPtr->_setupCallback; + connPtr->indicateUsed(); refreshCb(connPtr, callback()); } } @@ -210,6 +213,7 @@ void ConnectionImpl::refresh(Milliseconds timeout, RefreshCallback cb) { _pushRefreshQueue.pop_front(); auto refreshCb = connPtr->_refreshCallback; + connPtr->indicateUsed(); refreshCb(connPtr, callback()); } } |