LIST_HEAD(struct inode_data, inode_data_to_close);
/* A list of inotify objects that already have events buffered which aren't processed yet */
- LIST_HEAD(struct inotify_data, inotify_data_buffered);
+ LIST_HEAD(struct inotify_data, buffered_inotify_data_list);
pid_t original_pid;
assert(hashmap_isempty(d->wd));
if (d->buffer_filled > 0)
- LIST_REMOVE(buffered, e->inotify_data_buffered, d);
+ LIST_REMOVE(buffered, e->buffered_inotify_data_list, d);
hashmap_free(d->inodes);
hashmap_free(d->wd);
assert(n > 0);
d->buffer_filled = (size_t) n;
- LIST_PREPEND(buffered, e->inotify_data_buffered, d);
+ LIST_PREPEND(buffered, e->buffered_inotify_data_list, d);
return 1;
}
d->buffer_filled -= sz;
if (d->buffer_filled == 0)
- LIST_REMOVE(buffered, e->inotify_data_buffered, d);
+ LIST_REMOVE(buffered, e->buffered_inotify_data_list, d);
}
static int event_inotify_data_process(sd_event *e, struct inotify_data *d) {
assert(e);
- LIST_FOREACH(buffered, d, e->inotify_data_buffered) {
+ LIST_FOREACH(buffered, d, e->buffered_inotify_data_list) {
r = event_inotify_data_process(e, d);
if (r < 0)
return r;
event_close_inode_data_fds(e);
- if (event_next_pending(e) || e->need_process_child || e->inotify_data_buffered)
+ if (event_next_pending(e) || e->need_process_child || e->buffered_inotify_data_list)
goto pending;
e->state = SD_EVENT_ARMED;
n_event_max = MALLOC_ELEMENTSOF(e->event_queue);
/* If we still have inotify data buffered, then query the other fds, but don't wait on it */
- if (e->inotify_data_buffered)
+ if (e->buffered_inotify_data_list)
timeout = 0;
for (;;) {