Lines Matching refs:process_work
400 k_work_cancel_delayable(&client->process_work); in mqtt_sn_disconnect_internal()
951 static void process_work(struct k_work *wrk) in process_work() function
959 client = CONTAINER_OF(dwork, struct mqtt_sn_client, process_work); in process_work()
1020 k_work_init_delayable(&client->process_work, process_work); in mqtt_sn_client_init()
1043 k_work_cancel_delayable(&client->process_work); in mqtt_sn_client_deinit()
1073 k_work_schedule(&client->process_work, K_NO_WAIT); in mqtt_sn_search()
1169 err = k_work_reschedule(&client->process_work, K_NO_WAIT); in mqtt_sn_subscribe()
1206 err = k_work_reschedule(&client->process_work, K_NO_WAIT); in mqtt_sn_unsubscribe()
1249 k_work_reschedule(&client->process_work, K_NO_WAIT); in mqtt_sn_publish()
1259 err = k_work_reschedule(&client->process_work, K_NO_WAIT); in mqtt_sn_publish()
1288 k_work_schedule(&client->process_work, K_NO_WAIT); in handle_advertise()
1308 k_work_schedule(&client->process_work, K_NO_WAIT); in handle_searchgw()
1324 k_work_schedule(&client->process_work, K_NO_WAIT); in handle_gwinfo()
1370 k_work_schedule(&client->process_work, K_NO_WAIT); in handle_connack()
1648 k_work_reschedule(&client->process_work, K_NO_WAIT); in handle_msg()