Home
last modified time | relevance | path

Searched refs:topic (Results 1 – 6 of 6) sorted by relevance

/curl/lib/
H A Dmqtt.c419 char **topic, size_t *topiclen) in mqtt_get_topic() argument
424 result = Curl_urldecode(path + 1, 0, topic, topiclen, REJECT_NADA); in mqtt_get_topic()
439 char *topic = NULL; in mqtt_subscribe() local
447 result = mqtt_get_topic(data, &topic, &topiclen); in mqtt_subscribe()
470 memcpy(&packet[5 + n], topic, topiclen); in mqtt_subscribe()
476 free(topic); in mqtt_subscribe()
518 char *topic = NULL; in mqtt_publish() local
536 result = mqtt_get_topic(data, &topic, &topiclen); in mqtt_publish()
556 memcpy(&pkt[i], topic, topiclen); in mqtt_publish()
564 free(topic); in mqtt_publish()
/curl/tests/server/
H A Dmqttd.c392 char *topic, char *payload, size_t payloadlen) in publish() argument
394 size_t topiclen = strlen(topic); in publish()
429 memcpy(&packet[3 + encodedlen], topic, topiclen); in publish()
453 static char topic[MAX_TOPIC_LENGTH + 1]; variable
641 memcpy(topic, &buffer[4], topic_len); in mqttit()
642 topic[topic_len] = 0; in mqttit()
646 logmsg("SUBSCRIBE to '%s' [%d]", topic, packet_id); in mqttit()
657 if(publish(dump, fd, packet_id, topic, data, datalen)) { in mqttit()
672 publish(dump, fd, packet_id, topic, def, strlen(def)); in mqttit()
/curl/tests/data/
H A Dtest119930 MQTT PUBLISH empty payload, no topic
H A Dtest119830 MQTT PUBLISH empty payload, single space topic
H A Dtest119230 MQTT SUBSCRIBE 2k topic
/curl/.github/
H A Dlabeler.yml13 # PR is all about that one topic, like HTTP/3), while the second ones are

Completed in 13 milliseconds