std::move(ic),
std::forward<OpFunc>(opfunc),
std::forward<Params>(params)...
- ).template handle_interruption(std::move(efunc));
+ ).handle_interruption(std::move(efunc));
}
template <typename OpFunc, typename OnInterrupt,
return insert_size(key, value);
} else {
assert(stage < STAGE);
- return NXT_STAGE_T::template insert_size_at(stage, key, value);
+ return NXT_STAGE_T::insert_size_at(stage, key, value);
}
}
return container_t::insert_at(
mut, container, key, value, 0, _insert_size, p_left_bound);
} else {
- auto range = container_t::template insert_prefix_at(
+ auto range = container_t::insert_prefix_at(
mut, container, key, 0, _insert_size, p_left_bound);
return NXT_STAGE_T::template insert_new<KT>(mut, range, key, value);
}
auto [commit_fut, reply] = co_await pg->handle_rep_op(req);
// Transitions from OrderedExclusive->OrderedConcurrent cannot block
- this->template enter_stage_sync(repop_pipeline(*pg).wait_commit);
+ this->enter_stage_sync(repop_pipeline(*pg).wait_commit);
co_await std::move(commit_fut);
return get_pg_to_shard_mapping().get_or_create_pg_mapping(
pgid, shard_core
).then([this, pgid] (auto core) {
- return this->template with_remote_shard_state(
+ return this->with_remote_shard_state(
core,
[pgid](
PerShardState &per_shard_state,