Lines Matching refs:topic
43 * - Fix restriction of a single topic in each (UN)SUBSCRIBE message (protocol has support for multiple topics)
717 /* Should have topic and pkt id*/
718 u8_t *topic;
731 LWIP_DEBUGF(MQTT_DEBUG_WARN,( "mqtt_message_received: Received short PUBLISH packet (topic)\n"));
735 topic = var_hdr_payload + 2;
739 LWIP_DEBUGF(MQTT_DEBUG_WARN, ("mqtt_message_received: Receive buffer can not fit topic + pkt_id\n"));
754 /* Take backup of byte after topic */
755 bkp = topic[topic_len];
757 topic[topic_len] = 0;
762 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_incomming_publish: Received message with QoS %d at topic: %s, payload length %"U32_F"\n",
763 qos, topic, remaining_length + payload_length));
765 client->pub_cb(client->inpub_arg, (const char *)topic, remaining_length + payload_length);
767 /* Restore byte after topic */
768 topic[topic_len] = bkp;
1084 * @param topic Publish topic string
1096 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
1108 LWIP_ASSERT("mqtt_publish: topic != NULL", topic);
1111 topic_strlen = strlen(topic);
1112 LWIP_ERROR("mqtt_publish: topic length overflow", (topic_strlen <= (0xFFFF - 2)), return ERR_ARG);
1127 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_publish: Publish with payload length %d to topic \"%s\"\n", payload_length, topic));
1142 mqtt_output_append_string(&client->output, topic, topic_len);
1164 * @param topic topic to subscribe to
1172 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub)
1183 LWIP_ASSERT("mqtt_sub_unsub: topic != NULL", topic);
1185 topic_strlen = strlen(topic);
1186 LWIP_ERROR("mqtt_sub_unsub: topic length overflow", (topic_strlen <= (0xFFFF - 2)), return ERR_ARG);
1210 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_sub_unsub: Client (un)subscribe to topic \"%s\", id: %d\n", topic, pkt_id));
1216 mqtt_output_append_string(&client->output, topic, topic_len);
1232 * @param pub_cb Callback invoked when publish starts, contain topic and total length of payload