Lines Matching defs:channel

339     zx_handle_t inferior, channel;
340 if (!setup_inferior(test_inferior_child_name, &lp, &inferior, &channel))
356 if (!verify_inferior_running(channel))
361 send_msg(channel, MSG_CRASH_AND_RECOVER_TEST);
362 if (!recv_msg(channel, &msg))
367 if (!shutdown_inferior(channel, inferior))
379 tu_handle_close(channel);
389 zx_handle_t inferior, channel;
390 if (!setup_inferior(test_inferior_child_name, &lp, &inferior, &channel))
402 if (!verify_inferior_running(channel))
406 send_msg(channel, MSG_START_EXTRA_THREADS);
407 if (!recv_msg(channel, &msg))
434 if (!shutdown_inferior(channel, inferior))
443 tu_handle_close(channel);
549 zx_handle_t channel;
558 send_msg(arg->channel, MSG_PONG);
611 tu_handle_close(arg->channel);
624 zx_handle_t channel;
625 tu_channel_create(&channel, &arg.channel);
634 recv_msg(channel, &msg);
684 tu_handle_close(channel);
841 // Make sure the remote channel didn't get signaled
845 // Make sure we can't read from the remote channel (the message should have
987 zx_handle_t inferior, channel;
988 if (!setup_inferior(test_inferior_child_name, &lp, &inferior, &channel))
993 if (!verify_inferior_running(channel))
1000 ASSERT_TRUE(get_inferior_thread_handle(channel, &data.thread_handle));
1015 send_msg(channel, MSG_CRASH_AND_RECOVER_TEST);
1016 if (!recv_msg(channel, &msg)) {
1022 if (!shutdown_inferior(channel, inferior))
1041 tu_handle_close(channel);
1123 bool msg_loop(zx_handle_t channel) {
1130 ASSERT_TRUE(recv_msg(channel, &msg), "Error while receiving msg");
1136 send_msg(channel, MSG_PONG);
1143 send_msg(channel, MSG_RECOVERED_FROM_CRASH);
1156 send_msg(channel, MSG_EXTRA_THREADS_STARTED);
1164 unittest_printf("sending handle %d message on channel %u\n", copy, channel);
1165 tu_channel_write(channel, 0, &data, sizeof(data), &copy, 1);
1178 zx_handle_t channel = zx_take_startup_handle(PA_USER0);
1179 unittest_printf("test_inferior: got handle %d\n", channel);
1181 if (!msg_loop(channel))