Method next

bolt/exec/ExchangeClient.cpp:131–153

}

std::vector<std::unique_ptr<SerializedPage>>
ExchangeClient::next(uint32_t maxBytes, bool* atEnd, ContinueFuture* future) {
  RequestSpec requestSpec;
  std::vector<std::unique_ptr<SerializedPage>> pages;
  {
    std::lock_guard<std::mutex> l(queue_->mutex());
    *atEnd = false;
    pages = queue_->dequeueLocked(maxBytes, atEnd, future);
    if (*atEnd) {
      return pages;
    }

    if (!pages.empty() && queue_->totalBytes() > maxQueuedBytes_) {
      return pages;
    }

    requestSpec = pickSourcesToRequestLocked();
  }

  // Outside of lock
  request(requestSpec);
  return pages;
}

void ExchangeClient::request(const RequestSpec& requestSpec) {
  auto self = shared_from_this();