| /Zephyr-latest/samples/userspace/prod_consumer/src/ |
| D | app_b.c | 38 void *payload; in processor_thread() local
57 payload = k_queue_get(&shared_queue_incoming, K_FOREVER); in processor_thread()
71 k_queue_alloc_append(&shared_queue_outgoing, payload); in processor_thread()
|
| D | app_a.c | 83 void *payload; in monitor_entry() local
102 payload = sys_heap_alloc(&shared_pool, in monitor_entry()
104 if (payload == NULL) { in monitor_entry()
114 ret = k_msgq_get(&mqueue, payload, K_FOREVER); in monitor_entry()
132 k_queue_alloc_append(&shared_queue_incoming, payload); in monitor_entry()
|
| /Zephyr-latest/tests/net/lib/lwm2m/content_raw_cbor/src/ |
| D | main.c | 67 static void test_payload_set(const uint8_t *payload, size_t len) in test_payload_set() argument
69 memcpy(test_payload + 1, payload, len); in test_payload_set()
653 struct test_payload_buffer payload[] = { in ZTEST() local
685 test_payload_set(payload[i].data, payload[i].len); in ZTEST()
688 zassert_equal(ret, payload[i].len, "Invalid length returned"); in ZTEST()
690 zassert_equal(test_in.offset, payload[i].len + 1, in ZTEST()
708 struct test_payload_buffer payload[] = { in ZTEST() local
742 test_payload_set(payload[i].data, payload[i].len); in ZTEST()
745 zassert_equal(ret, payload[i].len, "Invalid length returned"); in ZTEST()
747 zassert_equal(test_in.offset, payload[i].len + 1, in ZTEST()
[all …]
|
| /Zephyr-latest/samples/net/secure_mqtt_sensor_actuator/src/ |
| D | mqtt_client.c | 126 uint8_t payload[CONFIG_NET_SAMPLE_MQTT_PAYLOAD_SIZE]; in on_mqtt_publish() local
128 rc = mqtt_read_publish_payload(client, payload, in on_mqtt_publish()
135 payload[rc] = '\0'; in on_mqtt_publish()
139 evt->param.publish.message.topic.topic.utf8, payload); in on_mqtt_publish()
144 device_command_handler(payload); in on_mqtt_publish()
267 static int get_mqtt_payload(struct mqtt_binstr *payload) in get_mqtt_payload() argument
285 payload->data = payload_buf; in get_mqtt_payload()
286 payload->len = strlen(payload->data); in get_mqtt_payload()
295 struct mqtt_binstr payload; in app_mqtt_publish() local
306 rc = get_mqtt_payload(&payload); in app_mqtt_publish()
[all …]
|
| /Zephyr-latest/samples/net/sockets/coap_server/src/ |
| D | observer.c | 29 char payload[14]; in send_notification_packet() local
69 r = snprintk((char *) payload, sizeof(payload), in send_notification_packet()
75 r = coap_packet_append_payload(&response, (uint8_t *)payload, in send_notification_packet()
76 strlen(payload)); in send_notification_packet()
|
| /Zephyr-latest/subsys/net/lib/lwm2m/ |
| D | lwm2m_rw_cbor.c | 79 tag_sz = CPKT_CBOR_W_SZ(states[0].payload, out->out_cpkt); in put_time()
89 str_sz = CPKT_CBOR_W_SZ(states[0].payload, out->out_cpkt); in put_time()
107 payload_len = CPKT_CBOR_W_SZ(states[0].payload, out->out_cpkt); in put_s64()
127 payload_len = CPKT_CBOR_W_SZ(states[0].payload, out->out_cpkt); in put_s32()
158 payload_len = CPKT_CBOR_W_SZ(states[0].payload, out->out_cpkt); in put_float()
178 payload_len = CPKT_CBOR_W_SZ(states[0].payload, out->out_cpkt); in put_string()
198 payload_len = CPKT_CBOR_W_SZ(states[0].payload, out->out_cpkt); in put_opaque()
217 payload_len = CPKT_CBOR_W_SZ(states[0].payload, out->out_cpkt); in put_bool()
245 int len = ICTX_CBOR_R_SZ(states[0].payload, in); in get_s64()
262 int len = ICTX_CBOR_R_SZ(states[0].payload, in); in get_s32()
[all …]
|
| /Zephyr-latest/subsys/bluetooth/mesh/ |
| D | testing.c | 41 const void *payload, size_t payload_len) in bt_mesh_test_net_recv() argument
47 cb->net_recv(ttl, ctl, src, dst, payload, payload_len); in bt_mesh_test_net_recv()
52 void bt_mesh_test_model_recv(uint16_t src, uint16_t dst, const void *payload, size_t payload_len) in bt_mesh_test_model_recv() argument
58 cb->model_recv(src, dst, payload, payload_len); in bt_mesh_test_model_recv()
|
| /Zephyr-latest/include/zephyr/bluetooth/ |
| D | ead.h | 78 const uint8_t *payload, size_t payload_size, uint8_t *encrypted_payload);
105 uint8_t *payload);
|
| /Zephyr-latest/arch/posix/core/ |
| D | posix_core_nsi.c | 46 int posix_new_thread(void *payload) in posix_new_thread() argument
48 return nct_new_thread(te_state, payload); in posix_new_thread()
|
| /Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/ |
| D | main.c | 45 const uint8_t *payload; member
230 zassert_equal(length - var_len, strlen(test_ctx.payload), in broker_validate_packet()
232 zassert_mem_equal(buf + var_len, test_ctx.payload, in broker_validate_packet()
233 strlen(test_ctx.payload), "Invalid payload"); in broker_validate_packet()
444 evt->param.publish.message.payload.len, in publish_handler()
446 evt->param.publish.message.payload.len); in publish_handler()
450 zassert_mem_equal(test_ctx.payload, buf, in publish_handler()
451 evt->param.publish.message.payload.len, in publish_handler()
609 test_ctx.payload_left = strlen(test_ctx.payload); in test_publish()
618 param.message.payload.data = (uint8_t *)test_ctx.payload; in test_publish()
[all …]
|
| /Zephyr-latest/tests/net/lib/lwm2m/content_json/src/ |
| D | main.c | 129 static void test_payload_set(const char *payload) in test_payload_set() argument
131 memcpy(test_msg.msg_data + 1, payload, strlen(payload)); in test_payload_set()
132 test_msg.cpkt.offset = strlen(payload) + 1; in test_payload_set()
491 char * const payload[] = { in ZTEST() local
501 test_payload_set(payload[i]); in ZTEST()
523 char * const payload[] = { in ZTEST() local
533 test_payload_set(payload[i]); in ZTEST()
554 const char *payload = in ZTEST() local
560 test_payload_set(payload); in ZTEST()
584 char * const payload[] = { in ZTEST() local
[all …]
|
| /Zephyr-latest/subsys/net/l2/ppp/ |
| D | pap.c | 23 uint8_t payload[] = { 5, 'b', 'l', 'a', 'n', 'k', in pap_config_info_add() local
27 pkt = net_pkt_alloc_with_buffer(ppp_fsm_iface(fsm), sizeof(payload), in pap_config_info_add()
33 (void)net_pkt_write(pkt, payload, sizeof(payload)); in pap_config_info_add()
|
| /Zephyr-latest/samples/net/cloud/tagoio_http_post/src/ |
| D | main.c | 46 (void)snprintf(ctx.payload, sizeof(ctx.payload), in collect_data()
|
| D | sockets.c | 115 req.payload = ctx->payload; in tagoio_http_push()
116 req.payload_len = strlen(ctx->payload); in tagoio_http_push()
|
| /Zephyr-latest/subsys/net/lib/websocket/ |
| D | websocket.c | 606 uint8_t *payload, size_t payload_len, in websocket_prepare_and_send() argument
614 io_vector[1].iov_base = payload; in websocket_prepare_and_send()
624 if ((payload != NULL) && (payload_len > 0)) { in websocket_prepare_and_send()
625 LOG_HEXDUMP_DBG(payload, payload_len, "Payload"); in websocket_prepare_and_send()
652 int websocket_send_msg(int ws_sock, const uint8_t *payload, size_t payload_len, in websocket_send_msg() argument
658 uint8_t *data_to_send = (uint8_t *)payload; in websocket_send_msg()
730 if ((payload != NULL) && (payload_len > 0)) { in websocket_send_msg()
736 memcpy(data_to_send, payload, payload_len); in websocket_send_msg()
752 if (data_to_send != payload) { in websocket_send_msg()
783 static int websocket_parse(struct websocket_context *ctx, struct websocket_buffer *payload) in websocket_parse() argument
[all …]
|
| /Zephyr-latest/samples/net/mqtt_publisher/src/ |
| D | main.c | 220 static APP_BMEM char payload[30]; in get_mqtt_payload() local
222 snprintk(payload, sizeof(payload), "{d:{temperature:%d}}", in get_mqtt_payload()
225 static APP_DMEM char payload[] = "DOORS:OPEN_QoSx"; in get_mqtt_payload()
227 payload[strlen(payload) - 1] = '0' + qos; in get_mqtt_payload()
230 return payload; in get_mqtt_payload()
251 param.message.payload.data = get_mqtt_payload(qos); in publish()
252 param.message.payload.len = in publish()
253 strlen(param.message.payload.data); in publish()
|
| /Zephyr-latest/drivers/serial/ |
| D | uart_hostlink.c | 114 volatile union payload_u payload; member
215 return sizeof(__HOSTLINK__.payload); in hl_payload_size()
337 hl_static_pack_int(&__HOSTLINK__.payload.pkt_write_char_put.syscall_nr, HL_SYSCALL_WRITE); in hl_write_char()
339 hl_static_pack_int(&__HOSTLINK__.payload.pkt_write_char_put.fd, fd); in hl_write_char()
341 hl_static_pack_char(&__HOSTLINK__.payload.pkt_write_char_put.buff, c); in hl_write_char()
343 hl_static_pack_int(&__HOSTLINK__.payload.pkt_write_char_put.nbyte, 1); in hl_write_char()
349 int ret = hl_static_unpack_int(&__HOSTLINK__.payload.pkt_write_char_get.byte_written, &bwr); in hl_write_char()
|
| /Zephyr-latest/tests/subsys/logging/log_syst/src/ |
| D | mock_backend.c | 64 const char *payload) in validate_msg() argument
102 zassert_mem_equal(output_str, payload, strlen(payload), in validate_msg()
|
| /Zephyr-latest/soc/realtek/ec/common/rts5912_imgtool/ |
| D | img_gen.py | 91 payload = bytearray(0)
126 payload[: len(header)] = header
129 signed.write(payload)
|
| /Zephyr-latest/drivers/disk/nvme/ |
| D | nvme_cmd.h | 367 void *payload; member
401 void *payload,
409 uint32_t nsid, void *payload,
432 void *payload, uint32_t payload_size,
437 void *payload, uint32_t payload_size,
459 struct nvme_request *nvme_allocate_request_vaddr(void *payload, in nvme_allocate_request_vaddr() argument
469 request->payload = payload; in nvme_allocate_request_vaddr()
|
| /Zephyr-latest/doc/connectivity/canbus/ |
| D | isotp.rst | 20 This transport protocol extends the limited payload data size for classical
23 behavior. ISO-TP segments packets into small fragments depending on the payload
32 the entire payload data and additionally, the first few bytes of payload data.
|
| /Zephyr-latest/samples/net/sockets/http_server/src/static_web_resources/ |
| D | main.js | 25 const payload = JSON.stringify({"led_num" : 0, "led_state" : state});
27 const response = await fetch("/led", {method : "POST", body : payload});
|
| /Zephyr-latest/drivers/ieee802154/ |
| D | ieee802154_b91.c | 174 static int b91_set_tx_payload(uint8_t *payload, uint8_t payload_len) in b91_set_tx_payload() argument
191 memcpy(data.tx_buffer + B91_PAYLOAD_OFFSET, payload, payload_len); in b91_set_tx_payload()
265 uint8_t *payload; in b91_rf_rx_isr() local
288 payload = (uint8_t *)(data.rx_buffer + B91_PAYLOAD_OFFSET); in b91_rf_rx_isr()
292 ((payload[B91_FRAME_TYPE_OFFSET] & B91_FRAME_TYPE_MASK) == B91_ACK_TYPE)) { in b91_rf_rx_isr()
300 if (b91_run_filter(payload) == false) { in b91_rf_rx_isr()
306 if (payload[B91_FRAME_TYPE_OFFSET] & B91_ACK_REQUEST) { in b91_rf_rx_isr()
307 b91_send_ack(payload[B91_DSN_OFFSET]); in b91_rf_rx_isr()
318 if (net_pkt_write(pkt, payload, length)) { in b91_rf_rx_isr()
|
| /Zephyr-latest/subsys/bluetooth/controller/ll_sw/nordic/lll/ |
| D | lll_adv_iso.c | 317 pdu->payload[0] = lll->bn_curr; in prepare_cb_common()
318 pdu->payload[1] = lll->irc_curr; in prepare_cb_common()
319 pdu->payload[2] = lll->ptc_curr; in prepare_cb_common()
320 pdu->payload[3] = lll->bis_curr; in prepare_cb_common()
322 pdu->payload[4] = payload_count; in prepare_cb_common()
323 pdu->payload[5] = payload_count >> 8; in prepare_cb_common()
324 pdu->payload[6] = payload_count >> 16; in prepare_cb_common()
325 pdu->payload[7] = payload_count >> 24; in prepare_cb_common()
326 pdu->payload[8] = payload_count >> 32; in prepare_cb_common()
785 pdu->payload[0] = lll->bn_curr; in isr_tx_common()
[all …]
|
| /Zephyr-latest/samples/net/cloud/aws_iot_mqtt/ |
| D | README.rst | 70 ``zephyr_sample/data`` topic, and publish a payload to the ``zephyr_sample/downlink``
71 topic. The device console will display the payload received by your device, and
89 …[00:00:03.390,000] <inf> aws: PUBLISHED on topic "zephyr_sample/data" [ id: 1 qos: 0 ], payload: 1…
90 [00:00:03.390,000] <dbg> aws: publish_message: Published payload:
93 …6,000] <inf> aws: RECEIVED on topic "zephyr_sample/downlink" [ id: 13 qos: 0 ] payload: 45 / 4096 B
94 [00:00:11.856,000] <dbg> aws: handle_published_message: Received payload:
98 …[00:00:11.857,000] <inf> aws: PUBLISHED on topic "zephyr_sample/data" [ id: 2 qos: 0 ], payload: 1…
99 [00:00:11.857,000] <dbg> aws: publish_message: Published payload:
|
