summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorPavel Březina <pbrezina@redhat.com>2012-05-07 14:04:52 +0200
committerStephen Gallagher <sgallagh@redhat.com>2012-06-29 11:37:17 -0400
commit015882243625e51595423da929a2f72cd23c75ba (patch)
treeedb6d6b2505fd41d046eab651cabddff11129498 /src
parent0f808798eefaedc3eb241f26aa49680d87f22336 (diff)
downloadsssd-015882243625e51595423da929a2f72cd23c75ba.tar.gz
sssd-015882243625e51595423da929a2f72cd23c75ba.tar.xz
sssd-015882243625e51595423da929a2f72cd23c75ba.zip
sudo ldap provider: support periodical full refresh
Diffstat (limited to 'src')
-rw-r--r--src/providers/ldap/sdap_sudo.c129
1 files changed, 129 insertions, 0 deletions
diff --git a/src/providers/ldap/sdap_sudo.c b/src/providers/ldap/sdap_sudo.c
index 271964d9a..06d359b78 100644
--- a/src/providers/ldap/sdap_sudo.c
+++ b/src/providers/ldap/sdap_sudo.c
@@ -55,6 +55,8 @@ static int sdap_sudo_rules_refresh_recv(struct tevent_req *req,
int *dp_error,
int *error);
+static void sdap_sudo_periodical_full_refresh_done(struct tevent_req *req);
+
static void
sdap_sudo_shutdown(struct be_req *req)
{
@@ -66,6 +68,8 @@ struct bet_ops sdap_sudo_ops = {
.finalize = sdap_sudo_shutdown
};
+int sdap_sudo_setup_periodical_full_refresh(struct sdap_id_ctx *id_ctx);
+
int sdap_sudo_init(struct be_ctx *be_ctx,
struct sdap_id_ctx *id_ctx,
struct bet_ops **ops,
@@ -86,6 +90,76 @@ int sdap_sudo_init(struct be_ctx *be_ctx,
return ret;
}
+ ret = sdap_sudo_setup_periodical_full_refresh(id_ctx);
+ if (ret != EOK) {
+ DEBUG(SSSDBG_OP_FAILURE, ("Unable to setup periodical full refresh"
+ "of sudo rules [%d]: %s\n", ret, strerror(ret)));
+ }
+
+ return EOK;
+}
+
+int sdap_sudo_setup_periodical_full_refresh(struct sdap_id_ctx *id_ctx)
+{
+ struct tevent_req *req;
+ time_t full_interval;
+ time_t last_full;
+ time_t now;
+ struct timeval tv;
+ int ret;
+
+ /* setup periodical full refresh */
+ full_interval = dp_opt_get_int(id_ctx->opts->basic,
+ SDAP_SUDO_FULL_REFRESH_INTERVAL);
+ if (full_interval != 0) {
+ ret = sysdb_sudo_get_last_full_refresh(id_ctx->be->sysdb, &last_full);
+ if (ret != EOK) {
+ return ret;
+ }
+
+ if (last_full == 0) {
+ /* If this is the first startup, we need to kick off
+ * an refresh immediately, to close a window where
+ * clients requesting sudo information won't get an
+ * immediate reply with no entries
+ */
+ tv = tevent_timeval_current();
+ } else {
+ /* At least one update has previously run,
+ * so clients will get cached data.
+ * We will delay the refresh so we don't slow
+ * down the startup process if this is happening
+ * during system boot.
+ */
+
+ now = time(NULL);
+ if (last_full + full_interval < now) {
+ /* delay at least by 10s */
+ tv = tevent_timeval_current_ofs(10, 0);
+ } else {
+ tv = tevent_timeval_set(last_full + full_interval, 0);
+ }
+ }
+
+ req = sdap_sudo_timer_send(id_ctx, id_ctx->be->ev, id_ctx,
+ tv, full_interval,
+ sdap_sudo_full_refresh_send);
+ if (req == NULL) {
+ DEBUG(SSSDBG_OP_FAILURE, ("Unable to schedule full refresh of sudo "
+ "rules! Full periodical refresh will not work.\n"));
+ return ENOMEM;
+ }
+
+ tevent_req_set_callback(req, sdap_sudo_periodical_full_refresh_done,
+ id_ctx);
+
+ DEBUG(SSSDBG_TRACE_FUNC, ("Full refresh scheduled at: %lld\n",
+ (long long)tv.tv_sec));
+ } else {
+ DEBUG(SSSDBG_CONF_SETTINGS, ("Periodical full refresh of sudo rules "
+ "is disabled\n"));
+ }
+
return EOK;
}
@@ -358,3 +432,58 @@ static int sdap_sudo_rules_refresh_recv(struct tevent_req *req,
{
return sdap_sudo_refresh_recv(req, dp_error, error);
}
+
+static void sdap_sudo_periodical_full_refresh_done(struct tevent_req *req)
+{
+ struct tevent_req *subreq = NULL; /* req from sdap_sudo_full_refresh_send() */
+ struct tevent_req *newreq = NULL;
+ struct sdap_id_ctx *id_ctx = NULL;
+ struct timeval tv;
+ time_t delay;
+ int dp_error;
+ int error;
+ int ret;
+
+ ret = sdap_sudo_timer_recv(req, req, &subreq);
+ if (ret != EOK) {
+ DEBUG(SSSDBG_OP_FAILURE,
+ ("Sudo timer failed [%d]: %s\n", ret, strerror(ret)));
+ goto schedule;
+ }
+
+ ret = sdap_sudo_full_refresh_recv(subreq, &dp_error, &error);
+ if (dp_error != DP_ERR_OK || error != EOK) {
+ DEBUG(SSSDBG_OP_FAILURE, ("Periodical full refresh of sudo rules "
+ "failed [dp_error: %d] ([%d]: %s)",
+ dp_error, error, strerror(error)));
+ goto schedule;
+ }
+
+schedule:
+ id_ctx = tevent_req_callback_data(req, struct sdap_id_ctx);
+ talloc_zfree(req);
+
+ delay = dp_opt_get_int(id_ctx->opts->basic, SDAP_SUDO_FULL_REFRESH_INTERVAL);
+ if (delay == 0) {
+ /* runtime configuration change? */
+ DEBUG(SSSDBG_TRACE_FUNC, ("Periodical full refresh of sudo rules "
+ "is disabled\n"));
+ return;
+ }
+
+ /* schedule new refresh */
+ tv = tevent_timeval_current_ofs(delay, 0);
+ newreq = sdap_sudo_timer_send(id_ctx, id_ctx->be->ev, id_ctx,
+ tv, delay, sdap_sudo_full_refresh_send);
+ if (newreq == NULL) {
+ DEBUG(SSSDBG_OP_FAILURE, ("Unable to schedule full refresh of sudo "
+ "rules! Full periodical refresh will not work.\n"));
+ return;
+ }
+
+ tevent_req_set_callback(newreq, sdap_sudo_periodical_full_refresh_done,
+ id_ctx);
+
+ DEBUG(SSSDBG_TRACE_FUNC, ("Full refresh scheduled at: %lld\n",
+ (long long)tv.tv_sec));
+}