Cleanup, no longer used.
Signed-off-by: Matan Breizman <mbreizma@redhat.com>
Signed-off-by: Xuehan Xu <xuxuehan@qianxin.com>
std::vector<pg_log_entry_t>&& log_entries)
{
// todo
- return make_ready_future<rep_op_ret_t>(seastar::now(),
- seastar::make_ready_future<crimson::osd::acked_peers_t>());
+ return make_ready_future<rep_op_ret_t>(seastar::now(), seastar::now());
}
::crimson::osd::IOInterruptCondition, T>;
using rep_op_ret_t =
std::tuple<interruptible_future<>,
- interruptible_future<crimson::osd::acked_peers_t>>;
+ interruptible_future<>>;
using rep_op_fut_t = interruptible_future<rep_op_ret_t>;
PGBackend(shard_id_t shard, CollectionRef coll,
crimson::osd::ShardServices &shard_services,
if (!to_push_delete.empty()) {
pg.enqueue_delete_for_backfill(hoid, {}, to_push_delete);
}
- return seastar::make_ready_future<
- crimson::osd::acked_peers_t>(std::move(acked_peers));
+ return seastar::now();
});
auto sends_complete = seastar::when_all_succeed(