adafruit-mirror/zephyr
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 9

modules: hal_nordic: nrfs: Enqueue requests when not connected

Browse source 
Allow `nrfs_backend_send` to push early requests into the message queue,
but defer sending them until a connection is established, at which point
the queue will be flushed. This benefits asynchronous code by making it
optional to call `nrfs_backend_wait_for_connection` before using the
nrfs service API, which is already non-blocking.

Signed-off-by: Grzegorz Swiderski <grzegorz.swiderski@nordicsemi.no>
This commit is contained in:
Grzegorz Swiderski 2024-11-15 08:41:59 +01:00 committed by Benjamin Cabé
parent dae37b69c5
commit c120f4fe56
1 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
modules/hal_nordic/nrfs/backends/nrfs_backend_ipc_service.c
View file

@ -95,6 +95,10 @@ static void ipc_sysctrl_ept_bound(void *priv)
LOG_DBG("Bound to sysctrl.");
k_event_post(&ipc_connected_event, IPC_INIT_DONE_EVENT);
atomic_set(&ipc_cpusys_channel_config.status, CONNECTED);
if (k_msgq_num_used_get(&ipc_transmit_msgq) > 0) {
k_work_submit(&backend_send_work);
}
}
static void ipc_sysctrl_ept_recv(const void *data, size_t size, void *priv)
@ -172,11 +176,6 @@ nrfs_err_t nrfs_backend_send(void *message, size_t size)
nrfs_err_t nrfs_backend_send_ex(void *message, size_t size, k_timeout_t timeout, bool high_prio)
{
if (atomic_get(&ipc_cpusys_channel_config.status) != CONNECTED) {
LOG_WRN("Backend not yet connected to sysctrl");
return NRFS_ERR_INVALID_STATE;
}
if (size <= MAX_PACKET_DATA_SIZE) {
int err;
struct ipc_data_packet tx_data;
@ -190,7 +189,9 @@ nrfs_err_t nrfs_backend_send_ex(void *message, size_t size, k_timeout_t timeout,
return NRFS_ERR_IPC;
}
err = k_work_submit(&backend_send_work);
if (nrfs_backend_connected()) {
err = k_work_submit(&backend_send_work);
}
return err >= 0 ? 0 : NRFS_ERR_IPC;
}