Home
last modified time | relevance | path

Searched refs:topiclen (Results 1 – 2 of 2) sorted by relevance

/curl/lib/
H A Dmqtt.c425 if(!result && (*topiclen > 0xffff)) { in mqtt_get_topic()
440 size_t topiclen; in mqtt_subscribe() local
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] = 0; /* QoS zero */ in mqtt_subscribe()
519 size_t topiclen; in mqtt_publish() local
554 pkt[i++] = (topiclen >> 8) & 0xff; in mqtt_publish()
555 pkt[i++] = (topiclen & 0xff); in mqtt_publish()
556 memcpy(&pkt[i], topic, topiclen); in mqtt_publish()
[all …]
/curl/tests/server/
H A Dmqttd.c394 size_t topiclen = strlen(topic); in publish() local
397 size_t remaininglength = topiclen + 2 + payloadlen; in publish()
427 packet[1 + encodedlen] = (unsigned char)(topiclen >> 8); in publish()
428 packet[2 + encodedlen] = (unsigned char)(topiclen & 0xff); in publish()
429 memcpy(&packet[3 + encodedlen], topic, topiclen); in publish()
431 payloadindex = 3 + topiclen + encodedlen; in publish()
677 size_t topiclen; in mqttit() local
683 topiclen = (size_t)(buffer[1 + bytes] << 8) | buffer[2 + bytes]; in mqttit()
684 logmsg("Got %zu bytes topic", topiclen); in mqttit()

Completed in 8 milliseconds