core/threads/threads.cpp

120                          zxr_thread_t* thread_out, zx_handle_t* thread_h) {
137     if (thread_h) {
139                                       thread_h),
149     zx_handle_t thread_h;
150     ASSERT_TRUE(start_thread(entry, arg, &thread, &thread_h));
152     ASSERT_EQ(zx_task_kill(thread_h), ZX_OK);
153     ASSERT_EQ(zx_object_wait_one(thread_h, ZX_THREAD_TERMINATED,
157     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
193     zx_handle_t thread_h;
195                              &thread, &thread_h));
196     ASSERT_EQ(zx_object_wait_one(thread_h, ZX_THREAD_TERMINATED, ZX_TIME_INFINITE, NULL),
198     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
208     zx_handle_t thread_h;
209     ASSERT_TRUE(start_thread(threads_test_wait_detach_fn, &event, &thread, &thread_h));
220     ASSERT_EQ(zx_object_wait_one(thread_h,
224     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
430     zx_handle_t thread_h;
433     ASSERT_TRUE(start_thread(threads_test_wait_fn, &event, &thread, &thread_h));
436     ASSERT_TRUE(wait_thread_blocked(thread_h, ZX_THREAD_STATE_BLOCKED_WAIT_ONE));
439     ASSERT_EQ(zx_task_suspend_token(thread_h, &suspend_token), ZX_OK);
445     ASSERT_TRUE(wait_thread_blocked(thread_h, ZX_THREAD_STATE_BLOCKED_WAIT_ONE));
449     ASSERT_TRUE(suspend_thread_synchronous(thread_h, &suspend_token));
453     ASSERT_TRUE(get_thread_info(thread_h, &info));
458     ASSERT_TRUE(resume_thread_synchronous(thread_h, suspend_token));
460     ASSERT_TRUE(wait_thread_blocked(thread_h, ZX_THREAD_STATE_BLOCKED_WAIT_ONE));
464     ASSERT_TRUE(suspend_thread_synchronous(thread_h, &suspend_token));
473                   thread_h, ZX_THREAD_TERMINATED, ZX_TIME_INFINITE, NULL),
477     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
488     zx_handle_t thread_h;
489     ASSERT_TRUE(start_thread(threads_test_sleep_fn, (void*)sleep_deadline, &thread, &thread_h));
495     zx_status_t status = zx_task_suspend_token(thread_h, &suspend_token);
503         ASSERT_EQ(zx_object_get_info(thread_h, ZX_INFO_THREAD,
507         ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
512     ASSERT_EQ(zx_object_wait_one(thread_h, ZX_THREAD_SUSPENDED, ZX_TIME_INFINITE, NULL), ZX_OK);
516     ASSERT_EQ(zx_object_wait_one(thread_h, ZX_THREAD_TERMINATED, ZX_TIME_INFINITE, NULL),
522     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
536     zx_handle_t thread_h;
537     ASSERT_TRUE(start_thread(threads_test_channel_call_fn, &thread_arg, &thread, &thread_h));
545     ASSERT_TRUE(suspend_thread_synchronous(thread_h, &suspend_token));
573     ASSERT_EQ(zx_object_wait_one(thread_h, ZX_THREAD_TERMINATED, ZX_TIME_INFINITE, NULL),
578     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
591     zx_handle_t thread_h;
592     ASSERT_TRUE(start_thread(threads_test_port_fn, port, &thread, &thread_h));
596     ASSERT_EQ(zx_task_suspend_token(thread_h, &suspend_token), ZX_OK);
616                   thread_h, ZX_THREAD_TERMINATED, ZX_TIME_INFINITE, NULL),
619     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
644     zx_handle_t thread_h;
645     ASSERT_TRUE(start_thread(test_writing_thread_fn, &arg, &thread, &thread_h));
652     ASSERT_EQ(zx_task_suspend_token(thread_h, &suspend_token), ZX_OK);
664     ASSERT_EQ(zx_task_kill(thread_h), ZX_OK);
668     ASSERT_EQ(zx_object_wait_one(thread_h, ZX_THREAD_TERMINATED,
671     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
686     zx_handle_t thread_h;
690                              &thread_h));
697     ASSERT_TRUE(wait_thread_excp_type(thread_h, exception_port, ZX_EXCP_SW_BREAKPOINT,
701     ASSERT_TRUE(wait_thread_blocked(thread_h, ZX_THREAD_STATE_BLOCKED_EXCEPTION));
703     ASSERT_TRUE(get_thread_info(thread_h, &info));
706     advance_over_breakpoint(thread_h);
712     ASSERT_EQ(zx_task_suspend_token(thread_h, &suspend_token1), ZX_OK);
714     ASSERT_EQ(zx_task_suspend_token(thread_h, &suspend_token2), ZX_OK);
718     ASSERT_TRUE(get_thread_info(thread_h, &info));
725     ASSERT_EQ(zx_task_resume_from_exception(thread_h, exception_port, 23), ZX_ERR_INVALID_ARGS);
730     ASSERT_EQ(zx_task_resume_from_exception(thread_h, exception_port, 0), ZX_OK);
732     ASSERT_EQ(zx_object_wait_one(thread_h, ZX_THREAD_SUSPENDED, ZX_TIME_INFINITE, &observed),
735     ASSERT_TRUE(get_thread_info(thread_h, &info));
739     ASSERT_TRUE(resume_thread_synchronous(thread_h, suspend_token2));
740     ASSERT_TRUE(get_thread_info(thread_h, &info));
745     ASSERT_EQ(zx_task_kill(thread_h), ZX_OK);
746     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
758     zx_handle_t thread_h;
759     ASSERT_TRUE(start_thread(test_writing_thread_fn, &arg, &thread, &thread_h));
767     ASSERT_TRUE(suspend_thread_synchronous(thread_h, &suspend_token));
775     ASSERT_EQ(zx_task_kill(thread_h), ZX_OK);
777     ASSERT_EQ(zx_object_wait_one(thread_h, ZX_THREAD_TERMINATED,
785     ASSERT_TRUE(wait_thread_excp_type(thread_h, eport, ZX_EXCP_THREAD_EXITING, 0));
791     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);
820     zx_handle_t thread_h;
824     ASSERT_TRUE(start_thread(threads_test_wait_fn, &event, &thread, &thread_h));
828         ASSERT_EQ(zx_object_wait_async(thread_h, port, 0u, run_susp_mask,
839         ASSERT_TRUE(port_wait_for_signal_once(port, thread_h, 0u, run_susp_mask, &packet));
849         ASSERT_EQ(zx_object_wait_async(thread_h, port, 0u,
854         ASSERT_EQ(zx_port_cancel(port, thread_h, 0u), ZX_OK);
858     ASSERT_TRUE(suspend_thread_synchronous(thread_h, &suspend_token));
861     ASSERT_TRUE(get_thread_info(thread_h, &info));
864     ASSERT_TRUE(resume_thread_synchronous(thread_h, suspend_token));
865     ASSERT_TRUE(get_thread_info(thread_h, &info));
883         ASSERT_TRUE(port_wait_for_signal_once(port, thread_h, 0u, run_susp_mask,
889     ASSERT_TRUE(wait_thread_blocked(thread_h, ZX_THREAD_STATE_BLOCKED_WAIT_ONE));
894     ASSERT_EQ(zx_task_suspend_token(thread_h, &suspend_token), ZX_OK);
900         ASSERT_TRUE(port_wait_for_signal_once(port, thread_h,
906     ASSERT_TRUE(get_thread_info(thread_h, &info));
914         ASSERT_TRUE(port_wait_for_signal_once(port, thread_h,
922     ASSERT_TRUE(wait_thread_blocked(thread_h, ZX_THREAD_STATE_BLOCKED_WAIT_ONE));
928                   thread_h, ZX_THREAD_TERMINATED, ZX_TIME_INFINITE, NULL),
933     ASSERT_EQ(zx_handle_close(thread_h), ZX_OK);