Lines Matching refs:mysub
332 lws_mqtt_subs_t *mysub;
351 mysub = lws_malloc(sizeof(*mysub) + topiclen + 1, "sub");
352 if (!mysub) {
353 lwsl_err("%s: Error allocating mysub\n",
357 mysub->wildcard = (flag == LMVTR_VALID_WILDCARD);
358 mysub->shadow = (flag == LMVTR_VALID_SHADOW);
367 mysub->next = mqtt->subs_head;
368 mqtt->subs_head = mysub;
369 memcpy(mysub->topic, topic, strlen(topic) + 1);
370 mysub->ref_count = 1;
372 lwsl_info("%s: Created mysub %p for wsi->mqtt %p\n",
373 __func__, mysub, mqtt);
375 return mysub;
2127 lws_mqtt_subs_t *mysub;
2162 mysub = lws_mqtt_find_sub(nwsi->mqtt, sub->topic[n].name);
2163 if (mysub && mysub->ref_count) {
2164 mysub->ref_count++; /* another stream using it */
2314 lws_mqtt_subs_t *mysub;
2326 mysub = lws_mqtt_find_sub(nwsi->mqtt,
2328 assert(mysub);
2330 if (mysub && --mysub->ref_count == 0) {