Searched refs:topic (Results 1 – 6 of 6) sorted by relevance
| /curl/lib/ |
| H A D | mqtt.c | 419 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 D | mqttd.c | 390 char *topic, char *payload, size_t payloadlen) in publish() argument
392 size_t topiclen = strlen(topic); in publish()
427 memcpy(&packet[3 + encodedlen], topic, topiclen); in publish()
451 static char topic[MAX_TOPIC_LENGTH + 1]; variable
639 memcpy(topic, &buffer[4], topic_len); in mqttit()
640 topic[topic_len] = 0; in mqttit()
644 logmsg("SUBSCRIBE to '%s' [%d]", topic, packet_id); in mqttit()
655 if(publish(dump, fd, packet_id, topic, data, datalen)) { in mqttit()
670 publish(dump, fd, packet_id, topic, def, strlen(def)); in mqttit()
|
| /curl/tests/data/ |
| H A D | test1199 | 30 MQTT PUBLISH empty payload, no topic
|
| H A D | test1198 | 30 MQTT PUBLISH empty payload, single space topic
|
| H A D | test1192 | 30 MQTT SUBSCRIBE 2k topic
|
| /curl/.github/ |
| H A D | labeler.yml | 13 # PR is all about that one topic, like HTTP/3), while the second ones are
|
Completed in 15 milliseconds
