Searched refs:topiclen (Results 1 - 3 of 3) sorted by relevance
| /third_party/curl/lib/ |
| H A D | mqtt.c | 419 char **topic, size_t *topiclen) in mqtt_get_topic()
424 result = Curl_urldecode(path + 1, 0, topic, topiclen, REJECT_NADA); in mqtt_get_topic()
425 if(!result && (*topiclen > 0xffff)) { in mqtt_get_topic()
440 size_t topiclen; in mqtt_subscribe() local
447 result = mqtt_get_topic(data, &topic, &topiclen); in mqtt_subscribe()
453 packetlen = topiclen + 5; /* packetid + topic (has a two byte length field) in mqtt_subscribe()
468 packet[3 + n] = (topiclen >> 8) & 0xff; in mqtt_subscribe()
469 packet[4 + n ] = topiclen & 0xff; in mqtt_subscribe()
470 memcpy(&packet[5 + n], topic, topiclen); in mqtt_subscribe()
471 packet[5 + n + topiclen] in mqtt_subscribe()
418 mqtt_get_topic(struct Curl_easy *data, char **topic, size_t *topiclen) mqtt_get_topic() argument
519 size_t topiclen; mqtt_publish() local
[all...] |
| /third_party/curl/tests/server/ |
| H A D | mqttd.c | 396 size_t topiclen = strlen(topic); in publish() local
399 ssize_t remaininglength = topiclen + 2 + payloadlen; in publish()
429 packet[1 + encodedlen] = (unsigned char)(topiclen >> 8); in publish()
430 packet[2 + encodedlen] = (unsigned char)(topiclen & 0xff); in publish()
431 memcpy(&packet[3 + encodedlen], topic, topiclen); in publish()
433 payloadindex = 3 + topiclen + encodedlen; in publish()
675 size_t topiclen; in mqttit() local
681 topiclen = (size_t)(buffer[1 + bytes] << 8) | buffer[2 + bytes]; in mqttit()
682 logmsg("Got %zu bytes topic", topiclen); in mqttit()
683 /* TODO: verify topiclen */ in mqttit()
[all...] |
| /third_party/libwebsockets/lib/roles/mqtt/ |
| H A D | mqtt.c | 274 lws_mqtt_validate_topic(const char *topic, size_t topiclen, uint8_t awsiot) in lws_mqtt_validate_topic() argument
282 if (topiclen > LWS_MQTT_MAX_AWSIOT_TOPICLEN) in lws_mqtt_validate_topic()
289 if (topiclen > LWS_MQTT_MAX_TOPICLEN) in lws_mqtt_validate_topic()
333 size_t topiclen = strlen(topic); in lws_mqtt_create_sub() local
336 flag = lws_mqtt_validate_topic(topic, topiclen, mqtt->client.aws_iot); in lws_mqtt_create_sub()
351 mysub = lws_malloc(sizeof(*mysub) + topiclen + 1, "sub"); in lws_mqtt_create_sub()
|
Completed in 5 milliseconds