Lines Matching refs:subscribe
66 if (!h->policy->u.mqtt.subscribe || wsi->mqtt->done_subscribe)
76 if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe,
77 strlen(h->policy->u.mqtt.subscribe), &used_in,
80 "%s, failed to expand MQTT subscribe"
89 "%s, failed to allocate MQTT subscribe"
98 if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe,
99 strlen(h->policy->u.mqtt.subscribe), &used_in,
101 lwsl_err("%s, failed to expand MQTT subscribe topic\n",
110 * The policy says to subscribe to something, and we
128 lwsl_notice("%s: unable to subscribe", __func__);
464 lwsl_wsi_notice(wsi, "Unable to subscribe Shadow topics");
578 if (!h->policy->u.mqtt.subscribe ||
579 !h->policy->u.mqtt.subscribe[0]) {
581 * If subscribe is empty in the policy, then,
591 * stored session, then, do not subscribe.
596 } else if (h->policy->u.mqtt.subscribe &&
599 * If a subscribe is pending on the stream, then make
655 if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe,
656 strlen(h->policy->u.mqtt.subscribe),
658 lwsl_err("%s, failed to expand subscribe topic",
665 lwsl_err("%s, failed to find metadata for subscribe",
727 * Stream demanded a subscribe without a Birth while connecting, once
806 if (!wsi->mqtt->done_subscribe && h->policy->u.mqtt.subscribe)
954 h->policy->u.mqtt.subscribe,