57 	if (!h || !h->policy)  in secstream_mqtt_subscribe()
60 	if (h->policy->u.mqtt.aws_iot)  in secstream_mqtt_subscribe()
65 	if (!h->policy->u.mqtt.subscribe || wsi->mqtt->done_subscribe)  in secstream_mqtt_subscribe()
75 	if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe,  in secstream_mqtt_subscribe()
76 			      strlen(h->policy->u.mqtt.subscribe), &used_in,  in secstream_mqtt_subscribe()
97 	if (lws_strexp_expand(&exp, h->policy->u.mqtt.subscribe,  in secstream_mqtt_subscribe()
98 			      strlen(h->policy->u.mqtt.subscribe), &used_in,  in secstream_mqtt_subscribe()
117 	h->u.mqtt.sub_top.qos = h->policy->u.mqtt.qos;  in secstream_mqtt_subscribe()
124 	h->u.mqtt.sub_info.topic[0].qos = h->policy->u.mqtt.qos;  in secstream_mqtt_subscribe()
154 	if (h->policy->u.mqtt.aws_iot)  in secstream_mqtt_publish()
199 	mqpp.qos = h->policy->u.mqtt.qos;  in secstream_mqtt_publish()
271 		if (h->policy && !(h->policy->flags & LWSSSPOLF_OPPORTUNISTIC) &&  in secstream_mqtt()
288 		if (!h->policy->u.mqtt.subscribe ||  in secstream_mqtt()
289 		    !h->policy->u.mqtt.subscribe[0]) {  in secstream_mqtt()
296 		} else if (!h->policy->u.mqtt.clean_start &&  in secstream_mqtt()
306 		} else if (h->policy->u.mqtt.subscribe &&  in secstream_mqtt()
326 		if (h->policy->u.mqtt.topic)  in secstream_mqtt()
393 		if (!wsi->mqtt->done_subscribe && h->policy->u.mqtt.subscribe)  in secstream_mqtt()
396 		if (!wsi->mqtt->done_birth && h->policy->u.mqtt.birth_topic) {  in secstream_mqtt()
399 			if (h->policy->u.mqtt.birth_message) {  in secstream_mqtt()
402 				if (lws_strexp_expand(&exp, h->policy->u.mqtt.birth_message,  in secstream_mqtt()
403 						      strlen(h->policy->u.mqtt.birth_message),  in secstream_mqtt()
410 					used_out, h->policy->u.mqtt.birth_topic,  in secstream_mqtt()
411 					h->policy->u.mqtt.birth_qos, LWSSS_FLAG_EOM);  in secstream_mqtt()
438 					      h->policy->u.mqtt.topic,  in secstream_mqtt()
439 					      h->policy->u.mqtt.qos, f);  in secstream_mqtt()
497 		h->policy->u.mqtt.will_topic,  in secstream_connect_munge_mqtt()
498 		h->policy->u.mqtt.will_message,  in secstream_connect_munge_mqtt()
499 		h->policy->u.mqtt.subscribe,  in secstream_connect_munge_mqtt()
500 		h->policy->u.mqtt.topic,  in secstream_connect_munge_mqtt()
501 		h->policy->u.mqtt.birth_topic,  in secstream_connect_munge_mqtt()
502 		h->policy->u.mqtt.birth_message  in secstream_connect_munge_mqtt()
575 	ct->ccp.keep_alive		= h->policy->u.mqtt.keep_alive;  in secstream_connect_munge_mqtt()
576 	ct->ccp.clean_start		= (h->policy->u.mqtt.clean_start & 1u);  in secstream_connect_munge_mqtt()
577 	ct->ccp.will_param.qos		= h->policy->u.mqtt.will_qos;  in secstream_connect_munge_mqtt()
578 	ct->ccp.will_param.retain	= h->policy->u.mqtt.will_retain;  in secstream_connect_munge_mqtt()
579 	ct->ccp.birth_param.qos		= h->policy->u.mqtt.birth_qos;  in secstream_connect_munge_mqtt()
580 	ct->ccp.birth_param.retain	= h->policy->u.mqtt.birth_retain;  in secstream_connect_munge_mqtt()
581 	ct->ccp.aws_iot			= h->policy->u.mqtt.aws_iot;  in secstream_connect_munge_mqtt()
582 	h->u.mqtt.topic_qos.qos		= h->policy->u.mqtt.qos;  in secstream_connect_munge_mqtt()