Method beginPipeline

src/brpc/couchbase.cpp:2409–2423

}

bool CouchbaseOperations::beginPipeline() {
  if (pipeline_active) {
    DEBUG_PRINT("Pipeline already active. Call clearPipeline() first.");
    return false;
  }

  // Clear any previous state
  while (!pipeline_operations_queue.empty()) {
    pipeline_operations_queue.pop();
  }
  pipeline_request_couchbase_req.Clear();

  pipeline_active = true;
  return true;
}

bool CouchbaseOperations::pipelineRequest(operation_type op_type,
                                          const std::string& key,