Skip to content

Commit f8fc04a

Browse files
athanatosMatan-B
authored andcommitted
crimson/.../osd.cc: convert active ops to start_pg_operation_active
Signed-off-by: Samuel Just <[email protected]> (cherry picked from commit 607c773)
1 parent 8b06b72 commit f8fc04a

File tree

1 file changed

+12
-12
lines changed

1 file changed

+12
-12
lines changed

src/crimson/osd/osd.cc

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1401,36 +1401,36 @@ seastar::future<> OSD::handle_update_log_missing(
14011401
crimson::net::ConnectionRef conn,
14021402
Ref<MOSDPGUpdateLogMissing> m)
14031403
{
1404-
return pg_shard_manager.start_pg_operation<LogMissingRequest>(
1404+
return pg_shard_manager.start_pg_operation_active<LogMissingRequest>(
14051405
std::move(conn),
1406-
std::move(m)).second;
1406+
std::move(m));
14071407
}
14081408

14091409
seastar::future<> OSD::handle_update_log_missing_reply(
14101410
crimson::net::ConnectionRef conn,
14111411
Ref<MOSDPGUpdateLogMissingReply> m)
14121412
{
1413-
return pg_shard_manager.start_pg_operation<LogMissingRequestReply>(
1413+
return pg_shard_manager.start_pg_operation_active<LogMissingRequestReply>(
14141414
std::move(conn),
1415-
std::move(m)).second;
1415+
std::move(m));
14161416
}
14171417

14181418
seastar::future<> OSD::handle_pg_pct(
14191419
crimson::net::ConnectionRef conn,
14201420
Ref<MOSDPGPCT> m)
14211421
{
1422-
return pg_shard_manager.start_pg_operation<PGPCTRequest>(
1422+
return pg_shard_manager.start_pg_operation_active<PGPCTRequest>(
14231423
std::move(conn),
1424-
std::move(m)).second;
1424+
std::move(m));
14251425
}
14261426

14271427
seastar::future<> OSD::handle_rep_op(
14281428
crimson::net::ConnectionRef conn,
14291429
Ref<MOSDRepOp> m)
14301430
{
1431-
return pg_shard_manager.start_pg_operation<RepRequest>(
1431+
return pg_shard_manager.start_pg_operation_active<RepRequest>(
14321432
std::move(conn),
1433-
std::move(m)).second;
1433+
std::move(m));
14341434
}
14351435

14361436
seastar::future<> OSD::handle_rep_op_reply(
@@ -1473,9 +1473,9 @@ seastar::future<> OSD::handle_scrub_message(
14731473
crimson::net::ConnectionRef conn,
14741474
Ref<MOSDFastDispatchOp> m)
14751475
{
1476-
return pg_shard_manager.start_pg_operation<
1476+
return pg_shard_manager.start_pg_operation_active<
14771477
crimson::osd::ScrubMessage
1478-
>(m, conn, m->get_min_epoch(), m->get_spg()).second;
1478+
>(m, conn, m->get_min_epoch(), m->get_spg());
14791479
}
14801480

14811481
seastar::future<> OSD::handle_mark_me_down(
@@ -1493,8 +1493,8 @@ seastar::future<> OSD::handle_recovery_subreq(
14931493
crimson::net::ConnectionRef conn,
14941494
Ref<MOSDFastDispatchOp> m)
14951495
{
1496-
return pg_shard_manager.start_pg_operation<RecoverySubRequest>(
1497-
conn, std::move(m)).second;
1496+
return pg_shard_manager.start_pg_operation_active<RecoverySubRequest>(
1497+
conn, std::move(m));
14981498
}
14991499

15001500
vector<DaemonHealthMetric> OSD::get_health_metrics()

0 commit comments

Comments
 (0)