Home
last modified time | relevance | path

Searched refs:buf_ctx (Results 1 – 7 of 7) sorted by relevance

/Zephyr-latest/subsys/net/lib/mqtt/
Dmqtt_internal.h128 struct buf_ctx { struct
180 struct buf_ctx *buf);
192 int publish_encode(const struct mqtt_publish_param *param, struct buf_ctx *buf);
205 struct buf_ctx *buf);
218 struct buf_ctx *buf);
231 struct buf_ctx *buf);
244 struct buf_ctx *buf);
255 int disconnect_encode(struct buf_ctx *buf);
268 struct buf_ctx *buf);
281 struct buf_ctx *buf);
[all …]
Dmqtt_decoder.c30 static int unpack_uint8(struct buf_ctx *buf, uint8_t *val) in unpack_uint8()
60 static int unpack_uint16(struct buf_ctx *buf, uint16_t *val) in unpack_uint16()
90 static int unpack_utf8_str(struct buf_ctx *buf, struct mqtt_utf8 *str) in unpack_utf8_str()
133 static int unpack_data(uint32_t length, struct buf_ctx *buf, in unpack_data()
168 static int packet_length_decode(struct buf_ctx *buf, uint32_t *length) in packet_length_decode()
198 int fixed_header_decode(struct buf_ctx *buf, uint8_t *type_and_flags, in fixed_header_decode()
211 int connect_ack_decode(const struct mqtt_client *client, struct buf_ctx *buf, in connect_ack_decode()
240 int publish_decode(uint8_t flags, uint32_t var_length, struct buf_ctx *buf, in publish_decode()
279 int publish_ack_decode(struct buf_ctx *buf, struct mqtt_puback_param *param) in publish_ack_decode()
284 int publish_receive_decode(struct buf_ctx *buf, struct mqtt_pubrec_param *param) in publish_receive_decode()
[all …]
Dmqtt_encoder.c46 static int pack_uint8(uint8_t val, struct buf_ctx *buf) in pack_uint8()
74 static int pack_uint16(uint16_t val, struct buf_ctx *buf) in pack_uint16()
102 static int pack_utf8_str(const struct mqtt_utf8 *str, struct buf_ctx *buf) in pack_utf8_str()
145 static uint8_t packet_length_encode(uint32_t length, struct buf_ctx *buf) in packet_length_encode()
194 struct buf_ctx *buf) in mqtt_encode_fixed_header()
237 static int zero_len_str_encode(struct buf_ctx *buf) in zero_len_str_encode()
254 struct buf_ctx *buf) in mqtt_message_id_only_enc()
277 struct buf_ctx *buf) in connect_request_encode()
398 int publish_encode(const struct mqtt_publish_param *param, struct buf_ctx *buf) in publish_encode()
443 struct buf_ctx *buf) in publish_ack_encode()
[all …]
Dmqtt.c31 static void tx_buf_init(struct mqtt_client *client, struct buf_ctx *buf) in tx_buf_init()
76 struct buf_ctx packet; in client_connect()
243 struct buf_ctx packet; in mqtt_publish()
294 struct buf_ctx packet; in mqtt_publish_qos1_ack()
331 struct buf_ctx packet; in mqtt_publish_qos2_receive()
368 struct buf_ctx packet; in mqtt_publish_qos2_release()
405 struct buf_ctx packet; in mqtt_publish_qos2_complete()
444 struct buf_ctx packet; in mqtt_disconnect()
479 struct buf_ctx packet; in mqtt_subscribe()
517 struct buf_ctx packet; in mqtt_unsubscribe()
[all …]
Dmqtt_rx.c22 struct buf_ctx *buf) in mqtt_handle_packet()
149 struct buf_ctx *buf, uint32_t length) in mqtt_read_message_chunk()
198 struct buf_ctx *buf) in mqtt_read_publish_var_header()
234 struct buf_ctx *buf) in mqtt_read_and_parse_fixed_header()
261 struct buf_ctx buf; in mqtt_handle_rx()
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_packet/src/
Dmqtt_packet.c209 static int eval_buffers(const struct buf_ctx *buf,
437 static ZTEST_DMEM struct buf_ctx publish_corrupted_buf = {
554 static ZTEST_DMEM struct buf_ctx max_pkt_len_buf = {
560 static ZTEST_DMEM struct buf_ctx corrupted_pkt_len_buf = {
688 int eval_buffers(const struct buf_ctx *buf, const uint8_t *expected, uint16_t len) in eval_buffers()
714 struct buf_ctx buf; in eval_msg_connect()
744 struct buf_ctx buf; in eval_msg_disconnect()
769 struct buf_ctx buf; in eval_msg_publish()
824 struct buf_ctx *buf = (struct buf_ctx *)mqtt_test->ctx; in eval_msg_corrupted_publish()
844 struct buf_ctx buf; in eval_msg_subscribe()
[all …]
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/
Dmain.c324 struct buf_ctx buf; in broker_receive()