Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 168) sorted by relevance

1234567

/subsys/net/lib/lwm2m/
A Dlwm2m_message_handling.c397 msg->body_encode_buffer = msg->cpkt; in prepare_msg_for_send()
400 msg->cpkt.data = msg->msg_data; in prepare_msg_for_send()
604 (void)memset(msg, 0, sizeof(*msg)); in lwm2m_reset_message()
623 if (!msg || !msg->ctx) { in lwm2m_init_message()
701 msg->reply->reply = msg->reply_cb; in lwm2m_init_message()
2324 msg->out.out_cpkt = &msg->cpkt; in handle_request()
2967 msg->token, msg->tkl); in notify_message_timeout_cb()
3169 msg->out.out_cpkt = &msg->cpkt; in generate_notify_message()
3496 if (msg && msg->send_status_cb) { in do_send_reply_cb()
3623 msg->out.out_cpkt = &msg->cpkt; in lwm2m_send_cb()
[all …]
A Dlwm2m_message_handling.h47 void lwm2m_reset_message(struct lwm2m_message *msg, bool release);
48 void lm2m_message_clear_allocations(struct lwm2m_message *msg);
49 int lwm2m_init_message(struct lwm2m_message *msg);
50 int lwm2m_send_message_async(struct lwm2m_message *msg);
57 int lwm2m_information_interface_send(struct lwm2m_message *msg);
60 int lwm2m_register_payload_handler(struct lwm2m_message *msg);
62 int lwm2m_perform_read_op(struct lwm2m_message *msg, uint16_t content_format);
70 int lwm2m_discover_handler(struct lwm2m_message *msg, bool is_bootstrap);
74 struct lwm2m_engine_obj_field *obj_field, struct lwm2m_message *msg);
81 static inline bool lwm2m_outgoing_is_part_of_blockwise(struct lwm2m_message *msg) in lwm2m_outgoing_is_part_of_blockwise() argument
[all …]
A Dlwm2m_rw_oma_tlv.c825 &msg->in.offset) < 0) { in do_write_op_tlv_dummy_read()
885 if (msg->in.block_ctx) { in write_tlv_resource()
889 msg->path.res_id = tlv->id; in write_tlv_resource()
890 msg->path.level = 3U; in write_tlv_resource()
913 if (msg->in.block_ctx) { in write_tlv_resource_instance()
937 if (msg->in.block_ctx) { in lwm2m_multi_resource_tlv_parse()
964 (msg->ctx->bootstrap_mode || msg->operation == LWM2M_OP_CREATE))) { in lwm2m_multi_resource_tlv_parse()
987 if (msg->in.block_ctx != NULL && msg->in.block_ctx->ctx.current > 0) { in do_write_op_tlv()
988 msg->path.res_id = msg->in.block_ctx->path.res_id; in do_write_op_tlv()
989 msg->path.level = 3U; in do_write_op_tlv()
[all …]
A Dlwm2m_rw_opaque.c116 int do_read_op_opaque(struct lwm2m_message *msg, int content_format) in do_read_op_opaque() argument
119 if (msg->path.level < LWM2M_PATH_LEVEL_RESOURCE) { in do_read_op_opaque()
121 } else if (msg->path.level > LWM2M_PATH_LEVEL_RESOURCE) { in do_read_op_opaque()
124 } else if (msg->path.level > LWM2M_PATH_LEVEL_RESOURCE_INST) { in do_read_op_opaque()
129 return lwm2m_perform_read_op(msg, content_format); in do_read_op_opaque()
132 int do_write_op_opaque(struct lwm2m_message *msg) in do_write_op_opaque() argument
141 ret = lwm2m_get_or_create_engine_obj(msg, &obj_inst, &created); in do_write_op_opaque()
146 ret = lwm2m_engine_validate_write_access(msg, obj_inst, &obj_field); in do_write_op_opaque()
151 ret = lwm2m_engine_get_create_res_inst(&msg->path, &res, &res_inst); in do_write_op_opaque()
156 if (msg->path.level < LWM2M_PATH_LEVEL_RESOURCE) { in do_write_op_opaque()
[all …]
A Dlwm2m_rw_senml_cbor.c827 setup_out_fmt_data(msg); in do_read_op_senml_cbor()
831 clear_out_fmt_data(msg); in do_read_op_senml_cbor()
856 setup_in_fmt_data(msg); in parse_composite_read_paths()
916 clear_in_fmt_data(msg); in parse_composite_read_paths()
971 if (msg->in.block_ctx != NULL && msg->in.block_ctx->ctx.current > 0) { in do_write_op_senml_cbor()
972 msg->path.res_id = msg->in.block_ctx->path.res_id; in do_write_op_senml_cbor()
973 msg->path.level = msg->in.block_ctx->path.level; in do_write_op_senml_cbor()
976 msg->path.res_inst_id = msg->in.block_ctx->path.res_inst_id; in do_write_op_senml_cbor()
982 setup_in_fmt_data(msg); in do_write_op_senml_cbor()
1032 (msg->ctx->bootstrap_mode || msg->operation == LWM2M_OP_CREATE))) { in do_write_op_senml_cbor()
[all …]
/subsys/net/lib/ptp/
A Dmsg.c216 msg_tlv_free(msg); in msg_tlv_pre_send()
229 memset(msg, 0, sizeof(*msg)); in ptp_msg_alloc()
233 return msg; in ptp_msg_alloc()
246 msg_tlv_free(msg); in ptp_msg_unref()
268 struct ptp_msg *msg; in ptp_msg_from_pkt() local
304 return msg; in ptp_msg_from_pkt()
346 msg->announce.steps_rm = htons(msg->announce.steps_rm); in ptp_msg_pre_send()
391 msg_timestamp_post_recv(msg, &msg->sync.origin_timestamp); in ptp_msg_post_recv()
405 msg_timestamp_post_recv(msg, &msg->delay_resp.receive_timestamp); in ptp_msg_post_recv()
417 msg_timestamp_post_recv(msg, &msg->announce.origin_timestamp); in ptp_msg_post_recv()
[all …]
A Dport.c161 if (!port || !msg) { in port_delay_req_timestamp_cb()
257 if (!msg) { in port_announce_msg_transmit()
279 ptp_msg_unref(msg); in port_announce_msg_transmit()
295 if (!msg) { in port_delay_req_msg_transmit()
331 if (!msg) { in port_sync_msg_transmit()
351 ptp_msg_unref(msg); in port_sync_msg_transmit()
480 ptp_msg_ref(msg); in port_sync_fup_ooo_handle()
511 ptp_msg_ref(msg); in port_sync_fup_ooo_handle()
1057 if (!msg) { in ptp_port_event_gen()
1385 ptp_msg_ref(msg); in ptp_port_add_foreign_tt()
[all …]
/subsys/net/lib/shell/
A Devents.c57 struct event_msg msg; in event_handler() local
60 memset(&msg, 0, sizeof(msg)); in event_handler()
62 msg.len = MIN(sizeof(msg.data), cb->info_length); in event_handler()
63 msg.event = mgmt_event; in event_handler()
64 msg.iface = iface; in event_handler()
67 memcpy(msg.data, cb->info, msg.len); in event_handler()
90 switch (msg->event) { in get_l2_desc()
160 switch (msg->event) { in get_l3_desc()
414 switch (msg->event) { in get_l4_desc()
511 struct event_msg msg; in event_mon_handler() local
[all …]
/subsys/bluetooth/mesh/
A Ddelayable_msg.c96 if (msg) { in reschedule_delayable_msg()
155 return msg; in allocate_delayable_msg_ctx()
173 if (!msg) { in push_msg_from_delayable_msgs()
177 len = msg->len; in push_msg_from_delayable_msgs()
190 err = bt_mesh_access_send(&msg->ctx, &buf, msg->src_addr, msg->cb, msg->cb_data); in push_msg_from_delayable_msgs()
200 if (err && msg->cb && msg->cb->start) { in push_msg_from_delayable_msgs()
201 msg->cb->start(0, err, msg->cb_data); in push_msg_from_delayable_msgs()
241 if (!msg) { in bt_mesh_delayable_msg_manage()
274 msg->ctx = *ctx; in bt_mesh_delayable_msg_manage()
276 msg->cb = cb; in bt_mesh_delayable_msg_manage()
[all …]
A Dbrg_cfg_srv.c60 net_buf_simple_add_u8(&msg, status); in bridging_table_status_send()
61 net_buf_simple_add_u8(&msg, entry->directions); in bridging_table_status_send()
63 net_buf_simple_add_le16(&msg, entry->addr1); in bridging_table_status_send()
64 net_buf_simple_add_le16(&msg, entry->addr2); in bridging_table_status_send()
145 net_buf_simple_add_le16(&msg, net_idx_filter); in bridged_subnets_get()
146 net_buf_simple_add_u8(&msg, start_id); in bridged_subnets_get()
163 key_idx_pack_pair(&msg, net_idx1, net_idx2); in bridged_subnets_get()
171 key_idx_pack_pair(&msg, net_idx1, net_idx2); in bridged_subnets_get()
230 net_buf_simple_add_u8(&msg, status); in bridging_table_get()
231 key_idx_pack_pair(&msg, net_idx1, net_idx2); in bridging_table_get()
[all …]
A Dhealth_cli.c271 net_buf_simple_add_u8(&msg, divisor); in bt_mesh_health_cli_period_set()
289 net_buf_simple_add_u8(&msg, divisor); in bt_mesh_health_cli_period_set_unack()
307 net_buf_simple_add_u8(&msg, test_id); in bt_mesh_health_cli_fault_test()
308 net_buf_simple_add_le16(&msg, cid); in bt_mesh_health_cli_fault_test()
326 net_buf_simple_add_u8(&msg, test_id); in bt_mesh_health_cli_fault_test_unack()
327 net_buf_simple_add_le16(&msg, cid); in bt_mesh_health_cli_fault_test_unack()
345 net_buf_simple_add_le16(&msg, cid); in bt_mesh_health_cli_fault_clear()
364 net_buf_simple_add_le16(&msg, cid); in bt_mesh_health_cli_fault_clear_unack()
382 net_buf_simple_add_le16(&msg, cid); in bt_mesh_health_cli_fault_get()
430 cli->pub.msg = &cli->pub_buf; in health_cli_init()
[all …]
A Dcfg_srv.c294 net_buf_simple_add_u8(&msg, status); in send_app_key_status()
402 net_buf_simple_add_u8(&msg, status); in app_key_get()
1231 struct net_buf_simple *msg; member
1290 net_buf_simple_add_le16(&msg, id); in mod_sub_get()
1298 net_buf_simple_add_le16(&msg, id); in mod_sub_get()
1305 net_buf_simple_add_le16(&msg, id); in mod_sub_get()
1307 visit_ctx.msg = &msg; in mod_sub_get()
1347 net_buf_simple_add_le16(&msg, id); in mod_sub_get_vnd()
1364 net_buf_simple_add_le16(&msg, id); in mod_sub_get_vnd()
1366 visit_ctx.msg = &msg; in mod_sub_get_vnd()
[all …]
A Dbrg_cfg_cli.c216 bt_mesh_model_msg_init(&msg, OP_SUBNET_BRIDGE_GET); in bt_mesh_brg_cfg_cli_get()
234 net_buf_simple_add_u8(&msg, (uint8_t)val); in bt_mesh_brg_cfg_cli_set()
285 net_buf_simple_add_u8(&msg, entry->directions); in bt_mesh_brg_cfg_cli_table_add()
287 net_buf_simple_add_le16(&msg, entry->addr1); in bt_mesh_brg_cfg_cli_table_add()
288 net_buf_simple_add_le16(&msg, entry->addr2); in bt_mesh_brg_cfg_cli_table_add()
315 key_idx_pack_pair(&msg, net_idx1, net_idx2); in bt_mesh_brg_cfg_cli_table_remove()
316 net_buf_simple_add_le16(&msg, addr1); in bt_mesh_brg_cfg_cli_table_remove()
317 net_buf_simple_add_le16(&msg, addr2); in bt_mesh_brg_cfg_cli_table_remove()
337 net_buf_simple_add_u8(&msg, start_idx); in bt_mesh_brg_cfg_cli_subnets_get()
356 key_idx_pack_pair(&msg, net_idx1, net_idx2); in bt_mesh_brg_cfg_cli_table_get()
[all …]
A Dop_agg.c19 int bt_mesh_op_agg_encode_msg(struct net_buf_simple *msg, struct net_buf_simple *buf) in bt_mesh_op_agg_encode_msg() argument
21 if (msg->len > LENGTH_SHORT_MAX) { in bt_mesh_op_agg_encode_msg()
22 if (net_buf_simple_tailroom(buf) < (msg->len + 2)) { in bt_mesh_op_agg_encode_msg()
26 net_buf_simple_add_le16(buf, (msg->len << 1) | 1); in bt_mesh_op_agg_encode_msg()
28 if (net_buf_simple_tailroom(buf) < (msg->len + 1)) { in bt_mesh_op_agg_encode_msg()
32 net_buf_simple_add_u8(buf, msg->len << 1); in bt_mesh_op_agg_encode_msg()
34 net_buf_simple_add_mem(buf, msg->data, msg->len); in bt_mesh_op_agg_encode_msg()
39 int bt_mesh_op_agg_decode_msg(struct net_buf_simple *msg, in bt_mesh_op_agg_decode_msg() argument
62 net_buf_simple_init_with_data(msg, net_buf_simple_pull_mem(buf, len), len); in bt_mesh_op_agg_decode_msg()
A Dproxy_msg.c175 struct net_buf_simple *msg, in bt_mesh_proxy_msg_send() argument
184 bt_hex(msg->data, msg->len)); in bt_mesh_proxy_msg_send()
193 if (mtu > msg->len) { in bt_mesh_proxy_msg_send()
195 return role->cb.send(conn, msg->data, msg->len, end, user_data); in bt_mesh_proxy_msg_send()
204 net_buf_simple_pull(msg, mtu); in bt_mesh_proxy_msg_send()
206 while (msg->len) { in bt_mesh_proxy_msg_send()
207 if (msg->len + 1 <= mtu) { in bt_mesh_proxy_msg_send()
209 err = role->cb.send(conn, msg->data, msg->len, end, user_data); in bt_mesh_proxy_msg_send()
223 net_buf_simple_pull(msg, mtu); in bt_mesh_proxy_msg_send()
245 net_buf_simple_reserve(&msg, 1); in proxy_relay_send()
[all …]
A Dcfg_cli.c1139 net_buf_simple_add_u8(&msg, page); in bt_mesh_cfg_cli_comp_data_get()
1155 bt_mesh_model_msg_init(&msg, op); in get_state_u8()
1171 bt_mesh_model_msg_init(&msg, op); in set_state_u8()
1548 net_buf_simple_add_le16(&msg, cid); in mod_app_bind()
1597 net_buf_simple_add_le16(&msg, cid); in mod_app_unbind()
1646 bt_mesh_model_msg_init(&msg, op); in mod_member_list_get()
1650 net_buf_simple_add_le16(&msg, cid); in mod_member_list_get()
1697 bt_mesh_model_msg_init(&msg, op); in mod_sub()
1705 net_buf_simple_add_le16(&msg, cid); in mod_sub()
1825 bt_mesh_model_msg_init(&msg, op); in mod_sub_va()
[all …]
/subsys/logging/
A Dlog_multidomain_link.c42 switch (msg->id) { in log_multidomain_link_on_recv_cb()
45 msg->data.log_msg.data, in log_multidomain_link_on_recv_cb()
114 struct log_multidomain_msg msg = { in link_remote_get_domain_count() local
118 err = getter_msg_process(link_remote, &msg, sizeof(msg)); in link_remote_get_domain_count()
133 struct log_multidomain_msg msg = { in link_remote_get_source_count() local
138 err = getter_msg_process(link_remote, &msg, sizeof(msg)); in link_remote_get_source_count()
155 err = getter_msg_process(link_remote, &msg, sizeof(msg)); in link_remote_ready()
229 err = getter_msg_process(link_remote, &msg, sizeof(msg)); in link_remote_get_domain_name()
256 err = getter_msg_process(link_remote, &msg, sizeof(msg)); in link_remote_get_source_name()
280 err = getter_msg_process(link_remote, &msg, sizeof(msg)); in link_remote_get_levels()
[all …]
A Dlog_output_dict.c16 struct log_msg *msg, uint32_t flags) in log_dict_output_msg_process() argument
19 void *source = (void *)log_msg_get_source(msg); in log_dict_output_msg_process()
23 output_hdr.domain = msg->hdr.desc.domain; in log_dict_output_msg_process()
24 output_hdr.level = msg->hdr.desc.level; in log_dict_output_msg_process()
26 output_hdr.data_len = msg->hdr.desc.data_len; in log_dict_output_msg_process()
27 output_hdr.timestamp = msg->hdr.timestamp; in log_dict_output_msg_process()
41 data = log_msg_get_data(msg, &len); in log_dict_output_msg_process()
51 struct log_dict_output_dropped_msg_t msg; in log_dict_output_dropped_process() local
53 msg.type = MSG_DROPPED_MSG; in log_dict_output_dropped_process()
54 msg.num_dropped_messages = MIN(cnt, 9999); in log_dict_output_dropped_process()
[all …]
A Dlog_msg.c34 if (!msg) { in z_log_msg_finalize()
46 msg->hdr.desc = desc; in z_log_msg_finalize()
47 msg->hdr.source = source; in z_log_msg_finalize()
51 z_log_msg_commit(msg); in z_log_msg_finalize()
108 if (msg) { in z_log_msg_simple_create()
294 struct log_msg *msg; in z_impl_z_log_msg_static_create() local
322 if (msg) { in z_impl_z_log_msg_static_create()
370 struct log_msg *msg; in z_log_msg_runtime_vcreate() local
377 msg = NULL; in z_log_msg_runtime_vcreate()
383 pkg = msg ? msg->data : NULL; in z_log_msg_runtime_vcreate()
[all …]
/subsys/net/lib/sockets/
A Dsockets.c82 if (msg->msg_iov[i].iov_len) { in msghdr_non_empty_iov_count()
421 if (msg->msg_namelen > 0) { in z_vrfy_zsock_sendmsg()
423 msg->msg_namelen); in z_vrfy_zsock_sendmsg()
432 msg->msg_controllen); in z_vrfy_zsock_sendmsg()
551 if (msg == NULL) { in z_vrfy_zsock_recvmsg()
556 if (msg->msg_iov == NULL) { in z_vrfy_zsock_recvmsg()
599 if (msg->msg_namelen > 0) { in z_vrfy_zsock_recvmsg()
600 if (msg->msg_name == NULL) { in z_vrfy_zsock_recvmsg()
606 msg->msg_namelen); in z_vrfy_zsock_recvmsg()
634 if (msg->msg_namelen > 0 && msg->msg_name != NULL) { in z_vrfy_zsock_recvmsg()
[all …]
/subsys/testsuite/ztest/include/zephyr/
A Dztest_assert.h80 const char *func, const char *msg, ...) in z_zassert() argument
85 va_start(vargs, msg); in z_zassert()
88 vprintk(msg, vargs); in z_zassert()
104 const char *func, const char *msg, ...) in z_zassume() argument
109 va_start(vargs, msg); in z_zassume()
112 vprintk(msg, vargs); in z_zassume()
128 const char *func, const char *msg, ...) in z_zexpect() argument
133 va_start(vargs, msg); in z_zexpect()
136 vprintk(msg, vargs); in z_zexpect()
191 _zassert_base(cond, default_msg, msg, ##__VA_ARGS__)
[all …]
/subsys/net/lib/ocpp/
A Docpp_j.c32 char *start = strchr(msg, '{'); in extract_payload()
33 char *end = strrchr(msg, '}'); in extract_payload()
44 memmove(msg, start, len); in extract_payload()
45 msg[len] = '\0'; in extract_payload()
184 if (msg.iccid != NULL) { in frame_bootnotif_msg()
190 if (msg.imsi != NULL) { in frame_bootnotif_msg()
318 if (msg.reason != NULL) { in frame_stop_txn_msg()
324 if (msg.id_tag != NULL) { in frame_stop_txn_msg()
406 msg.unknown_key = key; in frame_getconfig_msg()
663 switch (*msg.status) { in parse_bootnotification_msg()
[all …]
/subsys/logging/backends/
A Dlog_multidomain_backend.c15 union log_msg_generic *msg) in process() argument
27 msg->log.hdr.desc.package_len, in process()
58 fsc_plen = cbprintf_fsc_package(msg->log.data, msg->log.hdr.desc.package_len, in process()
68 &msg->log.data[msg->log.hdr.desc.package_len], in process()
132 .id = msg->id, in log_multidomain_backend_on_recv_cb()
139 switch (msg->id) { in log_multidomain_backend_on_recv_cb()
151 msg->data.domain_name.domain_id, in log_multidomain_backend_on_recv_cb()
157 msg->data.source_name.domain_id, in log_multidomain_backend_on_recv_cb()
158 msg->data.source_name.source_id, in log_multidomain_backend_on_recv_cb()
226 struct log_multidomain_msg msg = { in dropped() local
[all …]
/subsys/usb/device_next/
A Dusbd_msg.c26 struct usbd_msg msg; member
33 const struct usbd_msg msg) in usbd_msg_pub() argument
44 m_pkt->msg = msg; in usbd_msg_pub()
81 m_pkt->ctx->msg_cb(m_pkt->ctx, &m_pkt->msg); in msg_work_handler()
113 const struct usbd_msg msg = { in usbd_msg_pub_simple() local
120 usbd_msg_pub(ctx, msg); in usbd_msg_pub_simple()
122 ctx->msg_cb(ctx, &msg); in usbd_msg_pub_simple()
130 const struct usbd_msg msg = { in usbd_msg_pub_device() local
137 usbd_msg_pub(ctx, msg); in usbd_msg_pub_device()
139 ctx->msg_cb(ctx, &msg); in usbd_msg_pub_device()
/subsys/net/lib/dns/
A Ddns_pack.c194 dns_header = msg->msg; in dns_unpack_response_header()
195 size = msg->msg_size; in dns_unpack_response_header()
379 uint8_t *msg = dns_msg->msg; in dns_copy_qname() local
391 lb_size = msg[pos]; in dns_copy_qname()
403 pos = ((msg[pos] & mask) << 8) + msg[pos + 1]; in dns_copy_qname()
455 dns_header = msg->msg; in mdns_unpack_query_header()
456 size = msg->msg_size; in mdns_unpack_query_header()
500 if (curr_src < msg || curr_src >= (msg + maxlen)) { in dns_unpack_name()
509 if (curr_src >= (msg + maxlen)) { in dns_unpack_name()
522 curr_src = msg + pos; in dns_unpack_name()
[all …]

Completed in 109 milliseconds

1234567