diff --git a/qmanager/modules/qmanager_callbacks.cpp b/qmanager/modules/qmanager_callbacks.cpp index b4dae068b..8180f7e13 100644 --- 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> &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 index e0d5ab1bd..9c1725ad6 100644 --- 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> &queues); }; #endif // #define QMANAGER_CALLBACKS_HPP