Objecter &objecter;
Client &client;
Finisher &finisher;
- TTLCache<string, PyObject*> ttl_cache;
+ TTLCache<std::string, PyObject*> ttl_cache;
public:
Finisher cmd_finisher;
private:
DaemonServer &server;
PyModuleRegistry &py_module_registry;
- map<std::string,ProgressEvent> progress_events;
+ std::map<std::string,ProgressEvent> progress_events;
mutable ceph::mutex lock = ceph::make_mutex("ActivePyModules::lock");
const std::string ¬ify_id);
void notify_all(const LogEntry &log_entry);
+ auto& get_module_finisher(const std::string &name) {
+ return modules.at(name)->finisher;
+ }
+
bool is_pending(std::string_view name) const {
return pending_modules.count(name) > 0;
}