diff options
author | Samantha Ritter <samantha.ritter@10gen.com> | 2016-05-31 14:05:17 -0400 |
---|---|---|
committer | Jason Carey <jcarey@argv.me> | 2016-07-12 18:38:37 -0400 |
commit | c263ce1f95586f8652058e6202015a77f9becc49 (patch) | |
tree | d623fb9da9fd5da3cc4e20cac0653f1fa4af00eb /src/mongo/tools/bridge.cpp | |
parent | dead3cf8b4b3cb5528ad1abb9eeb722b395e3632 (diff) | |
download | mongo-c263ce1f95586f8652058e6202015a77f9becc49.tar.gz |
SERVER-24162 Integrate TransportLayer
Expand the transport layer as needed to replace uses of abstract message port for ingress
networking.
Diffstat (limited to 'src/mongo/tools/bridge.cpp')
-rw-r--r-- | src/mongo/tools/bridge.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/tools/bridge.cpp b/src/mongo/tools/bridge.cpp index 7109c174a99..d37751fe537 100644 --- a/src/mongo/tools/bridge.cpp +++ b/src/mongo/tools/bridge.cpp @@ -320,17 +320,17 @@ public: log() << "Setting random seed: " << mongoBridgeGlobalParams.seed; } - void accepted(AbstractMessagingPort* mp) override final { + void accepted(std::unique_ptr<AbstractMessagingPort> mp) override final { { stdx::lock_guard<stdx::mutex> lk(_portsMutex); if (_inShutdown.load()) { mp->shutdown(); return; } - _ports.insert(mp); + _ports.insert(mp.get()); } - Forwarder f(mp, &_settingsMutex, &_settings, _seedSource.nextInt64()); + Forwarder f(mp.release(), &_settingsMutex, &_settings, _seedSource.nextInt64()); stdx::thread t(f); t.detach(); } |