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.h37
1 files changed, 18 insertions, 19 deletions
diff --git a/src/crimson/osd/shard_services.h b/src/crimson/osd/shard_services.h
index 407fa8a3643..d19aa648d85 100644
--- a/src/crimson/osd/shard_services.h
+++ b/src/crimson/osd/shard_services.h
@@ -12,19 +12,19 @@
#include "osd/PeeringState.h"
#include "crimson/osd/osdmap_service.h"
-namespace ceph::net {
+namespace crimson::net {
class Messenger;
}
-namespace ceph::mgr {
+namespace crimson::mgr {
class Client;
}
-namespace ceph::mon {
+namespace crimson::mon {
class Client;
}
-namespace ceph::os {
+namespace crimson::os {
class FuturizedStore;
}
@@ -33,7 +33,7 @@ class OSDMap;
class PeeringCtx;
class BufferedRecoveryMessages;
-namespace ceph::osd {
+namespace crimson::osd {
/**
* Represents services available to each PG
@@ -41,11 +41,11 @@ namespace ceph::osd {
class ShardServices {
using cached_map_t = boost::local_shared_ptr<const OSDMap>;
OSDMapService &osdmap_service;
- ceph::net::Messenger &cluster_msgr;
- ceph::net::Messenger &public_msgr;
- ceph::mon::Client &monc;
- ceph::mgr::Client &mgrc;
- ceph::os::FuturizedStore &store;
+ crimson::net::Messenger &cluster_msgr;
+ crimson::net::Messenger &public_msgr;
+ crimson::mon::Client &monc;
+ crimson::mgr::Client &mgrc;
+ crimson::os::FuturizedStore &store;
CephContext cct;
@@ -55,18 +55,18 @@ class ShardServices {
public:
ShardServices(
OSDMapService &osdmap_service,
- ceph::net::Messenger &cluster_msgr,
- ceph::net::Messenger &public_msgr,
- ceph::mon::Client &monc,
- ceph::mgr::Client &mgrc,
- ceph::os::FuturizedStore &store);
+ crimson::net::Messenger &cluster_msgr,
+ crimson::net::Messenger &public_msgr,
+ crimson::mon::Client &monc,
+ crimson::mgr::Client &mgrc,
+ crimson::os::FuturizedStore &store);
seastar::future<> send_to_osd(
int peer,
MessageRef m,
epoch_t from_epoch);
- ceph::os::FuturizedStore &get_store() {
+ crimson::os::FuturizedStore &get_store() {
return store;
}
@@ -98,7 +98,7 @@ public:
/// Dispatch and reset ctx transaction
seastar::future<> dispatch_context_transaction(
- ceph::os::CollectionRef col, PeeringCtx &ctx);
+ crimson::os::CollectionRef col, PeeringCtx &ctx);
/// Dispatch and reset ctx messages
seastar::future<> dispatch_context_messages(
@@ -106,7 +106,7 @@ public:
/// Dispatch ctx and dispose of context
seastar::future<> dispatch_context(
- ceph::os::CollectionRef col,
+ crimson::os::CollectionRef col,
PeeringCtx &&ctx);
/// Dispatch ctx and dispose of ctx, transaction must be empty
@@ -160,5 +160,4 @@ public:
std::map<int, HeartbeatStampsRef> heartbeat_stamps;
};
-
}