Home
last modified time | relevance | path

Searched refs:evt (Results 1 – 25 of 211) sorted by relevance

123456789

/Zephyr-latest/subsys/pm/policy/
Dpolicy_events.c25 struct pm_policy_event *evt; in update_next_event() local
29 SYS_SLIST_FOR_EACH_CONTAINER(&events_list, evt, node) { in update_next_event()
31 next_event = evt; in update_next_event()
35 if (next_event->uptime_ticks <= evt->uptime_ticks) { in update_next_event()
39 next_event = evt; in update_next_event()
62 void pm_policy_event_register(struct pm_policy_event *evt, int64_t uptime_ticks) in pm_policy_event_register() argument
65 evt->uptime_ticks = uptime_ticks; in pm_policy_event_register()
66 sys_slist_append(&events_list, &evt->node); in pm_policy_event_register()
71 void pm_policy_event_update(struct pm_policy_event *evt, int64_t uptime_ticks) in pm_policy_event_update() argument
74 evt->uptime_ticks = uptime_ticks; in pm_policy_event_update()
[all …]
/Zephyr-latest/subsys/net/lib/mqtt/
Dmqtt_rx.c26 struct mqtt_evt evt; in mqtt_handle_packet() local
29 evt.result = 0; in mqtt_handle_packet()
35 evt.type = MQTT_EVT_CONNACK; in mqtt_handle_packet()
36 err_code = connect_ack_decode(client, buf, &evt.param.connack); in mqtt_handle_packet()
39 evt.param.connack.return_code); in mqtt_handle_packet()
41 if (evt.param.connack.return_code == in mqtt_handle_packet()
49 evt.result = evt.param.connack.return_code; in mqtt_handle_packet()
51 evt.result = err_code; in mqtt_handle_packet()
59 evt.type = MQTT_EVT_PUBLISH; in mqtt_handle_packet()
61 &evt.param.publish); in mqtt_handle_packet()
[all …]
/Zephyr-latest/tests/subsys/mgmt/ec_host_cmd/uart/src/
Dmain.c36 struct uart_event evt; in tx_done() local
40 evt.type = UART_TX_DONE; in tx_done()
41 evt.data.tx.buf = data->tx_buf; in tx_done()
42 evt.data.tx.len = data->tx_len; in tx_done()
44 data->cb(&uart_mock, &evt, data->user_data); in tx_done()
97 struct uart_event evt; in test_hello() local
108 evt.type = UART_RX_RDY; in test_hello()
109 evt.data.rx.len = CMD_HEADER_SIZE + sizeof(struct hello_cmd_data); in test_hello()
110 evt.data.rx.offset = 0; in test_hello()
111 evt.data.rx.buf = data->rx_buf; in test_hello()
[all …]
/Zephyr-latest/subsys/bluetooth/host/
Dcs.c298 struct bt_hci_evt_le_cs_read_remote_supported_capabilities_complete *evt; in bt_hci_le_cs_read_remote_supported_capabilities_complete() local
300 if (buf->len < sizeof(*evt)) { in bt_hci_le_cs_read_remote_supported_capabilities_complete()
305 evt = net_buf_pull_mem(buf, sizeof(*evt)); in bt_hci_le_cs_read_remote_supported_capabilities_complete()
306 if (evt->status) { in bt_hci_le_cs_read_remote_supported_capabilities_complete()
307 LOG_WRN("Read Remote Supported Capabilities failed (status 0x%02X)", evt->status); in bt_hci_le_cs_read_remote_supported_capabilities_complete()
311 conn = bt_conn_lookup_handle(sys_le16_to_cpu(evt->conn_handle), BT_CONN_TYPE_LE); in bt_hci_le_cs_read_remote_supported_capabilities_complete()
317 remote_cs_capabilities.num_config_supported = evt->num_config_supported; in bt_hci_le_cs_read_remote_supported_capabilities_complete()
319 sys_le16_to_cpu(evt->max_consecutive_procedures_supported); in bt_hci_le_cs_read_remote_supported_capabilities_complete()
320 remote_cs_capabilities.num_antennas_supported = evt->num_antennas_supported; in bt_hci_le_cs_read_remote_supported_capabilities_complete()
321 remote_cs_capabilities.max_antenna_paths_supported = evt->max_antenna_paths_supported; in bt_hci_le_cs_read_remote_supported_capabilities_complete()
[all …]
Dhci_ecc.c76 struct bt_hci_evt_cmd_status *evt; in send_cmd_status() local
86 hdr->evt = BT_HCI_EVT_CMD_STATUS; in send_cmd_status()
87 hdr->len = sizeof(*evt); in send_cmd_status()
89 evt = net_buf_add(buf, sizeof(*evt)); in send_cmd_status()
90 evt->ncmd = 1U; in send_cmd_status()
91 evt->opcode = sys_cpu_to_le16(opcode); in send_cmd_status()
92 evt->status = status; in send_cmd_status()
146 struct bt_hci_evt_le_p256_public_key_complete *evt; in emulate_le_p256_public_key_cmd() local
159 hdr->evt = BT_HCI_EVT_LE_META_EVENT; in emulate_le_p256_public_key_cmd()
160 hdr->len = sizeof(*meta) + sizeof(*evt); in emulate_le_p256_public_key_cmd()
[all …]
Ddirection.c376 struct bt_hci_evt_le_connectionless_iq_report *evt; in hci_df_prepare_connectionless_iq_report() local
379 if (buf->len < sizeof(*evt)) { in hci_df_prepare_connectionless_iq_report()
384 evt = net_buf_pull_mem(buf, sizeof(*evt)); in hci_df_prepare_connectionless_iq_report()
386 per_adv_sync = bt_hci_per_adv_sync_lookup_handle(sys_le16_to_cpu(evt->sync_handle)); in hci_df_prepare_connectionless_iq_report()
390 sys_le16_to_cpu(evt->sync_handle)); in hci_df_prepare_connectionless_iq_report()
399 if (!(per_adv_sync->cte_types & BIT(evt->cte_type))) { in hci_df_prepare_connectionless_iq_report()
400 LOG_DBG("CTE filtered out by cte_type: %u", evt->cte_type); in hci_df_prepare_connectionless_iq_report()
404 report->chan_idx = evt->chan_idx; in hci_df_prepare_connectionless_iq_report()
405 report->rssi = sys_le16_to_cpu(evt->rssi); in hci_df_prepare_connectionless_iq_report()
406 report->rssi_ant_id = evt->rssi_ant_id; in hci_df_prepare_connectionless_iq_report()
[all …]
Dscan.c755 static void create_ext_adv_info(struct bt_hci_evt_le_ext_advertising_info const *const evt, in create_ext_adv_info() argument
758 scan_info->primary_phy = bt_get_phy(evt->prim_phy); in create_ext_adv_info()
759 scan_info->secondary_phy = bt_get_phy(evt->sec_phy); in create_ext_adv_info()
760 scan_info->tx_power = evt->tx_power; in create_ext_adv_info()
761 scan_info->rssi = evt->rssi; in create_ext_adv_info()
762 scan_info->sid = evt->sid; in create_ext_adv_info()
763 scan_info->interval = sys_le16_to_cpu(evt->interval); in create_ext_adv_info()
764 scan_info->adv_type = get_adv_type(sys_le16_to_cpu(evt->evt_type)); in create_ext_adv_info()
765 scan_info->adv_props = get_adv_props_extended(sys_le16_to_cpu(evt->evt_type)); in create_ext_adv_info()
775 struct bt_hci_evt_le_ext_advertising_info *evt; in bt_hci_le_adv_ext_report() local
[all …]
/Zephyr-latest/subsys/bluetooth/controller/ll_sw/
Dull_llcp_enc.c254 static void lp_enc_complete(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in lp_enc_complete() argument
272 static void lp_enc_send_enc_req(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_enc_send_enc_req() argument
292 static void lp_enc_send_pause_enc_req(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_enc_send_pause_enc_req() argument
305 static void lp_enc_send_pause_enc_rsp(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_enc_send_pause_enc_rsp() argument
325 static void lp_enc_send_start_enc_rsp(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_enc_send_start_enc_rsp() argument
346 static void lp_enc_st_wait_tx_enc_req(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_enc_st_wait_tx_enc_req() argument
349 switch (evt) { in lp_enc_st_wait_tx_enc_req()
351 lp_enc_send_enc_req(conn, ctx, evt, param); in lp_enc_st_wait_tx_enc_req()
397 static void lp_enc_st_wait_rx_enc_rsp(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_enc_st_wait_rx_enc_rsp() argument
402 switch (evt) { in lp_enc_st_wait_rx_enc_rsp()
[all …]
Dull_llcp_chmu.c105 static void lp_chmu_complete(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in lp_chmu_complete() argument
113 uint8_t evt, void *param) in lp_chmu_send_channel_map_update_ind() argument
129 static void lp_chmu_st_wait_tx_chan_map_ind(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_chmu_st_wait_tx_chan_map_ind() argument
132 switch (evt) { in lp_chmu_st_wait_tx_chan_map_ind()
134 lp_chmu_send_channel_map_update_ind(conn, ctx, evt, param); in lp_chmu_st_wait_tx_chan_map_ind()
142 static void lp_chmu_check_instant(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_chmu_check_instant() argument
149 lp_chmu_complete(conn, ctx, evt, param); in lp_chmu_check_instant()
153 static void lp_chmu_st_wait_instant(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_chmu_st_wait_instant() argument
156 switch (evt) { in lp_chmu_st_wait_instant()
158 lp_chmu_check_instant(conn, ctx, evt, param); in lp_chmu_st_wait_instant()
[all …]
Dull_llcp_cc.c129 static void rp_cc_check_instant(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt,
233 static void rp_cc_complete(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in rp_cc_complete() argument
240 static void rp_cc_send_cis_rsp(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in rp_cc_send_cis_rsp() argument
254 static void rp_cc_send_reject_ind(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in rp_cc_send_reject_ind() argument
280 rp_cc_complete(conn, ctx, evt, param); in rp_cc_send_reject_ind()
289 static void rp_cc_state_idle(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in rp_cc_state_idle() argument
292 switch (evt) { in rp_cc_state_idle()
324 static void rp_cc_state_wait_rx_cis_req(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in rp_cc_state_wait_rx_cis_req() argument
329 switch (evt) { in rp_cc_state_wait_rx_cis_req()
349 rp_cc_send_reject_ind(conn, ctx, evt, param); in rp_cc_state_wait_rx_cis_req()
[all …]
Dull_llcp_conn_upd.c357 static void lp_cu_ntf_complete(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_cu_ntf_complete() argument
365 static void lp_cu_send_reject_ext_ind(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_cu_send_reject_ext_ind() argument
377 static void lp_cu_send_conn_param_req(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_cu_send_conn_param_req() argument
420 uint8_t evt, void *param) in lp_cu_send_conn_update_ind_finalize() argument
438 static void lp_cu_send_conn_update_ind(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_cu_send_conn_update_ind() argument
450 lp_cu_send_conn_update_ind_finalize(conn, ctx, evt, param); in lp_cu_send_conn_update_ind()
455 static void lp_cu_st_wait_ntf_avail(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_cu_st_wait_ntf_avail() argument
458 switch (evt) { in lp_cu_st_wait_ntf_avail()
461 lp_cu_send_conn_update_ind_finalize(conn, ctx, evt, param); in lp_cu_st_wait_ntf_avail()
471 static void lp_cu_st_idle(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in lp_cu_st_idle() argument
[all …]
Dull_llcp_phy.c377 static void lp_pu_tx(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in lp_pu_tx() argument
503 static void lp_pu_tx_ntf(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in lp_pu_tx_ntf() argument
512 static void lp_pu_complete(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in lp_pu_complete() argument
524 static void lp_pu_send_phy_req(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in lp_pu_send_phy_req() argument
537 lp_pu_tx(conn, ctx, evt, param); in lp_pu_send_phy_req()
542 static void lp_pu_send_phy_update_ind(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in lp_pu_send_phy_update_ind() argument
552 lp_pu_tx(conn, ctx, evt, param); in lp_pu_send_phy_update_ind()
557 static void lp_pu_st_idle(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in lp_pu_st_idle() argument
559 switch (evt) { in lp_pu_st_idle()
561 lp_pu_send_phy_req(conn, ctx, evt, param); in lp_pu_st_idle()
[all …]
Dull_llcp_past.c108 static void rp_past_st_idle(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, void *param) in rp_past_st_idle() argument
110 switch (evt) { in rp_past_st_idle()
185 static void rp_past_st_wait_resolve_if(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in rp_past_st_wait_resolve_if() argument
188 switch (evt) { in rp_past_st_wait_resolve_if()
201 static void rp_past_st_wait_rx(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in rp_past_st_wait_rx() argument
206 switch (evt) { in rp_past_st_wait_rx()
269 static void rp_past_st_wait_next_evt(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in rp_past_st_wait_next_evt() argument
272 switch (evt) { in rp_past_st_wait_next_evt()
306 static void rp_past_execute_fsm(struct ll_conn *conn, struct proc_ctx *ctx, uint8_t evt, in rp_past_execute_fsm() argument
311 rp_past_st_idle(conn, ctx, evt, param); in rp_past_execute_fsm()
[all …]
/Zephyr-latest/tests/subsys/portability/cmsis_rtos_v1/src/
Dmsgq.c67 osEvent evt; in message_recv() local
71 evt = osMessageGet(message_id, 0); in message_recv()
72 zassert_true(evt.status == osOK, in message_recv()
76 evt = osMessageGet(message_id, TIMEOUT); in message_recv()
77 zassert_true(evt.status == osEventTimeout, in message_recv()
81 evt = osMessageGet(message_id, osWaitForever); in message_recv()
82 zassert_true(evt.status == osEventMessage, "osMessageGet failure"); in message_recv()
84 data = evt.value.v; in message_recv()
92 evt = osMessageGet(message_id, osWaitForever); in message_recv()
93 zassert_true(evt.status == osEventMessage, in message_recv()
[all …]
Dsignal.c75 osEvent evt; in ZTEST() local
86 evt = osSignalWait(SIGNAL1, 0); in ZTEST()
87 zassert_equal(evt.status, osEventSignal, ""); in ZTEST()
88 zassert_equal((evt.value.signals & SIGNAL1), SIGNAL1, ""); in ZTEST()
96 osEvent evt; in ZTEST() local
110 evt = osSignalWait(SIGNAL1, TIMEOUT); in ZTEST()
111 zassert_equal(evt.status, osEventTimeout, "signal timeout failed"); in ZTEST()
118 osEvent evt; in ZTEST() local
128 evt = osSignalWait(SIGNAL, TIMEOUT); in ZTEST()
129 zassert_equal(evt.status, osEventSignal, in ZTEST()
[all …]
Dmailq.c112 osEvent evt; in mail_recv() local
116 evt = osMailGet(mail_id, 0); in mail_recv()
117 zassert_true(evt.status == osOK, in mail_recv()
121 evt = osMailGet(mail_id, TIMEOUT); in mail_recv()
122 zassert_true(evt.status == osEventTimeout, in mail_recv()
126 evt = osMailGet(mail_id, osWaitForever); in mail_recv()
127 zassert_true(evt.status == osEventMail, "osMailGet failure"); in mail_recv()
129 rx_ptr = evt.value.p; in mail_recv()
142 evt = osMailGet(mail_id, osWaitForever); in mail_recv()
143 zassert_true(evt.status == osEventMail, "osMailGet failure"); in mail_recv()
[all …]
/Zephyr-latest/subsys/bluetooth/host/classic/
Dssp.c422 struct bt_hci_evt_pin_code_req *evt = (void *)buf->data; in bt_hci_pin_code_req() local
427 conn = bt_conn_lookup_addr_br(&evt->bdaddr); in bt_hci_pin_code_req()
429 LOG_ERR("Can't find conn for %s", bt_addr_str(&evt->bdaddr)); in bt_hci_pin_code_req()
439 struct bt_hci_evt_link_key_notify *evt = (void *)buf->data; in bt_hci_link_key_notify() local
442 conn = bt_conn_lookup_addr_br(&evt->bdaddr); in bt_hci_link_key_notify()
444 LOG_ERR("Can't find conn for %s", bt_addr_str(&evt->bdaddr)); in bt_hci_link_key_notify()
448 LOG_DBG("%s, link type 0x%02x", bt_addr_str(&evt->bdaddr), evt->key_type); in bt_hci_link_key_notify()
450 if (IS_ENABLED(CONFIG_BT_SMP_SC_ONLY) && (evt->key_type != BT_LK_AUTH_COMBINATION_P256)) { in bt_hci_link_key_notify()
468 conn->br.link_key = bt_keys_get_link_key(&evt->bdaddr); in bt_hci_link_key_notify()
471 LOG_ERR("Can't update keys for %s", bt_addr_str(&evt->bdaddr)); in bt_hci_link_key_notify()
[all …]
Dbr.c78 struct bt_hci_evt_conn_request *evt = (void *)buf->data; in bt_hci_conn_req() local
81 LOG_DBG("conn req from %s, type 0x%02x", bt_addr_str(&evt->bdaddr), evt->link_type); in bt_hci_conn_req()
83 if (evt->link_type != BT_HCI_ACL) { in bt_hci_conn_req()
86 err = bt_esco_conn_req(evt); in bt_hci_conn_req()
88 reject_conn(&evt->bdaddr, err); in bt_hci_conn_req()
93 conn = bt_conn_add_br(&evt->bdaddr); in bt_hci_conn_req()
95 reject_conn(&evt->bdaddr, BT_HCI_ERR_INSUFFICIENT_RESOURCES); in bt_hci_conn_req()
99 accept_conn(&evt->bdaddr); in bt_hci_conn_req()
186 struct bt_hci_evt_sync_conn_complete *evt = (void *)buf->data; in bt_hci_synchronous_conn_complete() local
188 uint16_t handle = sys_le16_to_cpu(evt->handle); in bt_hci_synchronous_conn_complete()
[all …]
/Zephyr-latest/subsys/input/
Dinput.c21 static void input_process(struct input_event *evt) in input_process() argument
24 if (callback->dev == NULL || callback->dev == evt->dev) { in input_process()
25 callback->callback(evt, callback->user_data); in input_process()
44 struct input_event evt = { in input_report() local
61 ret = k_msgq_put(&input_msgq, &evt, timeout); in input_report()
69 input_process(&evt); in input_report()
78 struct input_event evt; in input_thread() local
82 ret = k_msgq_get(&input_msgq, &evt, K_FOREVER); in input_thread()
88 input_process(&evt); in input_thread()
/Zephyr-latest/subsys/portability/cmsis_rtos_v1/
Dcmsis_signal.c74 osEvent evt = {0}; in osSignalWait() local
79 evt.status = osErrorISR; in osSignalWait()
80 return evt; in osSignalWait()
85 evt.status = osErrorValue; in osSignalWait()
86 return evt; in osSignalWait()
110 evt.status = osEventSignal; in osSignalWait()
114 evt.status = osOK; in osSignalWait()
116 evt.status = osEventTimeout; in osSignalWait()
118 return evt; in osSignalWait()
120 evt.status = osErrorValue; in osSignalWait()
[all …]
Dcmsis_msgq.c66 osEvent evt = {0}; in osMessageGet() local
70 evt.status = osErrorParameter; in osMessageGet()
71 return evt; in osMessageGet()
83 evt.status = osEventMessage; in osMessageGet()
84 evt.value.v = info; in osMessageGet()
86 evt.status = osEventTimeout; in osMessageGet()
88 evt.status = osOK; in osMessageGet()
91 evt.def.message_id = queue_id; in osMessageGet()
93 return evt; in osMessageGet()
/Zephyr-latest/tests/bsim/bluetooth/mesh/src/
Dfriendship_common.c19 static void evt_signal(enum bt_mesh_test_friendship_evt_flags evt) in evt_signal() argument
21 atomic_set_bit(bt_mesh_test_friendship_state, evt); in evt_signal()
22 k_sem_give(&bt_mesh_test_friendship_events[evt]); in evt_signal()
25 int bt_mesh_test_friendship_evt_wait(enum bt_mesh_test_friendship_evt_flags evt, in bt_mesh_test_friendship_evt_wait() argument
28 return k_sem_take(&bt_mesh_test_friendship_events[evt], timeout); in bt_mesh_test_friendship_evt_wait()
31 void bt_mesh_test_friendship_evt_clear(enum bt_mesh_test_friendship_evt_flags evt) in bt_mesh_test_friendship_evt_clear() argument
33 atomic_clear_bit(bt_mesh_test_friendship_state, evt); in bt_mesh_test_friendship_evt_clear()
34 k_sem_reset(&bt_mesh_test_friendship_events[evt]); in bt_mesh_test_friendship_evt_clear()
37 bool bt_mesh_test_friendship_state_check(enum bt_mesh_test_friendship_evt_flags evt) in bt_mesh_test_friendship_state_check() argument
39 return atomic_test_bit(bt_mesh_test_friendship_state, evt); in bt_mesh_test_friendship_state_check()
/Zephyr-latest/tests/bluetooth/host_long_adv_recv/src/
Dmain.c53 void (*handler)(struct net_buf *buf, struct net_buf **evt, uint8_t len, uint16_t opcode);
57 static void evt_create(struct net_buf *buf, uint8_t evt, uint8_t len) in evt_create() argument
62 hdr->evt = evt; in evt_create()
66 static void le_meta_evt_create(struct bt_hci_evt_le_meta_event *evt, uint8_t subevent) in le_meta_evt_create() argument
68 evt->subevent = subevent; in le_meta_evt_create()
71 static void adv_info_create(struct bt_hci_evt_le_ext_advertising_info *evt, uint16_t evt_type, in adv_info_create() argument
74 evt->evt_type = evt_type; in adv_info_create()
75 bt_addr_le_copy(&evt->addr, addr); in adv_info_create()
76 evt->prim_phy = 0; in adv_info_create()
77 evt->sec_phy = 0; in adv_info_create()
[all …]
/Zephyr-latest/subsys/bluetooth/controller/hci/
Dhci.c299 static void hci_evt_create(struct net_buf *buf, uint8_t evt, uint8_t len) in hci_evt_create() argument
304 hdr->evt = evt; in hci_evt_create()
346 struct bt_hci_evt_vs *evt; in vs_event() local
348 hci_evt_create(buf, BT_HCI_EVT_VENDOR, sizeof(*evt) + evt_len); in vs_event()
349 evt = net_buf_add(buf, sizeof(*evt)); in vs_event()
350 evt->subevent = subevt; in vs_event()
371 static void disconnect(struct net_buf *buf, struct net_buf **evt) in disconnect() argument
380 *evt = cmd_status(status); in disconnect()
383 static void read_remote_ver_info(struct net_buf *buf, struct net_buf **evt) in read_remote_ver_info() argument
392 *evt = cmd_status(status); in read_remote_ver_info()
[all …]
/Zephyr-latest/samples/net/secure_mqtt_sensor_actuator/src/
Dmqtt_client.c123 static void on_mqtt_publish(struct mqtt_client *const client, const struct mqtt_evt *evt) in on_mqtt_publish() argument
139 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()
149 static void mqtt_event_handler(struct mqtt_client *const client, const struct mqtt_evt *evt) in mqtt_event_handler() argument
151 switch (evt->type) { in mqtt_event_handler()
153 if (evt->result != 0) { in mqtt_event_handler()
154 LOG_ERR("MQTT Event Connect failed [%d]", evt->result); in mqtt_event_handler()
169 if (evt->result != 0) { in mqtt_event_handler()
170 LOG_ERR("MQTT PUBACK error [%d]", evt->result); in mqtt_event_handler()
174 LOG_INF("PUBACK packet ID: %u", evt->param.puback.message_id); in mqtt_event_handler()
[all …]

123456789