Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
return get_osd_priv(conn.get()).client_request_conn_pipeline;
}
-ConnectionPipeline &ClientRequest::cp()
-{
- return get_osd_priv(conn.get()).client_request_conn_pipeline;
-}
-
ClientRequest::PGPipeline &ClientRequest::pp(PG &pg)
{
return pg.request_pg_pipeline;
}
-bool ClientRequest::same_session_and_pg(const ClientRequest& other_op) const
-{
- return &get_osd_priv(conn.get()) == &get_osd_priv(other_op.conn.get()) &&
- m->get_spg() == other_op.m->get_spg();
-}
-
bool ClientRequest::is_pg_op() const
{
return std::any_of(
seastar::future<> with_pg_int(
ShardServices &shard_services, Ref<PG> pg);
-public:
- bool same_session_and_pg(const ClientRequest& other_op) const;
+public:
seastar::future<> with_pg(
ShardServices &shard_services, Ref<PG> pgref);
+
private:
template <typename FuncT>
interruptible_future<> with_sequencer(FuncT&& func);
Ref<PG> &pg);
bool is_pg_op() const;
- ConnectionPipeline &cp();
PGPipeline &pp(PG &pg);
template <typename Errorator>