| /Zephyr-Core-3.4.0/tests/lib/p4workq/src/ |
| D | main.c | 24 struct k_p4wq_work item; member
35 static void stress_handler(struct k_p4wq_work *item);
37 static void stress_sub(struct test_item *item) in stress_sub() argument
43 item->item.priority = sys_rand32_get() % (K_LOWEST_THREAD_PRIO - 1); in stress_sub()
44 item->item.deadline = sys_rand32_get() % k_ms_to_cyc_ceil32(2); in stress_sub()
45 item->item.handler = stress_handler; in stress_sub()
46 item->running = false; in stress_sub()
47 item->active = true; in stress_sub()
49 k_p4wq_submit(&wq, &item->item); in stress_sub()
52 static void stress_handler(struct k_p4wq_work *item) in stress_handler() argument
[all …]
|
| /Zephyr-Core-3.4.0/scripts/ci/ |
| D | version_mgr.py | 52 def handle_compat(item): argument
54 if isinstance(item, str):
55 item_compat['version'] = item
59 item_compat = item
65 for item in data:
66 item_compat = handle_compat(item)
114 found = list(filter(lambda item: (isinstance(item, dict) and
115 item.get('version') == version) or item == version, data))
124 item = {}
125 item['version'] = version
[all …]
|
| /Zephyr-Core-3.4.0/lib/os/ |
| D | mpsc_pbuf.c | 116 static inline bool is_valid(union mpsc_pbuf_generic *item) in is_valid() argument
118 return item->hdr.valid; in is_valid()
121 static inline bool is_invalid(union mpsc_pbuf_generic *item) in is_invalid() argument
123 return !item->hdr.valid && !item->hdr.busy; in is_invalid()
138 static inline uint32_t get_skip(union mpsc_pbuf_generic *item) in get_skip() argument
140 if (item->hdr.busy && !item->hdr.valid) { in get_skip()
141 return item->skip.len; in get_skip()
178 union mpsc_pbuf_generic *item; in drop_item_locked() local
181 item = (union mpsc_pbuf_generic *)&buffer->buf[buffer->rd_idx]; in drop_item_locked()
182 skip_wlen = get_skip(item); in drop_item_locked()
[all …]
|
| D | p4wq.c | 18 static void set_prio(struct k_thread *th, struct k_p4wq_work *item) in set_prio() argument
21 th->base.prio = item->priority; in set_prio()
22 th->base.prio_deadline = item->deadline; in set_prio()
217 void k_p4wq_submit(struct k_p4wq *queue, struct k_p4wq_work *item) in k_p4wq_submit() argument
225 item->deadline += k_cycle_get_32(); in k_p4wq_submit()
228 if (item->thread == _current) { in k_p4wq_submit()
229 sys_dlist_remove(&item->dlnode); in k_p4wq_submit()
231 item->thread = NULL; in k_p4wq_submit()
233 k_sem_init(&item->done_sem, 0, 1); in k_p4wq_submit()
235 __ASSERT_NO_MSG(item->thread == NULL); in k_p4wq_submit()
[all …]
|
| /Zephyr-Core-3.4.0/scripts/kconfig/ |
| D | guiconfig.py | 581 item = node.item
583 values=item.name if item.__class__ is Symbol_ else "")
690 if node.list and not isinstance(node.item, Symbol):
691 if _tree.item(id(node), "open"):
713 if node.list and isinstance(node.item, Symbol):
717 elif node.list and isinstance(node.item, Symbol):
754 elif node.list and isinstance(node.item, Symbol):
774 (node.item == MENU and not expr_value(node.visibility))
784 _tree.item(
799 if node.item == COMMENT:
[all …]
|
| D | menuconfig.py | 1117 if isinstance(menu.item, Choice):
1130 choice = _cur_menu.item
1156 jump_into = (isinstance(node.item, Choice) or node.item == MENU) and \
1186 if jump_into and isinstance(_cur_menu.item, Choice):
1420 if isinstance(node.item, (Symbol, Choice)) and node.help:
1453 standard_sc_expr_str(menu.item))
1504 elif node.list and isinstance(node.item, Symbol):
1519 if isinstance(menu.item, Choice):
1543 seen_syms = {node.item for node in rec(menu.list)
1544 if isinstance(node.item, Symbol)}
[all …]
|
| D | kconfiglib.py | 1048 self.top_node.item = MENU
1617 if node.item is MENU and expr_value(node.dep) and \
1632 item = node.item
1634 if item.__class__ is Symbol:
1635 if item._visited:
1637 item._visited = True
1639 conf_string = item.config_string
1651 ((item is MENU and expr_value(node.visibility)) or
1652 item is COMMENT):
1950 if unique_syms and node.item.__class__ is Symbol:
[all …]
|
| /Zephyr-Core-3.4.0/samples/modules/tflite-micro/magic_wand/train/ |
| D | data_split.py | 57 for idx, item in enumerate(data): # pylint: disable=unused-variable
59 if item["gesture"] == i:
69 for idx, item in enumerate(data):
71 if item["gesture"] == i:
73 train_data.append(item)
76 valid_data.append(item)
79 test_data.append(item)
|
| /Zephyr-Core-3.4.0/tests/kernel/workq/work_queue/ |
| D | README.txt | 37 - Running test item 1
41 - Running test item 2
45 - Running test item 3
46 - Running test item 4
47 - Running test item 5
48 - Running test item 6
69 - Running delayed test item 1
70 - Running delayed test item 2
71 - Running delayed test item 3
72 - Running delayed test item 4
[all …]
|
| /Zephyr-Core-3.4.0/doc/kernel/services/data_passing/ |
| D | message_queues.rst | 24 * A **data item size**, measured in bytes.
30 the ring buffer are similarly aligned to this boundary, the data item size
36 A data item can be **sent** to a message queue by a thread or an ISR.
37 The data item pointed at by the sending thread is copied to a waiting thread,
38 if one exists; otherwise the item is copied to the message queue's ring buffer,
40 *must* equal the message queue's data item size.
42 If a thread attempts to send a data item when the ring buffer is full,
48 A data item can be **received** from a message queue by a thread.
49 The data item is copied to the area specified by the receiving thread;
50 the size of the receiving area *must* equal the message queue's data item size.
[all …]
|
| D | lifos.rst | 28 the first word of an item for use as a pointer to the next data item in the
29 queue. Consequently, a data item that holds N bytes of application data
37 data queues. Any attempt to re-add a LIFO data item to a queue before
41 A data item may be **added** to a LIFO by a thread or an ISR.
42 The item is given directly to a waiting thread, if one exists;
43 otherwise the item is added to the LIFO's queue.
46 A data item may be **removed** from a LIFO by a thread. If the LIFO's queue
47 is empty a thread may choose to wait for a data item to be given.
49 When a data item is added, it is given to the highest priority thread
53 The kernel does allow an ISR to remove an item from a LIFO, however
[all …]
|
| D | fifos.rst | 28 the first word of an item for use as a pointer to the next data item in
29 the queue. Consequently, a data item that holds N bytes of application
37 data queues. Any attempt to re-add a FIFO data item to a queue before
41 A data item may be **added** to a FIFO by a thread or an ISR.
42 The item is given directly to a waiting thread, if one exists;
43 otherwise the item is added to the FIFO's queue.
46 A data item may be **removed** from a FIFO by a thread. If the FIFO's queue
47 is empty a thread may choose to wait for a data item to be given.
49 When a data item is added, it is given to the highest priority thread
53 The kernel does allow an ISR to remove an item from a FIFO, however
[all …]
|
| /Zephyr-Core-3.4.0/scripts/dts/ |
| D | gen_dts_cmake.py | 106 for item in node.props:
108 if "phandle" not in node.props[item].type:
109 if "array" in node.props[item].type:
112 for val in node.props[item].val:
115 cmake_value = node.props[item].val
122 if item == 'compatible':
124 for comp in node.props[item].val:
|
| /Zephyr-Core-3.4.0/tests/lib/mpsc_pbuf/src/ |
| D | main.c | 44 union mpsc_pbuf_generic item; member
47 static uint32_t get_wlen(const union mpsc_pbuf_generic *item) in get_wlen() argument
49 union test_item *t_item = (union test_item *)item; in get_wlen()
59 static void drop(const struct mpsc_pbuf_buffer *buffer, const union mpsc_pbuf_generic *item) in drop() argument
61 struct test_data_var *packet = (struct test_data_var *)item; in drop()
127 mpsc_pbuf_put_word(&buffer, test_1word.item); in item_put_no_overwrite()
132 mpsc_pbuf_free(&buffer, &t->item); in item_put_no_overwrite()
159 mpsc_pbuf_put_word(&buffer, test_1word.item); in item_put_overwrite()
186 mpsc_pbuf_put_word(&buffer, test_1word.item); in item_put_saturate()
193 mpsc_pbuf_free(&buffer, &t->item); in item_put_saturate()
[all …]
|
| /Zephyr-Core-3.4.0/doc/kernel/services/threads/ |
| D | workqueue.rst | 11 work items in a first in, first out manner. Each work item is processed by
12 calling the function specified by the work item. A workqueue is typically
28 between each submitted work item, to prevent a cooperative workqueue from
40 caller need not be concerned that an item may be processing when the
46 * The ability to wait until a work item has completed or a queue has been
48 * Finer control of behavior when scheduling a delayable work item,
50 item is scheduled again.
51 * Safe handling of work item resubmission when the item is being processed
63 Any number of **work items** can be defined. Each work item is referenced
66 A work item is assigned a **handler function**, which is the function
[all …]
|
| /Zephyr-Core-3.4.0/subsys/bluetooth/services/ots/ |
| D | ots_obj_manager.c | 204 struct bt_gatt_ots_pool_item *item; in bt_gatt_ots_obj_manager_obj_delete() local
206 item = CONTAINER_OF(obj, struct bt_gatt_ots_pool_item, val); in bt_gatt_ots_obj_manager_obj_delete()
208 if (!item->is_allocated) { in bt_gatt_ots_obj_manager_obj_delete()
217 item->is_allocated = false; in bt_gatt_ots_obj_manager_obj_delete()
218 sys_dlist_remove(&item->dnode); in bt_gatt_ots_obj_manager_obj_delete()
227 struct bt_gatt_ots_pool_item *item; in bt_gatt_ots_obj_manager_obj_contains() local
229 item = CONTAINER_OF(obj, struct bt_gatt_ots_pool_item, val); in bt_gatt_ots_obj_manager_obj_contains()
231 return PART_OF_ARRAY(obj_manager->pool, item); in bt_gatt_ots_obj_manager_obj_contains()
|
| /Zephyr-Core-3.4.0/scripts/release/ |
| D | list_issues.py | 78 item = response.json()
79 return item
87 item = response.json()
88 return item
190 item = i.get_pull(p)
192 item['body'], re.MULTILINE)
210 item = i.get_issue(m)
211 if item:
214 item['number'], item['title'].strip()))
|
| /Zephyr-Core-3.4.0/subsys/shell/ |
| D | shell_history.c | 96 struct shell_history_item *item, in add_to_head() argument
99 item->len = len; in add_to_head()
100 item->padding = padding; in add_to_head()
101 memcpy(item->data, src, len); in add_to_head()
102 sys_dlist_prepend(&history->list, &item->dnode); in add_to_head()
|
| /Zephyr-Core-3.4.0/doc/connectivity/bluetooth/api/mesh/ |
| D | core.rst | 75 the change needs to be stored persistently, the stack schedules a work item.
76 The delay between scheduling the work item and submitting it to the workqueue
78 storing of data is scheduled, it can not be rescheduled until the work item is
82 item is submitted to the workqueue without the delay. If the work item was
85 The Replay Protection List uses the same work item to store RPL entries. If
90 :kconfig:option:`CONFIG_BT_MESH_RPL_STORE_TIMEOUT`, and the work item was
91 scheduled by the Replay Protection List, the work item will be rescheduled.
93 When the work item is running, the stack will store all pending configuration,
96 Work item execution context
100 context from which the work item is executed. This option is enabled by
[all …]
|
| /Zephyr-Core-3.4.0/doc/ |
| D | index.rst | 36 <li class="grid-item">
43 <li class="grid-item">
51 <li class="grid-item">
59 <li class="grid-item">
67 <li class="grid-item">
74 <li class="grid-item">
81 <li class="grid-item">
88 <li class="grid-item">
|
| /Zephyr-Core-3.4.0/tests/benchmarks/latency_measure/src/ |
| D | int_to_thread_evt.c | 45 static void worker(struct k_work *item) in worker() argument
47 (void)item; in worker()
|
| /Zephyr-Core-3.4.0/include/zephyr/logging/ |
| D | log_internal.h | 136 const union mpsc_pbuf_generic *item) in z_log_notify_drop() argument
139 ARG_UNUSED(item); in z_log_notify_drop()
|
| /Zephyr-Core-3.4.0/include/zephyr/rtio/ |
| D | rtio_spsc.h | 312 #define rtio_spsc_next(spsc, item) \ argument
314 unsigned long idx = ((item) - (spsc)->buffer); \
328 #define rtio_spsc_prev(spsc, item) \ argument
330 unsigned long idx = ((item) - &(spsc)->buffer[0]) / sizeof((spsc)->buffer[0]); \
|
| /Zephyr-Core-3.4.0/scripts/build/ |
| D | gen_syscalls.py | 162 def typename_split(item): argument
163 if "[" in item:
166 item)
168 if "(" in item:
172 mo = typename_regex.match(item)
461 for i, item in enumerate(ids):
462 ids_as_defines += "#define {} {}\n".format(item, i)
|
| /Zephyr-Core-3.4.0/doc/kernel/data_structures/ |
| D | ring_buffers.rst | 18 * **Data item mode**: Multiple 32-bit word data items with metadata
20 chunks of up to 1020 bytes. Each data item also has two
105 which returns the number of free bytes or free 32-bit item words respectively,
144 Data item mode
147 A **data item mode** ring buffer instance is declared using
151 A ring buffer **data item** is an array of 32-bit words from 0 to 1020 bytes
152 in length. When a data item is **enqueued** (:c:func:`ring_buf_item_put`)
155 insufficient space to hold the new data item the enqueue operation fails.
157 A data item is **dequeued** (:c:func:`ring_buf_item_get`) from a ring
158 buffer by removing the oldest enqueued item. The contents of the dequeued data
[all …]
|
