// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- // vim: ts=8 sw=2 smarttab /* * Ceph - scalable distributed file system * * Copyright (C) 2016 John Spray * * This is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License version 2.1, as published by the Free Software * Foundation. See file COPYING. */ #ifndef MGR_STANDBY_H_ #define MGR_STANDBY_H_ #include "auth/Auth.h" #include "common/Finisher.h" #include "common/Timer.h" #include "common/LogClient.h" #include "client/Client.h" #include "mon/MonClient.h" #include "osdc/Objecter.h" #include "PyModuleRegistry.h" class MMgrMap; class Mgr; class MgrStandby : public Dispatcher, public md_config_obs_t { public: // config observer bits const char** get_tracked_conf_keys() const override; void handle_conf_change(const struct md_config_t *conf, const std::set &changed) override; protected: MonClient monc; std::unique_ptr client_messenger; Objecter objecter; Client client; LogClient log_client; LogChannelRef clog, audit_clog; Mutex lock; SafeTimer timer; PyModuleRegistry py_module_registry; std::shared_ptr active_mgr; int orig_argc; const char **orig_argv; std::string state_str(); void handle_mgr_map(MMgrMap *m); void _update_log_config(); void send_beacon(); bool available_in_map; public: MgrStandby(int argc, const char **argv); ~MgrStandby() override; bool ms_dispatch(Message *m) override; bool ms_handle_reset(Connection *con) override { return false; } void ms_handle_remote_reset(Connection *con) override {} bool ms_get_authorizer(int dest_type, AuthAuthorizer **authorizer, bool force_new) override; bool ms_handle_refused(Connection *con) override; int init(); void shutdown(); void respawn(); int main(vector args); void handle_signal(int signum); void tick(); }; #endif