version 1.3.4.4, 2022/09/14 14:32:48
|
version 1.3.4.6, 2022/09/16 04:14:03
|
Line 333 mqtt_strs2subs(const char **csStr, u_short strnum, u_c
|
Line 333 mqtt_strs2subs(const char **csStr, u_short strnum, u_c
|
v[i].sub_topic.msg_len = strlen(csStr[i]); |
v[i].sub_topic.msg_len = strlen(csStr[i]); |
v[i].sub_topic.msg_base = (u_char*) e_strdup(csStr[i]); |
v[i].sub_topic.msg_base = (u_char*) e_strdup(csStr[i]); |
if (qoses && qoses[i] < MQTT_QOS_RESERVED) |
if (qoses && qoses[i] < MQTT_QOS_RESERVED) |
v[i].sub_ret = qoses[i]; | v[i].sub_qos = qoses[i]; |
} |
} |
|
|
return v; |
return v; |
Line 407 mqtt_subRealloc(mqtt_subscr_t ** __restrict subs, u_sh
|
Line 407 mqtt_subRealloc(mqtt_subscr_t ** __restrict subs, u_sh
|
return NULL; |
return NULL; |
|
|
for (i = 0, ss = *subs; ss; i++, ss++); |
for (i = 0, ss = *subs; ss; i++, ss++); |
if (i < num) |
|
return NULL; |
|
if (i == num) |
if (i == num) |
return *subs; |
return *subs; |
|
|
Line 473 mqtt_subCopy(mqtt_subscr_t * __restrict dst, mqtt_subs
|
Line 471 mqtt_subCopy(mqtt_subscr_t * __restrict dst, mqtt_subs
|
dst->sub_value.msg_len = 0; |
dst->sub_value.msg_len = 0; |
} |
} |
|
|
dst->sub_ret = src->sub_ret; | dst->sub_qos = src->sub_qos; |
return dst; |
return dst; |
} |
} |
|
|