Home
last modified time | relevance | path

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

12345678910>>...21

/openbmc/phosphor-bmc-code-mgmt/i2c-vr/mps/
H A Dmp5998.hpp12 MP5998(sdbusplus::async::context& ctx, uint16_t bus, uint16_t address) : in MP5998()
16 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
18 sdbusplus::async::task<bool> updateFirmware(bool force) final;
19 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
20 sdbusplus::async::task<bool> parseDeviceConfiguration() final;
24 sdbusplus::async::task<bool> checkId(PMBusCmd pmBusCmd, uint32_t expected);
25 sdbusplus::async::task<bool> unlockPasswordProtection();
26 sdbusplus::async::task<bool> unlockWriteProtection();
27 sdbusplus::async::task<bool> storeMTP();
28 sdbusplus::async::task<bool> waitForMTPComplete();
[all …]
H A Dmp297x.hpp12 MP297X(sdbusplus::async::context& ctx, uint16_t bus, uint16_t address) : in MP297X()
16 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
18 sdbusplus::async::task<bool> updateFirmware(bool force) final;
19 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
20 sdbusplus::async::task<bool> parseDeviceConfiguration() final;
24 sdbusplus::async::task<bool> checkId(PMBusCmd pmBusCmd, uint32_t expected);
25 sdbusplus::async::task<bool> isPasswordUnlock();
26 sdbusplus::async::task<bool> unlockWriteProtect();
27 sdbusplus::async::task<bool> storeDataIntoMTP();
28 sdbusplus::async::task<bool> enableMTPPageWriteRead();
[all …]
H A Dmp2x6xx.hpp12 MP2X6XX(sdbusplus::async::context& ctx, uint16_t bus, uint16_t address) : in MP2X6XX()
16 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
18 sdbusplus::async::task<bool> updateFirmware(bool force) final;
19 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
20 sdbusplus::async::task<bool> parseDeviceConfiguration() final;
24 sdbusplus::async::task<bool> checkId(PMBusCmd pmBusCmd, uint32_t expected);
25 sdbusplus::async::task<bool> unlockWriteProtect();
26 sdbusplus::async::task<bool> storeUserCode();
27 sdbusplus::async::task<bool> checkMTPCRC();
28 sdbusplus::async::task<bool> selectConfig(uint8_t config);
[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):
90 async def setup_connection(self):
101 async def send_stream_batch(self, mode, msgs):
117 async def proc():
[all …]
/openbmc/phosphor-bmc-code-mgmt/i2c-vr/isl69269/
H A Disl69269.hpp6 #include <sdbusplus/async.hpp>
22 ISL69269(sdbusplus::async::context& ctx, uint16_t bus, uint16_t address,
25 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
28 sdbusplus::async::task<bool> updateFirmware(bool force) final;
29 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
54 sdbusplus::async::task<bool> dmaReadWrite(uint8_t* reg, uint8_t* resp);
55 sdbusplus::async::task<bool> getRemainingWrites(uint8_t* remain);
56 sdbusplus::async::task<bool> getHexMode(uint8_t* mode);
57 sdbusplus::async::task<bool> getDeviceId(uint32_t* deviceId);
58 sdbusplus::async::task<bool> getDeviceRevision(uint32_t* revision);
[all …]
/openbmc/phosphor-bmc-code-mgmt/cpld/lattice/
H A Dlattice_xo3_cpld.hpp9 LatticeXO3CPLD(sdbusplus::async::context& ctx, const uint16_t bus, in LatticeXO3CPLD()
21 sdbusplus::async::task<bool> prepareUpdate(const uint8_t* image,
23 sdbusplus::async::task<bool> doUpdate() override;
24 sdbusplus::async::task<bool> finishUpdate() override;
27 sdbusplus::async::task<bool> readUserCode(uint32_t& userCode) override;
28 sdbusplus::async::task<bool> readDeviceId();
29 sdbusplus::async::task<bool> eraseFlash();
30 sdbusplus::async::task<bool> writeProgramPage();
31 sdbusplus::async::task<bool> programUserCode();
32 sdbusplus::async::task<bool> programSinglePage(
[all …]
H A Dlattice_xo5_cpld.hpp9 LatticeXO5CPLD(sdbusplus::async::context& ctx, const uint16_t bus, in LatticeXO5CPLD()
21 sdbusplus::async::task<bool> prepareUpdate(const uint8_t* image,
23 sdbusplus::async::task<bool> doUpdate() override;
24 sdbusplus::async::task<bool> finishUpdate() override;
25 sdbusplus::async::task<bool> readUserCode(uint32_t& userCode) override;
28 sdbusplus::async::task<bool> waitUntilReady(
30 sdbusplus::async::task<bool> eraseCfg();
31 sdbusplus::async::task<bool> programCfg();
32 sdbusplus::async::task<bool> programPage(uint8_t block, uint8_t page,
34 sdbusplus::async::task<bool> verifyCfg();
[all …]
H A Dlattice_base_cpld.hpp123 LatticeBaseCPLD(sdbusplus::async::context& ctx, const uint16_t bus, in LatticeBaseCPLD()
135 sdbusplus::async::task<bool> updateFirmware(
139 sdbusplus::async::task<bool> getVersion(std::string& version);
142 sdbusplus::async::context& ctx;
151 virtual sdbusplus::async::task<bool> prepareUpdate(const uint8_t*,
153 virtual sdbusplus::async::task<bool> doUpdate() = 0;
154 virtual sdbusplus::async::task<bool> finishUpdate() = 0;
158 sdbusplus::async::task<bool> enableProgramMode();
159 sdbusplus::async::task<bool> resetConfigFlash();
160 sdbusplus::async::task<bool> programDone();
[all …]
/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;
H A DNotifyWatch.hpp3 #include <sdbusplus/async.hpp>
15 using Callback_t = std::function<sdbusplus::async::task<>(std::string)>;
18 explicit NotifyWatch(sdbusplus::async::context& ctx, const std::string& dir,
23 auto readNotifyAsync() -> sdbusplus::async::task<>;
26 sdbusplus::async::context& ctx;
30 std::unique_ptr<sdbusplus::async::fdio> fdioInstance;
/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>
/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/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;
23 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
56 sdbusplus::async::task<bool> getDeviceId(uint8_t* deviceId);
57 sdbusplus::async::task<bool> mfrFWcmd(uint8_t cmd, uint16_t processTime,
59 sdbusplus::async::task<bool> getRemainingWrites(uint8_t* remain);
60 sdbusplus::async::task<bool> program(bool force);
61 sdbusplus::async::task<bool> getScratchPadAddress();
/openbmc/phosphor-bmc-code-mgmt/common/include/
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;
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,
56 sdbusplus::async::context& ctx;
59 sdbusplus::async::task<void> handleInterfaceAdded(
63 sdbusplus::async::task<void> handleInterfaceRemoved(
66 sdbusplus::async::task<void> interfaceAddedMatch(
68 sdbusplus::async::task<void> interfaceRemovedMatch(
[all …]
/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/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/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/qemu/hw/usb/
H A Dhcd-uhci.c8 * Support for fully async operation and multiple outstanding transactions
71 * Pending async transaction.
108 static void uhci_async_cancel(UHCIAsync *async);
143 UHCIAsync *async; in uhci_queue_free() local
146 async = QTAILQ_FIRST(&queue->asyncs); in uhci_queue_free()
147 uhci_async_cancel(async); in uhci_queue_free()
184 UHCIAsync *async = g_new0(UHCIAsync, 1); in uhci_async_alloc() local
186 async->queue = queue; in uhci_async_alloc()
187 async->td_addr = td_addr; in uhci_async_alloc()
188 usb_packet_init(&async->packet); in uhci_async_alloc()
[all …]
/openbmc/phosphor-bmc-code-mgmt/i2c-vr/
H A Dvr.hpp3 #include <sdbusplus/async.hpp>
25 explicit VoltageRegulator(sdbusplus::async::context& ctx) : ctx(ctx) {} in VoltageRegulator()
35 // @return sdbusplus::async::task<bool> true indicates success.
36 virtual sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
40 // @return sdbusplus::async::task<bool> true indicates success.
41 virtual sdbusplus::async::task<bool> updateFirmware(bool force) = 0;
46 virtual sdbusplus::async::task<bool> getCRC(uint32_t* checksum) = 0;
53 sdbusplus::async::context& ctx;
56 std::unique_ptr<VoltageRegulator> create(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/dbus-sensors/src/cable-monitor/
H A DCableMonitor.hpp8 #include <sdbusplus/async.hpp>
27 explicit Monitor(sdbusplus::async::context& ctx);
40 /** @brief Callback handler for async updates to cable JSON configuration */
42 -> sdbusplus::async::task<>;
45 auto start() -> sdbusplus::async::task<>;
49 -> sdbusplus::async::task<>;
53 -> sdbusplus::async::task<>;
58 sdbusplus::async::context& ctx;

12345678910>>...21