Searched refs:_task (Results 1 – 12 of 12) sorted by relevance
| /external/pandora/avatar/avatar/ |
| D | pandora_server.py | 71 _task: Optional[asyncio.Task[None]] = None variable in BumblePandoraServer
75 assert self._task is None
84 … self._task = avatar.aio.loop.create_task(serve_bumble(self.device, grpc_server=server, port=port))
92 assert self._task is not None
93 if not self._task.done():
94 self._task.cancel()
96 await self._task
97 self._task = None
|
| /external/cronet/testing/iossim/ |
| D | iossim.mm | 54 NSTask* _task; field
68 _task = [[NSTask alloc] init];
70 if ([_task respondsToSelector:selector])
71 [_task performSelector:selector withObject:nil];
72 [_task setLaunchPath:@"/usr/bin/xcrun"];
73 [_task setArguments:arguments];
79 [_task release];
84 [_task setStandardOutput:output];
88 [_task setStandardError:error];
92 return [_task terminationStatus];
[all …]
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | schedule.rs | 38 fn release(&self, _task: &Task<Self>) -> Option<Task<Self>> { in release()
53 fn schedule(&self, _task: task::Notified<Self>) { in schedule()
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | device_spec.py | 125 self._task = _as_int_or_none(task)
131 task=self._task,
276 return self._task
432 self._task = _as_int_or_none(task)
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | mod.rs | 15 fn release(&self, _task: &Task<Self>) -> Option<Task<Self>> { in release()
19 fn schedule(&self, _task: task::Notified<Self>) { in schedule()
|
| D | queue.rs | 241 fn release(&self, _task: &Task<Self>) -> Option<Task<Self>> { in release()
245 fn schedule(&self, _task: task::Notified<Self>) { in schedule()
|
| /external/pigweed/pw_transfer/py/pw_transfer/ |
| D | transfer.py | 62 self._task: Optional[asyncio.Task[Any]] = None
73 self._task = asyncio.create_task(self._run(timeout_s))
77 if self._task is not None:
78 self._task.cancel()
79 self._task = None
83 self._task = None
|
| /external/python/asn1crypto/ |
| D | run.py | 5 from dev._task import run_task
|
| /external/rust/crates/async-task/tests/ |
| D | basic.rs | 232 let (runnable, _task) = async_task::spawn(future::poll_fn(|_| Poll::<()>::Pending), schedule); in schedule()
257 let (runnable, _task) = async_task::spawn(future::poll_fn(|_| Poll::<()>::Pending), schedule); in schedule_counter()
288 let (runnable, _task) = async_task::spawn(future::poll_fn(|_| Poll::<()>::Pending), schedule); in waker()
|
| D | waker_pending.rs | 98 let (runnable, _task) = async_task::spawn(f, s); in wake_during_run()
|
| /external/autotest/utils/frozen_chromite/lib/ |
| D | parallel.py | 177 self._task = task
450 self._task(*self._task_args, **self._task_kwargs)
|
| /external/libwebsockets/lib/misc/threadpool/ |
| D | threadpool.c | 1090 struct lws_threadpool_task **_task, void **user) in lws_threadpool_task_status_wsi() argument
1104 *_task = task; in lws_threadpool_task_status_wsi()
|