heimdal/kcm/events.c

48 		  kcm_event *event)
52     if (event->action == KCM_EVENT_NONE) {
57     ret = kcm_enqueue_event_internal(context, event);
73 log_event(kcm_event *event, char *msg)
77     print_times(event->fire_time, fire_time);
78     print_times(event->expire_time, expire_time);
80     kcm_log(7, "%s event %08x: fire_time %s fire_count %d expire_time %s "
82 	    msg, event, fire_time, event->fire_count, expire_time,
83 	    event->backoff_time, action_strings[event->action],
84 	    event->ccache->name);
89 			   kcm_event *event)
93     if (event->action == KCM_EVENT_NONE)
105     (*e)->fire_time = event->fire_time;
107     (*e)->expire_time = event->expire_time;
108     (*e)->backoff_time = event->backoff_time;
110     (*e)->action = event->action;
112     kcm_retain_ccache(context, event->ccache);
113     (*e)->ccache = event->ccache;
137 			   kcm_event *event)
142     e = *event;
203 			      kcm_event *event,
207     kcm_ccache ccache = event->ccache;
209     event->fire_time = 0;
210     event->expire_time = 0;
211     event->backoff_time = KCM_EVENT_DEFAULT_BACKOFF_TIME;
220 	event->fire_time = time(NULL); /* right away */
221 	event->action = KCM_EVENT_ACQUIRE_CREDS;
224 	    event->action = KCM_EVENT_RENEW_CREDS;
228 		event->action = KCM_EVENT_ACQUIRE_CREDS;
230 		event->action = KCM_EVENT_NONE;
234 	event->fire_time = newcred->times.endtime - KCM_EVENT_QUEUE_INTERVAL;
236 	event->action = KCM_EVENT_NONE;
247     kcm_event event;
250     memset(&event, 0, sizeof(event));
251     event.ccache = ccache;
253     ret = kcm_ccache_make_default_event(context, &event, newcred);
257     ret = kcm_enqueue_event_internal(context, &event);
266 		 kcm_event *event)
272     log_event(event, "removing");
276 	if (event == *e) {
277 	    *e = event->next;
288     ret = kcm_remove_event_internal(context, &event);
323     kcm_event *event;
328     event = *e;
330     switch (event->action) {
332 	ret = kcm_ccache_acquire(context, event->ccache, &credp);
336 	ret = kcm_ccache_refresh(context, event->ccache, &credp);
338 	    ret = kcm_ccache_acquire(context, event->ccache, &credp);
343 	ret = kcm_ccache_destroy(context, event->ccache->name);
346 	ret = kcm_ccache_destroy_if_empty(context, event->ccache);
353     event->fire_count++;
356 	/* Reschedule failed event for another time */
357 	event->fire_time += event->backoff_time;
358 	if (event->backoff_time < KCM_EVENT_MAX_BACKOFF_TIME)
359 	    event->backoff_time *= 2;
362 	if (event->expire_time &&
363 	    event->fire_time > event->expire_time)
369 	    if (krb5_unparse_name(context, event->ccache->client,
374 		    (event->action == KCM_EVENT_ACQUIRE_CREDS) ?
376 		    event->ccache->name,
382 	    /* Succeeded, but possibly replaced with another event */
383 	    ret = kcm_ccache_make_default_event(context, event, credp);
384 	    if (ret || event->action == KCM_EVENT_NONE)
387 		log_event(event, "requeuing");
404     /* Only run event queue every N seconds */
418 		kcm_log(1, "Could not fire event for cache %s: %s",
424 		kcm_log(1, "Could not expire event for cache %s: %s",