diff options
author | Pavi Vetriselvan <pavithra.vetriselvan@mongodb.com> | 2021-01-07 09:17:30 -0500 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-01-07 15:34:30 +0000 |
commit | 6596c551f656381bf357e6be90914ff60f574971 (patch) | |
tree | e1f75ac2aab973534cd18bad05c93a210c5ed39c /src/mongo/client/connpool.cpp | |
parent | 90c89d33c400d2f1eb8972170b7a17e3315c4198 (diff) | |
download | mongo-6596c551f656381bf357e6be90914ff60f574971.tar.gz |
Revert "SERVER-53423: Make ConnectString::connect return a status instead of setting error message"
This reverts commit ad1169d34cbd457a4d0637230e615bdf1d177531.
Diffstat (limited to 'src/mongo/client/connpool.cpp')
-rw-r--r-- | src/mongo/client/connpool.cpp | 21 |
1 files changed, 10 insertions, 11 deletions
diff --git a/src/mongo/client/connpool.cpp b/src/mongo/client/connpool.cpp index 946c5b8741d..e3a5a925636 100644 --- a/src/mongo/client/connpool.cpp +++ b/src/mongo/client/connpool.cpp @@ -389,12 +389,10 @@ DBClientBase* DBConnectionPool::_finishCreate(const string& ident, DBClientBase* DBConnectionPool::get(const ConnectionString& url, double socketTimeout) { auto connect = [&]() { - auto c = url.connect(StringData(), socketTimeout); - uassert(13328, - fmt::format( - "{}: connect failed {} : {}", _name, url.toString(), c.getStatus().reason()), - c.isOK()); - return c.getValue().release(); + string errmsg; + auto c = url.connect(StringData(), errmsg, socketTimeout).release(); + uassert(13328, _name + ": connect failed " + url.toString() + " : " + errmsg, c); + return c; }; return Detail::get(this, url.toString(), socketTimeout, connect); @@ -404,14 +402,15 @@ DBClientBase* DBConnectionPool::get(const string& host, double socketTimeout) { auto connect = [&] { const ConnectionString cs(uassertStatusOK(ConnectionString::parse(host))); - auto swConn = cs.connect(StringData(), socketTimeout); - if (!swConn.isOK()) { + string errmsg; + auto c = cs.connect(StringData(), errmsg, socketTimeout).release(); + if (!c) { throwSocketError(SocketErrorKind::CONNECT_ERROR, host, - fmt::format("{} error: {}", _name, swConn.getStatus().reason())); + str::stream() << _name << " error: " << errmsg); } - return swConn.getValue().release(); + return c; }; return Detail::get(this, host, socketTimeout, connect); @@ -421,7 +420,7 @@ DBClientBase* DBConnectionPool::get(const MongoURI& uri, double socketTimeout) { auto connect = [&] { string errmsg; std::unique_ptr<DBClientBase> c(uri.connect(uri.getAppName().get(), errmsg, socketTimeout)); - uassert(40356, fmt::format("{}: connect failed {} : {}", _name, uri.toString(), errmsg), c); + uassert(40356, _name + ": connect failed " + uri.toString() + " : " + errmsg, c); return c.release(); }; |