Searched refs:topiclen (Results 1 – 3 of 3) sorted by relevance
| /third_party/curl/lib/ |
| D | mqtt.c | 383 char **topic, size_t *topiclen) in mqtt_get_topic() argument
387 return Curl_urldecode(data, path + 1, 0, topic, topiclen, in mqtt_get_topic()
397 size_t topiclen; in mqtt_subscribe() local
404 result = mqtt_get_topic(data, &topic, &topiclen); in mqtt_subscribe()
410 packetlen = topiclen + 5; /* packetid + topic (has a two byte length field) in mqtt_subscribe()
425 packet[3 + n] = (topiclen >> 8) & 0xff; in mqtt_subscribe()
426 packet[4 + n ] = topiclen & 0xff; in mqtt_subscribe()
427 memcpy(&packet[5 + n], topic, topiclen); in mqtt_subscribe()
428 packet[5 + n + topiclen] = 0; /* QoS zero */ in mqtt_subscribe()
478 size_t topiclen; in mqtt_publish() local
[all …]
|
| /third_party/curl/tests/server/ |
| 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()
671 size_t topiclen; in mqttit() local
677 topiclen = (buffer[1 + bytes] << 8) | buffer[2 + bytes]; in mqttit()
678 logmsg("Got %d bytes topic", topiclen); in mqttit()
|
| /third_party/libwebsockets/lib/roles/mqtt/ |
| D | mqtt.c | 349 lws_mqtt_validate_topic(const char *topic, size_t topiclen, uint8_t awsiot) in lws_mqtt_validate_topic() argument
357 if (topiclen > LWS_MQTT_MAX_AWSIOT_TOPICLEN) in lws_mqtt_validate_topic()
364 if (topiclen > LWS_MQTT_MAX_TOPICLEN) in lws_mqtt_validate_topic()
408 size_t topiclen = strlen(topic); in lws_mqtt_create_sub() local
411 flag = lws_mqtt_validate_topic(topic, topiclen, mqtt->client.aws_iot); in lws_mqtt_create_sub()
426 mysub = lws_malloc(sizeof(*mysub) + topiclen + 1, "sub"); in lws_mqtt_create_sub()
|