Searched refs:writer_task (Results 1 – 13 of 13) sorted by relevance
127 writer_task = threading.Thread(137 writer_task.start()
237 writer_task = threading.Thread(247 writer_task.start()
196 writer_task = asyncio.ensure_future(writer())240 await asyncio.wait_for(writer_task, timeout=None)
210 writer_task = self.server.start_background_task(writer)247 writer_task.join()
222 writer_task = self.server.start_background_task(writer)257 writer_task.join()
206 writer_task = asyncio.ensure_future(writer())250 await asyncio.wait_for(writer_task, timeout=None)
118 13 if (writer_task != NULL) {120 15 kthread_stop(writer_task);122 17 writer_task = NULL;
135 static struct task_struct *writer_task; variable1175 current == writer_task); in rcu_torture_writer()1833 wtp = READ_ONCE(writer_task); in rcu_torture_stats_print()2775 torture_stop_kthread(rcu_torture_writer, writer_task); in rcu_torture_cleanup()3024 writer_task); in rcu_torture_init()
1535 struct aws_task writer_task; in s_sock_write_cb_is_async() local1536 aws_task_init(&writer_task, s_async_write_task, NULL, "async_test_write_task"); in s_sock_write_cb_is_async()1537 aws_event_loop_schedule_task_now(event_loop, &writer_task); in s_sock_write_cb_is_async()