dist/kcm/events.c

50 		  kcm_event *event)
54     if (event->action == KCM_EVENT_NONE) {
59     ret = kcm_enqueue_event_internal(context, event);
75 log_event(kcm_event *event, char *msg)
79     print_times(event->fire_time, fire_time);
80     print_times(event->expire_time, expire_time);
82     kcm_log(7, "%s event %08x: fire_time %s fire_count %d expire_time %s "
84 	    msg, event, fire_time, event->fire_count, expire_time,
85 	    event->backoff_time, action_strings[event->action],
86 	    event->ccache->name);
91 			   kcm_event *event)
95     if (event->action == KCM_EVENT_NONE)
107     (*e)->fire_time = event->fire_time;
109     (*e)->expire_time = event->expire_time;
110     (*e)->backoff_time = event->backoff_time;
112     (*e)->action = event->action;
114     kcm_retain_ccache(context, event->ccache);
115     (*e)->ccache = event->ccache;
139 			   kcm_event *event)
144     e = *event;
205 			      kcm_event *event,
209     kcm_ccache ccache = event->ccache;
211     event->fire_time = 0;
212     event->expire_time = 0;
213     event->backoff_time = KCM_EVENT_DEFAULT_BACKOFF_TIME;
222 	event->fire_time = time(NULL); /* right away */
223 	event->action = KCM_EVENT_ACQUIRE_CREDS;
226 	    event->action = KCM_EVENT_RENEW_CREDS;
230 		event->action = KCM_EVENT_ACQUIRE_CREDS;
232 		event->action = KCM_EVENT_NONE;
236 	event->fire_time = newcred->times.endtime - KCM_EVENT_QUEUE_INTERVAL;
238 	event->action = KCM_EVENT_NONE;
249     kcm_event event;
252     memset(&event, 0, sizeof(event));
253     event.ccache = ccache;
255     ret = kcm_ccache_make_default_event(context, &event, newcred);
259     ret = kcm_enqueue_event_internal(context, &event);
268 		 kcm_event *event)
274     log_event(event, "removing");
278 	if (event == *e) {
279 	    *e = event->next;
290     ret = kcm_remove_event_internal(context, &event);
325     kcm_event *event;
330     event = *e;
332     switch (event->action) {
334 	ret = kcm_ccache_acquire(context, event->ccache, &credp);
338 	ret = kcm_ccache_refresh(context, event->ccache, &credp);
340 	    ret = kcm_ccache_acquire(context, event->ccache, &credp);
345 	ret = kcm_ccache_destroy(context, event->ccache->name);
348 	ret = kcm_ccache_destroy_if_empty(context, event->ccache);
355     event->fire_count++;
358 	/* Reschedule failed event for another time */
359 	event->fire_time += event->backoff_time;
360 	if (event->backoff_time < KCM_EVENT_MAX_BACKOFF_TIME)
361 	    event->backoff_time *= 2;
364 	if (event->expire_time &&
365 	    event->fire_time > event->expire_time)
371 	    if (krb5_unparse_name(context, event->ccache->client,
376 		    (event->action == KCM_EVENT_ACQUIRE_CREDS) ?
378 		    event->ccache->name,
384 	    /* Succeeded, but possibly replaced with another event */
385 	    ret = kcm_ccache_make_default_event(context, event, credp);
386 	    if (ret || event->action == KCM_EVENT_NONE)
389 		log_event(event, "requeuing");
406     /* Only run event queue every N seconds */
420 		kcm_log(1, "Could not fire event for cache %s: %s",
426 		kcm_log(1, "Could not expire event for cache %s: %s",