1 /*
2  * Tests for util/filemonitor-*.c
3  *
4  * Copyright 2018 Red Hat, Inc.
5  *
6  * This program is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 2 of the License, or
9  * (at your option) any later version.
10  *
11  * This program is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with this library; if not, see <http://www.gnu.org/licenses/>.
18  *
19  */
20 
21 #include "qemu/osdep.h"
22 #include "qemu/main-loop.h"
23 #include "qapi/error.h"
24 #include "qemu/filemonitor.h"
25 
26 #include <glib/gstdio.h>
27 
28 #include <utime.h>
29 
30 enum {
31     QFILE_MONITOR_TEST_OP_ADD_WATCH,
32     QFILE_MONITOR_TEST_OP_DEL_WATCH,
33     QFILE_MONITOR_TEST_OP_EVENT,
34     QFILE_MONITOR_TEST_OP_CREATE,
35     QFILE_MONITOR_TEST_OP_APPEND,
36     QFILE_MONITOR_TEST_OP_TRUNC,
37     QFILE_MONITOR_TEST_OP_RENAME,
38     QFILE_MONITOR_TEST_OP_TOUCH,
39     QFILE_MONITOR_TEST_OP_UNLINK,
40     QFILE_MONITOR_TEST_OP_MKDIR,
41     QFILE_MONITOR_TEST_OP_RMDIR,
42 };
43 
44 typedef struct {
45     int type;
46     const char *filesrc;
47     const char *filedst;
48     int64_t *watchid;
49     int eventid;
50     /*
51      * Only valid with OP_EVENT - this event might be
52      * swapped with the next OP_EVENT
53      */
54     bool swapnext;
55 } QFileMonitorTestOp;
56 
57 typedef struct {
58     int64_t id;
59     QFileMonitorEvent event;
60     char *filename;
61 } QFileMonitorTestRecord;
62 
63 
64 typedef struct {
65     QemuMutex lock;
66     GList *records;
67 } QFileMonitorTestData;
68 
69 static QemuMutex evlock;
70 static bool evstopping;
71 static bool evrunning;
72 static bool debug;
73 
74 /*
75  * Main function for a background thread that is
76  * running the event loop during the test
77  */
78 static void *
79 qemu_file_monitor_test_event_loop(void *opaque G_GNUC_UNUSED)
80 {
81     qemu_mutex_lock(&evlock);
82 
83     while (!evstopping) {
84         qemu_mutex_unlock(&evlock);
85         main_loop_wait(true);
86         qemu_mutex_lock(&evlock);
87     }
88 
89     evrunning = false;
90     qemu_mutex_unlock(&evlock);
91     return NULL;
92 }
93 
94 
95 /*
96  * File monitor event handler which simply maintains
97  * an ordered list of all events that it receives
98  */
99 static void
100 qemu_file_monitor_test_handler(int64_t id,
101                                QFileMonitorEvent event,
102                                const char *filename,
103                                void *opaque)
104 {
105     QFileMonitorTestData *data = opaque;
106     QFileMonitorTestRecord *rec = g_new0(QFileMonitorTestRecord, 1);
107 
108     if (debug) {
109         g_printerr("Queue event id %" PRIx64 " event %d file %s\n",
110                    id, event, filename);
111     }
112     rec->id = id;
113     rec->event = event;
114     rec->filename = g_strdup(filename);
115 
116     qemu_mutex_lock(&data->lock);
117     data->records = g_list_append(data->records, rec);
118     qemu_mutex_unlock(&data->lock);
119 }
120 
121 
122 static void
123 qemu_file_monitor_test_record_free(QFileMonitorTestRecord *rec)
124 {
125     g_free(rec->filename);
126     g_free(rec);
127 }
128 
129 
130 /*
131  * Get the next event record that has been received by
132  * the file monitor event handler. Since events are
133  * emitted in the background thread running the event
134  * loop, we can't assume there is a record available
135  * immediately. Thus we will sleep for upto 5 seconds
136  * to wait for the event to be queued for us.
137  */
138 static QFileMonitorTestRecord *
139 qemu_file_monitor_test_next_record(QFileMonitorTestData *data,
140                                    QFileMonitorTestRecord *pushback)
141 {
142     GTimer *timer = g_timer_new();
143     QFileMonitorTestRecord *record = NULL;
144     GList *tmp;
145 
146     qemu_mutex_lock(&data->lock);
147     while (!data->records && g_timer_elapsed(timer, NULL) < 5) {
148         qemu_mutex_unlock(&data->lock);
149         usleep(10 * 1000);
150         qemu_mutex_lock(&data->lock);
151     }
152     if (data->records) {
153         record = data->records->data;
154         if (pushback) {
155             data->records->data = pushback;
156         } else {
157             tmp = data->records;
158             data->records = g_list_remove_link(data->records, tmp);
159             g_list_free(tmp);
160         }
161     } else if (pushback) {
162         qemu_file_monitor_test_record_free(pushback);
163     }
164     qemu_mutex_unlock(&data->lock);
165 
166     g_timer_destroy(timer);
167     return record;
168 }
169 
170 
171 /*
172  * Check whether the event record we retrieved matches
173  * data we were expecting to see for the event
174  */
175 static bool
176 qemu_file_monitor_test_expect(QFileMonitorTestData *data,
177                               int64_t id,
178                               QFileMonitorEvent event,
179                               const char *filename,
180                               bool swapnext)
181 {
182     QFileMonitorTestRecord *rec;
183     bool ret = false;
184 
185     rec = qemu_file_monitor_test_next_record(data, NULL);
186 
187  retry:
188     if (!rec) {
189         g_printerr("Missing event watch id %" PRIx64 " event %d file %s\n",
190                    id, event, filename);
191         return false;
192     }
193 
194     if (id != rec->id) {
195         if (swapnext) {
196             rec = qemu_file_monitor_test_next_record(data, rec);
197             swapnext = false;
198             goto retry;
199         }
200         g_printerr("Expected watch id %" PRIx64 " but got %" PRIx64 "\n",
201                    id, rec->id);
202         goto cleanup;
203     }
204 
205     if (event != rec->event) {
206         g_printerr("Expected event %d but got %d\n", event, rec->event);
207         goto cleanup;
208     }
209 
210     if (!g_str_equal(filename, rec->filename)) {
211         g_printerr("Expected filename %s but got %s\n",
212                    filename, rec->filename);
213         goto cleanup;
214     }
215 
216     ret = true;
217 
218  cleanup:
219     qemu_file_monitor_test_record_free(rec);
220     return ret;
221 }
222 
223 
224 static void
225 test_file_monitor_events(void)
226 {
227     int64_t watch0 = 0;
228     int64_t watch1 = 0;
229     int64_t watch2 = 0;
230     int64_t watch3 = 0;
231     int64_t watch4 = 0;
232     int64_t watch5 = 0;
233     QFileMonitorTestOp ops[] = {
234         { .type = QFILE_MONITOR_TEST_OP_ADD_WATCH,
235           .filesrc = NULL, .watchid = &watch0 },
236         { .type = QFILE_MONITOR_TEST_OP_ADD_WATCH,
237           .filesrc = "one.txt", .watchid = &watch1 },
238         { .type = QFILE_MONITOR_TEST_OP_ADD_WATCH,
239           .filesrc = "two.txt", .watchid = &watch2 },
240 
241 
242         { .type = QFILE_MONITOR_TEST_OP_CREATE,
243           .filesrc = "one.txt", },
244         { .type = QFILE_MONITOR_TEST_OP_EVENT,
245           .filesrc = "one.txt", .watchid = &watch0,
246           .eventid = QFILE_MONITOR_EVENT_CREATED },
247         { .type = QFILE_MONITOR_TEST_OP_EVENT,
248           .filesrc = "one.txt", .watchid = &watch1,
249           .eventid = QFILE_MONITOR_EVENT_CREATED },
250 
251 
252         { .type = QFILE_MONITOR_TEST_OP_CREATE,
253           .filesrc = "two.txt", },
254         { .type = QFILE_MONITOR_TEST_OP_EVENT,
255           .filesrc = "two.txt", .watchid = &watch0,
256           .eventid = QFILE_MONITOR_EVENT_CREATED },
257         { .type = QFILE_MONITOR_TEST_OP_EVENT,
258           .filesrc = "two.txt", .watchid = &watch2,
259           .eventid = QFILE_MONITOR_EVENT_CREATED },
260 
261 
262         { .type = QFILE_MONITOR_TEST_OP_CREATE,
263           .filesrc = "three.txt", },
264         { .type = QFILE_MONITOR_TEST_OP_EVENT,
265           .filesrc = "three.txt", .watchid = &watch0,
266           .eventid = QFILE_MONITOR_EVENT_CREATED },
267 
268 
269         { .type = QFILE_MONITOR_TEST_OP_UNLINK,
270           .filesrc = "three.txt", },
271         { .type = QFILE_MONITOR_TEST_OP_EVENT,
272           .filesrc = "three.txt", .watchid = &watch0,
273           .eventid = QFILE_MONITOR_EVENT_DELETED },
274 
275 
276         { .type = QFILE_MONITOR_TEST_OP_RENAME,
277           .filesrc = "one.txt", .filedst = "two.txt" },
278         { .type = QFILE_MONITOR_TEST_OP_EVENT,
279           .filesrc = "one.txt", .watchid = &watch0,
280           .eventid = QFILE_MONITOR_EVENT_DELETED },
281         { .type = QFILE_MONITOR_TEST_OP_EVENT,
282           .filesrc = "one.txt", .watchid = &watch1,
283           .eventid = QFILE_MONITOR_EVENT_DELETED },
284         { .type = QFILE_MONITOR_TEST_OP_EVENT,
285           .filesrc = "two.txt", .watchid = &watch0,
286           .eventid = QFILE_MONITOR_EVENT_CREATED },
287         { .type = QFILE_MONITOR_TEST_OP_EVENT,
288           .filesrc = "two.txt", .watchid = &watch2,
289           .eventid = QFILE_MONITOR_EVENT_CREATED },
290 
291 
292         { .type = QFILE_MONITOR_TEST_OP_APPEND,
293           .filesrc = "two.txt", },
294         { .type = QFILE_MONITOR_TEST_OP_EVENT,
295           .filesrc = "two.txt", .watchid = &watch0,
296           .eventid = QFILE_MONITOR_EVENT_MODIFIED },
297         { .type = QFILE_MONITOR_TEST_OP_EVENT,
298           .filesrc = "two.txt", .watchid = &watch2,
299           .eventid = QFILE_MONITOR_EVENT_MODIFIED },
300 
301 
302         { .type = QFILE_MONITOR_TEST_OP_TOUCH,
303           .filesrc = "two.txt", },
304         { .type = QFILE_MONITOR_TEST_OP_EVENT,
305           .filesrc = "two.txt", .watchid = &watch0,
306           .eventid = QFILE_MONITOR_EVENT_ATTRIBUTES },
307         { .type = QFILE_MONITOR_TEST_OP_EVENT,
308           .filesrc = "two.txt", .watchid = &watch2,
309           .eventid = QFILE_MONITOR_EVENT_ATTRIBUTES },
310 
311 
312         { .type = QFILE_MONITOR_TEST_OP_DEL_WATCH,
313           .filesrc = "one.txt", .watchid = &watch1 },
314         { .type = QFILE_MONITOR_TEST_OP_ADD_WATCH,
315           .filesrc = "one.txt", .watchid = &watch3 },
316         { .type = QFILE_MONITOR_TEST_OP_CREATE,
317           .filesrc = "one.txt", },
318         { .type = QFILE_MONITOR_TEST_OP_EVENT,
319           .filesrc = "one.txt", .watchid = &watch0,
320           .eventid = QFILE_MONITOR_EVENT_CREATED },
321         { .type = QFILE_MONITOR_TEST_OP_EVENT,
322           .filesrc = "one.txt", .watchid = &watch3,
323           .eventid = QFILE_MONITOR_EVENT_CREATED },
324 
325 
326         { .type = QFILE_MONITOR_TEST_OP_DEL_WATCH,
327           .filesrc = "one.txt", .watchid = &watch3 },
328         { .type = QFILE_MONITOR_TEST_OP_UNLINK,
329           .filesrc = "one.txt", },
330         { .type = QFILE_MONITOR_TEST_OP_EVENT,
331           .filesrc = "one.txt", .watchid = &watch0,
332           .eventid = QFILE_MONITOR_EVENT_DELETED },
333 
334 
335         { .type = QFILE_MONITOR_TEST_OP_MKDIR,
336           .filesrc = "fish", },
337         { .type = QFILE_MONITOR_TEST_OP_EVENT,
338           .filesrc = "fish", .watchid = &watch0,
339           .eventid = QFILE_MONITOR_EVENT_CREATED },
340 
341 
342         { .type = QFILE_MONITOR_TEST_OP_ADD_WATCH,
343           .filesrc = "fish/", .watchid = &watch4 },
344         { .type = QFILE_MONITOR_TEST_OP_ADD_WATCH,
345           .filesrc = "fish/one.txt", .watchid = &watch5 },
346         { .type = QFILE_MONITOR_TEST_OP_CREATE,
347           .filesrc = "fish/one.txt", },
348         { .type = QFILE_MONITOR_TEST_OP_EVENT,
349           .filesrc = "one.txt", .watchid = &watch4,
350           .eventid = QFILE_MONITOR_EVENT_CREATED },
351         { .type = QFILE_MONITOR_TEST_OP_EVENT,
352           .filesrc = "one.txt", .watchid = &watch5,
353           .eventid = QFILE_MONITOR_EVENT_CREATED },
354 
355 
356         { .type = QFILE_MONITOR_TEST_OP_DEL_WATCH,
357           .filesrc = "fish/one.txt", .watchid = &watch5 },
358         { .type = QFILE_MONITOR_TEST_OP_RENAME,
359           .filesrc = "fish/one.txt", .filedst = "two.txt", },
360         { .type = QFILE_MONITOR_TEST_OP_EVENT,
361           .filesrc = "one.txt", .watchid = &watch4,
362           .eventid = QFILE_MONITOR_EVENT_DELETED },
363         { .type = QFILE_MONITOR_TEST_OP_EVENT,
364           .filesrc = "two.txt", .watchid = &watch0,
365           .eventid = QFILE_MONITOR_EVENT_CREATED },
366         { .type = QFILE_MONITOR_TEST_OP_EVENT,
367           .filesrc = "two.txt", .watchid = &watch2,
368           .eventid = QFILE_MONITOR_EVENT_CREATED },
369 
370 
371         { .type = QFILE_MONITOR_TEST_OP_RMDIR,
372           .filesrc = "fish", },
373         { .type = QFILE_MONITOR_TEST_OP_EVENT,
374           .filesrc = "", .watchid = &watch4,
375           .eventid = QFILE_MONITOR_EVENT_IGNORED,
376           .swapnext = true },
377         { .type = QFILE_MONITOR_TEST_OP_EVENT,
378           .filesrc = "fish", .watchid = &watch0,
379           .eventid = QFILE_MONITOR_EVENT_DELETED },
380         { .type = QFILE_MONITOR_TEST_OP_DEL_WATCH,
381           .filesrc = "fish", .watchid = &watch4 },
382 
383 
384         { .type = QFILE_MONITOR_TEST_OP_UNLINK,
385           .filesrc = "two.txt", },
386         { .type = QFILE_MONITOR_TEST_OP_EVENT,
387           .filesrc = "two.txt", .watchid = &watch0,
388           .eventid = QFILE_MONITOR_EVENT_DELETED },
389         { .type = QFILE_MONITOR_TEST_OP_EVENT,
390           .filesrc = "two.txt", .watchid = &watch2,
391           .eventid = QFILE_MONITOR_EVENT_DELETED },
392 
393 
394         { .type = QFILE_MONITOR_TEST_OP_DEL_WATCH,
395           .filesrc = "two.txt", .watchid = &watch2 },
396         { .type = QFILE_MONITOR_TEST_OP_DEL_WATCH,
397           .filesrc = NULL, .watchid = &watch0 },
398     };
399     Error *local_err = NULL;
400     GError *gerr = NULL;
401     QFileMonitor *mon = qemu_file_monitor_new(&local_err);
402     QemuThread th;
403     GTimer *timer;
404     gchar *dir = NULL;
405     int err = -1;
406     gsize i;
407     char *pathsrc = NULL;
408     char *pathdst = NULL;
409     QFileMonitorTestData data;
410     GHashTable *ids = g_hash_table_new(g_int64_hash, g_int64_equal);
411     char *travis_arch;
412 
413     qemu_mutex_init(&data.lock);
414     data.records = NULL;
415 
416     /*
417      * This test does not work on Travis LXD containers since some
418      * syscalls are blocked in that environment.
419      */
420     travis_arch = getenv("TRAVIS_ARCH");
421     if (travis_arch && !g_str_equal(travis_arch, "x86_64")) {
422         g_test_skip("Test does not work on non-x86 Travis containers.");
423         return;
424     }
425 
426     /*
427      * The file monitor needs the main loop running in
428      * order to receive events from inotify. We must
429      * thus spawn a background thread to run an event
430      * loop impl, while this thread triggers the
431      * actual file operations we're testing
432      */
433     evrunning = 1;
434     evstopping = 0;
435     qemu_thread_create(&th, "event-loop",
436                        qemu_file_monitor_test_event_loop, NULL,
437                        QEMU_THREAD_JOINABLE);
438 
439     if (local_err) {
440         g_printerr("File monitoring not available: %s",
441                    error_get_pretty(local_err));
442         error_free(local_err);
443         return;
444     }
445 
446     dir = g_dir_make_tmp("test-util-filemonitor-XXXXXX",
447                          &gerr);
448     if (!dir) {
449         g_printerr("Unable to create tmp dir %s",
450                    gerr->message);
451         g_error_free(gerr);
452         abort();
453     }
454 
455     /*
456      * Run through the operation sequence validating events
457      * as we go
458      */
459     for (i = 0; i < G_N_ELEMENTS(ops); i++) {
460         const QFileMonitorTestOp *op = &(ops[i]);
461         int fd;
462         struct utimbuf ubuf;
463         char *watchdir;
464         const char *watchfile;
465 
466         pathsrc = g_strdup_printf("%s/%s", dir, op->filesrc);
467         if (op->filedst) {
468             pathdst = g_strdup_printf("%s/%s", dir, op->filedst);
469         }
470 
471         switch (op->type) {
472         case QFILE_MONITOR_TEST_OP_ADD_WATCH:
473             if (debug) {
474                 g_printerr("Add watch %s %s\n",
475                            dir, op->filesrc);
476             }
477             if (op->filesrc && strchr(op->filesrc, '/')) {
478                 watchdir = g_strdup_printf("%s/%s", dir, op->filesrc);
479                 watchfile = strrchr(watchdir, '/');
480                 *(char *)watchfile = '\0';
481                 watchfile++;
482                 if (*watchfile == '\0') {
483                     watchfile = NULL;
484                 }
485             } else {
486                 watchdir = g_strdup(dir);
487                 watchfile = op->filesrc;
488             }
489             *op->watchid =
490                 qemu_file_monitor_add_watch(mon,
491                                             watchdir,
492                                             watchfile,
493                                             qemu_file_monitor_test_handler,
494                                             &data,
495                                             &local_err);
496             g_free(watchdir);
497             if (*op->watchid < 0) {
498                 g_printerr("Unable to add watch %s",
499                            error_get_pretty(local_err));
500                 error_free(local_err);
501                 goto cleanup;
502             }
503             if (debug) {
504                 g_printerr("Watch ID %" PRIx64 "\n", *op->watchid);
505             }
506             if (g_hash_table_contains(ids, op->watchid)) {
507                 g_printerr("Watch ID %" PRIx64 "already exists", *op->watchid);
508                 goto cleanup;
509             }
510             g_hash_table_add(ids, op->watchid);
511             break;
512         case QFILE_MONITOR_TEST_OP_DEL_WATCH:
513             if (debug) {
514                 g_printerr("Del watch %s %" PRIx64 "\n", dir, *op->watchid);
515             }
516             if (op->filesrc && strchr(op->filesrc, '/')) {
517                 watchdir = g_strdup_printf("%s/%s", dir, op->filesrc);
518                 watchfile = strrchr(watchdir, '/');
519                 *(char *)watchfile = '\0';
520             } else {
521                 watchdir = g_strdup(dir);
522             }
523             g_hash_table_remove(ids, op->watchid);
524             qemu_file_monitor_remove_watch(mon,
525                                            watchdir,
526                                            *op->watchid);
527             g_free(watchdir);
528             break;
529         case QFILE_MONITOR_TEST_OP_EVENT:
530             if (debug) {
531                 g_printerr("Event id=%" PRIx64 " event=%d file=%s\n",
532                            *op->watchid, op->eventid, op->filesrc);
533             }
534             if (!qemu_file_monitor_test_expect(&data, *op->watchid,
535                                                op->eventid, op->filesrc,
536                                                op->swapnext))
537                 goto cleanup;
538             break;
539         case QFILE_MONITOR_TEST_OP_CREATE:
540             if (debug) {
541                 g_printerr("Create %s\n", pathsrc);
542             }
543             fd = open(pathsrc, O_WRONLY | O_CREAT, 0700);
544             if (fd < 0) {
545                 g_printerr("Unable to create %s: %s",
546                            pathsrc, strerror(errno));
547                 goto cleanup;
548             }
549             close(fd);
550             break;
551 
552         case QFILE_MONITOR_TEST_OP_APPEND:
553             if (debug) {
554                 g_printerr("Append %s\n", pathsrc);
555             }
556             fd = open(pathsrc, O_WRONLY | O_APPEND, 0700);
557             if (fd < 0) {
558                 g_printerr("Unable to open %s: %s",
559                            pathsrc, strerror(errno));
560                 goto cleanup;
561             }
562 
563             if (write(fd, "Hello World", 10) != 10) {
564                 g_printerr("Unable to write %s: %s",
565                            pathsrc, strerror(errno));
566                 close(fd);
567                 goto cleanup;
568             }
569             close(fd);
570             break;
571 
572         case QFILE_MONITOR_TEST_OP_TRUNC:
573             if (debug) {
574                 g_printerr("Truncate %s\n", pathsrc);
575             }
576             if (truncate(pathsrc, 4) < 0) {
577                 g_printerr("Unable to truncate %s: %s",
578                            pathsrc, strerror(errno));
579                 goto cleanup;
580             }
581             break;
582 
583         case QFILE_MONITOR_TEST_OP_RENAME:
584             if (debug) {
585                 g_printerr("Rename %s -> %s\n", pathsrc, pathdst);
586             }
587             if (rename(pathsrc, pathdst) < 0) {
588                 g_printerr("Unable to rename %s to %s: %s",
589                            pathsrc, pathdst, strerror(errno));
590                 goto cleanup;
591             }
592             break;
593 
594         case QFILE_MONITOR_TEST_OP_UNLINK:
595             if (debug) {
596                 g_printerr("Unlink %s\n", pathsrc);
597             }
598             if (unlink(pathsrc) < 0) {
599                 g_printerr("Unable to unlink %s: %s",
600                            pathsrc, strerror(errno));
601                 goto cleanup;
602             }
603             break;
604 
605         case QFILE_MONITOR_TEST_OP_TOUCH:
606             if (debug) {
607                 g_printerr("Touch %s\n", pathsrc);
608             }
609             ubuf.actime = 1024;
610             ubuf.modtime = 1025;
611             if (utime(pathsrc, &ubuf) < 0) {
612                 g_printerr("Unable to touch %s: %s",
613                            pathsrc, strerror(errno));
614                 goto cleanup;
615             }
616             break;
617 
618         case QFILE_MONITOR_TEST_OP_MKDIR:
619             if (debug) {
620                 g_printerr("Mkdir %s\n", pathsrc);
621             }
622             if (g_mkdir_with_parents(pathsrc, 0700) < 0) {
623                 g_printerr("Unable to mkdir %s: %s",
624                            pathsrc, strerror(errno));
625                 goto cleanup;
626             }
627             break;
628 
629         case QFILE_MONITOR_TEST_OP_RMDIR:
630             if (debug) {
631                 g_printerr("Rmdir %s\n", pathsrc);
632             }
633             if (rmdir(pathsrc) < 0) {
634                 g_printerr("Unable to rmdir %s: %s",
635                            pathsrc, strerror(errno));
636                 goto cleanup;
637             }
638             break;
639 
640         default:
641             g_assert_not_reached();
642         }
643 
644         g_free(pathsrc);
645         g_free(pathdst);
646         pathsrc = pathdst = NULL;
647     }
648 
649     g_assert_cmpint(g_hash_table_size(ids), ==, 0);
650 
651     err = 0;
652 
653  cleanup:
654     g_free(pathsrc);
655     g_free(pathdst);
656 
657     qemu_mutex_lock(&evlock);
658     evstopping = 1;
659     timer = g_timer_new();
660     while (evrunning && g_timer_elapsed(timer, NULL) < 5) {
661         qemu_mutex_unlock(&evlock);
662         usleep(10 * 1000);
663         qemu_mutex_lock(&evlock);
664     }
665     qemu_mutex_unlock(&evlock);
666 
667     if (g_timer_elapsed(timer, NULL) >= 5) {
668         g_printerr("Event loop failed to quit after 5 seconds\n");
669     }
670     g_timer_destroy(timer);
671 
672     qemu_file_monitor_free(mon);
673     g_list_foreach(data.records,
674                    (GFunc)qemu_file_monitor_test_record_free, NULL);
675     g_list_free(data.records);
676     qemu_mutex_destroy(&data.lock);
677     if (dir) {
678         for (i = 0; i < G_N_ELEMENTS(ops); i++) {
679             const QFileMonitorTestOp *op = &(ops[i]);
680             char *path = g_strdup_printf("%s/%s",
681                                          dir, op->filesrc);
682             if (op->type == QFILE_MONITOR_TEST_OP_MKDIR) {
683                 rmdir(path);
684                 g_free(path);
685             } else {
686                 unlink(path);
687                 g_free(path);
688                 if (op->filedst) {
689                     path = g_strdup_printf("%s/%s",
690                                            dir, op->filedst);
691                     unlink(path);
692                     g_free(path);
693                 }
694             }
695         }
696         if (rmdir(dir) < 0) {
697             g_printerr("Failed to remove %s: %s\n",
698                        dir, strerror(errno));
699             abort();
700         }
701     }
702     g_hash_table_unref(ids);
703     g_free(dir);
704     g_assert(err == 0);
705 }
706 
707 
708 int main(int argc, char **argv)
709 {
710     g_test_init(&argc, &argv, NULL);
711 
712     qemu_init_main_loop(&error_abort);
713 
714     qemu_mutex_init(&evlock);
715 
716     debug = getenv("FILEMONITOR_DEBUG") != NULL;
717     g_test_add_func("/util/filemonitor", test_file_monitor_events);
718 
719     return g_test_run();
720 }
721