summaryrefslogtreecommitdiffstatshomepage
path: root/3rdparty/libuv/test/test-queue-foreach-delete.c
diff options
context:
space:
mode:
author ImJezze <jezze@gmx.net>2016-02-21 11:48:45 +0100
committer ImJezze <jezze@gmx.net>2016-02-21 11:48:45 +0100
commitcc24a339d8c0517259084b5c178d784626ba965c (patch)
tree9868e9687b5802ae0a3733712a3bbeb3bc75c953 /3rdparty/libuv/test/test-queue-foreach-delete.c
parentb5daabda5495dea5c50e17961ecfed2ea8619d76 (diff)
Merge remote-tracking branch 'refs/remotes/mamedev/master'
Second attempt
Diffstat (limited to '3rdparty/libuv/test/test-queue-foreach-delete.c')
-rw-r--r--3rdparty/libuv/test/test-queue-foreach-delete.c200
1 files changed, 200 insertions, 0 deletions
diff --git a/3rdparty/libuv/test/test-queue-foreach-delete.c b/3rdparty/libuv/test/test-queue-foreach-delete.c
new file mode 100644
index 00000000000..45da225381f
--- /dev/null
+++ b/3rdparty/libuv/test/test-queue-foreach-delete.c
@@ -0,0 +1,200 @@
+/* Copyright The libuv project and contributors. All rights reserved.
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to
+ * deal in the Software without restriction, including without limitation the
+ * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
+ * sell copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in
+ * all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
+ * IN THE SOFTWARE.
+ */
+
+#include "uv.h"
+#include "task.h"
+
+#include <string.h>
+
+
+/*
+ * The idea behind the test is as follows.
+ * Certain handle types are stored in a queue internally.
+ * Extra care should be taken for removal of a handle from the queue while iterating over the queue.
+ * (i.e., QUEUE_REMOVE() called within QUEUE_FOREACH())
+ * This usually happens when someone closes or stops a handle from within its callback.
+ * So we need to check that we haven't screwed the queue on close/stop.
+ * To do so we do the following (for each handle type):
+ * 1. Create and start 3 handles (#0, #1, and #2).
+ *
+ * The queue after the start() calls:
+ * ..=> [queue head] <=> [handle] <=> [handle #1] <=> [handle] <=..
+ *
+ * 2. Trigger handles to fire (for uv_idle_t, uv_prepare_t, and uv_check_t there is nothing to do).
+ *
+ * 3. In the callback for the first-executed handle (#0 or #2 depending on handle type)
+ * stop the handle and the next one (#1).
+ * (for uv_idle_t, uv_prepare_t, and uv_check_t callbacks are executed in the reverse order as they are start()'ed,
+ * so callback for handle #2 will be called first)
+ *
+ * The queue after the stop() calls:
+ * correct foreach "next" |
+ * \/
+ * ..=> [queue head] <==============================> [handle] <=..
+ * [ ] <- [handle] <=> [handle #1] -> [ ]
+ * /\
+ * wrong foreach "next" |
+ *
+ * 4. The callback for handle #1 shouldn't be called because the handle #1 is stopped in the previous step.
+ * However, if QUEUE_REMOVE() is not handled properly within QUEUE_FOREACH(), the callback _will_ be called.
+ */
+
+static const unsigned first_handle_number_idle = 2;
+static const unsigned first_handle_number_prepare = 2;
+static const unsigned first_handle_number_check = 2;
+#ifdef __linux__
+static const unsigned first_handle_number_fs_event = 0;
+#endif
+
+
+#define DEFINE_GLOBALS_AND_CBS(name) \
+ static uv_##name##_t (name)[3]; \
+ static unsigned name##_cb_calls[3]; \
+ \
+ static void name##2_cb(uv_##name##_t* handle) { \
+ ASSERT(handle == &(name)[2]); \
+ if (first_handle_number_##name == 2) { \
+ uv_close((uv_handle_t*)&(name)[2], NULL); \
+ uv_close((uv_handle_t*)&(name)[1], NULL); \
+ } \
+ name##_cb_calls[2]++; \
+ } \
+ \
+ static void name##1_cb(uv_##name##_t* handle) { \
+ ASSERT(handle == &(name)[1]); \
+ ASSERT(0 && "Shouldn't be called" && (&name[0])); \
+ } \
+ \
+ static void name##0_cb(uv_##name##_t* handle) { \
+ ASSERT(handle == &(name)[0]); \
+ if (first_handle_number_##name == 0) { \
+ uv_close((uv_handle_t*)&(name)[0], NULL); \
+ uv_close((uv_handle_t*)&(name)[1], NULL); \
+ } \
+ name##_cb_calls[0]++; \
+ } \
+ \
+ static const uv_##name##_cb name##_cbs[] = { \
+ (uv_##name##_cb)name##0_cb, \
+ (uv_##name##_cb)name##1_cb, \
+ (uv_##name##_cb)name##2_cb, \
+ };
+
+#define INIT_AND_START(name, loop) \
+ do { \
+ size_t i; \
+ for (i = 0; i < ARRAY_SIZE(name); i++) { \
+ int r; \
+ r = uv_##name##_init((loop), &(name)[i]); \
+ ASSERT(r == 0); \
+ \
+ r = uv_##name##_start(&(name)[i], name##_cbs[i]); \
+ ASSERT(r == 0); \
+ } \
+ } while (0)
+
+#define END_ASSERTS(name) \
+ do { \
+ ASSERT(name##_cb_calls[0] == 1); \
+ ASSERT(name##_cb_calls[1] == 0); \
+ ASSERT(name##_cb_calls[2] == 1); \
+ } while (0)
+
+DEFINE_GLOBALS_AND_CBS(idle)
+DEFINE_GLOBALS_AND_CBS(prepare)
+DEFINE_GLOBALS_AND_CBS(check)
+
+#ifdef __linux__
+DEFINE_GLOBALS_AND_CBS(fs_event)
+
+static const char watched_dir[] = ".";
+static uv_timer_t timer;
+static unsigned helper_timer_cb_calls;
+
+
+static void init_and_start_fs_events(uv_loop_t* loop) {
+ size_t i;
+ for (i = 0; i < ARRAY_SIZE(fs_event); i++) {
+ int r;
+ r = uv_fs_event_init(loop, &fs_event[i]);
+ ASSERT(r == 0);
+
+ r = uv_fs_event_start(&fs_event[i],
+ (uv_fs_event_cb)fs_event_cbs[i],
+ watched_dir,
+ 0);
+ ASSERT(r == 0);
+ }
+}
+
+static void helper_timer_cb(uv_timer_t* thandle) {
+ int r;
+ uv_fs_t fs_req;
+
+ /* fire all fs_events */
+ r = uv_fs_utime(thandle->loop, &fs_req, watched_dir, 0, 0, NULL);
+ ASSERT(r == 0);
+ ASSERT(fs_req.result == 0);
+ ASSERT(fs_req.fs_type == UV_FS_UTIME);
+ ASSERT(strcmp(fs_req.path, watched_dir) == 0);
+ uv_fs_req_cleanup(&fs_req);
+
+ helper_timer_cb_calls++;
+}
+#endif
+
+
+TEST_IMPL(queue_foreach_delete) {
+ uv_loop_t* loop;
+ int r;
+
+ loop = uv_default_loop();
+
+ INIT_AND_START(idle, loop);
+ INIT_AND_START(prepare, loop);
+ INIT_AND_START(check, loop);
+
+#ifdef __linux__
+ init_and_start_fs_events(loop);
+
+ /* helper timer to trigger async and fs_event callbacks */
+ r = uv_timer_init(loop, &timer);
+ ASSERT(r == 0);
+
+ r = uv_timer_start(&timer, helper_timer_cb, 0, 0);
+ ASSERT(r == 0);
+#endif
+
+ r = uv_run(loop, UV_RUN_NOWAIT);
+ ASSERT(r == 1);
+
+ END_ASSERTS(idle);
+ END_ASSERTS(prepare);
+ END_ASSERTS(check);
+
+#ifdef __linux__
+ ASSERT(helper_timer_cb_calls == 1);
+#endif
+
+ MAKE_VALGRIND_HAPPY();
+
+ return 0;
+}