summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-09-26 19:19:24 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-09-26 19:19:24 +0000
commit80b2585f2c5bed035d5fb9215533109ad00a3fc5 (patch)
tree6a3158f65d3c336b5ca05804b22171e100ed6bd4 /storage
parent72b6f0a82a7f1f7caec8cc58815b3802d94fb92d (diff)
Use && qualified member functions.
Diffstat (limited to 'storage')
-rw-r--r--storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp4
-rw-r--r--storage/src/vespa/storage/storageserver/rpc/storage_api_rpc_service.cpp3
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