#include "auth/AuthAuthorizeHandler.h"
+#include "ServiceMap.h"
#include "MgrSession.h"
#include "DaemonState.h"
/// connections for osds
ceph::unordered_map<int,set<ConnectionRef>> osd_cons;
+ ServiceMap pending_service_map; // uncommitted
+ epoch_t pending_service_map_dirty = 0;
+
Mutex lock;
static void _generate_command_map(map<string,cmd_vartype>& cmdmap,
bool _reply(MCommand* m,
int ret, const std::string& s, const bufferlist& payload);
+ void _prune_pending_service_map();
+
+ utime_t started_at;
+ bool pgmap_ready = false;
+ std::set<int32_t> reported_osds;
+ void maybe_ready(int32_t osd_id);
+
public:
int init(uint64_t gid, entity_addr_t client_addr);
void shutdown();
bool handle_report(MMgrReport *m);
bool handle_command(MCommand *m);
void send_report();
+ void got_service_map();
};
#endif