summaryrefslogtreecommitdiff
path: root/src/mongo/db/query/find.h
diff options
context:
space:
mode:
authorMark Benvenuto <mark.benvenuto@mongodb.com>2015-06-20 00:22:50 -0400
committerMark Benvenuto <mark.benvenuto@mongodb.com>2015-06-20 10:56:02 -0400
commit9c2ed42daa8fbbef4a919c21ec564e2db55e8d60 (patch)
tree3814f79c10d7b490948d8cb7b112ac1dd41ceff1 /src/mongo/db/query/find.h
parent01965cf52bce6976637ecb8f4a622aeb05ab256a (diff)
downloadmongo-9c2ed42daa8fbbef4a919c21ec564e2db55e8d60.tar.gz
SERVER-18579: Clang-Format - reformat code, no comment reflow
Diffstat (limited to 'src/mongo/db/query/find.h')
-rw-r--r--src/mongo/db/query/find.h222
1 files changed, 111 insertions, 111 deletions
diff --git a/src/mongo/db/query/find.h b/src/mongo/db/query/find.h
index 81803b66364..330afc76b90 100644
--- a/src/mongo/db/query/find.h
+++ b/src/mongo/db/query/find.h
@@ -38,132 +38,132 @@
namespace mongo {
- class NamespaceString;
- class OperationContext;
+class NamespaceString;
+class OperationContext;
- class ScopedRecoveryUnitSwapper {
- public:
- ScopedRecoveryUnitSwapper(ClientCursor* cc, OperationContext* txn);
+class ScopedRecoveryUnitSwapper {
+public:
+ ScopedRecoveryUnitSwapper(ClientCursor* cc, OperationContext* txn);
- ~ScopedRecoveryUnitSwapper();
+ ~ScopedRecoveryUnitSwapper();
- /**
- * Dismissing the RU swapper causes it to simply free the recovery unit rather than swapping
- * it back into the ClientCursor.
- */
- void dismiss();
+ /**
+ * Dismissing the RU swapper causes it to simply free the recovery unit rather than swapping
+ * it back into the ClientCursor.
+ */
+ void dismiss();
- private:
- ClientCursor* _cc;
- OperationContext* _txn;
- bool _dismissed;
+private:
+ ClientCursor* _cc;
+ OperationContext* _txn;
+ bool _dismissed;
- std::unique_ptr<RecoveryUnit> _txnPreviousRecoveryUnit;
- OperationContext::RecoveryUnitState _txnPreviousRecoveryUnitState;
- };
+ std::unique_ptr<RecoveryUnit> _txnPreviousRecoveryUnit;
+ OperationContext::RecoveryUnitState _txnPreviousRecoveryUnitState;
+};
- /**
- * Returns true if enough results have been prepared to stop adding more to the first batch.
- *
- * Should be called *after* adding to the result set rather than before.
- */
- bool enoughForFirstBatch(const LiteParsedQuery& pq, int numDocs, int bytesBuffered);
+/**
+ * Returns true if enough results have been prepared to stop adding more to the first batch.
+ *
+ * Should be called *after* adding to the result set rather than before.
+ */
+bool enoughForFirstBatch(const LiteParsedQuery& pq, int numDocs, int bytesBuffered);
- /**
- * Returns true if enough results have been prepared to stop adding more to a getMore batch.
- *
- * Should be called *after* adding to the result set rather than before.
- */
- bool enoughForGetMore(int ntoreturn, int numDocs, int bytesBuffered);
+/**
+ * Returns true if enough results have been prepared to stop adding more to a getMore batch.
+ *
+ * Should be called *after* adding to the result set rather than before.
+ */
+bool enoughForGetMore(int ntoreturn, int numDocs, int bytesBuffered);
- /**
- * Whether or not the ClientCursor* is tailable.
- */
- bool isCursorTailable(const ClientCursor* cursor);
+/**
+ * Whether or not the ClientCursor* is tailable.
+ */
+bool isCursorTailable(const ClientCursor* cursor);
- /**
- * Whether or not the ClientCursor* has the awaitData flag set.
- */
- bool isCursorAwaitData(const ClientCursor* cursor);
+/**
+ * Whether or not the ClientCursor* has the awaitData flag set.
+ */
+bool isCursorAwaitData(const ClientCursor* cursor);
- /**
- * Returns true if we should keep a cursor around because we're expecting to return more query
- * results.
- *
- * If false, the caller should close the cursor and indicate this to the client by sending back
- * a cursor ID of 0.
- */
- bool shouldSaveCursor(OperationContext* txn,
- const Collection* collection,
- PlanExecutor::ExecState finalState,
- PlanExecutor* exec);
+/**
+ * Returns true if we should keep a cursor around because we're expecting to return more query
+ * results.
+ *
+ * If false, the caller should close the cursor and indicate this to the client by sending back
+ * a cursor ID of 0.
+ */
+bool shouldSaveCursor(OperationContext* txn,
+ const Collection* collection,
+ PlanExecutor::ExecState finalState,
+ PlanExecutor* exec);
- /**
- * Similar to shouldSaveCursor(), but used in getMore to determine whether we should keep
- * the cursor around for additional getMores().
- *
- * If false, the caller should close the cursor and indicate this to the client by sending back
- * a cursor ID of 0.
- */
- bool shouldSaveCursorGetMore(PlanExecutor::ExecState finalState,
- PlanExecutor* exec,
- bool isTailable);
+/**
+ * Similar to shouldSaveCursor(), but used in getMore to determine whether we should keep
+ * the cursor around for additional getMores().
+ *
+ * If false, the caller should close the cursor and indicate this to the client by sending back
+ * a cursor ID of 0.
+ */
+bool shouldSaveCursorGetMore(PlanExecutor::ExecState finalState,
+ PlanExecutor* exec,
+ bool isTailable);
- /**
- * Fills out the CurOp for "txn" with information about this query.
- */
- void beginQueryOp(OperationContext* txn,
- const NamespaceString& nss,
- const BSONObj& queryObj,
- int ntoreturn,
- int ntoskip);
+/**
+ * Fills out the CurOp for "txn" with information about this query.
+ */
+void beginQueryOp(OperationContext* txn,
+ const NamespaceString& nss,
+ const BSONObj& queryObj,
+ int ntoreturn,
+ int ntoskip);
- /**
- * Fills out CurOp for "txn" with information regarding this query's execution.
- *
- * Uses explain functionality to extract stats from 'exec'.
- *
- * The database profiling level, 'dbProfilingLevel', is used to conditionalize whether or not we
- * do expensive stats gathering.
- */
- void endQueryOp(OperationContext* txn,
- PlanExecutor* exec,
- int dbProfilingLevel,
- int numResults,
- CursorId cursorId);
+/**
+ * Fills out CurOp for "txn" with information regarding this query's execution.
+ *
+ * Uses explain functionality to extract stats from 'exec'.
+ *
+ * The database profiling level, 'dbProfilingLevel', is used to conditionalize whether or not we
+ * do expensive stats gathering.
+ */
+void endQueryOp(OperationContext* txn,
+ PlanExecutor* exec,
+ int dbProfilingLevel,
+ int numResults,
+ CursorId cursorId);
- /**
- * Constructs a PlanExecutor for a query with the oplogReplay option set to true,
- * for the query 'cq' over the collection 'collection'. The PlanExecutor will
- * wrap a singleton OplogStart stage.
- *
- * The oplog start finding hack requires that 'cq' has a $gt or $gte predicate over
- * a field named 'ts'.
- *
- * On success, caller takes ownership of *execOut.
- */
- Status getOplogStartHack(OperationContext* txn,
- Collection* collection,
- CanonicalQuery* cq,
- PlanExecutor** execOut);
+/**
+ * Constructs a PlanExecutor for a query with the oplogReplay option set to true,
+ * for the query 'cq' over the collection 'collection'. The PlanExecutor will
+ * wrap a singleton OplogStart stage.
+ *
+ * The oplog start finding hack requires that 'cq' has a $gt or $gte predicate over
+ * a field named 'ts'.
+ *
+ * On success, caller takes ownership of *execOut.
+ */
+Status getOplogStartHack(OperationContext* txn,
+ Collection* collection,
+ CanonicalQuery* cq,
+ PlanExecutor** execOut);
- /**
- * Called from the getMore entry point in ops/query.cpp.
- */
- QueryResult::View getMore(OperationContext* txn,
- const char* ns,
- int ntoreturn,
- long long cursorid,
- int pass,
- bool& exhaust,
- bool* isCursorAuthorized);
+/**
+ * Called from the getMore entry point in ops/query.cpp.
+ */
+QueryResult::View getMore(OperationContext* txn,
+ const char* ns,
+ int ntoreturn,
+ long long cursorid,
+ int pass,
+ bool& exhaust,
+ bool* isCursorAuthorized);
- /**
- * Run the query 'q' and place the result in 'result'.
- */
- std::string runQuery(OperationContext* txn,
- QueryMessage& q,
- const NamespaceString& ns,
- Message &result);
+/**
+ * Run the query 'q' and place the result in 'result'.
+ */
+std::string runQuery(OperationContext* txn,
+ QueryMessage& q,
+ const NamespaceString& ns,
+ Message& result);
} // namespace mongo