Lines Matching full:topics
1279 * to track already-subscribed topics globally in _lws_mqtt_rx_parser()
2152 * and we're done, otherwise just ask the server for topics that in lws_mqtt_client_send_subcribe()
2181 * already subscribed to all the topics this stream in lws_mqtt_client_send_subcribe()
2184 lwsl_notice("%s: all topics already subscribed\n", __func__); in lws_mqtt_client_send_subcribe()
2199 * zero or more of the topics already existed, but not all, in lws_mqtt_client_send_subcribe()
2208 * Pid + (Topic len field + Topic len + Req. QoS) x Num of Topics in lws_mqtt_client_send_subcribe()
2218 lwsl_debug("%s: Number of topics = %d, Remaining len = %d\n", in lws_mqtt_client_send_subcribe()
2248 lwsl_info("%s: topics[%d] = %s\n", __func__, in lws_mqtt_client_send_subcribe()
2253 lwsl_info("%s: topics[%d] \"%s\" exists in nwsi\n", in lws_mqtt_client_send_subcribe()
2340 * topics. in lws_mqtt_client_send_unsubcribe()
2363 * one or more of the topics needs to be unsubscribed in lws_mqtt_client_send_unsubcribe()
2378 * Pid + (Topic len field + Topic len) x Num of Topics in lws_mqtt_client_send_unsubcribe()
2388 lwsl_debug("%s: Number of topics = %d, Remaining len = %d\n", in lws_mqtt_client_send_unsubcribe()
2418 lwsl_info("%s: topics[%d] = %s\n", __func__, in lws_mqtt_client_send_unsubcribe()