Lines Matching refs:zst
213 void smp_rx_remove_invalid(struct smp_transport *zst, void *arg) in smp_rx_remove_invalid() argument
218 if (zst->functions.query_valid_check == NULL) { in smp_rx_remove_invalid()
224 if (k_work_busy_get(&zst->work) & (K_WORK_RUNNING | K_WORK_QUEUED)) { in smp_rx_remove_invalid()
225 k_work_cancel(&zst->work); in smp_rx_remove_invalid()
233 while ((nb = k_fifo_get(&zst->fifo, K_NO_WAIT)) != NULL) { in smp_rx_remove_invalid()
234 if (!zst->functions.query_valid_check(nb, arg)) { in smp_rx_remove_invalid()
235 smp_free_buf(nb, zst); in smp_rx_remove_invalid()
243 k_fifo_put(&zst->fifo, nb); in smp_rx_remove_invalid()
247 if (!k_fifo_is_empty(&zst->fifo)) { in smp_rx_remove_invalid()
248 k_work_submit_to_queue(&smp_work_queue, &zst->work); in smp_rx_remove_invalid()
252 void smp_rx_clear(struct smp_transport *zst) in smp_rx_clear() argument
257 if (k_work_busy_get(&zst->work) & (K_WORK_RUNNING | K_WORK_QUEUED)) { in smp_rx_clear()
258 k_work_cancel(&zst->work); in smp_rx_clear()
262 while ((nb = k_fifo_get(&zst->fifo, K_NO_WAIT)) != NULL) { in smp_rx_clear()
263 smp_free_buf(nb, zst); in smp_rx_clear()