Searched refs:num_topics (Results 1 – 5 of 5) sorted by relevance
38 for (i = 0; i < h->u.mqtt.sub_info.num_topics; i++) { in secstream_mqtt_cleanup()119 h->u.mqtt.sub_info.num_topics = 1; in secstream_mqtt_subscribe()420 if (h->u.mqtt.sub_info.num_topics) { in secstream_mqtt()421 lmsp.num_topics = h->u.mqtt.sub_info.num_topics; in secstream_mqtt()
2112 assert(sub->num_topics); in lws_mqtt_client_send_subcribe()2113 assert(sub->num_topics < sizeof(exists)); in lws_mqtt_client_send_subcribe()2136 for (n = 0; n < sub->num_topics; n++) { in lws_mqtt_client_send_subcribe()2156 if (extant == sub->num_topics) { in lws_mqtt_client_send_subcribe()2182 tops = sub->num_topics - extant; in lws_mqtt_client_send_subcribe()2189 for (n = 0; n < sub->num_topics; n++) in lws_mqtt_client_send_subcribe()2223 for (n = 0; n < sub->num_topics; n++) { in lws_mqtt_client_send_subcribe()2301 for (n = 0; n < unsub->num_topics; n++) { in lws_mqtt_client_send_unsubcribe()2357 for (n = 0; n < unsub->num_topics; n++) in lws_mqtt_client_send_unsubcribe()2391 for (n = 0; n < unsub->num_topics; n++) { in lws_mqtt_client_send_unsubcribe()
131 uint32_t num_topics; /* Number of topics */ member
66 .num_topics = LWS_ARRAY_SIZE(topics),
76 .num_topics = LWS_ARRAY_SIZE(topics),