Lines Matching refs:shadow_sub
386 for (i = 0; i < h->u.mqtt.shadow_sub.num_topics; i++)
387 lws_free((void *)h->u.mqtt.shadow_sub.topic[i].name);
389 h->u.mqtt.shadow_sub.num_topics = 0;
391 if (h->u.mqtt.shadow_sub.topic) {
392 lws_free(h->u.mqtt.shadow_sub.topic);
393 h->u.mqtt.shadow_sub.topic = NULL;
402 if (h->u.mqtt.shadow_sub.num_topics == 0) {
410 if (lws_mqtt_client_send_unsubcribe(wsi, &h->u.mqtt.shadow_sub)) {
438 if (h->u.mqtt.shadow_sub.num_topics > 0)
441 memset(&h->u.mqtt.shadow_sub, 0, sizeof(lws_mqtt_subscribe_param_t));
442 h->u.mqtt.shadow_sub.topic = lws_malloc(
444 if (!h->u.mqtt.shadow_sub.topic) {
448 h->u.mqtt.shadow_sub.num_topics = suffixes_len;
458 h->u.mqtt.shadow_sub.topic[i].name = expbuf;
459 h->u.mqtt.shadow_sub.topic[i].qos = h->policy->u.mqtt.qos;
461 h->u.mqtt.shadow_sub.packet_id = (uint16_t)(h->txord - 1);
463 if (lws_mqtt_client_send_subcribe(wsi, &h->u.mqtt.shadow_sub)) {
692 for (i = 0; i < h->u.mqtt.shadow_sub.num_topics; i++) {
697 if (strncmp(h->u.mqtt.shadow_sub.topic[i].name,