Home
last modified time | relevance | path

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

12345678910>>...72

/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 …]
/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/phosphor-bmc-code-mgmt/cpld/lattice/
H A Dlattice.hpp35 CpldLatticeManager(sdbusplus::async::context& ctx, const uint16_t bus, in CpldLatticeManager()
43 sdbusplus::async::task<bool> updateFirmware(
45 sdbusplus::async::task<bool> getVersion(std::string& version);
48 sdbusplus::async::context& ctx;
58 sdbusplus::async::task<bool> XO2XO3FamilyUpdate(
64 sdbusplus::async::task<bool> readDeviceId();
65 sdbusplus::async::task<bool> enableProgramMode();
66 sdbusplus::async::task<bool> eraseFlash();
67 sdbusplus::async::task<bool> resetConfigFlash();
68 sdbusplus::async::task<bool> writeProgramPage();
[all …]
/openbmc/phosphor-bmc-code-mgmt/i2c-vr/isl69269/
H A Disl69269.hpp6 #include <sdbusplus/async.hpp>
16 ISL69269(sdbusplus::async::context& ctx, uint16_t bus, uint16_t address);
18 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
21 sdbusplus::async::task<bool> updateFirmware(bool force) final;
22 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
23 sdbusplus::async::task<bool> reset() final;
48 sdbusplus::async::task<bool> dmaReadWrite(uint8_t* reg, uint8_t* resp);
49 sdbusplus::async::task<bool> getRemainingWrites(uint8_t* remain);
50 sdbusplus::async::task<bool> getHexMode(uint8_t* mode);
51 sdbusplus::async::task<bool> getDeviceId(uint32_t* deviceId);
[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/gen/
H A Dtest_aserver_emit_interfaces_added_signal.cpp6 #include <sdbusplus/async/context.hpp>
7 #include <sdbusplus/async/match.hpp>
8 #include <sdbusplus/async/timer.hpp>
13 auto waitForMatch(sdbusplus::async::context& ctx, in waitForMatch()
14 sdbusplus::async::match& ifcAdded) -> sdbusplus::async::task<> in waitForMatch()
21 auto shouldEmitSignal(sdbusplus::async::context& ctx) in shouldEmitSignal()
22 -> sdbusplus::async::task<> in shouldEmitSignal()
24 co_await sdbusplus::async::sleep_for(ctx, std::chrono::seconds(1)); in shouldEmitSignal()
37 co_await sdbusplus::async::sleep_for(ctx, std::chrono::seconds(1)); in shouldEmitSignal()
44 sdbusplus::async::context ctx; in main()
[all …]
H A Dtest_aserver_multiple_interfaces.cpp7 #include <sdbusplus/async/context.hpp>
8 #include <sdbusplus/async/match.hpp>
9 #include <sdbusplus/async/timer.hpp>
14 auto constructInterfaces(sdbusplus::async::context& ctx, std::string& busName) in constructInterfaces()
15 -> sdbusplus::async::task<> in constructInterfaces()
31 sdbusplus::async::server_t<A, sdbusplus::aserver::server::Test> a2( in constructInterfaces()
36 sdbusplus::async::server_t<A, sdbusplus::aserver::server::Test>>( in constructInterfaces()
40 sdbusplus::async::server_t<A, sdbusplus::aserver::server::Test2> a4( in constructInterfaces()
44 // sdbusplus::async::server_t<A, sdbusplus::aserver::server::Test2> ax(ctx, in constructInterfaces()
48 sdbusplus::async::server_t<A, sdbusplus::aserver::server::Test, in constructInterfaces()
[all …]
/openbmc/phosphor-bmc-code-mgmt/i2c-vr/
H A Dvr.hpp3 #include <sdbusplus/async.hpp>
21 explicit VoltageRegulator(sdbusplus::async::context& ctx) : ctx(ctx) {} in VoltageRegulator()
31 // @return sdbusplus::async::task<bool> true indicates success.
32 virtual sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
36 // @return sdbusplus::async::task<bool> true indicates success.
37 virtual sdbusplus::async::task<bool> updateFirmware(bool force) = 0;
40 // @return sdbusplus::async::task<bool> true indicates success.
41 virtual sdbusplus::async::task<bool> reset() = 0;
46 virtual sdbusplus::async::task<bool> getCRC(uint32_t* checksum) = 0;
53 sdbusplus::async::context& ctx;
[all …]
/openbmc/phosphor-bmc-code-mgmt/i2c-vr/xdpe1x2xx/
H A Dxdpe1x2xx.hpp6 #include <sdbusplus/async.hpp>
16 XDPE1X2XX(sdbusplus::async::context& ctx, uint16_t bus, uint16_t address);
18 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
21 sdbusplus::async::task<bool> updateFirmware(bool force) final;
22 sdbusplus::async::task<bool> reset() final;
24 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
57 sdbusplus::async::task<bool> getDeviceId(uint8_t* deviceId);
58 sdbusplus::async::task<bool> mfrFWcmd(uint8_t cmd, uint16_t processTime,
60 sdbusplus::async::task<bool> getRemainingWrites(uint8_t* remain);
61 sdbusplus::async::task<bool> program(bool force);
[all …]
/openbmc/phosphor-bmc-code-mgmt/common/include/
H A Dsoftware_manager.hpp4 #include "sdbusplus/async/match.hpp"
10 #include <sdbusplus/async/context.hpp>
26 SoftwareManager(sdbusplus::async::context& ctx,
33 sdbusplus::async::task<> initDevices(
50 virtual sdbusplus::async::task<bool> initDevice(const std::string& service,
54 sdbusplus::async::context& ctx;
57 sdbusplus::async::task<void> handleInterfaceAdded(
61 sdbusplus::async::task<void> handleInterfaceRemoved(
64 sdbusplus::async::task<void> interfaceAddedMatch(
66 sdbusplus::async::task<void> interfaceRemovedMatch(
[all …]
H A Dhost_power.hpp3 #include <sdbusplus/async/context.hpp>
4 #include <sdbusplus/async/match.hpp>
21 HostPower(sdbusplus::async::context& ctx);
25 static sdbusplus::async::task<bool> setState(sdbusplus::async::context& ctx,
29 static sdbusplus::async::task<HostState> getState(
30 sdbusplus::async::context& ctx);
32 sdbusplus::async::match stateChangedMatch;
/openbmc/dbus-sensors/src/
H A DGPIOInterface.hpp4 #include <sdbusplus/async.hpp>
16 using Callback_t = std::function<sdbusplus::async::task<>(bool)>;
20 GPIOInterface(sdbusplus::async::context& ctx,
25 auto start() -> sdbusplus::async::task<>;
29 auto readGPIOAsync() -> sdbusplus::async::task<>;
32 auto readGPIOAsyncEvent() -> sdbusplus::async::task<>;
34 sdbusplus::async::context& ctx;
38 /** File descriptor based async event handler */
39 std::unique_ptr<sdbusplus::async::fdio> fdioInstance;
H A DEntityManagerInterface.hpp3 #include <sdbusplus/async.hpp>
23 EntityManagerInterface(sdbusplus::async::context& ctx,
29 auto handleInventoryGet() -> sdbusplus::async::task<>;
32 /** @brief Handle async inventory add from Entity Manager */
33 auto handleInventoryAdded() -> sdbusplus::async::task<>;
35 /** @brief Handle async inventory remove from Entity Manager */
36 auto handleInventoryRemoved() -> sdbusplus::async::task<>;
38 sdbusplus::async::context& ctx;
/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 …]
/openbmc/phosphor-logging/lib/include/phosphor-logging/
H A Dcommit.hpp3 #include <sdbusplus/async.hpp>
29 /** Commit a generated event/error (using async context).
31 * @param ctx - The async context to use.
35 auto commit(sdbusplus::async::context& ctx,
37 -> sdbusplus::async::task<sdbusplus::message::object_path>;
39 /** Resolve an existing event/error (using async context).
41 * @param ctx - The async context to use.
45 auto resolve(sdbusplus::async::context& ctx,
47 -> sdbusplus::async::task<>;
/openbmc/entity-manager/src/gpio-presence/
H A Dconfig_provider.hpp7 #include <sdbusplus/async/context.hpp>
8 #include <sdbusplus/async/task.hpp>
22 explicit ConfigProvider(sdbusplus::async::context& ctx,
26 -> sdbusplus::async::task<void>;
29 auto getConfig(AddedCallback addConfig) -> sdbusplus::async::task<void>;
32 -> sdbusplus::async::task<void>;
35 -> sdbusplus::async::task<void>;
40 sdbusplus::async::context& ctx;
/openbmc/sdbusplus/include/sdbusplus/
H A Dasync.hpp4 #include <sdbusplus/async/context.hpp>
5 #include <sdbusplus/async/execution.hpp>
6 #include <sdbusplus/async/fdio.hpp>
7 #include <sdbusplus/async/match.hpp>
8 #include <sdbusplus/async/proxy.hpp>
9 #include <sdbusplus/async/task.hpp>
10 #include <sdbusplus/async/timer.hpp>

12345678910>>...72