300 	lws_mqtt_subs_t *mysub;  in lws_mqtt_create_sub()  local
302 	mysub = lws_malloc(sizeof(*mysub) + strlen(topic) + 1, "sub");  in lws_mqtt_create_sub()
303 	if (!mysub)  in lws_mqtt_create_sub()
306 	mysub->next = mqtt->subs_head;  in lws_mqtt_create_sub()
307 	mqtt->subs_head = mysub;  in lws_mqtt_create_sub()
308 	memcpy(mysub->topic, topic, strlen(topic) + 1);  in lws_mqtt_create_sub()
309 	mysub->ref_count = 1;  in lws_mqtt_create_sub()
312 		  __func__, mysub, mqtt);  in lws_mqtt_create_sub()
314 	return mysub;  in lws_mqtt_create_sub()
1762 	lws_mqtt_subs_t *mysub;  in lws_mqtt_client_send_subcribe()  local
1797 			mysub = lws_mqtt_find_sub(nwsi->mqtt, sub->topic[n].name);  in lws_mqtt_client_send_subcribe()
1798 			if (mysub && mysub->ref_count) {  in lws_mqtt_client_send_subcribe()
1799 				mysub->ref_count++; /* another stream using it */  in lws_mqtt_client_send_subcribe()
1944 	lws_mqtt_subs_t *mysub;  in lws_mqtt_client_send_unsubcribe()  local
1956 			mysub = lws_mqtt_find_sub(nwsi->mqtt,  in lws_mqtt_client_send_unsubcribe()
1958 			assert(mysub);  in lws_mqtt_client_send_unsubcribe()
1960 			if (--mysub->ref_count == 0) {  in lws_mqtt_client_send_unsubcribe()