qmanager: hoist post_sched_loop to public

flux-framework · Jun 17, 2020 · e6095f9 · e6095f9
1 parent c67e00b
commit e6095f9
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 0 deletions.
diff --git a/qmanager/modules/qmanager_callbacks.cpp b/qmanager/modules/qmanager_callbacks.cpp
@@ -315,6 +315,21 @@ void qmanager_safe_cb_t::jobmanager_exception_cb (flux_t *h, flux_jobid_t id,
                         exception_safe_wrapper.get_err_message ());
 }
 
+int qmanager_safe_cb_t::post_sched_loop (flux_t *h, schedutil_t *schedutil,
+                                         std::map<std::string,
+                                                  std::shared_ptr<
+                                                      queue_policy_base_t>> &queues)
+{
+    int rc;
+    eh_wrapper_t exception_safe_wrapper;
+    rc = exception_safe_wrapper (qmanager_cb_t::post_sched_loop,
+                                 h, schedutil, queues);
+    if (exception_safe_wrapper.bad ())
+        flux_log_error (h, "%s: %s", __FUNCTION__,
+                        exception_safe_wrapper.get_err_message ());
+    return rc;
+}
+
 /*
  * vi:tabstop=4 shiftwidth=4 expandtab
  */
diff --git a/qmanager/modules/qmanager_callbacks.hpp b/qmanager/modules/qmanager_callbacks.hpp
@@ -74,6 +74,10 @@ struct qmanager_safe_cb_t : public qmanager_cb_t {
     static void jobmanager_exception_cb (flux_t *h, flux_jobid_t id,
                                          const char *type, int severity,
                                          void *arg);
+    static int post_sched_loop (flux_t *h,
+        schedutil_t *schedutil,
+        std::map<std::string, std::shared_ptr<
+            Flux::queue_manager::queue_policy_base_t>> &queues);
 };
 
 #endif // #define QMANAGER_CALLBACKS_HPP