Searched refs:await (Results 1 – 25 of 25) sorted by relevance
24 await super().setup_connection()27 await self._set_mode(cur_mode)32 await self.writer.drain()33 l = await self.reader.readline()38 return await self._send_wrapper(proc)42 r = await self.send_stream("END")46 r = await self.send_message({"get-stream": None})57 await self._set_mode(self.MODE_GET_STREAM)58 r = await self.send_stream("%s %s" % (method, taskhash))64 await self._set_mode(self.MODE_NORMAL)[all …]
148 d = await client.get_taskhash(method, taskhash)196 self.upstream_client = await create_async_client(self.upstream)200 await super().process_requests()203 await self.upstream_client.close()210 await self.handlers[k](msg[k])214 await self.handlers[k](msg[k])225 d = await self.get_unihash(cursor, method, taskhash, fetch_all)252 d = await self.upstream_client.get_taskhash(method, taskhash, True)261 d = await self.upstream_client.get_taskhash(method, taskhash)274 d = await self.get_outhash(cursor, method, outhash, taskhash)[all …]
151 await c.connect_unix(*a)153 await c.connect_tcp(*a)
28 return await asyncio.open_connection(address, port)44 return await asyncio.open_unix_connection(sock=sock)51 await self.writer.drain()55 (self.reader, self.writer) = await self._connect_sock()56 await self.setup_connection()69 await self.connect()70 return await proc()82 await self.close()88 line = await asyncio.wait_for(self.reader.readline(), self.timeout)105 await self.writer.drain()[all …]
44 client_protocol = await self.reader.readline()61 line = await self.reader.readline()71 d = await self.read_message()74 await self.dispatch_message(d)75 await self.writer.drain()85 await self.handlers[k](msg[k])95 l = await self.reader.readline()114 l = await self.reader.readline()128 await self.dispatch_message(msg)194 await client.process_requests()
24 bus = await MessageBus(bus_type=BusType.SYSTEM).connect()25 bus2 = await MessageBus(bus_type=BusType.SYSTEM).connect()27 await bus.request_name(bus_name)32 introspection = await bus2.introspect(bus_name, '/test/path')37 result = await interface.call_ping()40 result = await interface.call_concat_strings('hello ', 'world')
30 await asyncio.sleep(0.1)
17 response = await self.send_message(24 response = await self.send_message(31 response = await self.send_message(38 response = await self.send_message(
39 await super().dispatch_message(msg)
42 conn = await self._connector.connect(54 msg = await self._reader.read()65 msg = await self._reader.read()94 return await self._loop.create_connection(*args, **kwargs) # type: ignore # noqa103 _, proto = await self._loop.create_unix_connection(112 _, proto = await self._loop.create_pipe_connection( # type: ignore171 await self._error_handler180 await payload.readany()192 msg = await reader.read()203 msg = await self._reader.read()[all …]
437 return await check_url_status(session, pkg, npkgs, retry=False)456 await asyncio.wait(tasks)486 data = await resp.json()496 return await check_package_get_latest_version_by_distro(session, pkg, retry=False)508 data = await resp.json()522 return await check_package_get_latest_version_by_guess(session, pkg, retry=False)533 if await check_package_get_latest_version_by_distro(session, pkg):538 if await check_package_get_latest_version_by_guess(session, pkg):574 await asyncio.wait(tasks)
120 SyncAwait await; member
624 pAwait = &(pAwaitUnion + 1)->await; in SyncAwaitTriggerFired()1179 pAwait = &(pAwaitUnion + 1)->await; /* first await on list */ in FreeAwait()1531 pAwait = &(pAwaitUnion + 1)->await; /* skip over header */ in SyncAwaitEpilogue()1588 pAwait = &(pAwaitUnion + 1)->await; /* skip over header */ in ProcSyncAwait()2053 pAwait = &(pAwaitUnion + 1)->await; /* skip over header */ in ProcSyncAwaitFence()
79 static inline HRESULT await(const ComPtr<IAsyncOperation<GeolocationAccessStatus>> &asyncOp, in await() function666 QWinRTFunctions::await(op, &accessStatus); in requestAccess()668 await(op, &accessStatus); in requestAccess()
65 user space and await results.
585 Op4 is a mode : 0 (await) 1 (yield) 2 (initial) 3 (final) */
1050 * Queue of SCBs that have completed and await the host
1694 * and await the bus going free. If this is an untagged transaction
1282 * and await the bus going free. If this is an untagged transaction
1# ncurses 6.1 - patch 20191130 - Thomas E. Dickey 2# 3# --- ...
15 them onto the kernel channel and await results. This is especially27 testing and await feedback.
4919 be undefined. If you really detest this restriction we eagerly await a
6546 thus hang while both Xwayland and the wayland compositor await responses