summaryrefslogtreecommitdiff
path: root/src/mongo/client/parallel.cpp
diff options
context:
space:
mode:
authorMark Benvenuto <mark.benvenuto@mongodb.com>2015-06-19 10:57:36 -0400
committerMark Benvenuto <mark.benvenuto@mongodb.com>2015-06-20 10:56:04 -0400
commit6f6fa5a63d482b0dc117eb2ac21cf096deb5a6f3 (patch)
treeb76c2a4dfc7f45eb25dd62cb3ffe89ea448d9e0e /src/mongo/client/parallel.cpp
parent9c2ed42daa8fbbef4a919c21ec564e2db55e8d60 (diff)
downloadmongo-6f6fa5a63d482b0dc117eb2ac21cf096deb5a6f3.tar.gz
SERVER-18978: Clang-Format - Fix comment word wrapping indentation
Diffstat (limited to 'src/mongo/client/parallel.cpp')
-rw-r--r--src/mongo/client/parallel.cpp41
1 files changed, 23 insertions, 18 deletions
diff --git a/src/mongo/client/parallel.cpp b/src/mongo/client/parallel.cpp
index 939cd253e33..02af92a8812 100644
--- a/src/mongo/client/parallel.cpp
+++ b/src/mongo/client/parallel.cpp
@@ -765,14 +765,15 @@ void ParallelSortClusteredCursor::startInit() {
_qSpec.options(), // options
// NtoReturn is weird.
// If zero, it means use default size, so we do that for all cursors
- // If positive, it's the batch size (we don't want this cursor limiting results), that's
- // done at a higher level
- // If negative, it's the batch size, but we don't create a cursor - so we don't want
- // to create a child cursor either.
- // Either way, if non-zero, we want to pull back the batch size + the skip amount as
- // quickly as possible. Potentially, for a cursor on a single shard or if we keep better track of
- // chunks, we can actually add the skip value into the cursor and/or make some assumptions about the
- // return value size ( (batch size + skip amount) / num_servers ).
+ // If positive, it's the batch size (we don't want this cursor limiting
+ // results), that's done at a higher level
+ // If negative, it's the batch size, but we don't create a cursor - so we
+ // don't want to create a child cursor either.
+ // Either way, if non-zero, we want to pull back the batch size + the skip
+ // amount as quickly as possible. Potentially, for a cursor on a single
+ // shard or if we keep better track of chunks, we can actually add the skip
+ // value into the cursor and/or make some assumptions about the return value
+ // size ( (batch size + skip amount) / num_servers ).
_qSpec.ntoreturn() == 0 ? 0 : (_qSpec.ntoreturn() > 0
? _qSpec.ntoreturn() + _qSpec.ntoskip()
: _qSpec.ntoreturn() -
@@ -830,7 +831,8 @@ void ParallelSortClusteredCursor::startInit() {
<< (lazyInit ? "(lazily) " : "(full) ") << "on shard " << shardId
<< ", current connection state is " << mdata.toBSON() << endl;
} catch (StaleConfigException& e) {
- // Our version isn't compatible with the current version anymore on at least one shard, need to retry immediately
+ // Our version isn't compatible with the current version anymore on at least one shard,
+ // need to retry immediately
NamespaceString staleNS(e.getns());
// For legacy reasons, this may not be set in the exception :-(
@@ -1185,7 +1187,8 @@ void ParallelSortClusteredCursor::_oldInit() {
vector<shared_ptr<ShardConnection>> conns;
vector<string> servers;
- // Since we may get all sorts of errors, record them all as they come and throw them later if necessary
+ // Since we may get all sorts of errors, record them all as they come and throw them later if
+ // necessary
vector<string> staleConfigExs;
vector<string> socketExs;
vector<string> otherExs;
@@ -1194,7 +1197,8 @@ void ParallelSortClusteredCursor::_oldInit() {
int retries = -1;
// Loop through all the queries until we've finished or gotten a socket exception on all of them
- // We break early for non-socket exceptions, and socket exceptions if we aren't returning partial results
+ // We break early for non-socket exceptions, and socket exceptions if we aren't returning
+ // partial results
do {
retries++;
@@ -1224,7 +1228,8 @@ void ParallelSortClusteredCursor::_oldInit() {
const string errLoc = " @ " + serverHost;
if (firstPass) {
- // This may be the first time connecting to this shard, if so we can get an error here
+ // This may be the first time connecting to this shard, if so we can get an error
+ // here
try {
conns.push_back(shared_ptr<ShardConnection>(new ShardConnection(
uassertStatusOK(ConnectionString::parse(serverHost)), _ns)));
@@ -1288,10 +1293,10 @@ void ParallelSortClusteredCursor::_oldInit() {
}
}
- // Go through all the potentially started cursors and finish initializing them or log any errors and
- // potentially retry
- // TODO: Better error classification would make this easier, errors are indicated in all sorts of ways
- // here that we need to trap.
+ // Go through all the potentially started cursors and finish initializing them or log any
+ // errors and potentially retry
+ // TODO: Better error classification would make this easier, errors are indicated in all
+ // sorts of ways here that we need to trap.
for (size_t i = 0; i < num; i++) {
const string errLoc = " @ " + serverHosts[i];
@@ -1625,8 +1630,8 @@ bool Future::CommandResult::join(int maxRetries) {
}
}
- // We may not always have a collection, since we don't know from a generic command what collection
- // is supposed to be acted on, if any
+ // We may not always have a collection, since we don't know from a generic command what
+ // collection is supposed to be acted on, if any
if (nsGetCollection(staleNS).size() == 0) {
warning() << "no collection namespace in stale config exception "
<< "for lazy command " << _cmd << ", could not refresh " << staleNS