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

drivers: sensors: rtio

Browse source 
Inform the executor of a submissions completion with -ENOMEM
if the size of the workq is not big enough.

Signed-off-by: Florian Weber <Florian.Weber@live.de>
This commit is contained in:
Florian Weber 2024-10-15 09:59:38 +02:00 committed by Anas Nashif
parent 60a2d7d7d2
commit 0d9cdf0990
7 changed files with 42 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
drivers/sensor/asahi_kasei/akm09918c/akm09918c_async.c
View file

@ -48,7 +48,12 @@ void akm09918c_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe
{ {
struct rtio_work_req *req = rtio_work_req_alloc(); struct rtio_work_req *req = rtio_work_req_alloc();
__ASSERT_NO_MSG(req); if (req == NULL) {
LOG_ERR("RTIO work item allocation failed. Consider to increase "
"CONFIG_RTIO_WORKQ_POOL_ITEMS.");
rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
return;
}
rtio_work_req_submit(req, iodev_sqe, akm09918c_submit_sync); rtio_work_req_submit(req, iodev_sqe, akm09918c_submit_sync);
} }

7
drivers/sensor/bosch/bma4xx/bma4xx.c
View file

@ -444,7 +444,12 @@ static void bma4xx_submit(const struct device *dev, struct rtio_iodev_sqe *iodev
{ {
struct rtio_work_req *req = rtio_work_req_alloc(); struct rtio_work_req *req = rtio_work_req_alloc();
__ASSERT_NO_MSG(req); if (req == NULL) {
LOG_ERR("RTIO work item allocation failed. Consider to increase "
"CONFIG_RTIO_WORKQ_POOL_ITEMS.");
rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
return;
}
rtio_work_req_submit(req, iodev_sqe, bma4xx_submit_sync); rtio_work_req_submit(req, iodev_sqe, bma4xx_submit_sync);
} }

7
drivers/sensor/bosch/bme280/bme280_async.c
View file

@ -76,7 +76,12 @@ void bme280_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe)
{ {
struct rtio_work_req *req = rtio_work_req_alloc(); struct rtio_work_req *req = rtio_work_req_alloc();
__ASSERT_NO_MSG(req); if (req == NULL) {
LOG_ERR("RTIO work item allocation failed. Consider to increase "
"CONFIG_RTIO_WORKQ_POOL_ITEMS.");
rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
return;
}
rtio_work_req_submit(req, iodev_sqe, bme280_submit_sync); rtio_work_req_submit(req, iodev_sqe, bme280_submit_sync);
} }

7
drivers/sensor/default_rtio_sensor.c
View file

@ -265,7 +265,12 @@ static void sensor_submit_fallback(const struct device *dev, struct rtio_iodev_s
{ {
struct rtio_work_req *req = rtio_work_req_alloc(); struct rtio_work_req *req = rtio_work_req_alloc();
__ASSERT_NO_MSG(req); if (req == NULL) {
LOG_ERR("RTIO work item allocation failed. Consider to increase "
"CONFIG_RTIO_WORKQ_POOL_ITEMS.");
rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
return;
}
rtio_work_req_submit(req, iodev_sqe, sensor_submit_fallback_sync); rtio_work_req_submit(req, iodev_sqe, sensor_submit_fallback_sync);
} }

7
drivers/sensor/memsic/mmc56x3/mmc56x3_async.c
View file

@ -80,7 +80,12 @@ void mmc56x3_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe)
{ {
struct rtio_work_req *req = rtio_work_req_alloc(); struct rtio_work_req *req = rtio_work_req_alloc();
__ASSERT_NO_MSG(req); if (req == NULL) {
LOG_ERR("RTIO work item allocation failed. Consider to increase "
"CONFIG_RTIO_WORKQ_POOL_ITEMS.");
rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
return;
}
rtio_work_req_submit(req, iodev_sqe, mmc56x3_submit_sync); rtio_work_req_submit(req, iodev_sqe, mmc56x3_submit_sync);
} }

7
drivers/sensor/tdk/icm42688/icm42688_rtio.c
View file

@ -97,7 +97,12 @@ void icm42688_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe)
{ {
struct rtio_work_req *req = rtio_work_req_alloc(); struct rtio_work_req *req = rtio_work_req_alloc();
__ASSERT_NO_MSG(req); if (req == NULL) {
LOG_ERR("RTIO work item allocation failed. Consider to increase "
"CONFIG_RTIO_WORKQ_POOL_ITEMS.");
rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
return;
}
rtio_work_req_submit(req, iodev_sqe, icm42688_submit_sync); rtio_work_req_submit(req, iodev_sqe, icm42688_submit_sync);
} }

7
drivers/spi/spi_rtio.c
View file

@ -104,7 +104,12 @@ void spi_rtio_iodev_default_submit(const struct device *dev,
struct rtio_work_req *req = rtio_work_req_alloc(); struct rtio_work_req *req = rtio_work_req_alloc();
__ASSERT_NO_MSG(req); if (req == NULL) {
LOG_ERR("RTIO work item allocation failed. Consider to increase "
"CONFIG_RTIO_WORKQ_POOL_ITEMS.");
rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
return;
}
rtio_work_req_submit(req, iodev_sqe, spi_rtio_iodev_default_submit_sync); rtio_work_req_submit(req, iodev_sqe, spi_rtio_iodev_default_submit_sync);
} }