bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

frozen_mutation: avoid buffer linearization and copy

Browse Source 
Signed-off-by: Paweł Dziepak <pdziepak@scylladb.com>
This commit is contained in:
Paweł Dziepak
2016-08-09 07:43:05 +01:00
parent 3707d7fec3
commit 1daf4c73a3
2 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
frozen_mutation.cc
View File

@@ -80,11 +80,10 @@ frozen_mutation::frozen_mutation(bytes_ostream&& b)
, _pk(deserialize_key())
{ }
frozen_mutation::frozen_mutation(bytes_view bv, partition_key pk)
: _pk(std::move(pk))
{
_bytes.write(bv);
}
frozen_mutation::frozen_mutation(bytes_ostream&& b, partition_key pk)
: _bytes(std::move(b))
, _pk(std::move(pk))
{ }
frozen_mutation::frozen_mutation(const mutation& m)
: _pk(m.key())
@@ -162,7 +161,7 @@ frozen_mutation streamed_mutation_freezer::consume_end_of_stream() {
std::move(_sr), std::move(_rts),
std::move(_crs), std::move(wr));
}).end_mutation();
return frozen_mutation(out.linearize(), std::move(_key));
return frozen_mutation(std::move(out), std::move(_key));
}
future<frozen_mutation> freeze(streamed_mutation sm) {
@@ -202,7 +201,7 @@ private:
_rts.clear();
_crs.clear();
_dirty_size = 0;
return _consumer(frozen_mutation(out.linearize(), _key), _fragmented);
return _consumer(frozen_mutation(std::move(out), _key), _fragmented);
}
future<stop_iteration> maybe_flush() {

2
frozen_mutation.hh
View File

@@ -53,7 +53,7 @@ private:
public:
frozen_mutation(const mutation& m);
explicit frozen_mutation(bytes_ostream&& b);
frozen_mutation(bytes_view bv, partition_key key);
frozen_mutation(bytes_ostream&& b, partition_key key);
frozen_mutation(frozen_mutation&& m) = default;
frozen_mutation(const frozen_mutation& m) = default;
frozen_mutation& operator=(frozen_mutation&&) = default;