Lines Matching defs:resultQueue
709 std::shared_ptr<ResultMetadataQueue> resultQueue;
744 resultQueue(nullptr),
760 resultQueue(queue),
967 if (request->resultQueue == nullptr) {
971 if (!request->resultQueue->read(resultMetadata.data(),
3291 std::shared_ptr<ResultMetadataQueue> resultQueue;
3294 [&resultQueue](const auto& descriptor) {
3295 resultQueue = std::make_shared<ResultMetadataQueue>(
3297 if (!resultQueue->isValid() ||
3298 resultQueue->availableToWrite() <= 0) {
3301 resultQueue = nullptr;
3308 partialResultCount, resultQueue};
3380 resultQueue};
3499 std::shared_ptr<ResultMetadataQueue> resultQueue;
3502 [&resultQueue](const auto& descriptor) {
3503 resultQueue = std::make_shared<ResultMetadataQueue>(
3505 if (!resultQueue->isValid() ||
3506 resultQueue->availableToWrite() <= 0) {
3509 resultQueue = nullptr;
3516 supportsPartialResults, partialResultCount, resultQueue};
3590 supportsPartialResults, partialResultCount, resultQueue};
3687 std::shared_ptr<ResultMetadataQueue> resultQueue;
3690 [&resultQueue](const auto& descriptor) {
3691 resultQueue = std::make_shared<ResultMetadataQueue>(descriptor);
3692 if (!resultQueue->isValid() || resultQueue->availableToWrite() <= 0) {
3695 resultQueue = nullptr;
3700 ASSERT_NE(nullptr, resultQueue);
3741 inflightReqs[i] = {1, false, supportsPartialResults, partialResultCount, resultQueue};
3945 std::shared_ptr<ResultMetadataQueue> resultQueue;
3948 [&resultQueue](const auto& descriptor) {
3949 resultQueue = std::make_shared<ResultMetadataQueue>(
3951 if (!resultQueue->isValid() ||
3952 resultQueue->availableToWrite() <= 0) {
3955 resultQueue = nullptr;
3962 partialResultCount, resultQueue};