| /Zephyr-latest/subsys/net/lib/mqtt/ |
| D | mqtt_encoder.c | 193 static uint32_t mqtt_encode_fixed_header(uint8_t message_type, uint8_t *start, in mqtt_encode_fixed_header() argument
203 NET_DBG("<< msg type:0x%02x length:0x%08x", message_type, length); in mqtt_encode_fixed_header()
213 (void)pack_uint8(message_type, buf); in mqtt_encode_fixed_header()
253 static int mqtt_message_id_only_enc(uint8_t message_type, uint16_t message_id, in mqtt_message_id_only_enc() argument
273 return mqtt_encode_fixed_header(message_type, start, buf); in mqtt_message_id_only_enc()
280 const uint8_t message_type = in connect_request_encode() local
395 return mqtt_encode_fixed_header(message_type, start, buf); in connect_request_encode()
400 const uint8_t message_type = MQTT_MESSAGES_OPTIONS( in publish_encode() local
432 err_code = mqtt_encode_fixed_header(message_type, start, buf); in publish_encode()
445 const uint8_t message_type = in publish_ack_encode() local
[all …]
|
| D | mqtt_transport_websocket.c | 144 uint32_t message_type = 0U; in mqtt_client_websocket_read() local
152 data, buflen, &message_type, NULL, timeout); in mqtt_client_websocket_read()
153 if (ret >= 0 && message_type > 0) { in mqtt_client_websocket_read()
154 if (message_type & WEBSOCKET_FLAG_CLOSE) { in mqtt_client_websocket_read()
158 if ((ret == 0) || !(message_type & WEBSOCKET_FLAG_BINARY)) { in mqtt_client_websocket_read()
|
| /Zephyr-latest/subsys/net/lib/websocket/ |
| D | websocket_internal.h | 103 uint32_t message_type; member
|
| D | websocket.c | 798 ctx->message_type = websocket_opcode2flag(data); in websocket_parse()
800 ctx->message_type |= WEBSOCKET_FLAG_FINAL; in websocket_parse()
863 ctx->masked ? ctx->masking_value : 0, ctx->message_type, in websocket_parse()
938 uint32_t *message_type, uint64_t *remaining, int32_t timeout) in websocket_recv_msg() argument
1034 if (message_type != NULL) { in websocket_recv_msg()
1035 *message_type = ctx->message_type; in websocket_recv_msg()
1091 uint32_t message_type; in websocket_recv() local
1100 ret = websocket_recv_msg(ctx->sock, buf, buf_len, &message_type, in websocket_recv()
|
| /Zephyr-latest/include/zephyr/net/ |
| D | websocket.h | 178 uint32_t *message_type, uint64_t *remaining,
|
| D | gptp.h | 149 uint8_t message_type:4; member
|
| /Zephyr-latest/subsys/net/l2/ethernet/gptp/ |
| D | gptp_messages.c | 31 if (one_hdr->message_type == GPTP_ANNOUNCE_MESSAGE) { \
98 if (hdr->message_type == GPTP_SYNC_MESSAGE) { in gptp_sync_timestamp_callback()
124 if (hdr->message_type == GPTP_PATH_DELAY_RESP_MESSAGE) { in gptp_pdelay_response_timestamp_callback()
215 hdr->message_type = GPTP_SYNC_MESSAGE; in gptp_prepare_sync()
270 hdr->message_type = GPTP_FOLLOWUP_MESSAGE; in gptp_prepare_follow_up()
316 hdr->message_type = GPTP_PATH_DELAY_REQ_MESSAGE; in gptp_prepare_pdelay_req()
374 hdr->message_type = GPTP_PATH_DELAY_RESP_MESSAGE; in gptp_prepare_pdelay_resp()
437 hdr->message_type = GPTP_PATH_DELAY_FOLLOWUP_MESSAGE; in gptp_prepare_pdelay_follow_up()
500 hdr->message_type = GPTP_ANNOUNCE_MESSAGE; in gptp_prepare_announce()
|
| D | gptp.c | 96 switch (hdr->message_type) { in gptp_handle_critical_msg()
148 switch (hdr->message_type) { in gptp_handle_msg()
317 NET_DBG("Received unknown message %x", hdr->message_type); in gptp_handle_msg()
|
| /Zephyr-latest/drivers/wifi/winc1500/ |
| D | wifi_winc1500.c | 227 static char *wifi_cb_msg_2_str(uint8_t message_type) in wifi_cb_msg_2_str() argument
229 switch (message_type) { in wifi_cb_msg_2_str()
755 static void winc1500_wifi_cb(uint8_t message_type, void *pvMsg) in winc1500_wifi_cb() argument
758 message_type, wifi_cb_msg_2_str(message_type)); in winc1500_wifi_cb()
760 switch (message_type) { in winc1500_wifi_cb()
|
| /Zephyr-latest/samples/net/sockets/websocket_client/src/ |
| D | main.c | 170 uint32_t message_type; in recv_data_wso_api() local
179 &message_type, in recv_data_wso_api()
|
| /Zephyr-latest/subsys/usb/usb_c/ |
| D | usbc_pe_src_states.c | 410 switch (header.message_type) { in pe_src_ready_run()
431 switch (header.message_type) { in pe_src_ready_run()
|
| D | usbc_pe_snk_states.c | 431 switch (header.message_type) { in pe_snk_ready_run()
450 switch (header.message_type) { in pe_snk_ready_run()
|
| D | usbc_prl.c | 457 header.message_type = prl_tx->msg_type; in get_sop_star_header()
1187 msg_type = rx_emsg->header.message_type; in prl_rx_wait_for_phy_message()
|
| D | usbc_pe_common.c | 550 if (prl_rx->emsg.len == 0 && header.message_type == mt && header.extended == 0) { in received_control_message()
566 if (prl_rx->emsg.len > 0 && header.message_type == mt && header.extended == 0) { in received_data_message()
|
| /Zephyr-latest/drivers/ethernet/ |
| D | eth_native_tap.c | 96 switch (hdr->message_type) { in need_timestamping()
141 if (GPTP_IS_EVENT_MSG(hdr->message_type)) { in update_pkt_priority()
|
| D | eth_sam_gmac.c | 575 switch (hdr->message_type) { in need_timestamping()
586 if (GPTP_IS_EVENT_MSG(hdr->message_type)) { in update_pkt_priority()
654 switch (hdr->message_type) { in timestamp_tx_pkt()
674 switch (hdr->message_type) { in timestamp_rx_pkt()
|
| /Zephyr-latest/drivers/usb_c/tcpc/ |
| D | tcpci.c | 507 if (msg->header.message_type >= NUM_SOP_STAR_TYPES) { in tcpci_tcpm_transmit_data()
514 TCPC_REG_TRANSMIT_SET_WITHOUT_RETRY(msg->header.message_type)); in tcpci_tcpm_transmit_data()
|
| D | ucpd_stm32.c | 58 header.message_type == PD_CTRL_GOOD_CRC); in ucpd_msg_is_good_crc()
957 tx_header.message_type = PD_CTRL_GOOD_CRC; in ucpd_send_good_crc()
|
| /Zephyr-latest/include/zephyr/drivers/usb_c/ |
| D | usbc_pd.h | 323 uint16_t message_type : 5; member
|
