Home
last modified time | relevance | path

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

12

/Zephyr-latest/subsys/net/lib/mqtt_sn/
Dmqtt_sn.c33 struct mqtt_sn_topic *topic; member
215 struct mqtt_sn_topic *topic) in mqtt_sn_publish_find_topic() argument
220 if (pub->topic == topic) { in mqtt_sn_publish_find_topic()
230 struct mqtt_sn_topic *topic; in mqtt_sn_topic_create() local
232 if (k_mem_slab_alloc(&topics, (void **)&topic, K_NO_WAIT)) { in mqtt_sn_topic_create()
237 memset(topic, 0, sizeof(*topic)); in mqtt_sn_topic_create()
244 if (name->size > sizeof(topic->name)) { in mqtt_sn_topic_create()
249 memcpy(topic->name, name->data, name->size); in mqtt_sn_topic_create()
250 topic->namelen = name->size; in mqtt_sn_topic_create()
252 mqtt_sn_con_init(&topic->con); in mqtt_sn_topic_create()
[all …]
Dmqtt_sn_encoder.c139 size_t msgsz = 1 + params->topic.size; in mqtt_sn_encode_msg_willtopic()
150 net_buf_simple_add_data(buf, &params->topic); in mqtt_sn_encode_msg_willtopic()
174 size_t msgsz = 4 + params->topic.size; in mqtt_sn_encode_msg_register()
185 net_buf_simple_add_data(buf, &params->topic); in mqtt_sn_encode_msg_register()
314 msgsz += params->topic.topic_name.size; in mqtt_sn_encode_msg_subscribe()
328 net_buf_simple_add_data(buf, &params->topic.topic_name); in mqtt_sn_encode_msg_subscribe()
330 net_buf_simple_add_be16(buf, params->topic.topic_id); in mqtt_sn_encode_msg_subscribe()
344 msgsz += params->topic.topic_name.size; in mqtt_sn_encode_msg_unsubscribe()
359 net_buf_simple_add_data(buf, &params->topic.topic_name); in mqtt_sn_encode_msg_unsubscribe()
361 net_buf_simple_add_be16(buf, params->topic.topic_id); in mqtt_sn_encode_msg_unsubscribe()
[all …]
Dmqtt_sn_msg.h93 struct mqtt_sn_data topic; member
103 struct mqtt_sn_data topic; member
148 } topic; member
164 } topic; member
182 struct mqtt_sn_data topic; member
/Zephyr-latest/samples/net/secure_mqtt_sensor_actuator/src/
Dmqtt_client.c139 evt->param.publish.message.topic.topic.utf8, payload); in on_mqtt_publish()
142 if (strcmp(evt->param.publish.message.topic.topic.utf8, in on_mqtt_publish()
228 if (p->message.topic.qos == MQTT_QOS_1_AT_LEAST_ONCE) { in mqtt_event_handler()
233 } else if (p->message.topic.qos == MQTT_QOS_2_EXACTLY_ONCE) { in mqtt_event_handler()
297 struct mqtt_topic topic = { in app_mqtt_publish() local
298 .topic = { in app_mqtt_publish()
300 .size = strlen(topic.topic.utf8) in app_mqtt_publish()
311 param.message.topic = topic; in app_mqtt_publish()
323 param.message.topic.topic.utf8, in app_mqtt_publish()
324 param.message.topic.qos); in app_mqtt_publish()
[all …]
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_packet/
DREADME52 [PASS] 12 - SUBSCRIBE, one topic, qos = 0
53 [PASS] 13 - SUBSCRIBE, one topic, qos = 1
54 [PASS] 14 - SUBSCRIBE, one topic, qos = 2
55 [PASS] 15 - SUBACK, one topic, qos = 0
56 [PASS] 16 - SUBACK, one topic, qos = 1
57 [PASS] 17 - SUBACK, one topic, qos = 2
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/
Dmain.c478 if (evt->param.publish.message.topic.qos == MQTT_QOS_1_AT_LEAST_ONCE) { in mqtt_evt_handler()
487 if (evt->param.publish.message.topic.qos == MQTT_QOS_2_EXACTLY_ONCE) { in mqtt_evt_handler()
614 param.message.topic.qos = qos; in test_publish()
615 param.message.topic.topic.utf8 = (uint8_t *)get_mqtt_topic(); in test_publish()
616 param.message.topic.topic.size = in test_publish()
617 strlen(param.message.topic.topic.utf8); in test_publish()
644 struct mqtt_topic topic; in test_subscribe() local
651 topic.topic.utf8 = get_mqtt_topic(); in test_subscribe()
652 topic.topic.size = strlen(topic.topic.utf8); in test_subscribe()
653 topic.qos = MQTT_QOS_2_EXACTLY_ONCE; in test_subscribe()
[all …]
/Zephyr-latest/samples/net/cloud/aws_iot_mqtt/src/
Dmain.c100 .topic = {.utf8 = CONFIG_AWS_SUBSCRIBE_TOPIC, in subscribe_topic()
120 static int publish_message(const char *topic, size_t topic_len, uint8_t *payload, in publish_message() argument
130 msg.message.topic.topic.utf8 = topic; in publish_message()
131 msg.message.topic.topic.size = topic_len; in publish_message()
132 msg.message.topic.qos = CONFIG_AWS_QOS; in publish_message()
142 LOG_INF("PUBLISHED on topic \"%s\" [ id: %u qos: %u ], payload: %u B", topic, in publish_message()
143 msg.message_id, msg.message.topic.qos, payload_len); in publish_message()
157 (const char *)pub->message.topic.topic.utf8, pub->message_id, in handle_published_message()
158 pub->message.topic.qos, message_size, APP_BUFFER_SIZE); in handle_published_message()
176 switch (pub->message.topic.qos) { in handle_published_message()
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_packet/src/
Dmqtt_packet.c27 .topic = TOPIC,
31 .topic = TOPIC,
35 .topic = TOPIC,
39 .topic = WILL_TOPIC,
43 .topic = WILL_TOPIC,
372 .message.topic.qos = 0,
373 .message.topic.topic = TOPIC,
391 .message.topic.qos = 0,
392 .message.topic.topic = TOPIC,
410 .message.topic.qos = 1,
[all …]
/Zephyr-latest/subsys/net/lib/mqtt/
Dmqtt_decoder.c248 param->message.topic.qos = ((flags & MQTT_HEADER_QOS_MASK) >> 1); in publish_decode()
250 err_code = unpack_utf8_str(buf, &param->message.topic.topic); in publish_decode()
255 var_header_length = param->message.topic.topic.size + sizeof(uint16_t); in publish_decode()
257 if (param->message.topic.qos > MQTT_QOS_0_AT_MOST_ONCE) { in publish_decode()
Dmqtt_encoder.c341 NET_HEXDUMP_DBG(client->will_topic->topic.utf8, in connect_request_encode()
342 client->will_topic->topic.size, in connect_request_encode()
344 err_code = pack_utf8_str(&client->will_topic->topic, buf); in connect_request_encode()
402 param->message.topic.qos, param->retain_flag); in publish_encode()
407 if ((param->message.topic.qos) && (param->message_id == 0U)) { in publish_encode()
415 err_code = pack_utf8_str(&param->message.topic.topic, buf); in publish_encode()
420 if (param->message.topic.qos) { in publish_encode()
516 err_code = pack_utf8_str(&param->list[i].topic, buf); in subscribe_encode()
548 err_code = pack_utf8_str(&param->list[i].topic, buf); in unsubscribe_encode()
Dmqtt_rx.c68 evt.param.publish.message.topic.qos, in mqtt_handle_packet()
70 evt.param.publish.message.topic.topic.size); in mqtt_handle_packet()
/Zephyr-latest/samples/net/cloud/aws_iot_mqtt/
DREADME.rst16 - Subscribing to a topic on AWS IoT Core
52 - :kconfig:option:`CONFIG_AWS_SUBSCRIBE_TOPIC`: The topic to subscribe to.
53 - :kconfig:option:`CONFIG_AWS_PUBLISH_TOPIC`: The topic to publish to.
70 ``zephyr_sample/data`` topic, and publish a payload to the ``zephyr_sample/downlink``
71 topic. The device console will display the payload received by your device, and
73 ``zephyr_sample/data`` topic.
87 [00:00:03.327,000] <inf> aws: Subscribing to 1 topic(s)
89 …[00:00:03.390,000] <inf> aws: PUBLISHED on topic "zephyr_sample/data" [ id: 1 qos: 0 ], payload: 1…
93 …[00:00:11.856,000] <inf> aws: RECEIVED on topic "zephyr_sample/downlink" [ id: 13 qos: 0 ] payload…
98 …[00:00:11.857,000] <inf> aws: PUBLISHED on topic "zephyr_sample/data" [ id: 2 qos: 0 ], payload: 1…
DKconfig30 string "MQTT subscribe topic"
33 MQTT topic the client should subscribe to.
36 string "MQTT publish topic"
39 MQTT topic the client should publish to.
/Zephyr-latest/samples/net/cloud/mqtt_azure/src/
Dmain.c246 evt->param.publish.message.topic.qos); in mqtt_event_handler()
278 subs_topic.topic.utf8 = devbound_topic; in subscribe()
279 subs_topic.topic.size = strlen(devbound_topic); in subscribe()
297 param.message.topic.qos = qos; in publish()
298 param.message.topic.topic.utf8 = (uint8_t *)evt_topic; in publish()
299 param.message.topic.topic.size = len; in publish()
/Zephyr-latest/subsys/shell/backends/
Dshell_mqtt.c301 struct mqtt_topic subs_topic = { .topic = { .utf8 = sh_mqtt->sub_topic, in sh_mqtt_subscribe_handler()
574 LOG_DBG(" id: %d, qos: %d", pub->message_id, pub->message.topic.qos); in mqtt_evt_handler()
575 LOG_DBG(" item: %s", pub->message.topic.topic.utf8); in mqtt_evt_handler()
578 if (pub->message.topic.qos == MQTT_QOS_1_AT_LEAST_ONCE) { in mqtt_evt_handler()
670 sh_mqtt->pub_data.message.topic.qos = MQTT_QOS_0_AT_MOST_ONCE; in init()
671 sh_mqtt->pub_data.message.topic.topic.utf8 = (uint8_t *)sh_mqtt->pub_topic; in init()
672 sh_mqtt->pub_data.message.topic.topic.size = in init()
673 strlen(sh_mqtt->pub_data.message.topic.topic.utf8); in init()
/Zephyr-latest/samples/net/mqtt_publisher/src/
Dmain.c247 param.message.topic.qos = qos; in publish()
248 param.message.topic.topic.utf8 = (uint8_t *)get_mqtt_topic(); in publish()
249 param.message.topic.topic.size = in publish()
250 strlen(param.message.topic.topic.utf8); in publish()
/Zephyr-latest/tests/net/lib/mqtt_sn_packet/src/
Dmqtt_sn_packet.c160 .topic = {
361 .topic = MQTT_SN_DATA_STRING_LITERAL("/zephyr")
385 .topic = MQTT_SN_DATA_STRING_LITERAL("/zephyr")
463 .topic.topic_name = MQTT_SN_DATA_STRING_LITERAL("/zephyr")
474 .topic.topic_id = 0x1234
509 .topic = MQTT_SN_DATA_STRING_LITERAL("/zephyr")
/Zephyr-latest/samples/net/secure_mqtt_sensor_actuator/
DKconfig20 string "The MQTT topic the application should publish data to"
24 string "The MQTT topic the application will receive commands on"
DREADME.rst19 - Subscribing to user-defined topic(s) on MQTT broker
171 - The application will subscribe to a topic determined by ``CONFIG_NET_SAMPLE_MQTT_SUB_TOPIC_CMD``.
172 If a supported command string is received by the board on this topic, the board will execute
207 [00:00:01.198,000] <inf> app_mqtt: Subscribing to 1 topic(s)
209 [00:00:04.200,000] <inf> app_mqtt: Published to topic 'zephyr_sample/sensor', QoS 1
211 [00:00:07.202,000] <inf> app_mqtt: Published to topic 'zephyr_sample/sensor', QoS 1
213 [00:00:10.204,000] <inf> app_mqtt: Published to topic 'zephyr_sample/sensor', QoS 1
216 [00:00:12.769,000] <inf> app_mqtt: topic: 'zephyr_sample/command', payload: led_on
/Zephyr-latest/boards/shields/nrf7002eb/doc/
Dindex.rst70 - `nRF7002 EB product specification <https://infocenter.nordicsemi.com/topic/ug_nrf7002_eb/UG/nrf70…
71 - `nRF7002 product specification <https://infocenter.nordicsemi.com/index.jsp?topic=%2Fstruct_nrf70…
72 - `nRF7002 Co-existence <https://infocenter.nordicsemi.com/index.jsp?topic=%2Fps_nrf7002%2Fchapters…
/Zephyr-latest/samples/net/mqtt_sn_publisher/
DREADME.rst22 It also SUBSCRIBEs to a topic.
115 [00:00:10.200,000] <inf> net_mqtt_sn: Registering topic
117 [00:00:10.200,000] <inf> net_mqtt_sn: Can't publish; topic is not ready
120 [00:00:10.710,000] <inf> net_mqtt_sn: Publishing to topic ID 14
122 [00:00:20.400,000] <inf> net_mqtt_sn: Publishing to topic ID 14
/Zephyr-latest/include/zephyr/net/
Dmqtt.h180 struct mqtt_utf8 topic; member
190 struct mqtt_topic topic; /**< Topic on which data was published. */ member
/Zephyr-latest/boards/shields/npm1100_ek/doc/
Dindex.rst42 - `nPM1100 EK Manual <https://infocenter.nordicsemi.com/topic/ug_npm1100_ek/UG/nPM1100_EK/intro.htm…
/Zephyr-latest/boards/shields/npm6001_ek/doc/
Dindex.rst37 - `nPM6001 EK Manual <https://infocenter.nordicsemi.com/topic/ug_npm6001_ek/UG/nPM6001_EK/intro.htm…
/Zephyr-latest/boards/shields/nrf7002ek/doc/
Dindex.rst74 - `nRF7002 product specification <https://infocenter.nordicsemi.com/index.jsp?topic=%2Fstruct_nrf70…
75 - `nRF7002 EK Co-existence <https://infocenter.nordicsemi.com/index.jsp?topic=%2Fps_nrf7002%2Fchapt…

12