summaryrefslogtreecommitdiff
path: root/src/mongo/transport/transport_layer_legacy.cpp
diff options
context:
space:
mode:
authorJonathan Reams <jbreams@mongodb.com>2017-06-26 16:41:35 -0400
committerJonathan Reams <jbreams@mongodb.com>2017-06-26 16:41:35 -0400
commitf96a7014dc38fc6d28e3e997d13a818c271768e8 (patch)
tree3357ece5a4d6ba574d8c50f861f099232301925d /src/mongo/transport/transport_layer_legacy.cpp
parente8157bfbed3e86ed24eaffa84038500425c2ee49 (diff)
downloadmongo-f96a7014dc38fc6d28e3e997d13a818c271768e8.tar.gz
Revert "SERVER-29165 Don't create RestrictionEnvironment in TransportLayer"
This reverts commit e8157bfbed3e86ed24eaffa84038500425c2ee49.
Diffstat (limited to 'src/mongo/transport/transport_layer_legacy.cpp')
-rw-r--r--src/mongo/transport/transport_layer_legacy.cpp10
1 files changed, 7 insertions, 3 deletions
diff --git a/src/mongo/transport/transport_layer_legacy.cpp b/src/mongo/transport/transport_layer_legacy.cpp
index 843d30cc7e2..962b39425e4 100644
--- a/src/mongo/transport/transport_layer_legacy.cpp
+++ b/src/mongo/transport/transport_layer_legacy.cpp
@@ -38,6 +38,7 @@
#include "mongo/base/checked_cast.h"
#include "mongo/config.h"
+#include "mongo/db/auth/restriction_environment.h"
#include "mongo/db/service_context.h"
#include "mongo/db/stats/counters.h"
#include "mongo/stdx/functional.h"
@@ -88,8 +89,8 @@ std::shared_ptr<TransportLayerLegacy::LegacySession> TransportLayerLegacy::Legac
TransportLayerLegacy::LegacySession::LegacySession(std::unique_ptr<AbstractMessagingPort> amp,
TransportLayerLegacy* tl)
- : _remote(amp->remoteAddr()),
- _local(amp->localAddr()),
+ : _remote(amp->remote()),
+ _local(amp->localAddr().toString(true)),
_tl(tl),
_tags(kEmptyTagMask),
_connection(stdx::make_unique<Connection>(std::move(amp))) {}
@@ -327,8 +328,11 @@ void TransportLayerLegacy::_handleNewConnection(std::unique_ptr<AbstractMessagin
}
amp->setLogLevel(logger::LogSeverity::Debug(1));
-
+ auto restrictionEnvironment =
+ stdx::make_unique<RestrictionEnvironment>(amp->remoteAddr(), amp->localAddr());
auto session = LegacySession::create(std::move(amp), this);
+ RestrictionEnvironment::set(session, std::move(restrictionEnvironment));
+
stdx::list<std::weak_ptr<LegacySession>> list;
auto it = list.emplace(list.begin(), session);