diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-26 19:19:24 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-26 19:19:24 +0000 |
commit | 80b2585f2c5bed035d5fb9215533109ad00a3fc5 (patch) | |
tree | 6a3158f65d3c336b5ca05804b22171e100ed6bd4 /storage | |
parent | 72b6f0a82a7f1f7caec8cc58815b3802d94fb92d (diff) |
Use && qualified member functions.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp | 4 | ||||
-rw-r--r-- | storage/src/vespa/storage/storageserver/rpc/storage_api_rpc_service.cpp | 3 |
2 files changed, 2 insertions, 5 deletions
diff --git a/storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp b/storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp index a65e8678a72..8b009e02f28 100644 --- a/storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp +++ b/storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp @@ -15,7 +15,6 @@ #include <vespa/vespalib/gtest/gtest.h> #include <vector> -using vespalib::DataBuffer; namespace storage::rpc { using document::FixedBucketSpaces; @@ -83,8 +82,7 @@ struct SetStateFixture : FixtureBase { auto* params = bound_request->GetParams(); params->AddInt8(static_cast<uint8_t>(encoded_bundle._compression_type)); params->AddInt32(uncompressed_length); - const auto buf_len = encoded_bundle._buffer->getDataLen(); - params->AddData(DataBuffer::stealBuffer(std::move(*encoded_bundle._buffer)), buf_len); + params->AddData(std::move(*encoded_bundle._buffer)); bound_request->SetDetachedPT(&request_is_detached); bound_request->SetReturnHandler(&return_handler); diff --git a/storage/src/vespa/storage/storageserver/rpc/storage_api_rpc_service.cpp b/storage/src/vespa/storage/storageserver/rpc/storage_api_rpc_service.cpp index 42af872da9b..c234f623d45 100644 --- a/storage/src/vespa/storage/storageserver/rpc/storage_api_rpc_service.cpp +++ b/storage/src/vespa/storage/storageserver/rpc/storage_api_rpc_service.cpp @@ -117,8 +117,7 @@ void compress_and_add_payload_to_rpc_params(mbus::BlobRef payload, params.AddInt8(comp_type); params.AddInt32(static_cast<uint32_t>(to_compress.size())); - auto buffer_len = buf.getDataLen(); - params.AddData(vespalib::DataBuffer::stealBuffer(std::move(buf)), buffer_len); + params.AddData(std::move(buf)); } } // anon ns |