| /Zephyr-Core-3.6.0/samples/subsys/debug/fuzz/src/ |
| D | main.c | 26 #define GEN_CHECK(cur, nxt) \ argument
28 void __attribute__((noinline)) check##cur(const uint8_t *data, size_t sz) \
30 if (cur < sz && data[cur] == key[cur]) { \
31 if (!found[cur]) { \
32 printk("#\n# Found key %d\n#\n", cur); \
33 found[cur] = true; \
35 if (cur == LASTKEY) { \
|
| /Zephyr-Core-3.6.0/subsys/net/lib/mqtt/ |
| D | mqtt_encoder.c | 48 if ((buf->end - buf->cur) < sizeof(uint8_t)) { in pack_uint8()
52 NET_DBG(">> val:%02x cur:%p, end:%p", val, (void *)buf->cur, (void *)buf->end); in pack_uint8()
55 *(buf->cur++) = val; in pack_uint8()
72 if ((buf->end - buf->cur) < sizeof(uint16_t)) { in pack_uint16()
76 NET_DBG(">> val:%04x cur:%p, end:%p", val, (void *)buf->cur, (void *)buf->end); in pack_uint16()
79 *(buf->cur++) = (val >> 8) & 0xFF; in pack_uint16()
80 *(buf->cur++) = val & 0xFF; in pack_uint16()
97 if ((buf->end - buf->cur) < GET_UT8STR_BUFFER_SIZE(str)) { in pack_utf8_str()
102 (uint32_t)GET_UT8STR_BUFFER_SIZE(str), (void *)buf->cur, (void *)buf->end); in pack_utf8_str()
107 memcpy(buf->cur, str->utf8, str->size); in pack_utf8_str()
[all …]
|
| D | mqtt_decoder.c | 32 NET_DBG(">> cur:%p, end:%p", (void *)buf->cur, (void *)buf->end); in unpack_uint8()
34 if ((buf->end - buf->cur) < sizeof(uint8_t)) { in unpack_uint8()
38 *val = *(buf->cur++); in unpack_uint8()
58 NET_DBG(">> cur:%p, end:%p", (void *)buf->cur, (void *)buf->end); in unpack_uint16()
60 if ((buf->end - buf->cur) < sizeof(uint16_t)) { in unpack_uint16()
64 *val = *(buf->cur++) << 8; /* MSB */ in unpack_uint16()
65 *val |= *(buf->cur++); /* LSB */ in unpack_uint16()
88 NET_DBG(">> cur:%p, end:%p", (void *)buf->cur, (void *)buf->end); in unpack_utf8_str()
95 if ((buf->end - buf->cur) < utf8_strlen) { in unpack_utf8_str()
103 str->utf8 = buf->cur; in unpack_utf8_str()
[all …]
|
| D | mqtt.c | 34 buf->cur = client->tx_buf; in tx_buf_init()
92 err_code = mqtt_transport_write(client, packet.cur, in client_connect()
93 packet.end - packet.cur); in client_connect()
269 io_vector[0].iov_base = packet.cur; in mqtt_publish()
270 io_vector[0].iov_len = packet.end - packet.cur; in mqtt_publish()
316 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_publish_qos1_ack()
353 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_publish_qos2_receive()
390 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_publish_qos2_release()
427 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_publish_qos2_complete()
462 err_code = client_write(client, packet.cur, packet.end - packet.cur); in mqtt_disconnect()
[all …]
|
| D | mqtt_rx.c | 155 if (length <= (buf->end - buf->cur)) { in mqtt_read_message_chunk()
162 remaining = length - (buf->end - buf->cur); in mqtt_read_message_chunk()
210 variable_header_length = *buf->cur << 8; /* MSB */ in mqtt_read_publish_var_header()
211 variable_header_length |= *(buf->cur + 1); /* LSB */ in mqtt_read_publish_var_header()
247 buf->cur = client->rx_buf; in mqtt_read_and_parse_fixed_header()
263 buf.cur = client->rx_buf; in mqtt_handle_rx()
|
| /Zephyr-Core-3.6.0/scripts/west_commands/completion/ |
| D | west-completion.bash | 120 cur)
121 cur=$cur_
224 _tilde "$cur" || return
229 x=$( compgen -d -- "$cur" ) &&
236 _quote_readline_by_ref "$cur" quoted
309 if [ "$cur" = "=" ] ; then # key= case
312 elif [[ $cur == *=* ]] ; then # key=value case (OSX)
313 key=${cur%=*}
379 COMPREPLY=($(compgen -W "${*:1}" -- "$cur"))
411 case "$cur" in
[all …]
|
| /Zephyr-Core-3.6.0/include/zephyr/arch/xtensa/ |
| D | atomic_xtensa.h | 82 atomic_val_t res, cur; \
84 cur = *target; \
85 res = xtensa_cas(target, cur, (expr)); \
86 } while (res != cur); \
100 return Z__GEN_ATOMXCHG(cur + value); in atomic_add()
107 return Z__GEN_ATOMXCHG(cur - value); in atomic_sub()
114 return Z__GEN_ATOMXCHG(cur + 1); in atomic_inc()
121 return Z__GEN_ATOMXCHG(cur - 1); in atomic_dec()
128 return Z__GEN_ATOMXCHG(cur | value); in atomic_or()
135 return Z__GEN_ATOMXCHG(cur ^ value); in atomic_xor()
[all …]
|
| /Zephyr-Core-3.6.0/subsys/stats/ |
| D | stats.c | 22 const struct stats_name_map *cur; in stats_get_name() local
33 cur = hdr->s_map + i; in stats_get_name()
34 if (cur->snm_off == off) { in stats_get_name()
35 return cur->snm_name; in stats_get_name()
175 stats_group_get_next(const struct stats_hdr *cur) in stats_group_get_next() argument
177 if (cur == NULL) { in stats_group_get_next()
182 return cur->s_next; in stats_group_get_next()
222 struct stats_hdr *cur; in stats_register() local
226 for (cur = stats_list; cur != NULL; cur = cur->s_next) { in stats_register()
227 if (strcmp(cur->s_name, name) == 0) { in stats_register()
[all …]
|
| /Zephyr-Core-3.6.0/drivers/console/ |
| D | uart_console.c | 244 static uint8_t cur, end; variable
285 if (ansi_val > cur) { in handle_ansi()
290 cur -= ansi_val; in handle_ansi()
299 cur += ansi_val; in handle_ansi()
303 if (!cur) { in handle_ansi()
307 cursor_backward(cur); in handle_ansi()
308 end += cur; in handle_ansi()
309 cur = 0U; in handle_ansi()
317 cur += end; in handle_ansi()
326 del_char(&line[cur], --end); in handle_ansi()
[all …]
|
| /Zephyr-Core-3.6.0/subsys/tracing/ |
| D | tracing_backend_uart.c | 32 static uint32_t length, cur; in uart_isr() local
53 cmd[cur] = '\0'; in uart_isr()
54 tracing_cmd_handle(cmd, cur); in uart_isr()
56 cur = 0U; in uart_isr()
62 if (cur < length - 1) { in uart_isr()
63 cmd[cur++] = byte; in uart_isr()
|
| /Zephyr-Core-3.6.0/drivers/interrupt_controller/ |
| D | Kconfig.multilevel.aggregator_template | 3 config $(cur-level)_LVL_INTR_0$(aggregator)_OFFSET
4 int "Level $(prev-level-num) IRQ line for $(cur-level) level aggregator $(aggregator)"
6 depends on $(cur-level)_LEVEL_INTERRUPTS
9 $(cur-level-num) interrupt aggregator $(aggregator).
|
| D | Kconfig.multilevel | 72 cur-level-num = 2
73 cur-level = 2ND
126 cur-level-num = 3
127 cur-level = 3RD
|
| /Zephyr-Core-3.6.0/subsys/mgmt/mcumgr/grp/stat_mgmt/src/ |
| D | stat_mgmt.c | 191 const struct stats_hdr *cur = NULL; in stat_mgmt_list() local
197 cur = stats_group_get_next(cur); in stat_mgmt_list()
198 if (cur != NULL) { in stat_mgmt_list()
201 } while (cur != NULL); in stat_mgmt_list()
214 cur = NULL; in stat_mgmt_list()
216 cur = stats_group_get_next(cur); in stat_mgmt_list()
217 if (cur != NULL) { in stat_mgmt_list()
218 ok = zcbor_tstr_put_term(zse, cur->s_name, in stat_mgmt_list()
221 } while (ok && cur != NULL); in stat_mgmt_list()
|
| /Zephyr-Core-3.6.0/tests/subsys/fs/fs_api/src/ |
| D | test_fs.c | 21 static char *cur = buffer; variable
103 cur = read_pos; in temp_read()
128 cur = buffer + file_length; in temp_write()
142 cur = buffer + offset; in temp_seek()
145 cur += offset; in temp_seek()
148 cur = buffer + file_length + offset; in temp_seek()
154 if ((cur < buffer) || (cur > buffer + file_length)) { in temp_seek()
171 return cur - buffer; in temp_tell()
|
| /Zephyr-Core-3.6.0/subsys/fs/fcb/ |
| D | fcb_append.c | 18 struct flash_sector *cur; in fcb_new_sector() local
23 cur = fcb->f_active.fe_sector; in fcb_new_sector()
25 cur = fcb_getnext_sector(fcb, cur); in fcb_new_sector()
27 prev = cur; in fcb_new_sector()
29 if (cur == fcb->f_oldest) { in fcb_new_sector()
|
| /Zephyr-Core-3.6.0/arch/x86/core/ |
| D | spec_ctrl.c | 37 uint64_t cur = z_x86_msr_read(X86_SPEC_CTRL_MSR); in spec_ctrl_init() local
40 cur | enable_bits); in spec_ctrl_init()
|
| /Zephyr-Core-3.6.0/subsys/net/ip/ |
| D | utils.c | 602 struct net_pkt_cursor *cur = &pkt->cursor; in pkt_calc_chksum() local
605 if (!cur->buf || !cur->pos) { in pkt_calc_chksum()
609 len = cur->buf->len - (cur->pos - cur->buf->data); in pkt_calc_chksum()
611 while (cur->buf) { in pkt_calc_chksum()
612 sum = calc_chksum(sum, cur->pos, len); in pkt_calc_chksum()
614 cur->buf = cur->buf->frags; in pkt_calc_chksum()
615 if (!cur->buf || !cur->buf->len) { in pkt_calc_chksum()
619 cur->pos = cur->buf->data; in pkt_calc_chksum()
622 sum += *cur->pos; in pkt_calc_chksum()
623 if (sum < *cur->pos) { in pkt_calc_chksum()
[all …]
|
| /Zephyr-Core-3.6.0/subsys/mgmt/osdp/src/ |
| D | osdp_phy.c | 261 uint16_t comp, cur; in osdp_phy_check_packet() local
310 cur = (buf[pkt_len + 1] << 8) | buf[pkt_len]; in osdp_phy_check_packet()
312 if (comp != cur) { in osdp_phy_check_packet()
313 LOG_ERR("Invalid crc 0x%04x/0x%04x", comp, cur); in osdp_phy_check_packet()
320 cur = buf[pkt_len]; in osdp_phy_check_packet()
322 if (comp != cur) { in osdp_phy_check_packet()
323 LOG_ERR("Invalid checksum %02x/%02x", comp, cur); in osdp_phy_check_packet()
379 cur = osdp_phy_get_seq_number(pd, is_pd_mode(pd)); in osdp_phy_check_packet()
380 if (cur != comp && !ISSET_FLAG(pd, PD_FLAG_SKIP_SEQ_CHECK)) { in osdp_phy_check_packet()
381 LOG_ERR("packet seq mismatch %d/%d", cur, comp); in osdp_phy_check_packet()
|
| /Zephyr-Core-3.6.0/tests/net/lib/mqtt_packet/src/ |
| D | mqtt_packet.c | 438 .cur = publish_corrupted,
555 .cur = max_pkt_len, .end = max_pkt_len + sizeof(max_pkt_len)
561 .cur = corrupted_pkt_len,
690 if (buf->end - buf->cur != len) { in eval_buffers()
694 if (memcmp(expected, buf->cur, buf->end - buf->cur) != 0) { in eval_buffers()
703 print_array(buf->cur, buf->end - buf->cur); in eval_buffers()
726 buf.cur = client.tx_buf; in eval_msg_connect()
746 buf.cur = client.tx_buf; in eval_msg_disconnect()
773 buf.cur = client.tx_buf; in eval_msg_publish()
846 buf.cur = client.tx_buf; in eval_msg_subscribe()
[all …]
|
| /Zephyr-Core-3.6.0/drivers/flash/ |
| D | flash_gd32_v3.c | 96 uint32_t cur = 0U, next = 0U; in flash_gd32_valid_range() local
115 cur = next; in flash_gd32_valid_range()
120 if ((offset > cur) && (offset < next)) { in flash_gd32_valid_range()
125 if (((offset + len) > cur) && in flash_gd32_valid_range()
|
| /Zephyr-Core-3.6.0/tests/kernel/common/src/ |
| D | timeout_order.c | 16 static int results[NUM_TIMEOUTS], cur; variable
28 results[cur++] = id; in thread()
|
| /Zephyr-Core-3.6.0/scripts/kconfig/ |
| D | kconfiglib.py | 3616 cur = node
3617 while cur.next and _auto_menu_dep(node, cur.next):
3620 self._finalize_node(cur.next, visible_if)
3621 cur = cur.next
3622 cur.parent = node
3624 if cur is not node:
3628 node.next = cur.next
3629 cur.next = None
3644 cur = node.list
3645 while cur:
[all …]
|
| /Zephyr-Core-3.6.0/tests/arch/x86/pagetables/src/ |
| D | main.c | 230 struct k_thread *cur = k_current_get(); in z_impl_dump_my_ptables() local
232 printk("Page tables for thread %p\n", cur); in z_impl_dump_my_ptables()
233 z_x86_dump_page_tables(z_x86_thread_page_tables_get(cur)); in z_impl_dump_my_ptables()
|
| /Zephyr-Core-3.6.0/subsys/bluetooth/services/ots/ |
| D | ots_client.c | 186 if (cur_inst->rcvd_size >= cur_object->size.cur) { in rx_done()
190 if (cur_inst->rcvd_size > cur_object->size.cur) { in rx_done()
192 cur_object->size.cur); in rx_done()
200 const uint32_t rcv_size = cur_object->size.cur; in rx_done()
212 const uint32_t rcv_size = cur_object->size.cur; in rx_done()
808 cur_object->size.cur = in read_object_size_cb()
815 cur_object->size.cur, in read_object_size_cb()
818 if (cur_object->size.cur == 0) { in read_object_size_cb()
821 } else if (cur_object->size.cur > in read_object_size_cb()
827 cur_object->size.cur); in read_object_size_cb()
[all …]
|
| /Zephyr-Core-3.6.0/subsys/bluetooth/mesh/ |
| D | beacon.c | 437 sub->secure_beacon.last = sub->secure_beacon.cur; in sub_update_beacon_observation()
438 sub->secure_beacon.cur = 0U; in sub_update_beacon_observation()
441 sub->priv_beacon.last = sub->priv_beacon.cur; in sub_update_beacon_observation()
442 sub->priv_beacon.cur = 0U; in sub_update_beacon_observation()
616 bt_mesh_beacon_enabled()) && beacon->cur < 0xff) { in net_beacon_register()
617 beacon->cur++; in net_beacon_register()
810 sub->secure_beacon.cur = 0U; in subnet_beacon_enable()
814 sub->priv_beacon.cur = 0U; in subnet_beacon_enable()
|
