ObjectStore::CollectionHandle &ch,
ObjectStore *store,
CephContext *cct);
- };
-
-struct PG_SendMessageOnConn: public Context {
- PGBackend::Listener *pg;
- Message *reply;
- ConnectionRef conn;
- PG_SendMessageOnConn(
- PGBackend::Listener *pg,
- Message *reply,
- ConnectionRef conn) : pg(pg), reply(reply), conn(conn) {}
- void finish(int) {
- pg->send_message_osd_cluster(reply, conn.get());
- }
-};
-
-struct PG_RecoveryQueueAsync : public Context {
- PGBackend::Listener *pg;
- GenContext<ThreadPool::TPHandle&> *c;
- PG_RecoveryQueueAsync(
- PGBackend::Listener *pg,
- GenContext<ThreadPool::TPHandle&> *c) : pg(pg), c(c) {}
- void finish(int) {
- pg->schedule_recovery_work(c);
- }
};
#endif
return *_dout << pgb->get_parent()->gen_dbg_prefix();
}
+namespace {
+class PG_SendMessageOnConn: public Context {
+ PGBackend::Listener *pg;
+ Message *reply;
+ ConnectionRef conn;
+ public:
+ PG_SendMessageOnConn(
+ PGBackend::Listener *pg,
+ Message *reply,
+ ConnectionRef conn) : pg(pg), reply(reply), conn(conn) {}
+ void finish(int) {
+ pg->send_message_osd_cluster(reply, conn.get());
+ }
+};
+
+class PG_RecoveryQueueAsync : public Context {
+ PGBackend::Listener *pg;
+ GenContext<ThreadPool::TPHandle&> *c;
+ public:
+ PG_RecoveryQueueAsync(
+ PGBackend::Listener *pg,
+ GenContext<ThreadPool::TPHandle&> *c) : pg(pg), c(c) {}
+ void finish(int) {
+ pg->schedule_recovery_work(c);
+ }
+};
+}
+
struct ReplicatedBackend::C_OSD_RepModifyApply : public Context {
ReplicatedBackend *pg;
RepModifyRef rm;