| /Zephyr-4.3.0/subsys/net/ip/ |
| D | net_timeout.c | 10 void net_timeout_set(struct net_timeout *timeout, in net_timeout_set() argument
16 timeout->timer_start = now; in net_timeout_set()
22 timeout->wrap_counter = 0; in net_timeout_set()
23 timeout->timer_timeout = 0; in net_timeout_set()
28 timeout->wrap_counter = expire_timeout / in net_timeout_set()
30 timeout->timer_timeout = expire_timeout - in net_timeout_set()
32 (uint64_t)timeout->wrap_counter; in net_timeout_set()
38 if (timeout->timer_timeout == 0U) { in net_timeout_set()
39 timeout->timer_timeout = NET_TIMEOUT_MAX_VALUE; in net_timeout_set()
40 timeout->wrap_counter -= 1; in net_timeout_set()
[all …]
|
| /Zephyr-4.3.0/subsys/tracing/test/ |
| D | tracing_test.h | 23 #define sys_port_trace_k_thread_join_enter(thread, timeout) \ argument
24 sys_trace_k_thread_join_blocking(thread, timeout)
25 #define sys_port_trace_k_thread_join_blocking(thread, timeout) \ argument
26 sys_trace_k_thread_join_blocking(thread, timeout)
27 #define sys_port_trace_k_thread_join_exit(thread, timeout, ret) \ argument
28 sys_trace_k_thread_join_exit(thread, timeout, ret)
29 #define sys_port_trace_k_thread_sleep_enter(timeout) sys_trace_k_thread_sleep_enter(timeout) argument
30 #define sys_port_trace_k_thread_sleep_exit(timeout, ret) sys_trace_k_thread_sleep_exit(timeout, ret) argument
73 #define sys_port_trace_k_work_flush_blocking(work, timeout) argument
84 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
[all …]
|
| D | tracing_string_format_test.c | 96 void sys_trace_k_thread_sleep_enter(k_timeout_t timeout) in sys_trace_k_thread_sleep_enter() argument
101 void sys_trace_k_thread_sleep_exit(k_timeout_t timeout, int ret) in sys_trace_k_thread_sleep_exit() argument
177 void sys_trace_k_thread_join_blocking(struct k_thread *thread, k_timeout_t timeout) in sys_trace_k_thread_join_blocking() argument
179 TRACING_STRING("%s %p, timeout: %u\n", __func__, thread, (uint32_t)timeout.ticks); in sys_trace_k_thread_join_blocking()
182 void sys_trace_k_thread_join_exit(struct k_thread *thread, k_timeout_t timeout, int ret) in sys_trace_k_thread_join_exit() argument
184 TRACING_STRING("%s %p, timeout: %u\n", __func__, thread, (uint32_t)timeout.ticks); in sys_trace_k_thread_join_exit()
246 void sys_trace_k_condvar_wait_enter(struct k_condvar *condvar, k_timeout_t timeout) in sys_trace_k_condvar_wait_enter() argument
251 void sys_trace_k_condvar_wait_exit(struct k_condvar *condvar, k_timeout_t timeout, in sys_trace_k_condvar_wait_exit() argument
267 void sys_trace_k_sem_take_enter(struct k_sem *sem, k_timeout_t timeout) in sys_trace_k_sem_take_enter() argument
269 TRACING_STRING("%s: %p, timeout: %u\n", __func__, sem, (uint32_t)timeout.ticks); in sys_trace_k_sem_take_enter()
[all …]
|
| /Zephyr-4.3.0/include/zephyr/tracing/ |
| D | tracing.h | 92 #define sys_port_trace_k_thread_join_enter(thread, timeout) argument
99 #define sys_port_trace_k_thread_join_blocking(thread, timeout) argument
107 #define sys_port_trace_k_thread_join_exit(thread, timeout, ret) argument
113 #define sys_port_trace_k_thread_sleep_enter(timeout) argument
120 #define sys_port_trace_k_thread_sleep_exit(timeout, ret) argument
370 #define sys_port_trace_k_work_flush_blocking(work, timeout) argument
445 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
452 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) argument
460 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) argument
635 #define sys_port_trace_k_work_poll_submit_to_queue_enter(work_q, work, timeout) argument
[all …]
|
| /Zephyr-4.3.0/kernel/ |
| D | kheap.c | 80 k_timeout_t timeout, in z_heap_alloc_helper() argument
83 k_timepoint_t end = sys_timepoint_calc(timeout); in z_heap_alloc_helper()
88 __ASSERT(!arch_is_in_isr() || K_TIMEOUT_EQ(timeout, K_NO_WAIT), ""); in z_heap_alloc_helper()
96 (ret != NULL) || K_TIMEOUT_EQ(timeout, K_NO_WAIT)) { in z_heap_alloc_helper()
103 SYS_PORT_TRACING_OBJ_FUNC_BLOCKING(k_heap, alloc_helper, heap, timeout); in z_heap_alloc_helper()
110 timeout = sys_timepoint_timeout(end); in z_heap_alloc_helper()
111 (void) z_pend_curr(&heap->lock, key, &heap->wait_q, timeout); in z_heap_alloc_helper()
119 void *k_heap_alloc(struct k_heap *heap, size_t bytes, k_timeout_t timeout) in k_heap_alloc() argument
121 SYS_PORT_TRACING_OBJ_FUNC_ENTER(k_heap, alloc, heap, timeout); in k_heap_alloc()
123 void *ret = z_heap_alloc_helper(heap, 0, bytes, timeout, in k_heap_alloc()
[all …]
|
| D | nothread.c | 20 int32_t z_impl_k_sleep(k_timeout_t timeout) in z_impl_k_sleep() argument
27 SYS_PORT_TRACING_FUNC_ENTER(k_thread, sleep, timeout); in z_impl_k_sleep()
30 if (K_TIMEOUT_EQ(timeout, K_FOREVER)) { in z_impl_k_sleep()
33 SYS_PORT_TRACING_FUNC_EXIT(k_thread, sleep, timeout, (int32_t) K_TICKS_FOREVER); in z_impl_k_sleep()
38 ticks = timeout.ticks; in z_impl_k_sleep()
39 if (Z_IS_TIMEOUT_RELATIVE(timeout)) { in z_impl_k_sleep()
57 SYS_PORT_TRACING_FUNC_EXIT(k_thread, sleep, timeout, ret); in z_impl_k_sleep()
|
| D | timeout.c | 99 k_ticks_t z_add_timeout(struct _timeout *to, _timeout_func_t fn, k_timeout_t timeout) in z_add_timeout() argument
103 if (K_TIMEOUT_EQ(timeout, K_FOREVER)) { in z_add_timeout()
119 if (Z_IS_TIMEOUT_RELATIVE(timeout)) { in z_add_timeout()
122 to->dticks = timeout.ticks + 1 + ticks_elapsed; in z_add_timeout()
125 k_ticks_t dticks = Z_TICK_ABS(timeout.ticks) - curr_tick; in z_add_timeout()
128 ticks = timeout.ticks; in z_add_timeout()
179 static k_ticks_t timeout_rem(const struct _timeout *timeout) in timeout_rem() argument
185 if (timeout == t) { in timeout_rem()
193 k_ticks_t z_timeout_remaining(const struct _timeout *timeout) in z_timeout_remaining() argument
198 if (!z_is_inactive_timeout(timeout)) { in z_timeout_remaining()
[all …]
|
| /Zephyr-4.3.0/subsys/tracing/ctf/ |
| D | tracing_ctf.h | 30 #define sys_port_trace_k_thread_join_enter(thread, timeout) \ argument
31 sys_trace_k_thread_join_enter(thread, timeout)
32 #define sys_port_trace_k_thread_join_blocking(thread, timeout) \ argument
33 sys_trace_k_thread_join_blocking(thread, timeout)
34 #define sys_port_trace_k_thread_join_exit(thread, timeout, ret) \ argument
35 sys_trace_k_thread_join_exit(thread, timeout, ret)
37 #define sys_port_trace_k_thread_sleep_enter(timeout) sys_trace_k_thread_sleep_enter(timeout) argument
38 #define sys_port_trace_k_thread_sleep_exit(timeout, ret) sys_trace_k_thread_sleep_exit(timeout, ret) argument
88 #define sys_port_trace_k_work_flush_blocking(work, timeout) \ argument
89 sys_trace_k_work_flush_blocking(work, timeout)
[all …]
|
| /Zephyr-4.3.0/lib/os/zvfs/ |
| D | zvfs_poll.c | 20 int zvfs_poll_internal(struct zvfs_pollfd *fds, int nfds, k_timeout_t timeout) in zvfs_poll_internal() argument
36 end = sys_timepoint_calc(timeout); in zvfs_poll_internal()
64 timeout = K_NO_WAIT; in zvfs_poll_internal()
65 end = sys_timepoint_calc(timeout); in zvfs_poll_internal()
96 if (K_TIMEOUT_EQ(timeout, K_FOREVER)) { in zvfs_poll_internal()
99 poll_timeout = k_ticks_to_ms_floor32(timeout.ticks); in zvfs_poll_internal()
106 timeout = sys_timepoint_timeout(end); in zvfs_poll_internal()
109 ret = k_poll(poll_events, pev - poll_events, timeout); in zvfs_poll_internal()
161 timeout = sys_timepoint_timeout(end); in zvfs_poll_internal()
163 if (K_TIMEOUT_EQ(timeout, K_NO_WAIT)) { in zvfs_poll_internal()
[all …]
|
| /Zephyr-4.3.0/tests/net/lib/lwm2m/interop/pytest/ |
| D | test_blockwise.py | 30 to = leshan.timeout
32 leshan.timeout = 600
37 lines = dut.readlines_until(regex='app_fw_update: UPDATE', timeout=5.0)
44 leshan.timeout = to
51 to = leshan.timeout
54 leshan.timeout = 1
62 leshan.timeout = 600
67 lines = dut.readlines_until(regex='app_fw_update: UPDATE', timeout=5.0)
74 leshan.timeout = to
82 dut.readlines_until(regex='.*net_lwm2m_rd_client: Update Done', timeout=5.0)
[all …]
|
| D | test_bootstrap.py | 36 dut.readlines_until(regex='.*Bootstrap transfer complete', timeout=5.0)
52 dut.readlines_until(regex='.*Registration Done', timeout=5.0)
61 dut.readlines_until(regex='.*Server Initiated Bootstrap', timeout=1)
62 dut.readlines_until(regex='.*Bootstrap transfer complete', timeout=5.0)
63 dut.readlines_until(regex='.*Registration Done', timeout=5.0)
68 dut.readlines_until(regex=r'.*Deregistration success', timeout=5)
70 lines = dut.readlines_until(regex='.*Registration Done', timeout=5.0)
73 dut.readlines_until(regex=r'.*Deregistration success', timeout=5)
77 lines = dut.readlines_until(regex='.*Registration Done', timeout=5.0)
84 dut.readlines_until(regex=r'.*Deregistration success', timeout=5)
[all …]
|
| /Zephyr-4.3.0/include/zephyr/net/ |
| D | net_offload.h | 36 static inline int32_t timeout_to_int32(k_timeout_t timeout) in timeout_to_int32() argument
38 if (K_TIMEOUT_EQ(timeout, K_NO_WAIT)) { in timeout_to_int32()
40 } else if (K_TIMEOUT_EQ(timeout, K_FOREVER)) { in timeout_to_int32()
43 return k_ticks_to_ms_floor32(timeout.ticks); in timeout_to_int32()
82 int32_t timeout,
91 int32_t timeout,
99 int32_t timeout,
109 int32_t timeout,
118 int32_t timeout,
239 k_timeout_t timeout, in net_offload_connect() argument
[all …]
|
| D | socket_select.h | 50 zsock_fd_set *exceptfds, struct zsock_timeval *timeout) in zsock_select() argument
53 .tv_sec = (timeout == NULL) ? 0 : timeout->tv_sec, in zsock_select()
54 .tv_nsec = (long)((timeout == NULL) ? 0 : timeout->tv_usec * NSEC_PER_USEC)}; in zsock_select()
56 return zvfs_select(nfds, readfds, writefds, exceptfds, (timeout == NULL) ? NULL : &to, in zsock_select()
|
| /Zephyr-4.3.0/subsys/tracing/sysview/ |
| D | tracing_sysview.h | 41 #define sys_port_trace_k_thread_join_enter(thread, timeout) \ argument
43 (uint32_t)timeout.ticks)
44 #define sys_port_trace_k_thread_join_blocking(thread, timeout) argument
45 #define sys_port_trace_k_thread_join_exit(thread, timeout, ret) \ argument
48 #define sys_port_trace_k_thread_sleep_enter(timeout) \ argument
49 SEGGER_SYSVIEW_RecordU32(TID_SLEEP, (uint32_t)k_ticks_to_ms_floor32(timeout.ticks))
51 #define sys_port_trace_k_thread_sleep_exit(timeout, ret) \ argument
153 #define sys_port_trace_k_work_flush_blocking(work, timeout) argument
182 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) \ argument
184 (uint32_t)timeout.ticks)
[all …]
|
| /Zephyr-4.3.0/samples/sysbuild/hello_world/pytest/ |
| D | test_both_uart.py | 8 timeout = 5 variable
14 dut.readlines_until(regex=regex, print_output=True, timeout=timeout)
19 dut.readlines_until(connection_index=1, regex=regex, print_output=True, timeout=timeout)
|
| /Zephyr-4.3.0/tests/arch/arm64/arm64_gicv3_its/src/ |
| D | main.c | 92 unsigned int timeout; in ZTEST() local
101 timeout = ITS_TEST_LOOPS; in ZTEST()
102 while (!last_lpi_irq_num && timeout) { in ZTEST()
103 timeout--; in ZTEST()
115 unsigned int timeout; in ZTEST() local
126 timeout = ITS_TEST_LOOPS; in ZTEST()
127 while (!last_lpi_irq_num && timeout) { in ZTEST()
128 timeout--; in ZTEST()
140 timeout = ITS_TEST_LOOPS; in ZTEST()
141 while (!last_lpi_irq_num && timeout) { in ZTEST()
[all …]
|
| /Zephyr-4.3.0/subsys/tracing/user/ |
| D | tracing_user.h | 56 void sys_trace_timer_status_sync_blocking(struct k_timer *timer, k_timeout_t timeout);
139 #define sys_port_trace_k_thread_join_enter(thread, timeout) argument
140 #define sys_port_trace_k_thread_join_blocking(thread, timeout) argument
141 #define sys_port_trace_k_thread_join_exit(thread, timeout, ret) argument
142 #define sys_port_trace_k_thread_sleep_enter(timeout) argument
143 #define sys_port_trace_k_thread_sleep_exit(timeout, ret) argument
179 #define sys_port_trace_k_work_flush_blocking(work, timeout) argument
190 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
191 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) argument
192 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) argument
[all …]
|
| /Zephyr-4.3.0/tests/kernel/mem_heap/k_heap_api/src/ |
| D | test_kheap_api.c | 39 k_timeout_t timeout = Z_TIMEOUT_MS(200); in thread_alloc_heap() local
45 p = (char *)k_heap_alloc(&k_heap_test, ALLOC_SIZE_2, timeout); in thread_alloc_heap()
56 k_timeout_t timeout = Z_TIMEOUT_MS(200); in thread_alloc_heap_null() local
62 p = (char *)k_heap_alloc(&k_heap_test, ALLOC_SIZE_2, timeout); in thread_alloc_heap_null()
119 k_timeout_t timeout = Z_TIMEOUT_US(TIMEOUT); in ZTEST() local
120 char *p = (char *)k_heap_alloc(&k_heap_test, ALLOC_SIZE_1, timeout); in ZTEST()
144 k_timeout_t timeout = Z_TIMEOUT_US(TIMEOUT); in ZTEST() local
145 char *p = (char *)k_heap_alloc(&k_heap_test, ALLOC_SIZE_3, timeout); in ZTEST()
168 k_timeout_t timeout = Z_TIMEOUT_US(TIMEOUT); in ZTEST() local
169 char *p = (char *)k_heap_alloc(&k_heap_test, ALLOC_SIZE_1, timeout); in ZTEST()
[all …]
|
| /Zephyr-4.3.0/subsys/net/lib/sntp/ |
| D | sntp_simple.c | 12 static int sntp_simple_helper(struct net_sockaddr *addr, net_socklen_t addr_len, uint32_t timeout, in sntp_simple_helper() argument
26 if (timeout == SYS_FOREVER_MS) { in sntp_simple_helper()
27 deadline = (uint64_t)timeout; in sntp_simple_helper()
29 deadline = k_uptime_get() + (uint64_t)timeout; in sntp_simple_helper()
74 int sntp_simple_addr(struct net_sockaddr *addr, net_socklen_t addr_len, uint32_t timeout, in sntp_simple_addr() argument
84 return sntp_simple_helper(addr, addr_len, timeout, ts); in sntp_simple_addr()
87 int sntp_simple(const char *server, uint32_t timeout, struct sntp_time *ts) in sntp_simple() argument
105 res = sntp_simple_helper(addr->ai_addr, addr->ai_addrlen, timeout, ts); in sntp_simple()
|
| /Zephyr-4.3.0/subsys/mgmt/hawkbit/ |
| D | hawkbit_autohandler.c | 86 enum hawkbit_response hawkbit_autohandler_wait(uint32_t events, k_timeout_t timeout) in hawkbit_autohandler_wait() argument
88 uint32_t ret = k_event_wait(&hawkbit_autohandler_event, events, false, timeout); in hawkbit_autohandler_wait()
103 int hawkbit_autohandler_set_delay(k_timeout_t timeout, bool if_bigger) in hawkbit_autohandler_set_delay() argument
105 if (!if_bigger || timeout.ticks > k_work_delayable_remaining_get(&hawkbit_work_handle)) { in hawkbit_autohandler_set_delay()
108 (uint32_t)(timeout.ticks / CONFIG_SYS_CLOCK_TICKS_PER_SEC) / 3600, in hawkbit_autohandler_set_delay()
109 (uint32_t)((timeout.ticks / CONFIG_SYS_CLOCK_TICKS_PER_SEC) % 3600) / 60, in hawkbit_autohandler_set_delay()
110 (uint32_t)(timeout.ticks / CONFIG_SYS_CLOCK_TICKS_PER_SEC) % 60); in hawkbit_autohandler_set_delay()
111 return k_work_reschedule(&hawkbit_work_handle, timeout); in hawkbit_autohandler_set_delay()
|
| /Zephyr-4.3.0/scripts/pylib/pytest-twister-harness/src/twister_harness/helpers/ |
| D | shell.py | 26 self, device: DeviceAdapter, prompt: str = 'uart:~$', timeout: float | None = None
30 self.base_timeout: float = timeout or device.base_timeout
32 def wait_for_prompt(self, timeout: float | None = None) -> bool:
38 timeout = timeout or self.base_timeout
39 timeout_time = time.time() + timeout
44 line = self._device.readline(timeout=0.5, print_output=False)
54 self, command: str, timeout: float | None = None, print_output: bool = True
62 timeout = timeout or self.base_timeout
72 regex=regex_command, timeout=1.0, print_output=print_output
78 regex=regex_prompt, timeout=timeout, print_output=print_output
|
| /Zephyr-4.3.0/tests/kernel/fifo/fifo_timeout/src/ |
| D | main.c | 45 uint32_t timeout; member
101 static bool is_timeout_in_range(uint32_t start_time, uint32_t timeout) in is_timeout_in_range() argument
109 return timeout <= diff; in is_timeout_in_range()
115 uint32_t timeout = *((uint32_t *)p2); in test_thread_put_timeout() local
117 k_msleep(timeout); in test_thread_put_timeout()
131 packet = k_fifo_get(d->fifo, K_MSEC(d->timeout)); in test_thread_pend_and_timeout()
133 zassert_true(is_timeout_in_range(start_time, d->timeout)); in test_thread_pend_and_timeout()
166 data->q_order, data->timeout, data->fifo); in test_multiple_threads_pending()
177 if (data->timeout > test_data[j].timeout) { in test_multiple_threads_pending()
178 diff_ms = data->timeout - test_data[j].timeout; in test_multiple_threads_pending()
[all …]
|
| /Zephyr-4.3.0/scripts/pylib/pytest-twister-harness/src/twister_harness/device/ |
| D | device_connection.py | 33 def __init__(self, log_path: Path, timeout: float) -> None:
36 self.timeout = timeout
50 def join_reader_thread(self, timeout: float) -> None:
53 self._reader_thread.join(timeout)
83 def _read_from_queue(self, timeout: float) -> str:
86 data: str | object = self._device_read_queue.get(timeout=timeout)
93 def readline(self, timeout: float | None = None, print_output: bool = True) -> str:
98 timeout = timeout or self.timeout
100 data = self._read_from_queue(timeout)
113 timeout: float | None = None,
[all …]
|
| /Zephyr-4.3.0/tests/subsys/tracing/tracing_api/src/ |
| D | main.c | 130 k_timeout_t timeout = K_MSEC(1); in ZTEST() local
149 sys_trace_k_thread_sleep_enter(timeout); in ZTEST()
150 sys_trace_k_thread_sleep_exit(timeout, ret); in ZTEST()
160 sys_trace_k_thread_join_blocking(&thread, timeout); in ZTEST()
161 sys_trace_k_thread_join_exit(&thread, timeout, ret); in ZTEST()
173 sys_trace_k_condvar_wait_enter(&condvar, timeout); in ZTEST()
174 sys_trace_k_condvar_wait_exit(&condvar, timeout, ret); in ZTEST()
178 sys_trace_k_sem_take_enter(&sem2, timeout); in ZTEST()
179 sys_trace_k_sem_take_exit(&sem, timeout, ret); in ZTEST()
180 sys_trace_k_sem_take_blocking(&sem, timeout); in ZTEST()
[all …]
|
| /Zephyr-4.3.0/kernel/include/ |
| D | timeout_q.h | 37 k_ticks_t z_add_timeout(struct _timeout *to, _timeout_func_t fn, k_timeout_t timeout);
54 z_init_timeout(&thread_base->timeout); in z_init_thread_timeout()
57 extern void z_thread_timeout(struct _timeout *timeout);
61 return z_add_timeout(&thread->base.timeout, z_thread_timeout, ticks); in z_add_thread_timeout()
66 z_abort_timeout(&thread->base.timeout); in z_abort_thread_timeout()
72 return z_is_aborted_timeout(&thread->base.timeout); in z_is_aborted_thread_timeout()
77 k_ticks_t z_timeout_remaining(const struct _timeout *timeout);
|
