diff options
| author | Hugo Landau <hlandau@openssl.org> | 2023-02-21 10:18:59 +0000 |
|---|---|---|
| committer | Hugo Landau <hlandau@openssl.org> | 2023-03-30 11:14:08 +0100 |
| commit | ccd31037713ad1cdfd88c85a169bd18b08579813 (patch) | |
| tree | d00a9ea37ff1e04ad9ad4ae7d2c9bfd9c7aa9f13 /ssl/quic/quic_impl.c | |
| parent | f2f7c4f15ab1d8dc36b668877253c0e497da8ca6 (diff) | |
Add channel-only tick mode and use it for thread assisted mode
Reviewed-by: Tomas Mraz <tomas@openssl.org>
Reviewed-by: Matt Caswell <matt@openssl.org>
(Merged from https://github.com/openssl/openssl/pull/20348)
Diffstat (limited to 'ssl/quic/quic_impl.c')
| -rw-r--r-- | ssl/quic/quic_impl.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/ssl/quic/quic_impl.c b/ssl/quic/quic_impl.c index 73071d4a73..4286c526b7 100644 --- a/ssl/quic/quic_impl.c +++ b/ssl/quic/quic_impl.c @@ -450,7 +450,7 @@ int ossl_quic_tick(QUIC_CONNECTION *qc) return 1; } - ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch)); + ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch), 0); quic_unlock(qc); return 1; } @@ -587,7 +587,7 @@ int ossl_quic_conn_shutdown(QUIC_CONNECTION *qc, uint64_t flags, if (blocking_mode(qc) && (flags & SSL_SHUTDOWN_FLAG_RAPID) == 0) block_until_pred(qc, quic_shutdown_wait, qc, 0); else - ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch)); + ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch), 0); ret = ossl_quic_channel_is_terminated(qc->ch); quic_unlock(qc); @@ -783,7 +783,7 @@ static int quic_do_handshake(QUIC_CONNECTION *qc) return 1; } else { /* Try to advance the reactor. */ - ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch)); + ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch), 0); if (ossl_quic_channel_is_handshake_complete(qc->ch)) /* The handshake is now done. */ @@ -895,7 +895,7 @@ static void quic_post_write(QUIC_CONNECTION *qc, int did_append, int do_tick) * plus we should eventually consider Nagle's algorithm. */ if (do_tick) - ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch)); + ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch), 0); } struct quic_write_again_args { @@ -1282,7 +1282,7 @@ static int quic_read(SSL *s, void *buf, size_t len, size_t *bytes_read, int peek * Even though we succeeded, tick the reactor here to ensure we are * handling other aspects of the QUIC connection. */ - ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch)); + ossl_quic_reactor_tick(ossl_quic_channel_get_reactor(qc->ch), 0); ret = 1; } else if (blocking_mode(qc)) { /* |