summaryrefslogtreecommitdiffstats
path: root/src/crimson/osd/shard_services.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/crimson/osd/shard_services.h')
-rw-r--r--src/crimson/osd/shard_services.h16
1 files changed, 16 insertions, 0 deletions
diff --git a/src/crimson/osd/shard_services.h b/src/crimson/osd/shard_services.h
index 8786ec9626f..d71513a6645 100644
--- a/src/crimson/osd/shard_services.h
+++ b/src/crimson/osd/shard_services.h
@@ -70,6 +70,10 @@ class PerShardState {
OSDState &osd_state;
OSD_OSDMapGate osdmap_gate;
+ PerShardPipeline client_request_pipeline;
+ PerShardPipeline peering_request_pipeline;
+ PerShardPipeline replicated_request_pipeline;
+
PerfCounters *perf = nullptr;
PerfCounters *recoverystate_perf = nullptr;
@@ -453,6 +457,18 @@ public:
return dispatch_context({}, std::move(ctx));
}
+ PerShardPipeline &get_client_request_pipeline() {
+ return local_state.client_request_pipeline;
+ }
+
+ PerShardPipeline &get_peering_request_pipeline() {
+ return local_state.peering_request_pipeline;
+ }
+
+ PerShardPipeline &get_replicated_request_pipeline() {
+ return local_state.replicated_request_pipeline;
+ }
+
/// Return per-core tid
ceph_tid_t get_tid() { return local_state.get_tid(); }