| /Zephyr-latest/samples/boards/nordic/mesh/onoff_level_lighting_vnd_app/src/mesh/ |
| D | publisher.c | 27 bt_mesh_model_msg_init(root_models[3].pub->msg, in publish()
29 net_buf_simple_add_u8(root_models[3].pub->msg, 0x01); in publish()
30 net_buf_simple_add_u8(root_models[3].pub->msg, tid++); in publish()
33 bt_mesh_model_msg_init(root_models[3].pub->msg, in publish()
35 net_buf_simple_add_u8(root_models[3].pub->msg, 0x01); in publish()
36 net_buf_simple_add_u8(root_models[3].pub->msg, tid++); in publish()
37 net_buf_simple_add_u8(root_models[3].pub->msg, 0x45); in publish()
38 net_buf_simple_add_u8(root_models[3].pub->msg, 0x28); in publish()
41 bt_mesh_model_msg_init(vnd_models[0].pub->msg, in publish()
43 net_buf_simple_add_le16(vnd_models[0].pub->msg, 0x0001); in publish()
[all …]
|
| /Zephyr-latest/include/zephyr/drivers/i3c/ |
| D | hdr_ddr.h | 44 struct i3c_msg msg; in i3c_hdr_ddr_write() local
46 msg.buf = buf; in i3c_hdr_ddr_write()
47 msg.len = num_bytes; in i3c_hdr_ddr_write()
48 msg.flags = I3C_MSG_WRITE | I3C_MSG_STOP | I3C_MSG_HDR; in i3c_hdr_ddr_write()
49 msg.hdr_mode = I3C_MSG_HDR_DDR; in i3c_hdr_ddr_write()
50 msg.hdr_cmd_code = cmd; in i3c_hdr_ddr_write()
52 return i3c_transfer(target, &msg, 1); in i3c_hdr_ddr_write()
72 struct i3c_msg msg; in i3c_hdr_ddr_read() local
74 msg.buf = buf; in i3c_hdr_ddr_read()
75 msg.len = num_bytes; in i3c_hdr_ddr_read()
[all …]
|
| /Zephyr-latest/subsys/net/lib/lwm2m/ |
| D | lwm2m_message_handling.c | 104 static int handle_request(struct coap_packet *request, struct lwm2m_message *msg);
106 STATIC int build_msg_block_for_send(struct lwm2m_message *msg, uint16_t block_num,
283 STATIC int build_msg_block_for_send(struct lwm2m_message *msg, uint16_t block_num, in build_msg_block_for_send() argument
291 coap_packet_get_payload(&msg->body_encode_buffer, &complete_payload_len); in build_msg_block_for_send()
295 NET_ASSERT(msg->msg_data == msg->cpkt.data, in build_msg_block_for_send()
306 ret = buf_append(CPKT_BUF_WRITE(&msg->cpkt), msg->body_encode_buffer.data, in build_msg_block_for_send()
307 msg->body_encode_buffer.hdr_len); in build_msg_block_for_send()
311 msg->cpkt.hdr_len = msg->body_encode_buffer.hdr_len; in build_msg_block_for_send()
314 void *user_data = msg->reply ? msg->reply->user_data : NULL; in build_msg_block_for_send()
319 lwm2m_reset_message(msg, false); in build_msg_block_for_send()
[all …]
|
| D | lwm2m_message_handling.h | 47 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);
64 int lwm2m_perform_composite_read_op(struct lwm2m_message *msg, uint16_t content_format,
67 int do_composite_read_op_for_parsed_list(struct lwm2m_message *msg, uint16_t content_format,
70 int lwm2m_discover_handler(struct lwm2m_message *msg, bool is_bootstrap);
[all …]
|
| /Zephyr-latest/tests/net/lib/lwm2m/block_transfer/src/ |
| D | main.c | 13 int prepare_msg_for_send(struct lwm2m_message *msg);
14 int build_msg_block_for_send(struct lwm2m_message *msg, uint16_t block_num,
35 struct lwm2m_message msg; member
54 memset(&fixture->msg, 0, sizeof(struct lwm2m_message)); in net_block_transfer_before()
55 fixture->msg.ctx = &fixture->ctx; in net_block_transfer_before()
62 lwm2m_reset_message(&fixture->msg, true); in net_block_transfer_after()
68 struct lwm2m_message *msg = &fixture->msg; in ZTEST_F() local
71 ret = lwm2m_init_message(msg); in ZTEST_F()
74 zassert_not_equal(msg->msg_data, msg->cpkt.data, in ZTEST_F()
76 zassert_equal(msg->cpkt.data, msg->body_encode_buffer.data, in ZTEST_F()
[all …]
|
| /Zephyr-latest/subsys/net/lib/ptp/ |
| D | msg.c | 24 static const char *msg_type_str(struct ptp_msg *msg) in msg_type_str() argument
26 switch (ptp_msg_type(msg)) { in msg_type_str()
52 static void msg_timestamp_post_recv(struct ptp_msg *msg, struct ptp_timestamp *ts) in msg_timestamp_post_recv() argument
54 msg->timestamp.protocol._sec.high = ntohs(ts->seconds_high); in msg_timestamp_post_recv()
55 msg->timestamp.protocol._sec.low = ntohl(ts->seconds_low); in msg_timestamp_post_recv()
56 msg->timestamp.protocol.nanosecond = ntohl(ts->nanoseconds); in msg_timestamp_post_recv()
101 static uint8_t *msg_suffix(struct ptp_msg *msg) in msg_suffix() argument
105 switch (ptp_msg_type(msg)) { in msg_suffix()
107 suffix = msg->sync.suffix; in msg_suffix()
110 suffix = msg->delay_req.suffix; in msg_suffix()
[all …]
|
| D | port.c | 82 static int port_msg_send(struct ptp_port *port, struct ptp_msg *msg, enum ptp_socket idx) in port_msg_send() argument
84 ptp_msg_pre_send(msg); in port_msg_send()
86 return ptp_transport_send(port, msg, idx); in port_msg_send()
158 struct ptp_msg *req, *msg = ptp_msg_from_pkt(pkt); in port_delay_req_timestamp_cb() local
161 if (!port || !msg) { in port_delay_req_timestamp_cb()
165 msg->header.src_port_id.port_number = ntohs(msg->header.src_port_id.port_number); in port_delay_req_timestamp_cb()
167 if (!ptp_port_id_eq(&port->port_ds.id, &msg->header.src_port_id) || in port_delay_req_timestamp_cb()
168 ptp_msg_type(msg) != PTP_MSG_DELAY_REQ) { in port_delay_req_timestamp_cb()
178 if (req->header.sequence_id != msg->header.sequence_id) { in port_delay_req_timestamp_cb()
196 ntohs(msg->header.sequence_id)); in port_delay_req_timestamp_cb()
[all …]
|
| /Zephyr-latest/drivers/usb/uvb/ |
| D | uvb.c | 78 static ALWAYS_INLINE int submit_new_work(struct uvb_msg *const msg) in submit_new_work() argument
80 k_fifo_put(&uvb_queue, msg); in submit_new_work()
86 struct uvb_msg *msg; in uvb_alloc_msg() local
88 if (k_mem_slab_alloc(&uvb_msg_slab, (void **)&msg, K_NO_WAIT)) { in uvb_alloc_msg()
93 memset(msg, 0, sizeof(struct uvb_msg)); in uvb_alloc_msg()
94 msg->source = node; in uvb_alloc_msg()
96 return msg; in uvb_alloc_msg()
103 struct uvb_msg *msg; in uvb_advert() local
106 msg = uvb_alloc_msg(host_node); in uvb_advert()
107 if (msg == NULL) { in uvb_advert()
[all …]
|
| /Zephyr-latest/tests/modules/nanopb/src/ |
| D | main.c | 22 SimpleMessage msg = SimpleMessage_init_zero; in ZTEST() local
24 for (size_t i = 0; i < sizeof(msg.buffer); ++i) { in ZTEST()
25 msg.buffer[i] = i; in ZTEST()
30 zassert_true(pb_encode(&ostream, SimpleMessage_fields, &msg), in ZTEST()
34 memset(&msg, 0, sizeof(SimpleMessage)); in ZTEST()
38 zassert_true(pb_decode(&istream, SimpleMessage_fields, &msg), in ZTEST()
41 for (size_t i = 0; i < sizeof(msg.buffer); ++i) { in ZTEST()
42 zassert_equal(msg.buffer[i], i); in ZTEST()
49 ComplexMessage msg = ComplexMessage_init_zero; in ZTEST() local
51 msg.has_nested = true; in ZTEST()
[all …]
|
| /Zephyr-latest/samples/subsys/zbus/work_queue/src/ |
| D | main.c | 40 const struct sensor_msg *msg = zbus_chan_const_msg(chan); in fh1_cb() local
43 msg->temp, msg->press, msg->humidity); in fh1_cb()
50 const struct sensor_msg *msg = zbus_chan_const_msg(chan); in fh2_cb() local
53 msg->temp, msg->press, msg->humidity); in fh2_cb()
60 const struct sensor_msg *msg = zbus_chan_const_msg(chan); in fh3_cb() local
63 msg->temp, msg->press, msg->humidity); in fh3_cb()
80 struct sensor_msg msg; in wq_dh_cb() local
83 zbus_chan_read(sens->chan, &msg, K_MSEC(200)); in wq_dh_cb()
87 sens->handle, msg.temp, msg.press, msg.humidity); in wq_dh_cb()
136 struct sensor_msg msg; in thread_handler1_task() local
[all …]
|
| /Zephyr-latest/drivers/mipi_dsi/ |
| D | mipi_dsi.c | 15 struct mipi_dsi_msg msg = { in mipi_dsi_generic_read() local
24 msg.type = MIPI_DSI_GENERIC_READ_REQUEST_0_PARAM; in mipi_dsi_generic_read()
28 msg.type = MIPI_DSI_GENERIC_READ_REQUEST_1_PARAM; in mipi_dsi_generic_read()
32 msg.type = MIPI_DSI_GENERIC_READ_REQUEST_2_PARAM; in mipi_dsi_generic_read()
39 return mipi_dsi_transfer(dev, channel, &msg); in mipi_dsi_generic_read()
45 struct mipi_dsi_msg msg = { in mipi_dsi_generic_write() local
52 msg.type = MIPI_DSI_GENERIC_SHORT_WRITE_0_PARAM; in mipi_dsi_generic_write()
56 msg.type = MIPI_DSI_GENERIC_SHORT_WRITE_1_PARAM; in mipi_dsi_generic_write()
60 msg.type = MIPI_DSI_GENERIC_SHORT_WRITE_2_PARAM; in mipi_dsi_generic_write()
64 msg.type = MIPI_DSI_GENERIC_LONG_WRITE; in mipi_dsi_generic_write()
[all …]
|
| /Zephyr-latest/tests/bsim/babblekit/include/babblekit/ |
| D | testcase.h | 21 #define TEST_START(msg, ...) \ argument
24 bs_trace_info_time(2, "Test start: " msg "\n", ##__VA_ARGS__); \
35 #define TEST_FAIL(msg, ...) \ argument
38 bs_trace_error_time_line(msg "\n", ##__VA_ARGS__); \
54 #define TEST_PASS(msg, ...) \ argument
57 bs_trace_info_time(2, "Test end: " msg "\n", ##__VA_ARGS__); \
73 #define TEST_PASS_AND_EXIT(msg, ...) \ argument
76 bs_trace_info_time(2, "Test end: " msg "\n", ##__VA_ARGS__); \
110 #define TEST_PRINT(msg, ...) \ argument
112 msg "\n", ##__VA_ARGS__)
|
| /Zephyr-latest/tests/subsys/ipc/ipc_service/src/ |
| D | main.c | 13 uint8_t *msg = (uint8_t *) data; in received_cb() local
15 zassert_equal(*msg, expected, "msg doesn't match the expected value"); in received_cb()
17 printk("Received: %d, expected: %ld\n", *msg, expected); in received_cb()
33 uint8_t msg; in ZTEST() local
43 msg = 10; in ZTEST()
44 printk("Sending %d\n", msg); in ZTEST()
52 ret = ipc_service_send(&ept_10, &msg, sizeof(msg)); in ZTEST()
59 msg = 10; in ZTEST()
60 printk("Sending %d\n", msg); in ZTEST()
68 ret = ipc_service_send(&ept_20, &msg, sizeof(msg)); in ZTEST()
[all …]
|
| /Zephyr-latest/subsys/bluetooth/mesh/ |
| D | delayable_msg.c | 90 static void reschedule_delayable_msg(struct delayable_msg_ctx *msg) in reschedule_delayable_msg() argument
96 if (msg) { in reschedule_delayable_msg()
97 put_ctx_to_busy_list(msg); in reschedule_delayable_msg()
114 static int allocate_delayable_msg_chunks(struct delayable_msg_ctx *msg, int number) in allocate_delayable_msg_chunks() argument
124 sys_slist_append(&msg->chunks, node); in allocate_delayable_msg_chunks()
130 static void release_delayable_msg_chunks(struct delayable_msg_ctx *msg) in release_delayable_msg_chunks() argument
134 while ((node = sys_slist_get(&msg->chunks))) { in release_delayable_msg_chunks()
141 struct delayable_msg_ctx *msg; in allocate_delayable_msg_ctx() local
152 msg = CONTAINER_OF(node, struct delayable_msg_ctx, node); in allocate_delayable_msg_ctx()
153 sys_slist_init(&msg->chunks); in allocate_delayable_msg_ctx()
[all …]
|
| D | brg_cfg_srv.c | 20 BT_MESH_MODEL_BUF_DEFINE(msg, OP_SUBNET_BRIDGE_STATUS, 1); in bridge_status_send()
22 bt_mesh_model_msg_init(&msg, OP_SUBNET_BRIDGE_STATUS); in bridge_status_send()
23 net_buf_simple_add_u8(&msg, bt_mesh_brg_cfg_enable_get() ? 1 : 0); in bridge_status_send()
25 if (bt_mesh_model_send(model, ctx, &msg, NULL, NULL)) { in bridge_status_send()
57 BT_MESH_MODEL_BUF_DEFINE(msg, OP_BRIDGING_TABLE_STATUS, 9); in bridging_table_status_send()
59 bt_mesh_model_msg_init(&msg, OP_BRIDGING_TABLE_STATUS); in bridging_table_status_send()
60 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()
62 key_idx_pack_pair(&msg, entry->net_idx1, entry->net_idx2); in bridging_table_status_send()
63 net_buf_simple_add_le16(&msg, entry->addr1); in bridging_table_status_send()
[all …]
|
| D | health_cli.c | 193 BT_MESH_MODEL_BUF_DEFINE(msg, OP_ATTENTION_GET, 0); in bt_mesh_health_cli_attention_get()
198 bt_mesh_model_msg_init(&msg, OP_ATTENTION_GET); in bt_mesh_health_cli_attention_get()
207 return bt_mesh_msg_ackd_send(cli->model, ctx, &msg, attention ? &rsp : NULL); in bt_mesh_health_cli_attention_get()
213 BT_MESH_MODEL_BUF_DEFINE(msg, OP_ATTENTION_SET, 1); in bt_mesh_health_cli_attention_set()
218 bt_mesh_model_msg_init(&msg, OP_ATTENTION_SET); in bt_mesh_health_cli_attention_set()
219 net_buf_simple_add_u8(&msg, attention); in bt_mesh_health_cli_attention_set()
228 return bt_mesh_msg_ackd_send(cli->model, ctx, &msg, updated_attention ? &rsp : NULL); in bt_mesh_health_cli_attention_set()
234 BT_MESH_MODEL_BUF_DEFINE(msg, OP_ATTENTION_SET_UNREL, 1); in bt_mesh_health_cli_attention_set_unack()
236 bt_mesh_model_msg_init(&msg, OP_ATTENTION_SET_UNREL); in bt_mesh_health_cli_attention_set_unack()
237 net_buf_simple_add_u8(&msg, attention); in bt_mesh_health_cli_attention_set_unack()
[all …]
|
| D | op_agg.c | 19 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()
|
| /Zephyr-latest/subsys/logging/ |
| D | log_output_dict.c | 16 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()
25 output_hdr.package_len = msg->hdr.desc.package_len; 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()
35 uint8_t *data = log_msg_get_package(msg, &len); 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
[all …]
|
| D | log_multidomain_link.c | 33 struct log_multidomain_msg *msg = (struct log_multidomain_msg *)data; in log_multidomain_link_on_recv_cb() local
35 if (msg->status != Z_LOG_MULTIDOMAIN_STATUS_OK) { in log_multidomain_link_on_recv_cb()
42 switch (msg->id) { in log_multidomain_link_on_recv_cb()
45 msg->data.log_msg.data, in log_multidomain_link_on_recv_cb()
49 link_remote->dst.count = msg->data.domain_cnt.count; in log_multidomain_link_on_recv_cb()
52 link_remote->dst.count = msg->data.source_cnt.count; in log_multidomain_link_on_recv_cb()
59 memcpy(link_remote->dst.name.dst, msg->data.domain_name.name, slen); in log_multidomain_link_on_recv_cb()
68 memcpy(link_remote->dst.name.dst, msg->data.source_name.name, slen); in log_multidomain_link_on_recv_cb()
73 link_remote->dst.levels.level = msg->data.levels.level; in log_multidomain_link_on_recv_cb()
74 link_remote->dst.levels.runtime_level = msg->data.levels.runtime_level; in log_multidomain_link_on_recv_cb()
[all …]
|
| /Zephyr-latest/subsys/net/lib/shell/ |
| D | events.c | 49 struct event_msg msg; in event_handler() local
52 memset(&msg, 0, sizeof(msg)); in event_handler()
54 msg.len = MIN(sizeof(msg.data), cb->info_length); in event_handler()
55 msg.event = mgmt_event; in event_handler()
56 msg.iface = iface; in event_handler()
59 memcpy(msg.data, cb->info, msg.len); in event_handler()
62 ret = k_msgq_put(&event_mon_msgq, (void *)&msg, K_MSEC(10)); in event_handler()
84 static char *get_l3_desc(struct event_msg *msg, in get_l3_desc() argument
98 switch (msg->event) { in get_l3_desc()
102 info = net_addr_ntop(AF_INET6, msg->data, extra_info, in get_l3_desc()
[all …]
|
| /Zephyr-latest/drivers/firmware/scmi/ |
| D | clk.c | 28 struct scmi_message msg, reply; in scmi_clock_rate_get() local
41 msg.hdr = SCMI_MESSAGE_HDR_MAKE(SCMI_CLK_MSG_CLOCK_RATE_GET, in scmi_clock_rate_get()
43 msg.len = sizeof(clk_id); in scmi_clock_rate_get()
44 msg.content = &clk_id; in scmi_clock_rate_get()
46 reply.hdr = msg.hdr; in scmi_clock_rate_get()
50 ret = scmi_send_message(proto, &msg, &reply); in scmi_clock_rate_get()
67 struct scmi_message msg, reply; in scmi_clock_config_set() local
94 msg.hdr = SCMI_MESSAGE_HDR_MAKE(SCMI_CLK_MSG_CLOCK_CONFIG_SET, in scmi_clock_config_set()
96 msg.len = sizeof(*cfg); in scmi_clock_config_set()
97 msg.content = cfg; in scmi_clock_config_set()
[all …]
|
| D | shmem.c | 60 int scmi_shmem_read_message(const struct device *shmem, struct scmi_message *msg) in scmi_shmem_read_message() argument
71 if (!msg) { in scmi_shmem_read_message()
75 if (!msg->content && msg->len) { in scmi_shmem_read_message()
79 if (cfg->size < (sizeof(*layout) + msg->len)) { in scmi_shmem_read_message()
85 if (msg->len != (layout->len - sizeof(layout->msg_hdr))) { in scmi_shmem_read_message()
87 msg->len, in scmi_shmem_read_message()
93 if (layout->msg_hdr != msg->hdr) { in scmi_shmem_read_message()
95 msg->hdr, layout->msg_hdr); in scmi_shmem_read_message()
99 if (msg->content) { in scmi_shmem_read_message()
100 scmi_shmem_memcpy(POINTER_TO_UINT(msg->content), in scmi_shmem_read_message()
[all …]
|
| /Zephyr-latest/samples/tfm_integration/tfm_secure_partition/dummy_partition/ |
| D | dummy_partition.c | 72 static psa_status_t tfm_dp_secret_digest_ipc(psa_msg_t *msg) in tfm_dp_secret_digest_ipc() argument
77 if (msg->in_size[0] != sizeof(secret_index)) { in tfm_dp_secret_digest_ipc()
82 num = psa_read(msg->handle, 0, &secret_index, msg->in_size[0]); in tfm_dp_secret_digest_ipc()
83 if (num != msg->in_size[0]) { in tfm_dp_secret_digest_ipc()
87 return tfm_dp_secret_digest(secret_index, msg->out_size[0], in tfm_dp_secret_digest_ipc()
88 &msg->out_size[0], psa_write_digest, in tfm_dp_secret_digest_ipc()
89 (void *)msg->handle); in tfm_dp_secret_digest_ipc()
95 psa_msg_t msg; in dp_signal_handle() local
97 status = psa_get(signal, &msg); in dp_signal_handle()
98 switch (msg.type) { in dp_signal_handle()
[all …]
|
| /Zephyr-latest/tests/bsim/bluetooth/mesh/src/ |
| D | test_friendship.c | 568 net_buf_simple_reset(test_model->pub->msg); in test_lpn_msg_mesh()
569 bt_mesh_model_msg_init(test_model->pub->msg, TEST_MSG_OP_1); in test_lpn_msg_mesh()
630 struct bt_mesh_test_msg msg; in test_lpn_overflow() local
648 ASSERT_OK_MSG(bt_mesh_test_recv_msg(&msg, K_SECONDS(2)), in test_lpn_overflow()
651 if (msg.len != 5) { in test_lpn_overflow()
652 FAIL("Message %d: Invalid length %d", i, msg.len); in test_lpn_overflow()
655 if (msg.ctx.recv_dst != cfg->addr) { in test_lpn_overflow()
657 msg.ctx.recv_dst); in test_lpn_overflow()
663 if (msg.seq != i + 2) { in test_lpn_overflow()
664 FAIL("Message %d: Invalid seq 0x%02x", i, msg.seq); in test_lpn_overflow()
[all …]
|
| /Zephyr-latest/samples/subsys/zbus/msg_subscriber/ |
| D | README.rst | 1 .. zephyr:code-sample:: zbus-msg-subscriber
36 I: From msg subscriber bar_msg_sub1 -> Acc x=1, y=10, z=100
37 I: From msg subscriber bar_msg_sub2 -> Acc x=1, y=10, z=100
38 I: From msg subscriber bar_msg_sub3 -> Acc x=1, y=10, z=100
39 I: From msg subscriber bar_msg_sub4 -> Acc x=1, y=10, z=100
40 I: From msg subscriber bar_msg_sub5 -> Acc x=1, y=10, z=100
41 I: From msg subscriber bar_msg_sub6 -> Acc x=1, y=10, z=100
42 I: From msg subscriber bar_msg_sub7 -> Acc x=1, y=10, z=100
43 I: From msg subscriber bar_msg_sub8 -> Acc x=1, y=10, z=100
44 I: From msg subscriber bar_msg_sub9 -> Acc x=1, y=10, z=100
[all …]
|
