Searched refs:sh_mqtt (Results 1 – 1 of 1) sorted by relevance
41 struct shell_mqtt *sh_mqtt; variable48 return k_work_reschedule_for_queue(&sh_mqtt->workq, dwork, delay); in sh_mqtt_work_reschedule()53 return k_work_submit_to_queue(&sh_mqtt->workq, work); in sh_mqtt_work_submit()59 return k_mutex_lock(&sh_mqtt->lock, timeout); in sh_mqtt_context_lock()65 (void)k_mutex_unlock(&sh_mqtt->lock); in sh_mqtt_context_unlock()71 uint32_t size = ring_buf_size_get(&sh_mqtt->rx_rb); in sh_mqtt_rx_rb_flush()74 size = ring_buf_get(&sh_mqtt->rx_rb, &c, 1U); in sh_mqtt_rx_rb_flush()96 if (sh_mqtt->mqtt_cli.transport.type == MQTT_TRANSPORT_NON_SECURE) { in prepare_fds()97 sh_mqtt->fds[0].fd = sh_mqtt->mqtt_cli.transport.tcp.sock; in prepare_fds()100 sh_mqtt->fds[0].events = ZSOCK_POLLIN; in prepare_fds()[all …]
