| /third_party/libuv/src/unix/ |
| D | loop.c | 30 int uv_loop_init(uv_loop_t* loop) { in uv_loop_init() argument
36 saved_data = loop->data; in uv_loop_init()
37 memset(loop, 0, sizeof(*loop)); in uv_loop_init()
38 loop->data = saved_data; in uv_loop_init()
43 loop->internal_fields = lfields; in uv_loop_init()
49 heap_init((struct heap*) &loop->timer_heap); in uv_loop_init()
50 QUEUE_INIT(&loop->wq); in uv_loop_init()
52 uv__loop_internal_fields_t* lfields_qos = uv__get_internal_fields(loop); in uv_loop_init()
58 QUEUE_INIT(&loop->idle_handles); in uv_loop_init()
59 QUEUE_INIT(&loop->async_handles); in uv_loop_init()
[all …]
|
| D | posix-poll.c | 36 int uv__platform_loop_init(uv_loop_t* loop) { in uv__platform_loop_init() argument
37 loop->poll_fds = NULL; in uv__platform_loop_init()
38 loop->poll_fds_used = 0; in uv__platform_loop_init()
39 loop->poll_fds_size = 0; in uv__platform_loop_init()
40 loop->poll_fds_iterating = 0; in uv__platform_loop_init()
44 void uv__platform_loop_delete(uv_loop_t* loop) { in uv__platform_loop_delete() argument
45 uv__free(loop->poll_fds); in uv__platform_loop_delete()
46 loop->poll_fds = NULL; in uv__platform_loop_delete()
49 int uv__io_fork(uv_loop_t* loop) { in uv__io_fork() argument
50 uv__platform_loop_delete(loop); in uv__io_fork()
[all …]
|
| D | epoll.c | 27 int uv__epoll_init(uv_loop_t* loop) { in uv__epoll_init() argument
41 loop->backend_fd = fd; in uv__epoll_init()
49 void uv__platform_invalidate_fd(uv_loop_t* loop, int fd) { in uv__platform_invalidate_fd() argument
55 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
58 events = (struct epoll_event*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
59 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
72 if (loop->backend_fd >= 0) { in uv__platform_invalidate_fd()
77 epoll_ctl(loop->backend_fd, EPOLL_CTL_DEL, fd, &dummy); in uv__platform_invalidate_fd()
82 int uv__io_check_fd(uv_loop_t* loop, int fd) { in uv__io_check_fd() argument
91 if (epoll_ctl(loop->backend_fd, EPOLL_CTL_ADD, fd, &e)) in uv__io_check_fd()
[all …]
|
| D | async.c | 42 static int uv__async_start(uv_loop_t* loop);
45 int uv_async_init(uv_loop_t* loop, uv_async_t* handle, uv_async_cb async_cb) { in uv_async_init() argument
48 err = uv__async_start(loop); in uv_async_init()
52 uv__handle_init(loop, (uv_handle_t*)handle, UV_ASYNC); in uv_async_init()
56 QUEUE_INSERT_TAIL(&loop->async_handles, &handle->queue); in uv_async_init()
85 static void uv__async_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) { in uv__async_io() argument
92 assert(w == &loop->async_io_watcher); in uv__async_io()
112 QUEUE_MOVE(&loop->async_handles, &queue); in uv__async_io()
118 QUEUE_INSERT_TAIL(&loop->async_handles, q); in uv__async_io()
136 uv_loop_t* loop = handle->loop; in uv__async_send() local
[all …]
|
| D | kqueue.c | 48 static void uv__fs_event(uv_loop_t* loop, uv__io_t* w, unsigned int fflags);
51 int uv__kqueue_init(uv_loop_t* loop) { in uv__kqueue_init() argument
52 loop->backend_fd = kqueue(); in uv__kqueue_init()
53 if (loop->backend_fd == -1) in uv__kqueue_init()
56 uv__cloexec(loop->backend_fd, 1); in uv__kqueue_init()
66 int uv__io_fork(uv_loop_t* loop) { in uv__io_fork() argument
68 loop->backend_fd = -1; in uv__io_fork()
69 err = uv__kqueue_init(loop); in uv__io_fork()
74 if (loop->cf_state != NULL) { in uv__io_fork()
86 uv__free(loop->cf_state); in uv__io_fork()
[all …]
|
| /third_party/alsa-utils/alsaloop/ |
| D | pcmjob.c | 91 static inline snd_pcm_uframes_t get_whole_latency(struct loopback *loop) in get_whole_latency() argument
93 return loop->latency; in get_whole_latency()
321 static int setparams(struct loopback *loop, snd_pcm_uframes_t bufsize) in setparams() argument
334 if ((err = setparams_stream(loop->play, pt_params)) < 0) { in setparams()
335 …logit(LOG_CRIT, "Unable to set parameters for %s stream: %s\n", loop->play->id, snd_strerror(err)); in setparams()
338 if ((err = setparams_stream(loop->capt, ct_params)) < 0) { in setparams()
339 …logit(LOG_CRIT, "Unable to set parameters for %s stream: %s\n", loop->capt->id, snd_strerror(err)); in setparams()
343 if ((err = setparams_bufsize(loop->play, p_params, pt_params, bufsize / loop->play->pitch)) < 0) { in setparams()
344 …logit(LOG_CRIT, "Unable to set buffer parameters for %s stream: %s\n", loop->play->id, snd_strerro… in setparams()
347 if ((err = setparams_bufsize(loop->capt, c_params, ct_params, bufsize / loop->capt->pitch)) < 0) { in setparams()
[all …]
|
| /third_party/libuv/src/win/ |
| D | core.c | 93 static int uv__loops_add(uv_loop_t* loop) { in uv__loops_add() argument
109 uv__loops[uv__loops_size] = loop; in uv__loops_add()
121 static void uv__loops_remove(uv_loop_t* loop) { in uv__loops_remove() argument
129 if (uv__loops[loop_index] == loop) in uv__loops_remove()
167 uv_loop_t* loop; in uv__wake_all_loops() local
171 loop = uv__loops[i]; in uv__wake_all_loops()
172 assert(loop); in uv__wake_all_loops()
173 if (loop->iocp != INVALID_HANDLE_VALUE) in uv__wake_all_loops()
174 PostQueuedCompletionStatus(loop->iocp, 0, 0, NULL); in uv__wake_all_loops()
227 int uv_loop_init(uv_loop_t* loop) { in uv_loop_init() argument
[all …]
|
| D | req-inl.h | 56 #define REGISTER_HANDLE_REQ(loop, handle, req) \ argument
58 INCREASE_ACTIVE_COUNT((loop), (handle)); \
59 uv__req_register((loop), (req)); \
62 #define UNREGISTER_HANDLE_REQ(loop, handle, req) \ argument
64 DECREASE_ACTIVE_COUNT((loop), (handle)); \
65 uv__req_unregister((loop), (req)); \
76 #define POST_COMPLETION_FOR_REQ(loop, req) \ argument
77 if (!PostQueuedCompletionStatus((loop)->iocp, \
90 INLINE static void uv__insert_pending_req(uv_loop_t* loop, uv_req_t* req) { in uv__insert_pending_req() argument
92 if (loop->pending_reqs_tail) { in uv__insert_pending_req()
[all …]
|
| D | internal.h | 79 int uv__tcp_write(uv_loop_t* loop, uv_write_t* req, uv_tcp_t* handle,
84 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle, uv_req_t* req);
85 void uv__process_tcp_write_req(uv_loop_t* loop, uv_tcp_t* handle,
87 void uv__process_tcp_accept_req(uv_loop_t* loop, uv_tcp_t* handle,
89 void uv__process_tcp_connect_req(uv_loop_t* loop, uv_tcp_t* handle,
92 void uv__tcp_close(uv_loop_t* loop, uv_tcp_t* tcp);
93 void uv__tcp_endgame(uv_loop_t* loop, uv_tcp_t* handle);
107 void uv__process_udp_recv_req(uv_loop_t* loop, uv_udp_t* handle, uv_req_t* req);
108 void uv__process_udp_send_req(uv_loop_t* loop, uv_udp_t* handle,
111 void uv__udp_close(uv_loop_t* loop, uv_udp_t* handle);
[all …]
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_base_events.py | 155 self.loop = base_events.BaseEventLoop()
156 self.loop._selector = mock.Mock()
157 self.loop._selector.select.return_value = ()
158 self.set_event_loop(self.loop)
164 self.loop._make_socket_transport, m, m)
167 self.loop._make_ssl_transport, m, m, m, m)
170 self.loop._make_datagram_transport, m, m)
172 NotImplementedError, self.loop._process_events, [])
174 NotImplementedError, self.loop._write_to_self)
177 self.loop._make_read_pipe_transport, m, m)
[all …]
|
| D | test_streams.py | 32 self.loop = asyncio.new_event_loop()
33 self.set_event_loop(self.loop)
37 test_utils.run_briefly(self.loop)
39 self.loop.close()
45 self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
46 reader, writer = self.loop.run_until_complete(open_connection_fut)
49 data = self.loop.run_until_complete(f)
52 data = self.loop.run_until_complete(f)
70 self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
72 reader, writer = self.loop.run_until_complete(open_connection_fut)
[all …]
|
| D | test_events.py | 59 loop = asyncio.new_event_loop()
60 asyncio.set_event_loop(loop)
61 return loop.run_until_complete(doit())
82 def __init__(self, loop=None): argument
86 if loop is not None:
87 self.connected = loop.create_future()
88 self.done = loop.create_future()
125 def __init__(self, loop=None): argument
128 if loop is not None:
129 self.done = loop.create_future()
[all …]
|
| D | test_tasks.py | 111 def new_task(self, loop, coro, name='TestTask'): argument
112 return self.__class__.Task(coro, loop=loop, name=name)
114 def new_future(self, loop): argument
115 return self.__class__.Future(loop=loop)
119 self.loop = self.new_test_loop()
120 self.loop.set_task_factory(self.new_task)
121 self.loop.create_future = lambda: self.new_future(self.loop)
126 t = self.new_task(self.loop, coro())
134 self.loop.run_until_complete(t)
139 t = self.new_task(self.loop, coro())
[all …]
|
| D | test_futures.py | 88 self.loop = self.new_test_loop()
89 self.addCleanup(self.loop.close)
109 self.loop = self.new_test_loop()
110 self.addCleanup(self.loop.close)
126 f = self._new_future(loop=self.loop)
136 f = self._new_future(loop=self.loop)
151 f = self.loop.run_until_complete(test())
152 self.assertIs(f._loop, self.loop)
153 self.assertIs(f.get_loop(), self.loop)
157 asyncio.set_event_loop(self.loop)
[all …]
|
| D | test_sock_lowlevel.py | 18 def __init__(self, loop=None): argument
22 if loop is not None:
23 self.connected = loop.create_future()
24 self.done = loop.create_future()
59 self.loop = self.create_event_loop()
60 self.set_event_loop(self.loop)
65 if not self.loop.is_closed():
66 test_utils.run_briefly(self.loop)
73 if not isinstance(self.loop, proactor_events.BaseProactorEventLoop):
76 self.loop.set_debug(True)
[all …]
|
| D | test_queues.py | 18 self.loop = self.new_test_loop()
36 loop = self.new_test_loop(gen)
46 loop.create_task(q.get())
53 loop.run_until_complete(add_getter())
59 loop.create_task(q.put(2))
66 loop.run_until_complete(add_putter())
110 loop = self.new_test_loop(gen)
123 t = loop.create_task(putter())
139 loop.run_until_complete(test())
140 self.assertAlmostEqual(0.02, loop.time())
[all …]
|
| D | test_windows_events.py | 48 loop = asyncio.get_event_loop()
51 loop.call_soon(thread.start)
52 loop.run_forever()
57 self.close_loop(loop)
70 loop = asyncio.new_event_loop()
71 loop.run_until_complete(coro())
73 loop.close()
86 self.loop = asyncio.ProactorEventLoop()
87 self.set_event_loop(self.loop)
91 trans = self.loop._make_socket_transport(a, asyncio.Protocol())
[all …]
|
| /third_party/spirv-tools/test/opt/loop_optimizations/ |
| D | nested_loops.cpp | 196 static void CheckLoopBlocks(Loop* loop, in CheckLoopBlocks() argument
198 SCOPED_TRACE("Check loop " + std::to_string(loop->GetHeaderBlock()->id())); in CheckLoopBlocks()
199 for (uint32_t bb_id : loop->GetBlocks()) { in CheckLoopBlocks()
203 EXPECT_FALSE(loop->IsInsideLoop(loop->GetMergeBlock())); in CheckLoopBlocks()
362 Loop* loop = ld[23]; in TEST_F() local
363 CheckLoopBlocks(loop, &basic_block_in_loop); in TEST_F()
365 EXPECT_TRUE(loop->HasNestedLoops()); in TEST_F()
366 EXPECT_FALSE(loop->IsNested()); in TEST_F()
367 EXPECT_EQ(loop->GetDepth(), 1u); in TEST_F()
368 EXPECT_EQ(std::distance(loop->begin(), loop->end()), 1u); in TEST_F()
[all …]
|
| /third_party/skia/third_party/externals/spirv-tools/test/opt/loop_optimizations/ |
| D | nested_loops.cpp | 196 static void CheckLoopBlocks(Loop* loop, in CheckLoopBlocks() argument
198 SCOPED_TRACE("Check loop " + std::to_string(loop->GetHeaderBlock()->id())); in CheckLoopBlocks()
199 for (uint32_t bb_id : loop->GetBlocks()) { in CheckLoopBlocks()
203 EXPECT_FALSE(loop->IsInsideLoop(loop->GetMergeBlock())); in CheckLoopBlocks()
362 Loop* loop = ld[23]; in TEST_F() local
363 CheckLoopBlocks(loop, &basic_block_in_loop); in TEST_F()
365 EXPECT_TRUE(loop->HasNestedLoops()); in TEST_F()
366 EXPECT_FALSE(loop->IsNested()); in TEST_F()
367 EXPECT_EQ(loop->GetDepth(), 1u); in TEST_F()
368 EXPECT_EQ(std::distance(loop->begin(), loop->end()), 1u); in TEST_F()
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/test/opt/loop_optimizations/ |
| D | nested_loops.cpp | 196 static void CheckLoopBlocks(Loop* loop, in CheckLoopBlocks() argument
198 SCOPED_TRACE("Check loop " + std::to_string(loop->GetHeaderBlock()->id())); in CheckLoopBlocks()
199 for (uint32_t bb_id : loop->GetBlocks()) { in CheckLoopBlocks()
203 EXPECT_FALSE(loop->IsInsideLoop(loop->GetMergeBlock())); in CheckLoopBlocks()
362 Loop* loop = ld[23]; in TEST_F() local
363 CheckLoopBlocks(loop, &basic_block_in_loop); in TEST_F()
365 EXPECT_TRUE(loop->HasNestedLoops()); in TEST_F()
366 EXPECT_FALSE(loop->IsNested()); in TEST_F()
367 EXPECT_EQ(loop->GetDepth(), 1u); in TEST_F()
368 EXPECT_EQ(std::distance(loop->begin(), loop->end()), 1u); in TEST_F()
[all …]
|
| /third_party/mesa3d/src/compiler/nir/ |
| D | nir_opt_loop_unroll.c | 50 loop_prepare_for_unroll(nir_loop *loop) in loop_prepare_for_unroll() argument
53 nir_cf_node_get_function(&loop->cf_node)); in loop_prepare_for_unroll()
55 nir_convert_loop_to_lcssa(loop); in loop_prepare_for_unroll()
58 foreach_list_typed_safe(nir_cf_node, node, node, &loop->body) { in loop_prepare_for_unroll()
66 nir_cf_node_as_block(nir_cf_node_next(&loop->cf_node)); in loop_prepare_for_unroll()
71 nir_instr *last_instr = nir_block_last_instr(nir_loop_last_block(loop)); in loop_prepare_for_unroll()
106 simple_unroll(nir_loop *loop) in simple_unroll() argument
108 nir_loop_terminator *limiting_term = loop->info->limiting_terminator; in simple_unroll()
112 loop_prepare_for_unroll(loop); in simple_unroll()
116 &loop->info->loop_terminator_list, in simple_unroll()
[all …]
|
| /third_party/libuv/test/ |
| D | test-signal.c | 53 uv_loop_t* loop; in TEST_IMPL() local
55 loop = uv_default_loop(); in TEST_IMPL()
56 uv_signal_init(loop, &signal); in TEST_IMPL()
133 static void start_watcher(uv_loop_t* loop, in start_watcher() argument
141 ASSERT(0 == uv_signal_init(loop, &ctx->handle)); in start_watcher()
148 static void start_timer(uv_loop_t* loop, int signum, struct timer_ctx* ctx) { in start_timer() argument
151 ASSERT(0 == uv_timer_init(loop, &ctx->handle)); in start_timer()
159 uv_loop_t* loop; in TEST_IMPL() local
161 loop = uv_default_loop(); in TEST_IMPL()
162 start_timer(loop, SIGCHLD, &tc); in TEST_IMPL()
[all …]
|
| D | test-threadpool-cancel.c | 64 uv_loop_t* loop; in saturate_threadpool() local
74 loop = uv_default_loop(); in saturate_threadpool()
77 ASSERT(0 == uv_queue_work(loop, pause_reqs + i, work_cb, done_cb)); in saturate_threadpool()
168 uv_loop_t* loop; in TEST_IMPL() local
172 loop = uv_default_loop(); in TEST_IMPL()
175 r = uv_getaddrinfo(loop, reqs + 0, getaddrinfo_cb, "fail", NULL, NULL); in TEST_IMPL()
178 r = uv_getaddrinfo(loop, reqs + 1, getaddrinfo_cb, NULL, "fail", NULL); in TEST_IMPL()
181 r = uv_getaddrinfo(loop, reqs + 2, getaddrinfo_cb, "fail", "fail", NULL); in TEST_IMPL()
184 r = uv_getaddrinfo(loop, reqs + 3, getaddrinfo_cb, "fail", NULL, &hints); in TEST_IMPL()
187 ASSERT(0 == uv_timer_init(loop, &ci.timer_handle)); in TEST_IMPL()
[all …]
|
| /third_party/python/Lib/asyncio/ |
| D | tasks.py | 34 def current_task(loop=None): argument
36 if loop is None:
37 loop = events.get_running_loop()
38 return _current_tasks.get(loop)
41 def all_tasks(loop=None): argument
43 if loop is None:
44 loop = events.get_running_loop()
61 if futures._get_loop(t) is loop and not t.done()}
92 def __init__(self, coro, *, loop=None, name=None): argument
93 super().__init__(loop=loop)
[all …]
|
| /third_party/libuv/src/ |
| D | threadpool.c | 130 uv_mutex_lock(&w->loop->wq_mutex); in worker()
133 QUEUE_INSERT_TAIL(&w->loop->wq, &w->wq); in worker()
134 uv_async_send(&w->loop->wq_async); in worker()
135 uv_mutex_unlock(&w->loop->wq_mutex); in worker()
269 void uv__work_submit(uv_loop_t* loop, in uv__work_submit() argument
275 w->loop = loop; in uv__work_submit()
283 static int uv__work_cancel(uv_loop_t* loop, uv_req_t* req, struct uv__work* w) { in uv__work_cancel() argument
288 uv_mutex_lock(&w->loop->wq_mutex); in uv__work_cancel()
294 uv_mutex_unlock(&w->loop->wq_mutex); in uv__work_cancel()
297 uv_mutex_lock(&w->loop->wq_mutex); in uv__work_cancel()
[all …]
|