Searched refs:tailableMode (Results 1 – 17 of 17) sorted by relevance
50 return (_params->tailableMode == TailableMode::kTailableAndAwaitData in next()56 invariant(_params->tailableMode != TailableMode::kTailableAndAwaitData); in blockForNextNoTimeout()72 invariant(_params->tailableMode == TailableMode::kTailableAndAwaitData); in awaitNextWithTimeout()106 invariant(_params->tailableMode == TailableMode::kTailableAndAwaitData); in getNextEvent()
52 TailableMode tailableMode) { in storePossibleCursor() argument74 params.tailableMode = tailableMode; in storePossibleCursor()
129 if (_params->tailableMode != TailableMode::kTailableAndAwaitData) { in setAwaitDataTimeout()201 if (_params->tailableMode == TailableMode::kTailableAndAwaitData) { in _readySorted()205 invariant(_params->tailableMode == TailableMode::kNormal); in _readySorted()275 invariant(_params->tailableMode != TailableMode::kTailable); in _nextReadySorted()309 if (_params->tailableMode == TailableMode::kTailable && in _nextReadyUnsorted()586 if (_params->tailableMode == TailableMode::kTailable && !remote.hasNext()) { in _processBatchResults()
79 TailableMode tailableMode = TailableMode::kNormal);
127 TailableMode tailableMode = TailableMode::kNormal; member
115 return _params.tailableMode != TailableMode::kNormal; in isTailable()119 return _params.tailableMode == TailableMode::kTailableAndAwaitData; in isTailableAndAwaitData()
137 _params->tailableMode = qr->getTailableMode(); in makeCursorFromExistingCursors()1453 params->tailableMode = TailableMode::kTailableAndAwaitData; in TEST_F()1525 params->tailableMode = TailableMode::kTailableAndAwaitData; in TEST_F()1572 params->tailableMode = TailableMode::kTailableAndAwaitData; in TEST_F()1594 params->tailableMode = TailableMode::kTailableAndAwaitData; in TEST_F()1662 params->tailableMode = TailableMode::kTailableAndAwaitData; in TEST_F()
196 params.tailableMode = query.getQueryRequest().getTailableMode(); in runQueryWithoutRetrying()
164 return tailableMode == TailableMode::kTailableAndAwaitData; in isTailableAwaitData()200 TailableMode tailableMode = TailableMode::kNormal; variable
539 qr->setTailableMode(pExpCtx->tailableMode); in attemptToGetExecutor()772 if (expCtx->needsMerge && expCtx->tailableMode == TailableMode::kTailableAndAwaitData) { in prepareExecutor()
297 expCtx->tailableMode = TailableMode::kTailableAndAwaitData; in createFromBson()
347 ctx()->tailableMode = TailableMode::kTailableAndAwaitData; in TEST_F()385 ctx()->tailableMode = TailableMode::kNormal; in TEST_F()427 ctx()->tailableMode = TailableMode::kTailableAndAwaitData; in TEST_F()464 ctx()->tailableMode = TailableMode::kNormal; in TEST_F()
104 TailableMode tailableMode = TailableMode::kNormal) { in makeCollScanExec() argument113 qr->setTailableMode(tailableMode); in makeCollScanExec()
346 void setTailableMode(TailableMode tailableMode) { in setTailableMode() argument347 _tailableMode = tailableMode; in setTailableMode()
396 auto tailableMode = tailableModeFromBools(tailable, awaitData); in parseFromFindCommand() local397 if (!tailableMode.isOK()) { in parseFromFindCommand()398 return tailableMode.getStatus(); in parseFromFindCommand()400 qr->_tailableMode = tailableMode.getValue(); in parseFromFindCommand()
543 params.tailableMode = pipelineForMerging->getContext()->tailableMode; in establishMergingMongosCursor()803 mergeCtx->tailableMode)); in runAggregate()
544 if (expCtx->tailableMode == TailableMode::kTailableAndAwaitData) { in runAggregate()