Lines Matching refs:mysub
407 lws_mqtt_subs_t *mysub; in lws_mqtt_create_sub() local
426 mysub = lws_malloc(sizeof(*mysub) + topiclen + 1, "sub"); in lws_mqtt_create_sub()
427 if (!mysub) { in lws_mqtt_create_sub()
432 mysub->wildcard = (flag == LMVTR_VALID_WILDCARD); in lws_mqtt_create_sub()
433 mysub->shadow = (flag == LMVTR_VALID_SHADOW); in lws_mqtt_create_sub()
442 mysub->next = mqtt->subs_head; in lws_mqtt_create_sub()
443 mqtt->subs_head = mysub; in lws_mqtt_create_sub()
444 memcpy(mysub->topic, topic, strlen(topic) + 1); in lws_mqtt_create_sub()
445 mysub->ref_count = 1; in lws_mqtt_create_sub()
448 __func__, mysub, mqtt); in lws_mqtt_create_sub()
450 return mysub; in lws_mqtt_create_sub()
2105 lws_mqtt_subs_t *mysub; in lws_mqtt_client_send_subcribe() local
2140 mysub = lws_mqtt_find_sub(nwsi->mqtt, sub->topic[n].name); in lws_mqtt_client_send_subcribe()
2141 if (mysub && mysub->ref_count) { in lws_mqtt_client_send_subcribe()
2142 mysub->ref_count++; /* another stream using it */ in lws_mqtt_client_send_subcribe()
2290 lws_mqtt_subs_t *mysub; in lws_mqtt_client_send_unsubcribe() local
2302 mysub = lws_mqtt_find_sub(nwsi->mqtt, in lws_mqtt_client_send_unsubcribe()
2304 assert(mysub); in lws_mqtt_client_send_unsubcribe()
2306 if (mysub && --mysub->ref_count == 0) { in lws_mqtt_client_send_unsubcribe()