1
0
mirror of https://github.com/systemd/systemd synced 2025-10-06 12:14:46 +02:00

Compare commits

..

No commits in common. "a00078e8c8af30d1d2e23817646ed05ba1f9cfdd" and "879ed340a1e80ab64890f8f473df406fd0c80b76" have entirely different histories.

2 changed files with 1 additions and 38 deletions

View File

@ -3955,12 +3955,9 @@ static int event_inotify_data_process(sd_event *e, InotifyData *d) {
} }
} }
/* Something pending now? If so, let's finish. */ /* Something pending now? If so, let's finish, otherwise let's read more. */
if (d->n_pending > 0) if (d->n_pending > 0)
return 1; return 1;
/* otherwise, drop the event and let's read more */
event_inotify_data_drop(e, d, sz);
} }
return 0; return 0;

View File

@ -806,40 +806,6 @@ TEST(inotify_process_buffered_data) {
assert_se(sd_event_wait(e, 0) == 0); assert_se(sd_event_wait(e, 0) == 0);
} }
static int inotify_handler_issue_38265(sd_event_source *s, const struct inotify_event *event, void *userdata) {
log_debug("Inotify event: mask=0x%x name=%s", event->mask, event->name);
return 0;
}
TEST(inotify_issue_38265) {
_cleanup_(rm_rf_physical_and_freep) char *t = NULL;
_cleanup_(sd_event_source_unrefp) sd_event_source *a = NULL, *b = NULL;
_cleanup_(sd_event_unrefp) sd_event *e = NULL;
_cleanup_free_ char *p = NULL;
/* For issue #38265. */
ASSERT_OK(mkdtemp_malloc("/tmp/test-inotify-XXXXXX", &t));
ASSERT_OK(sd_event_default(&e));
/* Create inode data that watches IN_MODIFY */
ASSERT_OK(sd_event_add_inotify(e, &a, t, IN_CREATE | IN_MODIFY, inotify_handler_issue_38265, NULL));
ASSERT_OK(sd_event_add_inotify(e, &b, t, IN_CREATE, inotify_handler_issue_38265, NULL));
/* Then drop the event source that is interested in IN_MODIFY */
ASSERT_NULL(a = sd_event_source_unref(a));
/* Trigger IN_MODIFY (of course with IN_CREATE) */
ASSERT_NOT_NULL(p = path_join(t, "hoge"));
ASSERT_OK(write_string_file(p, "aaa", WRITE_STRING_FILE_CREATE));
for (unsigned i = 1; i < 5; i++) {
log_debug("Running event loop cycle %u to process inotify events...", i);
ASSERT_OK(sd_event_run(e, USEC_PER_MSEC));
}
}
TEST(fork) { TEST(fork) {
_cleanup_(sd_event_unrefp) sd_event *e = NULL; _cleanup_(sd_event_unrefp) sd_event *e = NULL;
int r; int r;