utest/events/events.c

47     zx_handle_t* events = (zx_handle_t*)(arg);
51         zx_status_t status = zx_object_signal(events[1], 0u, ZX_EVENT_SIGNALED);
53     } while (!wait(events[2], events[0]));
59     zx_handle_t* events = (zx_handle_t*)(arg);
61     while (!wait(events[1], events[0])) {
63         zx_status_t status = zx_object_signal(events[2], 0u, ZX_EVENT_SIGNALED);
73     zx_handle_t events[3];
74     ASSERT_EQ(zx_event_create(0u, &events[0]), 0, "Error during event create");
75     ASSERT_EQ(zx_event_create(0u, &events[1]), 0, "Error during event create");
76     ASSERT_EQ(zx_event_create(0u, &events[2]), 0, "Error during event create");
79     int ret = thrd_create_with_name(&threads[3], thread_fn_1, events, "master");
83         ret = thrd_create_with_name(&threads[ix], thread_fn_2, events, "worker");
88     zx_object_signal(events[0], 0u, ZX_EVENT_SIGNALED);
94     ASSERT_GE(zx_handle_close(events[0]), 0, "Error during event-0 close");
95     ASSERT_GE(zx_handle_close(events[1]), 0, "Error during event-1 close");
96     ASSERT_GE(zx_handle_close(events[2]), 0, "Error during event-2 close");
101     zx_handle_t* events = (zx_handle_t*)(arg);
105         zx_object_signal(events[1], ZX_USER_SIGNAL_ALL, ZX_USER_SIGNAL_1);
106     } while (!wait_user(events[2], events[0], ZX_USER_SIGNAL_2));
112     zx_handle_t* events = (zx_handle_t*)(arg);
114     while (!wait_user(events[1], events[0], ZX_USER_SIGNAL_1)) {
116         zx_object_signal(events[2], ZX_USER_SIGNAL_ALL, ZX_USER_SIGNAL_2);
125     zx_handle_t events[3];
126     ASSERT_GE(zx_event_create(0U, &events[0]), 0, "Error during event create");
127     ASSERT_GE(zx_event_create(0U, &events[1]), 0, "Error during event create");
128     ASSERT_GE(zx_event_create(0U, &events[2]), 0, "Error during event create");
131     int ret = thrd_create_with_name(&threads[3], thread_fn_3, events, "master");
135         ret = thrd_create_with_name(&threads[ix], thread_fn_4, events, "workers");
140     zx_object_signal(events[0], 0u, ZX_EVENT_SIGNALED);
146     ASSERT_GE(zx_handle_close(events[0]), 0, "Error during event-0 close");
147     ASSERT_GE(zx_handle_close(events[1]), 0, "Error during event-1 close");
148     ASSERT_GE(zx_handle_close(events[2]), 0, "Error during event-2 close");
164     zx_handle_t events[3];
165     ASSERT_EQ(zx_event_create(0U, &events[0]), 0, "Error during event create");
166     ASSERT_EQ(zx_event_create(0U, &events[1]), 0, "Error during event create");
167     ASSERT_EQ(zx_event_create(0U, &events[2]), 0, "Error during event create");
174     items[0].handle = events[0];
176     items[1].handle = events[1];
178     items[2].handle = events[2];
180     status = zx_object_wait_one(events[0], ZX_EVENT_SIGNALED, zx_deadline_after(1u), &pending);
190     status = zx_object_wait_one(events[0], ZX_EVENT_SIGNALED, 0u, &pending);
200     ASSERT_GE(zx_object_signal(events[0], 0u, ZX_EVENT_SIGNALED), 0, "Error during event signal");
202     status = zx_object_wait_one(events[0], ZX_EVENT_SIGNALED, zx_deadline_after(1u), &pending);
211     status = zx_object_wait_one(events[0], ZX_EVENT_SIGNALED, 0u, &pending);
215     ASSERT_GE(zx_object_signal(events[0], ZX_EVENT_SIGNALED, 0u), 0, "Error during event reset");
216     ASSERT_GE(zx_object_signal(events[2], 0u, ZX_EVENT_SIGNALED), 0, "Error during event signal");
223     int ret = thrd_create_with_name(&thread, thread_fn_closer, &events[1], "closer");
226     status = zx_object_wait_one(events[1], ZX_EVENT_SIGNALED, ZX_TIME_INFINITE, NULL);
231     ASSERT_GE(zx_handle_close(events[0]), 0, "Error during event-0 close");
232     ASSERT_GE(zx_handle_close(events[2]), 0, "Error during event-2 close");