Home
last modified time | relevance | path

Searched full:deadline (Results 1 – 25 of 88) sorted by relevance

1234

/freebsd/sys/contrib/ck/include/
H A Dck_ec.h82 * value changes, and can override the deadline passed to futex_wait.
112 * deadline is either NULL, or a `const struct timespec *` that will
113 * be treated as an absolute deadline.
134 * computes a deadline `timeout` away from the current time. If
135 * timeout is NULL, computes a deadline in the infinite future. The
136 * resulting deadline is written to `new_deadline`. Returns 0 on
139 * `int ck_ec_wait(ec, mode, value, deadline)`: waits until the event
140 * counter's value differs from `value`, or, if `deadline` is
142 * deadline. Use a deadline with tv_sec = 0 for a non-blocking
146 * `int ck_ec_wait_pred(ec, mode, value, pred, data, deadline)`: waits
[all …]
/freebsd/sys/contrib/ck/src/
H A Dck_ec.c29 /* Once we've waited for >= 1 sec, go for the full deadline. */
47 const struct timespec *deadline) in ck_ec32_wait_slow() argument
50 NULL, NULL, deadline); in ck_ec32_wait_slow()
66 const struct timespec *deadline) in ck_ec64_wait_slow() argument
69 NULL, NULL, deadline); in ck_ec64_wait_slow()
120 * If deadline is ever reached, returns -1 (timeout).
132 struct timespec *deadline), in exponential_backoff() argument
133 const struct timespec *deadline) in exponential_backoff() argument
153 if (check_deadline(&now, ops, *deadline) == true) { in exponential_backoff()
167 partial_deadline = *deadline; in exponential_backoff()
[all …]
H A Dck_ec_timeutil.h134 * true if the current time is greater than or equal to the deadline,
139 const struct timespec deadline) in check_deadline() argument
148 return timespec_cmp(*now, deadline) >= 0; in check_deadline()
/freebsd/crypto/openssl/ssl/quic/
H A Dquic_thread_assist.c32 OSSL_TIME deadline; in assist_thread_main() local
37 deadline = ossl_quic_reactor_get_tick_deadline(rtor); in assist_thread_main()
40 * deadline in assist_thread_main()
42 deadline = ossl_quic_engine_make_real_time(eng, deadline); in assist_thread_main()
43 ossl_crypto_condvar_wait_timeout(qta->cv, m, deadline); in assist_thread_main()
50 * - The tick deadline has passed. in assist_thread_main()
51 * - The tick deadline has changed. in assist_thread_main()
H A Dquic_reactor.c195 * deadline is a timestamp to return at. If it is ossl_time_infinite(), the call
212 OSSL_TIME deadline, in poll_two_fds() argument
258 || !ossl_time_is_infinite(deadline))) in poll_two_fds()
275 * select expects a timeout, not a deadline, so do the conversion. in poll_two_fds()
279 if (ossl_time_is_infinite(deadline)) { in poll_two_fds()
285 * now > deadline. in poll_two_fds()
287 timeout = ossl_time_subtract(deadline, now); in poll_two_fds()
331 if (!ossl_assert(npfd != 0 || !ossl_time_is_infinite(deadline))) in poll_two_fds()
341 if (ossl_time_is_infinite(deadline)) { in poll_two_fds()
345 timeout = ossl_time_subtract(deadline, now); in poll_two_fds()
[all …]
H A Dquic_channel_local.h229 * Deadline at which we move to TERMINATING state. Valid if in the
235 * Deadline at which connection dies due to idle timeout if no further
241 * Deadline at which we should send an ACK-eliciting packet to ensure
247 * The deadline at which the period in which it is RECOMMENDED that we not
248 * initiate any spontaneous TXKU ends. This is zero if no such deadline
254 * The deadline at which we take the QRX out of UPDATING and back to NORMAL.
H A Dquic_channel.c766 * So we defer TXKU cooldown deadline calculation to this point. in txku_in_progress()
2023 OSSL_TIME now, deadline; in ossl_quic_channel_subtick() local
2097 * detection deadline and the idle timeout. in ossl_quic_channel_subtick()
2099 * ACKM ACK generation deadline is polled by TXP, so we don't need to in ossl_quic_channel_subtick()
2119 deadline = ossl_ackm_get_loss_detection_deadline(ch->ackm); in ossl_quic_channel_subtick()
2120 if (!ossl_time_is_zero(deadline) in ossl_quic_channel_subtick()
2121 && ossl_time_compare(now, deadline) >= 0) in ossl_quic_channel_subtick()
2133 * request so bump the ping deadline. If we don't do this we will in ossl_quic_channel_subtick()
2134 * busy-loop endlessly as the above deadline comparison condition in ossl_quic_channel_subtick()
2781 /* Determine next tick deadline. */
[all …]
H A Dquic_ackm.c584 * The ACK frame coalescing deadline at which we should flush any unsent ACK
602 /* Callbacks for deadline updates. */
603 void (*loss_detection_deadline_cb)(OSSL_TIME deadline, void *arg);
606 void (*ack_deadline_cb)(OSSL_TIME deadline, int pkt_space, void *arg);
907 OSSL_TIME deadline) in ackm_set_loss_detection_timer_actual() argument
909 ackm->loss_detection_deadline = deadline; in ackm_set_loss_detection_timer_actual()
912 ackm->loss_detection_deadline_cb(deadline, in ackm_set_loss_detection_timer_actual()
1391 * - We have exceeded the ACK flush deadline, meaning that
1468 OSSL_TIME deadline) in ackm_set_flush_deadline() argument
1470 ackm->rx_ack_flush_deadline[pkt_space] = deadline; in ackm_set_flush_deadline()
[all …]
/freebsd/crypto/openssl/doc/designs/quic-design/
H A Dquic-ackm.md29 - be notified when its loss detection deadline arrives
39 - It indicates the current deadline by which the loss detection
46 - It indicates the current deadline by which new ACK frames
327 This must be called whenever the loss detection deadline expires.
339 ### Get Loss Detection Deadline
341 This returns a deadline after which `ossl_ackm_on_timeout` should be called.
372 the deadline returned by `ossl_ackm_get_ack_deadline`.
393 ### Get ACK Deadline
402 This function returns the deadline at which the return value of
404 means that no deadline is currently applicable. If the deadline has already
[all …]
/freebsd/crypto/openssl/ssl/rio/
H A Dpoll_builder.c139 int ossl_rio_poll_builder_poll(RIO_POLL_BUILDER *rpb, OSSL_TIME deadline) in ossl_rio_poll_builder_poll() argument
148 * select expects a timeout, not a deadline, so do the conversion. in ossl_rio_poll_builder_poll()
152 if (ossl_time_is_infinite(deadline)) in ossl_rio_poll_builder_poll()
157 * now > deadline. in ossl_rio_poll_builder_poll()
159 timeout = ossl_time_to_timeval(ossl_time_subtract(deadline, in ossl_rio_poll_builder_poll()
168 if (ossl_time_is_infinite(deadline)) in ossl_rio_poll_builder_poll()
171 timeout_ms = ossl_time2ms(ossl_time_subtract(deadline, in ossl_rio_poll_builder_poll()
H A Dpoll_immediate.c422 OSSL_TIME deadline; in SSL_poll() local
432 /* Convert timeout to deadline. */ in SSL_poll()
434 deadline = ossl_time_infinite(); in SSL_poll()
436 deadline = ossl_time_zero(); in SSL_poll()
438 deadline = ossl_time_add(ossl_time_now(), in SSL_poll()
451 * the deadline has expired, we're done. in SSL_poll()
454 || ossl_time_is_zero(deadline) /* (avoids now call) */ in SSL_poll()
455 || ossl_time_compare(ossl_time_now(), deadline) >= 0) in SSL_poll()
464 if (!poll_block(items, num_items, stride, deadline, &result_count)) { in SSL_poll()
H A Dpoll_builder.h68 * Polls the set of file descriptors added to a poll builder. deadline is a
69 * deadline time based on the ossl_time_now() clock or ossl_time_infinite() for
72 int ossl_rio_poll_builder_poll(RIO_POLL_BUILDER *rpb, OSSL_TIME deadline);
/freebsd/crypto/openssl/crypto/thread/arch/
H A Dthread_posix.c179 OSSL_TIME deadline) in ossl_crypto_condvar_wait_timeout() argument
184 if (ossl_time_is_infinite(deadline)) { in ossl_crypto_condvar_wait_timeout()
186 * No deadline. Some pthread implementations allow in ossl_crypto_condvar_wait_timeout()
195 = ossl_time2seconds(deadline); in ossl_crypto_condvar_wait_timeout()
197 = (ossl_time2ticks(deadline) % OSSL_TIME_SECOND) / OSSL_TIME_NS; in ossl_crypto_condvar_wait_timeout()
H A Dthread_win.c145 static int determine_timeout(OSSL_TIME deadline, DWORD *w_timeout_p) in determine_timeout() argument
150 if (ossl_time_is_infinite(deadline)) { in determine_timeout()
156 delta = ossl_time_subtract(deadline, now); in determine_timeout()
347 static uint32_t obj_wait(HANDLE h, OSSL_TIME deadline) in obj_wait() argument
351 if (!determine_timeout(deadline, &timeout)) in obj_wait()
358 OSSL_TIME deadline) in ossl_crypto_condvar_wait_timeout() argument
400 if (obj_wait(cv->prewait_sema, deadline) != WAIT_OBJECT_0) { in ossl_crypto_condvar_wait_timeout()
428 rc = obj_wait(cv->sema, deadline); in ossl_crypto_condvar_wait_timeout()
555 OSSL_TIME deadline) in ossl_crypto_condvar_wait_timeout() argument
561 if (!determine_timeout(deadline, &timeout)) in ossl_crypto_condvar_wait_timeout()
/freebsd/crypto/openssl/include/internal/
H A Dquic_ackm.h30 void (*fn)(OSSL_TIME deadline,
35 void (*fn)(OSSL_TIME deadline,
185 * This clears the flag returned by ossl_ackm_is_ack_desired and the deadline
192 * Returns the deadline after which an ACK frame should be generated by calling
193 * ossl_ackm_get_ack_frame, or OSSL_TIME_INFINITY if no deadline is currently
194 * applicable. If the deadline has already passed, this function may return that
195 * deadline, or may return OSSL_TIME_ZERO.
/freebsd/contrib/jemalloc/include/jemalloc/internal/
H A Darena_structs_b.h
/freebsd/usr.bin/tip/tip/
H A Dhunt.c37 static jmp_buf deadline; variable
47 longjmp(deadline, 1); in dead()
76 if (setjmp(deadline) == 0) { in hunt()
/freebsd/crypto/openssl/doc/designs/ddd/
H A Dddd-02-conn-nonblocking.c363 struct timeval start, now, deadline, t; in main() local
373 timeradd(&start, &timeout, &deadline); in main()
388 if (timercmp(&now, &deadline, >=)) in main()
407 struct timeval start, now, deadline, t; in main() local
417 timeradd(&start, &timeout, &deadline); in main()
432 if (timercmp(&now, &deadline, >=)) in main()
H A Dddd-04-fd-nonblocking.c378 struct timeval start, now, deadline, t; in main() local
388 timeradd(&start, &timeout, &deadline); in main()
403 if (timercmp(&now, &deadline, >=)) in main()
422 struct timeval start, now, deadline, t; in main() local
432 timeradd(&start, &timeout, &deadline); in main()
446 if (timercmp(&now, &deadline, >=)) in main()
/freebsd/crypto/openssl/test/
H A Dquic_ackm_test.c332 static void on_loss_detection_deadline_callback(OSSL_TIME deadline, void *arg) in on_loss_detection_deadline_callback() argument
334 *(OSSL_TIME *)arg = deadline; in on_loss_detection_deadline_callback()
418 OSSL_TIME deadline = ossl_ackm_get_loss_detection_deadline(h.ackm); in test_tx_ack_case_actual() local
421 if (!TEST_int_eq(ossl_time_compare(deadline, loss_detection_deadline), 0)) in test_tx_ack_case_actual()
424 /* We should have a PTO deadline. */ in test_tx_ack_case_actual()
425 if (!TEST_int_gt(ossl_time_compare(deadline, fake_time), 0)) in test_tx_ack_case_actual()
441 /* Advance to the PTO deadline. */ in test_tx_ack_case_actual()
442 fake_time = ossl_time_add(deadline, ossl_ticks2time(1)); in test_tx_ack_case_actual()
619 RX_OPK_CHECK_STATE, /* check is_desired/deadline */
759 RX_OP_CHECK_STATE (0, 0, 1) /* threshold not yet met, so deadline */
[all …]
/freebsd/lib/libtacplus/
H A Dtaclib.c485 const struct timeval *deadline) in read_timed() argument
506 timersub(deadline, &tv, &tv); in read_timed()
543 struct timeval deadline; in recv_msg() local
548 gettimeofday(&deadline, NULL); in recv_msg()
549 deadline.tv_sec += h->servers[h->cur_server].timeout; in recv_msg()
552 if (read_timed(h, msg, HDRSIZE, &deadline) == -1) in recv_msg()
579 if (read_timed(h, msg->u.body, len, &deadline) == -1) in recv_msg()
615 struct timeval deadline; in send_msg() local
638 gettimeofday(&deadline, NULL); in send_msg()
639 deadline.tv_sec += h->servers[h->cur_server].timeout; in send_msg()
[all …]
/freebsd/sys/net/altq/
H A Daltq_hfsc.h88 u_int64_t d; /* deadline */
131 u_int64_t d; /* deadline */
236 u_int64_t cl_d; /* deadline */
260 struct runtime_sc cl_deadline; /* deadline curve */
/freebsd/sys/dev/nvme/
H A Dnvme_qpair.c924 * an indefinite amount of time and have no deadline. in nvme_qpair_timeout()
926 if (tr->deadline == SBT_MAX) in nvme_qpair_timeout()
934 if (now <= tr->deadline) in nvme_qpair_timeout()
944 * deadline has passed. Poll the competions as a last-ditch in nvme_qpair_timeout()
963 * an indefinite amount of time and have no deadline. in nvme_qpair_timeout()
965 if (tr->deadline == SBT_MAX) in nvme_qpair_timeout()
976 if (now <= tr->deadline) in nvme_qpair_timeout()
1054 tr->deadline = getsbinuptime() + timeout * SBT_1S; in nvme_qpair_submit_tracker()
1061 tr->deadline = SBT_MAX; in nvme_qpair_submit_tracker()
1169 tr->deadline = SBT_MAX; in _nvme_qpair_submit_request()
[all …]
/freebsd/sys/dev/ufshci/
H A Dufshci_req_queue.c576 if (now <= tr->deadline) in ufshci_req_queue_timeout()
586 * deadline has passed. Poll the competions as a last-ditch in ufshci_req_queue_timeout()
606 if (now <= tr->deadline) in ufshci_req_queue_timeout()
699 tr->deadline = getsbinuptime() + timeout * SBT_1S; in ufshci_req_queue_submit_tracker()
703 * It wakes up once every 0.5 seconds to check if the deadline in ufshci_req_queue_submit_tracker()
771 tr->deadline = SBT_MAX; in _ufshci_req_queue_submit_request()
/freebsd/crypto/openssh/
H A Dssh-agent.c1077 time_t deadline = 0, now = monotime(); in reaper() local
1090 deadline = (deadline == 0) ? id->death : in reaper()
1091 MINIMUM(deadline, id->death); in reaper()
1093 if (deadline == 0 || deadline <= now) in reaper()
1096 return (deadline - now); in reaper()
2114 time_t deadline; in prepare_poll() local
2172 deadline = reaper(); in prepare_poll()
2174 deadline = (deadline == 0) ? parent_alive_interval : in prepare_poll()
2175 MINIMUM(deadline, parent_alive_interval); in prepare_poll()
2176 if (deadline != 0) in prepare_poll()
[all …]

1234