Skip to content

Commit dc0c6ab

Browse files
committed
crimson/osd/pg_backend: rep_op_ret_t to not return acked_peers
Cleanup, no longer used. Signed-off-by: Matan Breizman <[email protected]> Signed-off-by: Xuehan Xu <[email protected]>
1 parent 7462b1c commit dc0c6ab

File tree

3 files changed

+3
-5
lines changed

3 files changed

+3
-5
lines changed

src/crimson/osd/ec_backend.cc

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,5 @@ ECBackend::submit_transaction(const std::set<pg_shard_t> &pg_shards,
3333
std::vector<pg_log_entry_t>&& log_entries)
3434
{
3535
// todo
36-
return make_ready_future<rep_op_ret_t>(seastar::now(),
37-
seastar::make_ready_future<crimson::osd::acked_peers_t>());
36+
return make_ready_future<rep_op_ret_t>(seastar::now(), seastar::now());
3837
}

src/crimson/osd/pg_backend.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ class PGBackend
6262
::crimson::osd::IOInterruptCondition, T>;
6363
using rep_op_ret_t =
6464
std::tuple<interruptible_future<>,
65-
interruptible_future<crimson::osd::acked_peers_t>>;
65+
interruptible_future<>>;
6666
using rep_op_fut_t = interruptible_future<rep_op_ret_t>;
6767
PGBackend(shard_id_t shard, CollectionRef coll,
6868
crimson::osd::ShardServices &shard_services,

src/crimson/osd/replicated_backend.cc

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -188,8 +188,7 @@ ReplicatedBackend::submit_transaction(
188188
if (!to_push_delete.empty()) {
189189
pg.enqueue_delete_for_backfill(hoid, {}, to_push_delete);
190190
}
191-
return seastar::make_ready_future<
192-
crimson::osd::acked_peers_t>(std::move(acked_peers));
191+
return seastar::now();
193192
});
194193

195194
auto sends_complete = seastar::when_all_succeed(

0 commit comments

Comments
 (0)