Home
last modified time | relevance | path

Searched refs:cur (Results 1 – 25 of 42) sorted by relevance

12

/Zephyr-Core-2.7.6/subsys/net/lib/mqtt/
Dmqtt_encoder.c48 if ((buf->end - buf->cur) < sizeof(uint8_t)) { in pack_uint8()
52 MQTT_TRC(">> val:%02x cur:%p, end:%p", val, buf->cur, 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 MQTT_TRC(">> val:%04x cur:%p, end:%p", val, buf->cur, 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), buf->cur, buf->end); in pack_utf8_str()
107 memcpy(buf->cur, str->utf8, str->size); in pack_utf8_str()
[all …]
Dmqtt_decoder.c32 MQTT_TRC(">> cur:%p, end:%p", buf->cur, 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 MQTT_TRC(">> cur:%p, end:%p", buf->cur, 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 MQTT_TRC(">> cur:%p, end:%p", buf->cur, 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 …]
Dmqtt.c34 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 …]
Dmqtt_rx.c155 if (length <= (buf->end - buf->cur)) { in mqtt_read_message_chunk()
162 remaining = length - (buf->end - buf->cur); in mqtt_read_message_chunk()
208 variable_header_length = *buf->cur << 8; /* MSB */ in mqtt_read_publish_var_header()
209 variable_header_length |= *(buf->cur + 1); /* LSB */ in mqtt_read_publish_var_header()
245 buf->cur = client->rx_buf; in mqtt_read_and_parse_fixed_header()
261 buf.cur = client->rx_buf; in mqtt_handle_rx()
/Zephyr-Core-2.7.6/scripts/west_commands/completion/
Dwest-completion.bash120 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-2.7.6/include/arch/xtensa/
Datomic_xtensa.h62 atomic_val_t res, cur; \
64 cur = *target; \
65 res = xtensa_cas(target, cur, (expr)); \
66 } while (res != cur); \
78 return Z__GEN_ATOMXCHG(cur + value); in atomic_add()
84 return Z__GEN_ATOMXCHG(cur - value); in atomic_sub()
90 return Z__GEN_ATOMXCHG(cur + 1); in atomic_inc()
96 return Z__GEN_ATOMXCHG(cur - 1); in atomic_dec()
102 return Z__GEN_ATOMXCHG(cur | value); in atomic_or()
108 return Z__GEN_ATOMXCHG(cur ^ value); in atomic_xor()
[all …]
/Zephyr-Core-2.7.6/subsys/stats/
Dstats.c22 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-2.7.6/drivers/console/
Duart_console.c237 static uint8_t cur, end; variable
278 if (ansi_val > cur) { in handle_ansi()
283 cur -= ansi_val; in handle_ansi()
292 cur += ansi_val; in handle_ansi()
296 if (!cur) { in handle_ansi()
300 cursor_backward(cur); in handle_ansi()
301 end += cur; in handle_ansi()
302 cur = 0U; in handle_ansi()
310 cur += end; in handle_ansi()
319 del_char(&line[cur], --end); in handle_ansi()
[all …]
/Zephyr-Core-2.7.6/subsys/tracing/
Dtracing_backend_uart.c25 static uint32_t length, cur; in uart_isr() local
46 cmd[cur] = '\0'; in uart_isr()
47 tracing_cmd_handle(cmd, cur); in uart_isr()
49 cur = 0U; in uart_isr()
55 if (cur < length - 1) { in uart_isr()
56 cmd[cur++] = byte; in uart_isr()
/Zephyr-Core-2.7.6/drivers/interrupt_controller/
DKconfig.multilevel.aggregator_template3 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).
DKconfig.multilevel56 cur-level-num = 2
57 cur-level = 2ND
102 cur-level-num = 3
103 cur-level = 3RD
/Zephyr-Core-2.7.6/tests/subsys/fs/fs_api/src/
Dtest_fs.c21 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-2.7.6/subsys/fs/fcb/
Dfcb_append.c18 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-2.7.6/subsys/net/ip/
Dutils.c520 struct net_pkt_cursor *cur = &pkt->cursor; in pkt_calc_chksum() local
523 if (!cur->buf || !cur->pos) { in pkt_calc_chksum()
527 len = cur->buf->len - (cur->pos - cur->buf->data); in pkt_calc_chksum()
529 while (cur->buf) { in pkt_calc_chksum()
530 sum = calc_chksum(sum, cur->pos, len); in pkt_calc_chksum()
532 cur->buf = cur->buf->frags; in pkt_calc_chksum()
533 if (!cur->buf || !cur->buf->len) { in pkt_calc_chksum()
537 cur->pos = cur->buf->data; in pkt_calc_chksum()
540 sum += *cur->pos; in pkt_calc_chksum()
541 if (sum < *cur->pos) { in pkt_calc_chksum()
[all …]
/Zephyr-Core-2.7.6/subsys/mgmt/osdp/src/
Dosdp_phy.c220 uint16_t comp, cur; in osdp_phy_decode_packet() local
264 cur = pkt->control & PKT_CONTROL_SQN; in osdp_phy_decode_packet()
265 if (pd_mode && cur == 0) { in osdp_phy_decode_packet()
276 if (pd_mode && cur == pd->seq_number) { in osdp_phy_decode_packet()
287 if (comp != cur && !ISSET_FLAG(pd, PD_FLAG_SKIP_SEQ_CHECK)) { in osdp_phy_decode_packet()
288 LOG_ERR(TAG "packet seq mismatch %d/%d", comp, cur); in osdp_phy_decode_packet()
297 cur = (buf[pkt_len] << 8) | buf[pkt_len - 1]; in osdp_phy_decode_packet()
299 if (comp != cur) { in osdp_phy_decode_packet()
300 LOG_ERR(TAG "invalid crc 0x%04x/0x%04x", comp, cur); in osdp_phy_decode_packet()
310 LOG_ERR(TAG "invalid checksum %02x/%02x", comp, cur); in osdp_phy_decode_packet()
/Zephyr-Core-2.7.6/arch/x86/core/
Dspec_ctrl.c39 uint64_t cur = z_x86_msr_read(X86_SPEC_CTRL_MSR); in spec_ctrl_init() local
42 cur | enable_bits); in spec_ctrl_init()
/Zephyr-Core-2.7.6/tests/net/lib/mqtt_packet/src/
Dmqtt_packet.c438 .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-2.7.6/drivers/display/
Dmb_display.c100 uint8_t cur; /* Currently rendered row */ member
161 disp->cur = 0U; in start_image()
176 uint32_t pin, prev = (disp->cur + 2) % 3; in update_pins()
187 gpio_pin_set_raw(disp->dev, ROW_PIN(disp->cur), 1); in update_pins()
308 update_pins(disp, disp->row[disp->cur]); in show_row()
309 disp->cur = (disp->cur + 1) % DISPLAY_ROWS; in show_row()
311 if (disp->cur == 0U && disp->expiry != SYS_FOREVER_MS && in show_row()
/Zephyr-Core-2.7.6/scripts/kconfig/
Dkconfiglib.py3586 cur = node
3587 while cur.next and _auto_menu_dep(node, cur.next):
3590 self._finalize_node(cur.next, visible_if)
3591 cur = cur.next
3592 cur.parent = node
3594 if cur is not node:
3598 node.next = cur.next
3599 cur.next = None
3614 cur = node.list
3615 while cur:
[all …]
/Zephyr-Core-2.7.6/tests/kernel/common/src/
Dtimeout_order.c16 static int results[NUM_TIMEOUTS], cur; variable
28 results[cur++] = id; in thread()
/Zephyr-Core-2.7.6/subsys/bluetooth/services/ots/
Dots_dir_list.c67 net_buf_simple_add_le32(net_buf, obj->metadata.size.cur); in dir_list_object_encode()
105 dir_list->dir_list_obj->metadata.size.cur = dir_list->net_buf.len; in bt_ots_dir_list_obj_add()
163 dir_list->dir_list_obj->metadata.size.cur = dir_list->net_buf.len; in bt_ots_dir_list_obj_remove()
191 dir_list->dir_list_obj->metadata.size.cur = dir_list->net_buf.len; in dir_list_encode()
/Zephyr-Core-2.7.6/tests/arch/x86/pagetables/src/
Dmain.c215 struct k_thread *cur = k_current_get(); in z_impl_dump_my_ptables() local
217 printk("Page tables for thread %p\n", cur); in z_impl_dump_my_ptables()
218 z_x86_dump_page_tables(z_x86_thread_page_tables_get(cur)); in z_impl_dump_my_ptables()
/Zephyr-Core-2.7.6/scripts/
Dcheckpatch.pl1785 my $cur = $stream;
1789 while (length($cur)) {
1793 if ($cur =~ /^(\s+)/o) {
1800 } elsif ($cur =~ /^(\(\s*$Type\s*)\)/ && $av_pending eq '_') {
1805 } elsif ($cur =~ /^($Type)\s*(?:$Ident|,|\)|\(|\s*$)/) {
1809 } elsif ($cur =~ /^($Modifier)\s*/) {
1813 } elsif ($cur =~ /^(\#\s*define\s*$Ident)(\(?)/o) {
1822 } elsif ($cur =~ /^(\#\s*(?:undef\s*$Ident|include\b))/o) {
1827 } elsif ($cur =~ /^(\#\s*(?:ifdef|ifndef|if))/o) {
1835 } elsif ($cur =~ /^(\#\s*(?:else|elif))/o) {
[all …]
/Zephyr-Core-2.7.6/scripts/footprint/
Dsize_report583 cur = None
587 if cur is None:
588 cur = part
590 cur = str(Path(cur, part))
592 results = findall_by_attr(root, cur, name="identifier")
600 node = TreeNode(name=str(part), identifier=cur, size=size, parent=parent)
/Zephyr-Core-2.7.6/lib/os/
Djson.c636 const char *cur; in json_escape_internal() local
639 for (cur = str; ret == 0 && *cur; cur++) { in json_escape_internal()
640 char escaped = escape_as(*cur); in json_escape_internal()
647 ret = append_bytes(cur, 1, data); in json_escape_internal()

12