| 2373 | } |
| 2374 | |
| 2375 | CouchbaseOperations::Result CouchbaseOperations::version() { |
| 2376 | CouchbaseRequest request; |
| 2377 | CouchbaseResponse response; |
| 2378 | brpc::Controller cntl; |
| 2379 | CouchbaseOperations::Result result; |
| 2380 | if (request.versionRequest() == false) { |
| 2381 | DEBUG_PRINT("Failed to create Version request"); |
| 2382 | result.success = false; |
| 2383 | result.value = ""; |
| 2384 | return result; |
| 2385 | } |
| 2386 | channel_->CallMethod(NULL, &cntl, &request, &response, NULL); |
| 2387 | if (cntl.Failed()) { |
| 2388 | DEBUG_PRINT("Failed to get version from Couchbase: " << cntl.ErrorText()); |
| 2389 | result.success = false; |
| 2390 | result.value = ""; |
| 2391 | result.error_message = cntl.ErrorText(); |
| 2392 | return result; |
| 2393 | } |
| 2394 | std::string version; |
| 2395 | if (response.popVersion(&version) == false) { |
| 2396 | result.success = false; |
| 2397 | result.value = ""; |
| 2398 | result.error_message = response.lastError(); |
| 2399 | result.status_code = response._status_code; |
| 2400 | return result; |
| 2401 | } |
| 2402 | // Successfully got version |
| 2403 | result.success = true; |
| 2404 | result.value = version; |
| 2405 | result.status_code = 0; |
| 2406 | return result; |
| 2407 | } |
| 2408 | |
| 2409 | bool CouchbaseOperations::beginPipeline() { |
| 2410 | if (pipeline_active) { |
no test coverage detected