283 	if (wsi->mqtt && wsi->mqtt->send_pingreq && !wsi->mqtt->inside_payload) {  in rops_handle_POLLOUT_mqtt()
291 		wsi->mqtt->send_pingreq = 0;  in rops_handle_POLLOUT_mqtt()
305 	if (wsi->mqtt && !wsi->mqtt->inside_payload &&  in rops_handle_POLLOUT_mqtt()
306 	    (wsi->mqtt->send_pubrec || wsi->mqtt->send_pubrel ||  in rops_handle_POLLOUT_mqtt()
307 	     wsi->mqtt->send_pubcomp)) {  in rops_handle_POLLOUT_mqtt()
311 		if (wsi->mqtt->send_pubrec) {  in rops_handle_POLLOUT_mqtt()
313 				    __func__, wsi->mqtt->peer_ack_pkt_id);  in rops_handle_POLLOUT_mqtt()
317 				       wsi->mqtt->peer_ack_pkt_id);  in rops_handle_POLLOUT_mqtt()
318 			wsi->mqtt->send_pubrec = 0;  in rops_handle_POLLOUT_mqtt()
319 		} else if (wsi->mqtt->send_pubrel) {  in rops_handle_POLLOUT_mqtt()
321 				    __func__, wsi->mqtt->ack_pkt_id);  in rops_handle_POLLOUT_mqtt()
324 				       wsi->mqtt->ack_pkt_id);  in rops_handle_POLLOUT_mqtt()
325 			wsi->mqtt->send_pubrel = 0;  in rops_handle_POLLOUT_mqtt()
328 				    __func__, wsi->mqtt->peer_ack_pkt_id);  in rops_handle_POLLOUT_mqtt()
331 				       wsi->mqtt->peer_ack_pkt_id);  in rops_handle_POLLOUT_mqtt()
332 			wsi->mqtt->send_pubcomp = 0;  in rops_handle_POLLOUT_mqtt()
350 	if (!wsi->mqtt)  in rops_handle_POLLOUT_mqtt()
370 		if (wsi->mqtt->inside_payload && !(*wsi2)->mqtt->inside_payload)  in rops_handle_POLLOUT_mqtt()
387 		    !wsi->mqtt->inside_payload &&  in rops_handle_POLLOUT_mqtt()
388 		    wsi->mqtt->send_puback) {  in rops_handle_POLLOUT_mqtt()
391 				    __func__, wsi->mqtt->ack_pkt_id);  in rops_handle_POLLOUT_mqtt()
398 			lws_ser_wu16be(&buf[LWS_PRE + 2], wsi->mqtt->peer_ack_pkt_id);  in rops_handle_POLLOUT_mqtt()
404 			wsi->mqtt->send_puback = 0;  in rops_handle_POLLOUT_mqtt()
442 	nwsi->mqtt->send_pingreq = 1;  in rops_issue_keepalive_mqtt()
456 	if (!wsi->mqtt)  in rops_close_role_mqtt()
459 	c = &wsi->mqtt->client;  in rops_close_role_mqtt()
461 	lws_sul_cancel(&wsi->mqtt->sul_qos_puback_pubrec_wait);  in rops_close_role_mqtt()
471 	s = wsi->mqtt->subs_head;  in rops_close_role_mqtt()
472 	wsi->mqtt->subs_head = NULL;  in rops_close_role_mqtt()
478 		mysub = lws_mqtt_find_sub(nwsi->mqtt, (const char *)&s[1]);  in rops_close_role_mqtt()
490 				wsi->mqtt->rx_cpkt_param;  in rops_close_role_mqtt()
495 	lws_free_set_NULL(wsi->mqtt->rx_cpkt_param);  in rops_close_role_mqtt()
497 	lws_free_set_NULL(wsi->mqtt);  in rops_close_role_mqtt()