Home
last modified time | relevance | path

Searched refs:async (Results 1 – 25 of 500) sorted by relevance

12345678910>>...20

/openbmc/linux/drivers/comedi/
H A Dcomedi_buf.c55 struct comedi_async *async = s->async; in __comedi_buf_free() local
59 if (async->prealloc_buf) { in __comedi_buf_free()
61 vunmap(async->prealloc_buf); in __comedi_buf_free()
62 async->prealloc_buf = NULL; in __comedi_buf_free()
63 async->prealloc_bufsz = 0; in __comedi_buf_free()
67 bm = async->buf_map; in __comedi_buf_free()
68 async->buf_map = NULL; in __comedi_buf_free()
143 struct comedi_async *async = s->async; in __comedi_buf_alloc() local
161 async->buf_map = bm; in __comedi_buf_alloc()
170 async->prealloc_buf = buf->virt_addr; in __comedi_buf_alloc()
[all …]
H A Ddrivers.c169 if (s->async) { in comedi_device_detach_cleanup()
171 kfree(s->async); in comedi_device_detach_cleanup()
453 struct comedi_cmd *cmd = &s->async->cmd; in comedi_bytes_per_scan()
462 struct comedi_async *async = s->async; in __comedi_nscans_left() local
463 struct comedi_cmd *cmd = &async->cmd; in __comedi_nscans_left()
468 if (async->scans_done < cmd->stop_arg) in __comedi_nscans_left()
469 scans_left = cmd->stop_arg - async->scans_done; in __comedi_nscans_left()
514 struct comedi_async *async = s->async; in comedi_nsamples_left() local
515 struct comedi_cmd *cmd = &async->cmd; in comedi_nsamples_left()
527 comedi_bytes_to_samples(s, async->scan_progress); in comedi_nsamples_left()
[all …]
H A Dcomedi_fops.c328 struct comedi_async *async = s->async; in resize_async_buffer() local
333 if (new_size > async->max_bufsize) in resize_async_buffer()
361 s->index, async->prealloc_bufsz); in resize_async_buffer()
381 if (s && (s->subdev_flags & SDF_CMD_READ) && s->async) in max_read_buffer_kb_show()
382 size = s->async->max_bufsize / 1024; in max_read_buffer_kb_show()
412 if (s && (s->subdev_flags & SDF_CMD_READ) && s->async) in max_read_buffer_kb_store()
413 s->async->max_bufsize = size; in max_read_buffer_kb_store()
437 if (s && (s->subdev_flags & SDF_CMD_READ) && s->async) in read_buffer_kb_show()
438 size = s->async->prealloc_bufsz / 1024; in read_buffer_kb_show()
468 if (s && (s->subdev_flags & SDF_CMD_READ) && s->async) in read_buffer_kb_store()
[all …]
/openbmc/openbmc/poky/bitbake/lib/hashserv/
H A Dclient.py25 async def recv(self, socket):
27 async with self.cond:
38 async with self.cond:
41 async def send(self, socket, msgs):
51 async with self.cond:
59 async with self.cond:
63 async def process(self, socket, msgs):
89 async def setup_connection(self):
100 async def send_stream_batch(self, mode, msgs):
116 async def proc():
[all …]
H A Dsqlalchemy.py127 async def create(self):
138 async with self.engine.begin() as conn:
195 async def __aenter__(self):
199 async def __aexit__(self, exc_type, exc_value, traceback):
202 async def close(self):
206 async def _execute(self, statement):
210 async def _set_config(self, name, value):
234 async def _get_config(self, name):
241 async def get_unihash_by_taskhash_full(self, method, taskhash):
242 async with self.db.begin():
[all …]
H A Dsqlite.py118 async def create(self):
194 async def __aenter__(self):
197 async def __aexit__(self, exc_type, exc_value, traceback):
200 async def _set_config(self, cursor, name, value):
212 async def _get_config(self, cursor, name):
224 async def close(self):
227 async def get_unihash_by_taskhash_full(self, method, taskhash):
244 async def get_unihash_by_outhash(self, method, outhash):
261 async def unihash_exists(self, unihash):
274 async def get_outhash(self, method, outhash):
[all …]
H A Dserver.py149 async def new_token():
157 async with token_refresh_semaphore:
192 async def wrap(self, request):
295 async def process_requests(self):
296 async with self.server.db_engine.connect(self.logger) as db:
309 async def dispatch_message(self, msg):
322 async def handle_get(self, request):
329 async def get_unihash(self, method, taskhash, fetch_all=False):
351 async def handle_get_outhash(self, request):
359 async def get_outhash(self, method, outhash, taskhash, with_unihash=True):
[all …]
/openbmc/qemu/hw/usb/
H A Dhcd-uhci.c102 static void uhci_async_cancel(UHCIAsync *async);
137 UHCIAsync *async; in uhci_queue_free() local
140 async = QTAILQ_FIRST(&queue->asyncs); in uhci_queue_free()
141 uhci_async_cancel(async); in uhci_queue_free()
178 UHCIAsync *async = g_new0(UHCIAsync, 1); in uhci_async_alloc() local
180 async->queue = queue; in uhci_async_alloc()
181 async->td_addr = td_addr; in uhci_async_alloc()
182 usb_packet_init(&async->packet); in uhci_async_alloc()
183 trace_usb_uhci_packet_add(async->queue->token, async->td_addr); in uhci_async_alloc()
185 return async; in uhci_async_alloc()
[all …]
H A Dhcd-ehci.c259 static void ehci_set_state(EHCIState *s, int async, int state) in ehci_set_state() argument
261 if (async) { in ehci_set_state()
282 static int ehci_get_state(EHCIState *s, int async) in ehci_get_state() argument
284 return async ? s->astate : s->pstate; in ehci_get_state()
287 static void ehci_set_fetch_addr(EHCIState *s, int async, uint32_t addr) in ehci_set_fetch_addr() argument
289 if (async) { in ehci_set_fetch_addr()
296 static int ehci_get_fetch_addr(EHCIState *s, int async) in ehci_get_fetch_addr() argument
298 return async ? s->a_fetch_addr : s->p_fetch_addr; in ehci_get_fetch_addr()
438 (q->async && qh->next_qtd != q->qh.next_qtd) || in ehci_verify_qh()
451 (p->queue->async && !NLPTR_TBIT(p->qtd.next) && in ehci_verify_qtd()
[all …]
/openbmc/qemu/python/tests/
H A Dprotocol.py40 async def _establish_session(self):
44 async def _do_start_server(self, address, ssl=None):
52 async def _do_accept(self):
58 async def _do_connect(self, address, ssl=None):
65 async def _do_recv(self) -> None:
72 async def send_msg(self) -> None:
75 async def simulate_disconnect(self) -> None:
99 async def _do_recv(self) -> str:
109 async def send_msg(self, msg: str) -> None:
120 async def _runner():
[all …]
/openbmc/linux/drivers/base/regmap/
H A Dregmap-spi.c23 struct regmap_async_spi *async = data; in regmap_spi_complete() local
25 regmap_async_complete_cb(&async->core, async->m.status); in regmap_spi_complete()
58 struct regmap_async_spi *async = container_of(a, in regmap_spi_async_write() local
64 async->t[0].tx_buf = reg; in regmap_spi_async_write()
65 async->t[0].len = reg_len; in regmap_spi_async_write()
66 async->t[1].tx_buf = val; in regmap_spi_async_write()
67 async->t[1].len = val_len; in regmap_spi_async_write()
69 spi_message_init(&async->m); in regmap_spi_async_write()
70 spi_message_add_tail(&async->t[0], &async->m); in regmap_spi_async_write()
72 spi_message_add_tail(&async->t[1], &async->m); in regmap_spi_async_write()
[all …]
/openbmc/linux/drivers/gpu/drm/msm/
H A Dmsm_atomic_trace.h12 TP_PROTO(bool async, unsigned crtc_mask),
13 TP_ARGS(async, crtc_mask),
15 __field(bool, async)
19 __entry->async = async;
23 __entry->async, __entry->crtc_mask)
27 TP_PROTO(bool async, unsigned crtc_mask),
28 TP_ARGS(async, crtc_mask),
30 __field(bool, async)
34 __entry->async = async;
38 __entry->async, __entry->crtc_mask)
/openbmc/linux/drivers/staging/vc04_services/interface/
H A DTESTING60 vchi ping (size 0, 0 async, 0 oneway) -> 122.000000us
61 vchi bulk (size 0, 0 async, 0 oneway) -> 546.000000us
64 vchi ping (size 0, 0 async, 0 oneway) -> 70.000000us
65 vchi bulk (size 0, 0 async, 0 oneway) -> 296.000000us
67 vchi ping (size 0, 1 async, 0 oneway) -> 65.000000us
69 vchi ping (size 0, 2 async, 0 oneway) -> 74.000000us
71 vchi ping (size 0, 10 async, 0 oneway) -> 125.000000us
73 vchi ping (size 0, 0 async, 1 oneway) -> 70.000000us
74 vchi ping (size 0, 0 async, 2 oneway) -> 76.000000us
75 vchi ping (size 0, 0 async, 10 oneway) -> 105.000000us
[all …]
/openbmc/sdbusplus/test/async/
H A Dfdio.cpp27 fdioInstance = std::make_unique<sdbusplus::async::fdio>(*ctx, fd); in FdioTest()
43 auto writeToFile() -> sdbusplus::async::task<> in writeToFile()
54 -> sdbusplus::async::task<> in testFdEvents()
60 ctx->spawn(sdbusplus::async::sleep_for(*ctx, 1s) | in testFdEvents()
73 std::unique_ptr<sdbusplus::async::fdio> fdioInstance;
74 std::optional<sdbusplus::async::context> ctx{std::in_place};
86 sdbusplus::async::sleep_for(*ctx, 1s) | in TEST_F()
87 sdbusplus::async::execution::then([&]() { ctx->request_stop(); })); in TEST_F()
97 sdbusplus::async::sleep_for(*ctx, 5s) | in TEST_F()
98 sdbusplus::async::execution::then([&]() { ctx->request_stop(); })); in TEST_F()
H A Dcontext.cpp28 std::optional<sdbusplus::async::context> ctx{std::in_place};
59 ctx->spawn(sdbusplus::async::sleep_for(*ctx, timeout) | in TEST_F()
76 -> sdbusplus::async::task<size_t> in TEST_F()
103 auto m = std::make_optional<sdbusplus::async::match>( in TEST_F()
111 ctx->spawn(sdbusplus::async::sleep_for(*ctx, 1ms) | in TEST_F()
122 auto m = std::make_optional<sdbusplus::async::match>( in TEST_F()
129 -> sdbusplus::async::task<> in TEST_F()
139 ctx->spawn(sdbusplus::async::sleep_for(*ctx, 1ms) | in TEST_F()
/openbmc/openbmc/poky/bitbake/lib/bb/asyncrpc/
H A Dclient.py69 async def connect_tcp(self, address, port):
70 async def connect_sock():
76 async def connect_unix(self, path):
77 async def connect_sock():
93 async def connect_websocket(self, uri):
114 async def connect_sock():
124 async def setup_connection(self):
146 async def get_header(self, tag, default):
150 async def connect(self):
155 async def disconnect(self):
[all …]
H A Dconnection.py51 async def send_message(self, msg):
56 async def recv_message(self):
75 async def send(self, msg):
79 async def recv(self):
98 async def close(self):
114 async def send_message(self, msg):
117 async def recv_message(self):
121 async def send(self, msg):
129 async def recv(self):
143 async def close(self):
/openbmc/webui-vue/src/store/modules/Operations/
H A DControlStore.js52 async getLastPowerOperationTime({ commit }) {
64 async getLastBmcRebootTime({ commit }) {
74 async rebootBmc() {
89 async serverPowerOn({ dispatch, commit }) {
96 async serverSoftReboot({ dispatch, commit }) {
103 async serverHardReboot({ dispatch, commit }) {
110 async serverSoftPowerOff({ dispatch, commit }) {
117 async serverHardPowerOff({ dispatch, commit }) {
124 async serverPowerChange({ commit }, data) {
/openbmc/openbmc/poky/bitbake/lib/prserv/
H A Dclient.py17 async def getPR(self, version, pkgarch, checksum, history=False):
24 async def test_pr(self, version, pkgarch, checksum, history=False):
31 async def test_package(self, version, pkgarch):
38 async def max_package_pr(self, version, pkgarch):
45 async def importone(self, version, pkgarch, checksum, value):
52 async def export(self, version, pkgarch, checksum, colinfo, history=False):
59 async def is_readonly(self):
/openbmc/sdbusplus/include/sdbusplus/async/
H A Dclient.hpp5 namespace sdbusplus::async namespace
29 sdbusplus::async::proxy_ns::proxy<S, P, false, Preserved>>...
33 using Proxy = sdbusplus::async::proxy_ns::proxy<S, P, false, Preserved>;
42 explicit client(sdbusplus::async::context& ctx)
46 explicit client(sdbusplus::async::context& ctx) in client()
52 explicit client(sdbusplus::async::context& ctx, Proxy p) in client()
106 static sdbusplus::async::context& context(Self* self) in context()
/openbmc/qemu/python/qemu/qmp/
H A Dprotocol.py263 async def runstate_changed(self) -> Runstate:
272 async def start_server_and_accept(
302 async def start_server(self, address: SocketAddrT,
331 async def accept(self) -> None:
359 async def connect(self, address: Union[SocketAddrT, socket.socket],
388 async def disconnect(self) -> None:
405 async def _session_guard(self, coro: Awaitable[None], emsg: str) -> None:
488 async def _stop_server(self) -> None:
503 async def _incoming(self,
535 async def _do_start_server(self, address: SocketAddrT,
[all …]
/openbmc/sdbusplus/example/
H A Dcalculator-client.cpp2 #include <sdbusplus/async.hpp>
6 auto startup(sdbusplus::async::context& ctx) -> sdbusplus::async::task<> in startup()
14 // Alternatively, sdbusplus::async::client_t<Calculator, ...>() could have in startup()
17 sdbusplus::async::client_t< in startup()
74 sdbusplus::async::context ctx; in main()
77 sdbusplus::async::execution::just() |
78 sdbusplus::async::execution::then([&ctx]() { ctx.request_stop(); }));
H A Dcalculator-aserver.cpp10 explicit Calculator(sdbusplus::async::context& ctx, auto path) : in Calculator()
22 -> sdbusplus::async::task<divide_t::return_type> in method_call()
36 auto method_call(clear_t) -> sdbusplus::async::task<> in method_call()
62 sdbusplus::async::context ctx; in main()
67 ctx.spawn([](sdbusplus::async::context& ctx) -> sdbusplus::async::task<> { in main()
/openbmc/linux/drivers/comedi/drivers/
H A Dni_tiocmd.c79 struct comedi_cmd *cmd = &s->async->cmd; in ni_tio_input_inttrig()
95 s->async->inttrig = NULL; in ni_tio_input_inttrig()
107 struct comedi_async *async = s->async; in ni_tio_input_cmd() local
108 struct comedi_cmd *cmd = &async->cmd; in ni_tio_input_cmd()
112 comedi_buf_write_alloc(s, async->prealloc_bufsz); in ni_tio_input_cmd()
127 async->inttrig = &ni_tio_input_inttrig; in ni_tio_input_cmd()
129 async->inttrig = NULL; in ni_tio_input_cmd()
162 struct comedi_cmd *cmd = &s->async->cmd; in ni_tio_cmd_setup()
207 struct comedi_async *async = s->async; in ni_tio_cmd() local
208 struct comedi_cmd *cmd = &async->cmd; in ni_tio_cmd()
[all …]
/openbmc/sdbusplus/tools/sdbusplus/templates/
H A Dinterface.client.hpp.mako2 #include <sdbusplus/async/client.hpp>
3 #include <sdbusplus/async/execution.hpp>
25 * sdbusplus::async::client_t<${interface.classname}>() or
31 sdbusplus::async::client_t<details::${interface.classname}>,
37 sdbusplus::async::client_t<details::${interface.classname}>,
49 private sdbusplus::async::client::details::client_context_friend
57 // indirectly through sdbusplus::async::client_t.
71 sdbusplus::async::execution::then([](auto&& v) {
109 sdbusplus::async::context& context()
111 return sdbusplus::async
[all...]

12345678910>>...20