treewide: remove remaining with_linearized_managed_bytes uses

There is no point in calling the wrapper since linearization code
is private in `managed_bytes` class and there is no one to call
`managed_bytes::data` because it was deleted recently.

This patch is a prerequisite for removing
`with_linearized_managed_bytes` function completely, alongside with
the corresponding parts of implementation in `managed_bytes`.

Signed-off-by: Pavel Solodovnikov <pa.solodovnikov@scylladb.com>
This commit is contained in:
Pavel Solodovnikov
2020-10-27 01:01:05 +03:00
committed by Michał Chojnowski
parent bf8b138b42
commit e04eb68a9c
4 changed files with 0 additions and 10 deletions

View File

@@ -1219,8 +1219,6 @@ static
void
apply_monotonically(const column_definition& def, cell_and_hash& dst,
atomic_cell_or_collection& src, cell_hash_opt src_hash) {
// Must be run via with_linearized_managed_bytes() context, but assume it is
// provided via an upper layer
if (def.is_atomic()) {
if (def.is_counter()) {
counter_cell_view::apply(def, dst.cell, src); // FIXME: Optimize
@@ -2699,9 +2697,7 @@ stop_iteration mutation_cleaner_impl::merge_some(partition_snapshot& snp) noexce
}
try {
return _worker_state->alloc_section(region, [&] {
return with_linearized_managed_bytes([&] {
return snp.merge_partition_versions(_app_stats);
});
});
} catch (...) {
// Merging failed, give up as there is no guarantee of forward progress.

View File

@@ -73,9 +73,7 @@ class partition_snapshot_flat_reader : public flat_mutation_reader::impl, public
template<typename Function>
decltype(auto) in_alloc_section(Function&& fn) {
return _read_section.with_reclaiming_disabled(_region, [&] {
return with_linearized_managed_bytes([&] {
return fn();
});
});
}
void refresh_state(const query::clustering_range& ck_range,

View File

@@ -417,7 +417,6 @@ coroutine partition_entry::apply_to_incomplete(const schema& s,
static_done = false] () mutable {
auto&& allocator = reg.allocator();
return alloc(reg, [&] {
return with_linearized_managed_bytes([&] {
size_t dirty_size = 0;
if (!static_done) {
@@ -481,7 +480,6 @@ coroutine partition_entry::apply_to_incomplete(const schema& s,
}
} while (!preemptible || !need_preempt());
return stop_iteration::no;
});
});
});
}

View File

@@ -194,10 +194,8 @@ class cache_tester {
public:
static partition_snapshot_ptr snapshot_for_key(row_cache& rc, const dht::decorated_key& dk) {
return rc._read_section(rc._tracker.region(), [&] {
return with_linearized_managed_bytes([&] {
cache_entry& e = rc.lookup(dk);
return e.partition().read(rc._tracker.region(), rc._tracker.cleaner(), e.schema(), &rc._tracker);
});
});
}
};