Home
last modified time | relevance | path

Searched full:async (Results 1 – 25 of 1707) sorted by relevance

12345678910>>...69

/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 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 Dsqlalchemy.py127 async def create(self):
133 # Psygopg 3 (psygopg) driver can handle async connection pooling
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):
[all …]
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 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 …]
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 …]
/openbmc/qemu/hw/usb/
H A Dhcd-uhci.c8 * Support for fully async operation and multiple outstanding transactions
65 * Pending async transaction.
102 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()
[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()
262 trace_usb_ehci_state("async", state2str(state)); 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()
[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;
22 TP_printk("async=%d crtc_mask=%x",
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;
[all …]
/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/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/sdbusplus/test/async/
H A Dfdio.cpp1 #include <sdbusplus/async.hpp>
27 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()
[all …]
H A Dcontext.cpp1 #include <sdbusplus/async.hpp>
28 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/sdbusplus/include/sdbusplus/
H A Dasync.hpp3 #include <sdbusplus/async/context.hpp>
4 #include <sdbusplus/async/execution.hpp>
5 #include <sdbusplus/async/fdio.hpp>
6 #include <sdbusplus/async/match.hpp>
7 #include <sdbusplus/async/proxy.hpp>
8 #include <sdbusplus/async/task.hpp>
9 #include <sdbusplus/async/timer.hpp>
/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.py14 # The Python async server defaults to a 64K receive buffer, so we hardcode our
51 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):
[all …]
/openbmc/linux/include/media/
H A Dv4l2-async.h37 * struct v4l2_async_match_desc - async connection match information
69 * @notifier: the async notifier the connection is related to
181 * v4l2_async_nf_add_fwnode - Allocate and add a fwnode async
187 * @type: Type of the driver's async sub-device or connection struct. The
189 * driver's async struct, i.e. both begin at the same memory address.
204 * remote async subdev to the
210 * @type: Type of the driver's async connection struct. The &struct
211 * v4l2_async_connection shall be the first member of the driver's async
215 * matching and adds the async connection to the notifier's @asc_list. The
230 * v4l2_async_nf_add_i2c - Allocate and add an i2c async
[all …]
/openbmc/sdbusplus/include/sdbusplus/async/
H A Dclient.hpp3 #include <sdbusplus/async/proxy.hpp>
5 namespace sdbusplus::async namespace
16 /** An aggregation class of sdbusplus::async::proxy-based client types.
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()
113 } // namespace sdbusplus::async
H A Dexecution.hpp17 #include <sdbusplus/async/stdexec/async_scope.hpp>
18 #include <sdbusplus/async/stdexec/coroutine.hpp>
19 #include <sdbusplus/async/stdexec/execution.hpp>
22 // Add std::execution as sdbusplus::async::execution so that we can simplify
24 namespace sdbusplus::async namespace
28 } // namespace sdbusplus::async
/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()
67 sdbusplus::async::context ctx; in main()
70 sdbusplus::async::execution::just() | in main()
71 sdbusplus::async::execution::then([&ctx]() { ctx.request_stop(); })); in main()
H A Dcalculator-aserver.cpp2 #include <sdbusplus/async.hpp>
10 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/sdbusplus/tools/sdbusplus/templates/
H A Dinterface.client.hpp.mako2 #include <sdbusplus/async/client.hpp>
23 * sdbusplus::async::client_t<${interface.classname}>() or
29 sdbusplus::async::client_t<details::${interface.classname}>,
35 sdbusplus::async::client_t<details::${interface.classname}>,
47 private sdbusplus::async::client::details::client_context_friend
55 // indirectly through sdbusplus::async::client_t.
70 sdbusplus::async::context& context()
72 return sdbusplus::async::client::details::client_context_friend::
/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/linux/drivers/media/v4l2-core/
H A Dv4l2-async.c22 #include <media/v4l2-async.h>
101 "v4l2-async: fwnode match: need %pfw, trying %pfw\n", in match_fwnode_one()
106 "v4l2-async: direct match found\n"); in match_fwnode_one()
112 "v4l2-async: direct match not found\n"); in match_fwnode_one()
123 "v4l2-async: device--endpoint match %sfound\n", in match_fwnode_one()
134 "v4l2-async: matching for notifier %pfw, sd fwnode %pfw\n", in match_fwnode()
141 "v4l2-async: endpoint fwnode list available, looking for %pfw\n", in match_fwnode()
149 "v4l2-async: endpoint-endpoint match %sfound with %pfw\n", in match_fwnode()
156 dev_dbg(sd->dev, "async: no endpoint matched\n"); in match_fwnode()
169 "v4l2-async: trying secondary fwnode match\n"); in match_fwnode()
[all …]

12345678910>>...69