Lines Matching refs:events
349 LIST_HEAD(, externalevent) events;
499 LIST_HEAD(, externalevent) events;
700 /* The job is responsible for monitoring external events for this
704 // The event monitor job has retrieved the initial list of events.
1479 while ((eei = LIST_FIRST(&j->events))) {
6172 /* TODO: Coalesce external events and semaphore items, since they're basically
6176 LIST_FOREACH(ei, &j->events, job_le) {
7415 * safely handle the following sequence of events.
7508 * External events need to be tracked.
7509 * Internal events do NOT need to be tracked.
7637 LIST_INSERT_HEAD(&j->events, ee, job_le);
7638 LIST_INSERT_HEAD(&sys->events, ee, sys_le);
7686 LIST_FOREACH(ei, &es->events, sys_le) {
7717 while ((ei = LIST_FIRST(&es->events))) {
7746 job_log(j, LOG_DEBUG, "Importing events for stream: %s", key);
8432 /* Stop listening for events.
10627 /* Don't allow events to be set for anonymous jobs unless specifically
10638 LIST_FOREACH(eei, &j->events, job_le) {
10689 xpc_object_t events = NULL;
10696 job_log(j, LOG_DEBUG, "Fetching all events%s%s", stream ? " for stream: " : "", stream ? stream : "");
10697 events = xpc_dictionary_create(NULL, NULL, 0);
10704 LIST_FOREACH(eei, &j->events, job_le) {
10706 xpc_object_t sub = xpc_dictionary_get_value(events, eei->sys->name);
10709 xpc_dictionary_set_value(events, eei->sys->name, sub);
10715 xpc_dictionary_set_value(events, eei->name, eei->event);
10718 events = xpc_retain(eei->event);
10724 if (events) {
10726 xpc_dictionary_set_value(reply2, XPC_EVENT_ROUTINE_KEY_EVENT, events);
10727 xpc_release(events);
10824 xpc_object_t events = xpc_array_create(NULL, 0);
10827 /* If we had to create the event stream, there were no events, so just
10833 xpc_release(events);
10844 LIST_FOREACH(ei, &es->events, sys_le) {
10845 xpc_array_set_uint64(events, XPC_ARRAY_APPEND, ei->id);
10846 xpc_array_append_value(events, ei->event);
10851 xpc_dictionary_set_value(reply2, XPC_EVENT_ROUTINE_KEY_EVENTS, events);
10852 xpc_release(events);