| /Zephyr-Core-2.7.6/tests/lib/p4workq/src/ |
| D | main.c | 23 struct k_p4wq_work item; member
34 static void stress_handler(struct k_p4wq_work *item);
36 static void stress_sub(struct test_item *item) in stress_sub() argument
42 item->item.priority = sys_rand32_get() % (K_LOWEST_THREAD_PRIO - 1); in stress_sub()
43 item->item.deadline = sys_rand32_get() % k_ms_to_cyc_ceil32(2); in stress_sub()
44 item->item.handler = stress_handler; in stress_sub()
45 item->running = false; in stress_sub()
46 item->active = true; in stress_sub()
48 k_p4wq_submit(&wq, &item->item); in stress_sub()
51 static void stress_handler(struct k_p4wq_work *item) in stress_handler() argument
[all …]
|
| /Zephyr-Core-2.7.6/lib/os/ |
| D | mpsc_pbuf.c | 77 static inline bool is_valid(union mpsc_pbuf_generic *item) in is_valid() argument
79 return item->hdr.valid; in is_valid()
82 static inline bool is_invalid(union mpsc_pbuf_generic *item) in is_invalid() argument
84 return !item->hdr.valid && !item->hdr.busy; in is_invalid()
111 static inline uint32_t get_skip(union mpsc_pbuf_generic *item) in get_skip() argument
113 if (item->hdr.busy && !item->hdr.valid) { in get_skip()
114 return item->skip.len; in get_skip()
143 union mpsc_pbuf_generic *item; in drop_item_locked() local
148 item = (union mpsc_pbuf_generic *)&buffer->buf[buffer->rd_idx]; in drop_item_locked()
149 skip_wlen = get_skip(item); in drop_item_locked()
[all …]
|
| D | p4wq.c | 17 static void set_prio(struct k_thread *th, struct k_p4wq_work *item) in set_prio() argument
20 th->base.prio = item->priority; in set_prio()
21 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-2.7.6/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-2.7.6/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-2.7.6/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-2.7.6/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-2.7.6/doc/reference/kernel/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
35 A data item may be **added** to a LIFO by a thread or an ISR.
36 The item is given directly to a waiting thread, if one exists;
37 otherwise the item is added to the LIFO's queue.
40 A data item may be **removed** from a LIFO by a thread. If the LIFO's queue
41 is empty a thread may choose to wait for a data item to be given.
43 When a data item is added, it is given to the highest priority thread
47 The kernel does allow an ISR to remove an item from a LIFO, however
79 A data item is added to a LIFO by calling :c:func:`k_lifo_put`.
[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
35 A data item may be **added** to a FIFO by a thread or an ISR.
36 The item is given directly to a waiting thread, if one exists;
37 otherwise the item is added to the FIFO's queue.
40 A data item may be **removed** from a FIFO by a thread. If the FIFO's queue
41 is empty a thread may choose to wait for a data item to be given.
43 When a data item is added, it is given to the highest priority thread
47 The kernel does allow an ISR to remove an item from a FIFO, however
56 the first data item in a set will be able to remove the remaining data items
[all …]
|
| D | stacks.rst | 45 When a data item is added, it is given to the highest priority thread
49 The kernel does allow an ISR to remove an item from a stack, however
89 A data item is added to a stack by calling :c:func:`k_stack_push`.
112 A data item is taken from a stack by calling :c:func:`k_stack_pop`.
|
| /Zephyr-Core-2.7.6/doc/reference/kernel/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-2.7.6/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']))
|
| /Zephyr-Core-2.7.6/subsys/bluetooth/services/ots/ |
| D | ots_obj_manager.c | 206 struct bt_gatt_ots_pool_item *item; in bt_gatt_ots_obj_manager_obj_delete() local
208 item = CONTAINER_OF(obj, struct bt_gatt_ots_pool_item, val); in bt_gatt_ots_obj_manager_obj_delete()
210 if (!item->is_allocated) { in bt_gatt_ots_obj_manager_obj_delete()
219 item->is_allocated = false; in bt_gatt_ots_obj_manager_obj_delete()
220 sys_dlist_remove(&item->dnode); in bt_gatt_ots_obj_manager_obj_delete()
229 struct bt_gatt_ots_pool_item *item; in bt_gatt_ots_obj_manager_obj_contains() local
231 item = CONTAINER_OF(obj, struct bt_gatt_ots_pool_item, val); in bt_gatt_ots_obj_manager_obj_contains()
233 return PART_OF_ARRAY(obj_manager->pool, item); in bt_gatt_ots_obj_manager_obj_contains()
|
| /Zephyr-Core-2.7.6/scripts/dts/ |
| D | gen_dts_cmake.py | 96 for item in node.props:
98 if "phandle" not in node.props[item].type:
99 if "array" in node.props[item].type:
102 for val in node.props[item].val:
105 cmake_value = node.props[item].val
|
| /Zephyr-Core-2.7.6/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()
58 static void drop(const struct mpsc_pbuf_buffer *buffer, const union mpsc_pbuf_generic *item) in drop() argument
60 struct test_data_var *packet = (struct test_data_var *)item; in drop()
119 mpsc_pbuf_put_word(&buffer, test_1word.item); in item_put_no_overwrite()
124 mpsc_pbuf_free(&buffer, &t->item); in item_put_no_overwrite()
150 mpsc_pbuf_put_word(&buffer, test_1word.item); in item_put_overwrite()
177 mpsc_pbuf_put_word(&buffer, test_1word.item); in item_put_saturate()
184 mpsc_pbuf_free(&buffer, &t->item); in item_put_saturate()
[all …]
|
| /Zephyr-Core-2.7.6/subsys/shell/ |
| D | shell_history.c | 92 struct shell_history_item *item, in add_to_head() argument
95 item->len = len; in add_to_head()
96 item->padding = padding; in add_to_head()
97 memcpy(item->data, src, len); in add_to_head()
98 sys_dlist_prepend(&history->list, &item->dnode); in add_to_head()
|
| /Zephyr-Core-2.7.6/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-2.7.6/tests/benchmarks/latency_measure/src/ |
| D | int_to_thread_evt.c | 46 static void worker(struct k_work *item) in worker() argument
48 (void)item; in worker()
|
| /Zephyr-Core-2.7.6/scripts/ |
| D | gen_syscalls.py | 118 def typename_split(item): argument
119 if "[" in item:
122 item)
124 if "(" in item:
128 mo = typename_regex.match(item)
398 for i, item in enumerate(ids):
399 ids_as_defines += "#define {} {}\n".format(item, i)
|
| D | gen_app_partitions.py | 207 for partition, item in partitions.items():
209 if LIB in item:
210 for lib in item[LIB]:
213 if LIB in item:
214 for lib in item[LIB]:
|
| /Zephyr-Core-2.7.6/doc/reference/data_structures/ |
| D | ring_buffers.rst | 16 * **Data item mode**: Multiple 32-bit word data items with metadata
18 chunks of up to 1020 bytes. Each data item also has two
116 Data item mode
119 A **data item mode** ring buffer instance is declared using
124 A ring buffer **data item** is an array of 32-bit words from 0 to 1020 bytes
125 in length. When a data item is **enqueued** (:c:func:`ring_buf_item_put`)
128 insufficient space to hold the new data item the enqueue operation fails.
131 buffer by removing the oldest enqueued item. The contents of the dequeued data
132 item, as well as its two metadata values, are copied to areas supplied by the
134 retriever is not large enough to hold the data item's data, the dequeue
[all …]
|
| /Zephyr-Core-2.7.6/include/sys/ |
| D | p4wq.h | 188 void k_p4wq_submit(struct k_p4wq *queue, struct k_p4wq_work *item);
200 bool k_p4wq_cancel(struct k_p4wq *queue, struct k_p4wq_work *item);
|
