Skip to main content
  • Home
  • login
  • Browse the archive

    swh mirror partner logo
swh logo
SoftwareHeritage
Software
Heritage
Mirror
Features
  • Search

  • Downloads

  • Save code now

  • Add forge now

  • Help

swh:1:snp:dc2a5002442a00b1c0eda7c65d04ea7455e166cd
  • Code
  • Branches (204)
  • Releases (207)
    • Branches
    • Releases
    • HEAD
    • refs/heads/OpenSSL-engine-0_9_6-stable
    • refs/heads/OpenSSL-fips-0_9_7-stable
    • refs/heads/OpenSSL-fips-0_9_8-stable
    • refs/heads/OpenSSL-fips-1_2-stable
    • refs/heads/OpenSSL-fips-2_0-dev
    • refs/heads/OpenSSL-fips-2_0-stable
    • refs/heads/OpenSSL-fips2-0_9_7-stable
    • refs/heads/OpenSSL_0_9_6-stable
    • refs/heads/OpenSSL_0_9_7-stable
    • refs/heads/OpenSSL_0_9_8-stable
    • refs/heads/OpenSSL_0_9_8fg-stable
    • refs/heads/OpenSSL_1_0_0-stable
    • refs/heads/OpenSSL_1_0_1-stable
    • refs/heads/OpenSSL_1_0_2-stable
    • refs/heads/OpenSSL_1_1_0-stable
    • refs/heads/OpenSSL_1_1_1-stable
    • refs/heads/SSLeay
    • refs/heads/feature/dtls-1.3
    • refs/heads/feature/ech
    • refs/heads/feature/quic-server
    • refs/heads/master
    • refs/heads/openssl-3.0
    • refs/heads/openssl-3.1
    • refs/heads/openssl-3.2
    • refs/heads/openssl-3.3
    • refs/heads/openssl-3.4
    • refs/heads/tls1.3-draft-18
    • refs/heads/tls1.3-draft-19
    • refs/tags/AFTER_COMPAQ_PATCH
    • refs/tags/BEFORE_COMPAQ_PATCH
    • refs/tags/BEFORE_engine
    • refs/tags/BEN_FIPS_TEST_1
    • refs/tags/BEN_FIPS_TEST_2
    • refs/tags/BEN_FIPS_TEST_3
    • refs/tags/BEN_FIPS_TEST_4
    • refs/tags/BEN_FIPS_TEST_5
    • refs/tags/BEN_FIPS_TEST_6
    • refs/tags/BEN_FIPS_TEST_7
    • refs/tags/BEN_FIPS_TEST_8
    • refs/tags/FIPS_098_TEST_1
    • refs/tags/FIPS_098_TEST_2
    • refs/tags/FIPS_098_TEST_3
    • refs/tags/FIPS_098_TEST_4
    • refs/tags/FIPS_098_TEST_5
    • refs/tags/FIPS_098_TEST_6
    • refs/tags/FIPS_098_TEST_7
    • refs/tags/FIPS_098_TEST_8
    • refs/tags/FIPS_TEST_10
    • refs/tags/FIPS_TEST_9
    • refs/tags/LEVITTE_after_const
    • refs/tags/LEVITTE_before_const
    • refs/tags/OpenSSL-engine-0_9_6
    • refs/tags/OpenSSL-engine-0_9_6-beta1
    • refs/tags/OpenSSL-engine-0_9_6-beta2
    • refs/tags/OpenSSL-engine-0_9_6-beta3
    • refs/tags/OpenSSL-engine-0_9_6a
    • refs/tags/OpenSSL-engine-0_9_6a-beta1
    • refs/tags/OpenSSL-engine-0_9_6a-beta2
    • refs/tags/OpenSSL-engine-0_9_6a-beta3
    • refs/tags/OpenSSL-engine-0_9_6b
    • refs/tags/OpenSSL-engine-0_9_6c
    • refs/tags/OpenSSL-engine-0_9_6d
    • refs/tags/OpenSSL-engine-0_9_6d-beta1
    • refs/tags/OpenSSL-engine-0_9_6e
    • refs/tags/OpenSSL-engine-0_9_6f
    • refs/tags/OpenSSL-engine-0_9_6g
    • refs/tags/OpenSSL-engine-0_9_6h
    • refs/tags/OpenSSL-engine-0_9_6i
    • refs/tags/OpenSSL-engine-0_9_6j
    • refs/tags/OpenSSL-engine-0_9_6k
    • refs/tags/OpenSSL-engine-0_9_6l
    • refs/tags/OpenSSL-engine-0_9_6m
    • refs/tags/OpenSSL-fips-1_2_0
    • refs/tags/OpenSSL-fips-1_2_1
    • refs/tags/OpenSSL-fips-1_2_2
    • refs/tags/OpenSSL-fips-1_2_3
    • refs/tags/OpenSSL-fips-2_0
    • refs/tags/OpenSSL-fips-2_0-pl1
    • refs/tags/OpenSSL-fips-2_0-rc1
    • refs/tags/OpenSSL-fips-2_0-rc2
    • refs/tags/OpenSSL-fips-2_0-rc3
    • refs/tags/OpenSSL-fips-2_0-rc4
    • refs/tags/OpenSSL-fips-2_0-rc5
    • refs/tags/OpenSSL-fips-2_0-rc6
    • refs/tags/OpenSSL-fips-2_0-rc7
    • refs/tags/OpenSSL-fips-2_0-rc8
    • refs/tags/OpenSSL-fips-2_0-rc9
    • refs/tags/OpenSSL-fips-2_0_1
    • refs/tags/OpenSSL_0_9_1c
    • refs/tags/OpenSSL_0_9_2b
    • refs/tags/OpenSSL_0_9_3
    • refs/tags/OpenSSL_0_9_3a
    • refs/tags/OpenSSL_0_9_3beta1
    • refs/tags/OpenSSL_0_9_3beta2
    • refs/tags/OpenSSL_0_9_4
    • refs/tags/OpenSSL_0_9_5
    • refs/tags/OpenSSL_0_9_5a
    • refs/tags/OpenSSL_0_9_5a-beta1
    • refs/tags/OpenSSL_0_9_5a-beta2
    • refs/tags/OpenSSL_0_9_5beta1
    • refs/tags/OpenSSL_0_9_5beta2
    • refs/tags/OpenSSL_0_9_6
    • refs/tags/OpenSSL_0_9_6-beta1
    • refs/tags/OpenSSL_0_9_6-beta2
    • refs/tags/OpenSSL_0_9_6-beta3
    • refs/tags/OpenSSL_0_9_6a
    • refs/tags/OpenSSL_0_9_6a-beta1
    • refs/tags/OpenSSL_0_9_6a-beta2
    • refs/tags/OpenSSL_0_9_6a-beta3
    • refs/tags/OpenSSL_0_9_6b
    • refs/tags/OpenSSL_0_9_6c
    • refs/tags/OpenSSL_0_9_6d
    • refs/tags/OpenSSL_0_9_6d-beta1
    • refs/tags/OpenSSL_0_9_6e
    • refs/tags/OpenSSL_0_9_6f
    • refs/tags/OpenSSL_0_9_6g
    • refs/tags/OpenSSL_0_9_6h
    • refs/tags/OpenSSL_0_9_6i
    • refs/tags/OpenSSL_0_9_6j
    • refs/tags/OpenSSL_0_9_6k
    • refs/tags/OpenSSL_0_9_6l
    • refs/tags/OpenSSL_0_9_6m
    • refs/tags/OpenSSL_0_9_7
    • refs/tags/OpenSSL_0_9_7-beta1
    • refs/tags/OpenSSL_0_9_7-beta2
    • refs/tags/OpenSSL_0_9_7-beta3
    • refs/tags/OpenSSL_0_9_7-beta4
    • refs/tags/OpenSSL_0_9_7-beta5
    • refs/tags/OpenSSL_0_9_7-beta6
    • refs/tags/OpenSSL_0_9_7a
    • refs/tags/OpenSSL_0_9_7b
    • refs/tags/OpenSSL_0_9_7c
    • refs/tags/OpenSSL_0_9_7d
    • refs/tags/OpenSSL_0_9_7e
    • refs/tags/OpenSSL_0_9_7f
    • refs/tags/OpenSSL_0_9_7g
    • refs/tags/OpenSSL_0_9_7h
    • refs/tags/OpenSSL_0_9_7i
    • refs/tags/OpenSSL_0_9_7j
    • refs/tags/OpenSSL_0_9_7k
    • refs/tags/OpenSSL_0_9_7l
    • refs/tags/OpenSSL_0_9_7m
    • refs/tags/OpenSSL_0_9_8
    • refs/tags/OpenSSL_0_9_8-beta1
    • refs/tags/OpenSSL_0_9_8-beta2
    • refs/tags/OpenSSL_0_9_8-beta3
    • refs/tags/OpenSSL_0_9_8-beta4
    • refs/tags/OpenSSL_0_9_8-beta5
    • refs/tags/OpenSSL_0_9_8-beta6
    • refs/tags/OpenSSL_0_9_8a
    • refs/tags/OpenSSL_0_9_8b
    • refs/tags/OpenSSL_0_9_8c
    • refs/tags/OpenSSL_0_9_8d
    • refs/tags/OpenSSL_0_9_8e
    • refs/tags/OpenSSL_0_9_8f
    • refs/tags/OpenSSL_0_9_8g
    • refs/tags/OpenSSL_0_9_8h
    • refs/tags/OpenSSL_0_9_8i
    • refs/tags/OpenSSL_0_9_8j
    • refs/tags/OpenSSL_0_9_8k
    • refs/tags/OpenSSL_0_9_8l
    • refs/tags/OpenSSL_0_9_8m
    • refs/tags/OpenSSL_0_9_8m-beta1
    • refs/tags/OpenSSL_0_9_8n
    • refs/tags/OpenSSL_0_9_8o
    • refs/tags/OpenSSL_0_9_8p
    • refs/tags/OpenSSL_0_9_8q
    • refs/tags/OpenSSL_0_9_8r
    • refs/tags/OpenSSL_0_9_8s
    • refs/tags/OpenSSL_0_9_8t
    • refs/tags/OpenSSL_0_9_8u
    • refs/tags/OpenSSL_0_9_8v
    • refs/tags/OpenSSL_0_9_8w
    • refs/tags/OpenSSL_0_9_8x
    • refs/tags/OpenSSL_1_0_0
    • refs/tags/OpenSSL_1_0_0-beta1
    • refs/tags/OpenSSL_1_0_0-beta2
    • refs/tags/OpenSSL_1_0_0-beta3
    • refs/tags/OpenSSL_1_0_0-beta4
    • refs/tags/OpenSSL_1_0_0-beta5
    • refs/tags/OpenSSL_1_0_0a
    • refs/tags/OpenSSL_1_0_0b
    • refs/tags/OpenSSL_1_0_0c
    • refs/tags/OpenSSL_1_0_0d
    • refs/tags/OpenSSL_1_0_0e
    • refs/tags/OpenSSL_1_0_0f
    • refs/tags/OpenSSL_1_0_0g
    • refs/tags/OpenSSL_1_0_0h
    • refs/tags/OpenSSL_1_0_0i
    • refs/tags/OpenSSL_1_0_0j
    • refs/tags/OpenSSL_1_0_1
    • refs/tags/OpenSSL_1_0_1-beta1
    • refs/tags/OpenSSL_1_0_1-beta2
    • refs/tags/OpenSSL_1_0_1-beta3
    • refs/tags/OpenSSL_1_0_1a
    • refs/tags/OpenSSL_1_0_1b
    • refs/tags/OpenSSL_1_0_1c
    • refs/tags/OpenSSL_FIPS_1_0
    • refs/tags/SSLeay_0_8_1b
    • refs/tags/SSLeay_0_9_0b
    • refs/tags/SSLeay_0_9_1b
    • refs/tags/STATE_after_zlib
    • refs/tags/STATE_before_zlib
    • refs/tags/rsaref
    • openssl-3.4.0-alpha1
    • openssl-3.3.2
    • openssl-3.3.1
    • openssl-3.3.0-beta1
    • openssl-3.3.0-alpha1
    • openssl-3.3.0
    • openssl-3.2.3
    • openssl-3.2.2
    • openssl-3.2.1
    • openssl-3.2.0-beta1
    • openssl-3.2.0-alpha2
    • openssl-3.2.0-alpha1
    • openssl-3.2.0
    • openssl-3.1.7
    • openssl-3.1.6
    • openssl-3.1.5
    • openssl-3.1.4
    • openssl-3.1.3
    • openssl-3.1.2
    • openssl-3.1.1
    • openssl-3.1.0-beta1
    • openssl-3.1.0-alpha1
    • openssl-3.1.0
    • openssl-3.0.9
    • openssl-3.0.8
    • openssl-3.0.7
    • openssl-3.0.6
    • openssl-3.0.5
    • openssl-3.0.4
    • openssl-3.0.3
    • openssl-3.0.2
    • openssl-3.0.15
    • openssl-3.0.14
    • openssl-3.0.13
    • openssl-3.0.12
    • openssl-3.0.11
    • openssl-3.0.10
    • openssl-3.0.1
    • openssl-3.0.0-beta2
    • openssl-3.0.0-beta1
    • openssl-3.0.0-alpha9
    • openssl-3.0.0-alpha8
    • openssl-3.0.0-alpha7
    • openssl-3.0.0-alpha6
    • openssl-3.0.0-alpha5
    • openssl-3.0.0-alpha4
    • openssl-3.0.0-alpha3
    • openssl-3.0.0-alpha2
    • openssl-3.0.0-alpha17
    • openssl-3.0.0-alpha16
    • openssl-3.0.0-alpha15
    • openssl-3.0.0-alpha14
    • openssl-3.0.0-alpha13
    • openssl-3.0.0-alpha12
    • openssl-3.0.0-alpha11
    • openssl-3.0.0-alpha10
    • openssl-3.0.0-alpha1
    • openssl-3.0.0
    • master-pre-reformat
    • master-pre-auto-reformat
    • master-post-reformat
    • master-post-auto-reformat
    • OpenSSL_1_1_1w
    • OpenSSL_1_1_1v
    • OpenSSL_1_1_1u
    • OpenSSL_1_1_1t
    • OpenSSL_1_1_1s
    • OpenSSL_1_1_1r
    • OpenSSL_1_1_1q
    • OpenSSL_1_1_1p
    • OpenSSL_1_1_1o
    • OpenSSL_1_1_1n
    • OpenSSL_1_1_1m
    • OpenSSL_1_1_1l
    • OpenSSL_1_1_1k
    • OpenSSL_1_1_1j
    • OpenSSL_1_1_1i
    • OpenSSL_1_1_1h
    • OpenSSL_1_1_1g
    • OpenSSL_1_1_1f
    • OpenSSL_1_1_1e
    • OpenSSL_1_1_1d
    • OpenSSL_1_1_1c
    • OpenSSL_1_1_1b
    • OpenSSL_1_1_1a
    • OpenSSL_1_1_1-pre9
    • OpenSSL_1_1_1-pre8
    • OpenSSL_1_1_1-pre7
    • OpenSSL_1_1_1-pre6
    • OpenSSL_1_1_1-pre5
    • OpenSSL_1_1_1-pre4
    • OpenSSL_1_1_1-pre3
    • OpenSSL_1_1_1-pre2
    • OpenSSL_1_1_1-pre1
    • OpenSSL_1_1_1
    • OpenSSL_1_1_0l
    • OpenSSL_1_1_0k
    • OpenSSL_1_1_0j
    • OpenSSL_1_1_0i
    • OpenSSL_1_1_0h
    • OpenSSL_1_1_0g
    • OpenSSL_1_1_0f
    • OpenSSL_1_1_0e
    • OpenSSL_1_1_0d
    • OpenSSL_1_1_0c
    • OpenSSL_1_1_0b
    • OpenSSL_1_1_0a
    • OpenSSL_1_1_0-pre6
    • OpenSSL_1_1_0-pre5
    • OpenSSL_1_1_0-pre4
    • OpenSSL_1_1_0-pre3
    • OpenSSL_1_1_0-pre2
    • OpenSSL_1_1_0-pre1
    • OpenSSL_1_1_0
    • OpenSSL_1_0_2u
    • OpenSSL_1_0_2t
    • OpenSSL_1_0_2s
    • OpenSSL_1_0_2r
    • OpenSSL_1_0_2q
    • OpenSSL_1_0_2p
    • OpenSSL_1_0_2o
    • OpenSSL_1_0_2n
    • OpenSSL_1_0_2m
    • OpenSSL_1_0_2l
    • OpenSSL_1_0_2k
    • OpenSSL_1_0_2j
    • OpenSSL_1_0_2i
    • OpenSSL_1_0_2h
    • OpenSSL_1_0_2g
    • OpenSSL_1_0_2f
    • OpenSSL_1_0_2e
    • OpenSSL_1_0_2d
    • OpenSSL_1_0_2c
    • OpenSSL_1_0_2b
    • OpenSSL_1_0_2a
    • OpenSSL_1_0_2-pre-reformat
    • OpenSSL_1_0_2-pre-auto-reformat
    • OpenSSL_1_0_2-post-reformat
    • OpenSSL_1_0_2-post-auto-reformat
    • OpenSSL_1_0_2-beta3
    • OpenSSL_1_0_2-beta2
    • OpenSSL_1_0_2-beta1
    • OpenSSL_1_0_2
    • OpenSSL_1_0_1u
    • OpenSSL_1_0_1t
    • OpenSSL_1_0_1s
    • OpenSSL_1_0_1r
    • OpenSSL_1_0_1q
    • OpenSSL_1_0_1p
    • OpenSSL_1_0_1o
    • OpenSSL_1_0_1n
    • OpenSSL_1_0_1m
    • OpenSSL_1_0_1l
    • OpenSSL_1_0_1k
    • OpenSSL_1_0_1j
    • OpenSSL_1_0_1i
    • OpenSSL_1_0_1h
    • OpenSSL_1_0_1g
    • OpenSSL_1_0_1f
    • OpenSSL_1_0_1e
    • OpenSSL_1_0_1d
    • OpenSSL_1_0_1-pre-reformat
    • OpenSSL_1_0_1-pre-auto-reformat
    • OpenSSL_1_0_1-post-reformat
    • OpenSSL_1_0_1-post-auto-reformat
    • OpenSSL_1_0_0t
    • OpenSSL_1_0_0s
    • OpenSSL_1_0_0r
    • OpenSSL_1_0_0q
    • OpenSSL_1_0_0p
    • OpenSSL_1_0_0o
    • OpenSSL_1_0_0n
    • OpenSSL_1_0_0m
    • OpenSSL_1_0_0l
    • OpenSSL_1_0_0k
    • OpenSSL_1_0_0-pre-reformat
    • OpenSSL_1_0_0-pre-auto-reformat
    • OpenSSL_1_0_0-post-reformat
    • OpenSSL_1_0_0-post-auto-reformat
    • OpenSSL_0_9_8zh
    • OpenSSL_0_9_8zg
    • OpenSSL_0_9_8zf
    • OpenSSL_0_9_8ze
    • OpenSSL_0_9_8zd
    • OpenSSL_0_9_8zc
    • OpenSSL_0_9_8zb
    • OpenSSL_0_9_8za
    • OpenSSL_0_9_8y
    • OpenSSL_0_9_8-pre-reformat
    • OpenSSL_0_9_8-pre-auto-reformat
    • OpenSSL_0_9_8-post-reformat
    • OpenSSL_0_9_8-post-auto-reformat
    • OpenSSL-fips-2_0_9
    • OpenSSL-fips-2_0_8
    • OpenSSL-fips-2_0_7
    • OpenSSL-fips-2_0_6
    • OpenSSL-fips-2_0_5
    • OpenSSL-fips-2_0_4
    • OpenSSL-fips-2_0_3
    • OpenSSL-fips-2_0_2
    • OpenSSL-fips-2_0_16
    • OpenSSL-fips-2_0_15
    • OpenSSL-fips-2_0_14
    • OpenSSL-fips-2_0_13
    • OpenSSL-fips-2_0_12
    • OpenSSL-fips-2_0_11
    • OpenSSL-fips-2_0_10
  • 431efd3
  • /
  • test
  • /
  • quic_fc_test.c
Raw File
Permalinks

To reference or cite the objects present in the Software Heritage archive, permalinks based on SoftWare Hash IDentifiers (SWHIDs) must be used.
Select below a type of object currently browsed in order to display its associated SWHID and permalink.

  • content
  • directory
  • revision
  • snapshot
  • release
content badge Iframe embedding
swh:1:cnt:e624d81b7344c1614f092d9c49f4749f05688cbc
directory badge Iframe embedding
swh:1:dir:1bb7269b1e9b2900b760c40c6057de2cf3e8ceea
revision badge
swh:1:rev:26ecab1fd7fa7f5103ac57ef41ee0dd38fbe2ddc
snapshot badge
swh:1:snp:dc2a5002442a00b1c0eda7c65d04ea7455e166cd
release badge
swh:1:rel:560e0a73c6c96a70a9530870d5a361cd67b43c14
Tip revision: 26ecab1fd7fa7f5103ac57ef41ee0dd38fbe2ddc authored by Matt Caswell on 26 October 2023, 13:22:51 UTC
Prepare for release of 3.2 beta 1
Tip revision: 26ecab1
quic_fc_test.c
/*
 * Copyright 2022-2023 The OpenSSL Project Authors. All Rights Reserved.
 *
 * Licensed under the Apache License 2.0 (the "License").  You may not use
 * this file except in compliance with the License.  You can obtain a copy
 * in the file LICENSE in the source distribution or at
 * https://www.openssl.org/source/license.html
 */

#include "internal/quic_fc.h"
#include "internal/quic_error.h"
#include "testutil.h"

static int test_txfc(int is_stream)
{
    int testresult = 0;
    QUIC_TXFC conn_txfc, stream_txfc, *txfc, *parent_txfc;

    if (!TEST_true(ossl_quic_txfc_init(&conn_txfc, 0)))
        goto err;

    if (is_stream && !TEST_true(ossl_quic_txfc_init(&stream_txfc, &conn_txfc)))
        goto err;

    txfc = is_stream ? &stream_txfc : &conn_txfc;
    parent_txfc = is_stream ? &conn_txfc : NULL;

    if (!TEST_true(ossl_quic_txfc_bump_cwm(txfc, 2000)))
        goto err;

    if (is_stream && !TEST_true(ossl_quic_txfc_bump_cwm(parent_txfc, 2000)))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_swm(txfc), 0))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_cwm(txfc), 2000))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit_local(txfc), 2000))
        goto err;

    if (is_stream && !TEST_uint64_t_eq(ossl_quic_txfc_get_credit(txfc),
                                       2000))
        goto err;

    if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0)))
        goto err;

    if (!TEST_true(ossl_quic_txfc_consume_credit(txfc, 500)))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit_local(txfc), 1500))
        goto err;

    if (is_stream && !TEST_uint64_t_eq(ossl_quic_txfc_get_credit(txfc),
                                       1500))
        goto err;

    if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0)))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_swm(txfc), 500))
        goto err;

    if (!TEST_true(ossl_quic_txfc_consume_credit(txfc, 100)))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_swm(txfc), 600))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit_local(txfc), 1400))
        goto err;

    if (is_stream && !TEST_uint64_t_eq(ossl_quic_txfc_get_credit(txfc),
                                       1400))
        goto err;

    if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0)))
        goto err;

    if (!TEST_true(ossl_quic_txfc_consume_credit(txfc, 1400)))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit_local(txfc), 0))
        goto err;

    if (is_stream && !TEST_uint64_t_eq(ossl_quic_txfc_get_credit(txfc),
                                       0))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_swm(txfc), 2000))
        goto err;

    if (!TEST_true(ossl_quic_txfc_has_become_blocked(txfc, 0)))
        goto err;

    if (!TEST_true(ossl_quic_txfc_has_become_blocked(txfc, 0)))
        goto err;

    if (!TEST_true(ossl_quic_txfc_has_become_blocked(txfc, 1)))
        goto err;

    if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0)))
        goto err;

    if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0)))
        goto err;

    if (!TEST_false(ossl_quic_txfc_consume_credit(txfc, 1)))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_cwm(txfc), 2000))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_swm(txfc), 2000))
        goto err;

    if (!TEST_false(ossl_quic_txfc_bump_cwm(txfc, 2000)))
        goto err;

    if (!TEST_true(ossl_quic_txfc_bump_cwm(txfc, 2500)))
        goto err;

    if (is_stream && !TEST_true(ossl_quic_txfc_bump_cwm(parent_txfc, 2400)))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_cwm(txfc), 2500))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_swm(txfc), 2000))
        goto err;

    if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit_local(txfc), 500))
        goto err;

    if (is_stream)
        ossl_quic_txfc_has_become_blocked(parent_txfc, 1);

    if (is_stream) {
        if (!TEST_true(ossl_quic_txfc_consume_credit(txfc, 399)))
            goto err;

        if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0)))
            goto err;

        if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit(txfc), 1))
            goto err;

        if (!TEST_true(ossl_quic_txfc_consume_credit(txfc, 1)))
            goto err;

        if (!TEST_true(ossl_quic_txfc_has_become_blocked(parent_txfc, 0)))
            goto err;

        if (!TEST_true(ossl_quic_txfc_has_become_blocked(parent_txfc, 1)))
            goto err;

        if (!TEST_false(ossl_quic_txfc_has_become_blocked(parent_txfc, 0)))
            goto err;
    } else {
        if (!TEST_true(ossl_quic_txfc_consume_credit(txfc, 499)))
            goto err;

        if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0)))
            goto err;

        if (is_stream && !TEST_false(ossl_quic_txfc_has_become_blocked(parent_txfc, 0)))
            goto err;

        if (!TEST_true(ossl_quic_txfc_consume_credit(txfc, 1)))
            goto err;

        if (!TEST_true(ossl_quic_txfc_has_become_blocked(txfc, 0)))
            goto err;

        if (!TEST_true(ossl_quic_txfc_has_become_blocked(txfc, 1)))
            goto err;

        if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0)))
            goto err;
    }

    testresult = 1;
err:
    return testresult;
}

static OSSL_TIME cur_time;

static OSSL_TIME fake_now(void *arg)
{
    return cur_time;
}

#define RX_OPC_END                    0
#define RX_OPC_INIT_CONN              1 /* arg0=initial window, arg1=max window */
#define RX_OPC_INIT_STREAM            2 /* arg0=initial window, arg1=max window */
#define RX_OPC_RX                     3 /* arg0=end, arg1=is_fin */
#define RX_OPC_RETIRE                 4 /* arg0=num_bytes, arg1=rtt in OSSL_TIME ticks, expect_fail */
#define RX_OPC_CHECK_CWM_CONN         5 /* arg0=expected */
#define RX_OPC_CHECK_CWM_STREAM       6 /* arg0=expected */
#define RX_OPC_CHECK_SWM_CONN         7 /* arg0=expected */
#define RX_OPC_CHECK_SWM_STREAM       8 /* arg0=expected */
#define RX_OPC_CHECK_RWM_CONN         9 /* arg0=expected */
#define RX_OPC_CHECK_RWM_STREAM      10 /* arg0=expected */
#define RX_OPC_CHECK_CHANGED_CONN    11 /* arg0=expected, arg1=clear */
#define RX_OPC_CHECK_CHANGED_STREAM  12 /* arg0=expected, arg1=clear */
#define RX_OPC_CHECK_ERROR_CONN      13 /* arg0=expected, arg1=clear */
#define RX_OPC_CHECK_ERROR_STREAM    14 /* arg0=expected, arg1=clear */
#define RX_OPC_STEP_TIME             15 /* arg0=OSSL_TIME ticks to advance */
#define RX_OPC_MSG                   16

struct rx_test_op {
    unsigned char   op;
    size_t          stream_idx;
    uint64_t        arg0, arg1;
    unsigned char   expect_fail;
    const char     *msg;
};

#define RX_OP_END \
    { RX_OPC_END }
#define RX_OP_INIT_CONN(init_window_size, max_window_size) \
    { RX_OPC_INIT_CONN, 0, (init_window_size), (max_window_size) },
#define RX_OP_INIT_STREAM(stream_idx, init_window_size, max_window_size) \
    { RX_OPC_INIT_STREAM, (stream_idx), (init_window_size), (max_window_size) },
#define RX_OP_RX(stream_idx, end, is_fin) \
    { RX_OPC_RX, (stream_idx), (end), (is_fin) },
#define RX_OP_RETIRE(stream_idx, num_bytes, rtt, expect_fail) \
    { RX_OPC_RETIRE, (stream_idx), (num_bytes), (rtt), (expect_fail) },
#define RX_OP_CHECK_CWM_CONN(expected) \
    { RX_OPC_CHECK_CWM_CONN, 0, (expected) },
#define RX_OP_CHECK_CWM_STREAM(stream_id, expected) \
    { RX_OPC_CHECK_CWM_STREAM, (stream_id), (expected) },
#define RX_OP_CHECK_SWM_CONN(expected) \
    { RX_OPC_CHECK_SWM_CONN, 0, (expected) },
#define RX_OP_CHECK_SWM_STREAM(stream_id, expected) \
    { RX_OPC_CHECK_SWM_STREAM, (stream_id), (expected) },
#define RX_OP_CHECK_RWM_CONN(expected) \
    { RX_OPC_CHECK_RWM_CONN, 0, (expected) },
#define RX_OP_CHECK_RWM_STREAM(stream_id, expected) \
    { RX_OPC_CHECK_RWM_STREAM, (stream_id), (expected) },
#define RX_OP_CHECK_CHANGED_CONN(expected, clear) \
    { RX_OPC_CHECK_CHANGED_CONN, 0, (expected), (clear) },
#define RX_OP_CHECK_CHANGED_STREAM(stream_id, expected, clear) \
    { RX_OPC_CHECK_CHANGED_STREAM, (stream_id), (expected), (clear) },
#define RX_OP_CHECK_ERROR_CONN(expected, clear) \
    { RX_OPC_CHECK_ERROR_CONN, 0, (expected), (clear) },
#define RX_OP_CHECK_ERROR_STREAM(stream_id, expected, clear) \
    { RX_OPC_CHECK_ERROR_STREAM, (stream_id), (expected), (clear) },
#define RX_OP_STEP_TIME(t) \
    { RX_OPC_STEP_TIME, 0, (t) },
#define RX_OP_MSG(msg) \
    { RX_OPC_MSG, 0, 0, 0, 0, (msg) },

#define RX_OP_INIT(init_window_size, max_window_size) \
    RX_OP_INIT_CONN(init_window_size, max_window_size) \
    RX_OP_INIT_STREAM(0, init_window_size, max_window_size)
#define RX_OP_CHECK_CWM(expected) \
    RX_OP_CHECK_CWM_CONN(expected) \
    RX_OP_CHECK_CWM_STREAM(0, expected)
#define RX_OP_CHECK_SWM(expected) \
    RX_OP_CHECK_SWM_CONN(expected) \
    RX_OP_CHECK_SWM_STREAM(0, expected)
#define RX_OP_CHECK_RWM(expected) \
    RX_OP_CHECK_RWM_CONN(expected) \
    RX_OP_CHECK_RWM_STREAM(0, expected)
#define RX_OP_CHECK_CHANGED(expected, clear) \
    RX_OP_CHECK_CHANGED_CONN(expected, clear) \
    RX_OP_CHECK_CHANGED_STREAM(0, expected, clear)
#define RX_OP_CHECK_ERROR(expected, clear) \
    RX_OP_CHECK_ERROR_CONN(expected, clear) \
    RX_OP_CHECK_ERROR_STREAM(0, expected, clear)

#define INIT_WINDOW_SIZE (1 * 1024 * 1024)
#define INIT_S_WINDOW_SIZE (384 * 1024)

/* 1. Basic RXFC Tests (stream window == connection window) */
static const struct rx_test_op rx_script_1[] = {
    RX_OP_STEP_TIME(1000 * OSSL_TIME_MS)
    RX_OP_INIT(INIT_WINDOW_SIZE, 10 * INIT_WINDOW_SIZE)
    /* Check initial state. */
    RX_OP_CHECK_CWM(INIT_WINDOW_SIZE)
    RX_OP_CHECK_ERROR(0, 0)
    RX_OP_CHECK_CHANGED(0, 0)
    /* We cannot retire what we have not received. */
    RX_OP_RETIRE(0, 1, 0, 1)
    /* Zero bytes is a no-op and always valid. */
    RX_OP_RETIRE(0, 0, 0, 0)
    /* Consume some window. */
    RX_OP_RX(0, 50, 0)
    /* CWM has not changed. */
    RX_OP_CHECK_CWM(INIT_WINDOW_SIZE)
    RX_OP_CHECK_SWM(50)

    /* RX, Partial retire */
    RX_OP_RX(0, 60, 0)
    RX_OP_CHECK_SWM(60)
    RX_OP_RETIRE(0, 20, 50 * OSSL_TIME_MS, 0)
    RX_OP_CHECK_RWM(20)
    RX_OP_CHECK_SWM(60)
    RX_OP_CHECK_CWM(INIT_WINDOW_SIZE)
    RX_OP_CHECK_CHANGED(0, 0)
    RX_OP_CHECK_ERROR(0, 0)

    /* Fully retired */
    RX_OP_RETIRE(0, 41, 0, 1)
    RX_OP_RETIRE(0, 40, 0, 0)
    RX_OP_CHECK_SWM(60)
    RX_OP_CHECK_RWM(60)
    RX_OP_CHECK_CWM(INIT_WINDOW_SIZE)
    RX_OP_CHECK_CHANGED(0, 0)
    RX_OP_CHECK_ERROR(0, 0)

    /* Exhaustion of window - we do not enlarge the window this epoch */
    RX_OP_STEP_TIME(201 * OSSL_TIME_MS)
    RX_OP_RX(0, INIT_WINDOW_SIZE, 0)
    RX_OP_RETIRE(0, INIT_WINDOW_SIZE - 60, 50 * OSSL_TIME_MS, 0)
    RX_OP_CHECK_SWM(INIT_WINDOW_SIZE)
    RX_OP_CHECK_CHANGED(1, 0)
    RX_OP_CHECK_CHANGED(1, 1)
    RX_OP_CHECK_CHANGED(0, 0)
    RX_OP_CHECK_ERROR(0, 0)
    RX_OP_CHECK_CWM(INIT_WINDOW_SIZE * 2)

    /* Second epoch - we still do not enlarge the window this epoch */
    RX_OP_RX(0, INIT_WINDOW_SIZE + 1, 0)
    RX_OP_STEP_TIME(201 * OSSL_TIME_MS)
    RX_OP_RX(0, INIT_WINDOW_SIZE * 2, 0)
    RX_OP_RETIRE(0, INIT_WINDOW_SIZE, 50 * OSSL_TIME_MS, 0)
    RX_OP_CHECK_SWM(INIT_WINDOW_SIZE * 2)
    RX_OP_CHECK_CHANGED(1, 0)
    RX_OP_CHECK_CHANGED(1, 1)
    RX_OP_CHECK_CHANGED(0, 0)
    RX_OP_CHECK_ERROR(0, 0)
    RX_OP_CHECK_CWM(INIT_WINDOW_SIZE * 3)

    /* Third epoch - we enlarge the window */
    RX_OP_RX(0, INIT_WINDOW_SIZE * 2 + 1, 0)
    RX_OP_STEP_TIME(199 * OSSL_TIME_MS)
    RX_OP_RX(0, INIT_WINDOW_SIZE * 3, 0)
    RX_OP_RETIRE(0, INIT_WINDOW_SIZE, 50 * OSSL_TIME_MS, 0)
    RX_OP_CHECK_SWM(INIT_WINDOW_SIZE * 3)
    RX_OP_CHECK_CHANGED(1, 0)
    RX_OP_CHECK_CHANGED(1, 1)
    RX_OP_CHECK_CHANGED(0, 0)
    RX_OP_CHECK_ERROR(0, 0)
    RX_OP_CHECK_CWM(INIT_WINDOW_SIZE * 5)

    /* Fourth epoch - peer violates flow control */
    RX_OP_RX(0, INIT_WINDOW_SIZE * 5 - 5, 0)
    RX_OP_STEP_TIME(250 * OSSL_TIME_MS)
    RX_OP_RX(0, INIT_WINDOW_SIZE * 5 + 1, 0)
    RX_OP_CHECK_SWM(INIT_WINDOW_SIZE * 5)
    RX_OP_CHECK_ERROR(QUIC_ERR_FLOW_CONTROL_ERROR, 0)
    RX_OP_CHECK_ERROR(QUIC_ERR_FLOW_CONTROL_ERROR, 1)
    RX_OP_CHECK_ERROR(0, 0)
    RX_OP_CHECK_CWM(INIT_WINDOW_SIZE * 5)
    /* 
     * No window expansion due to flow control violation; window expansion is
     * triggered by retirement only.
     */
    RX_OP_CHECK_CHANGED(0, 0)

    RX_OP_END
};

/* 2. Interaction between connection and stream-level flow control */
static const struct rx_test_op rx_script_2[] = {
    RX_OP_STEP_TIME(1000 * OSSL_TIME_MS)
    RX_OP_INIT_CONN(INIT_WINDOW_SIZE, 10 * INIT_WINDOW_SIZE)
    RX_OP_INIT_STREAM(0, INIT_S_WINDOW_SIZE, 30 * INIT_S_WINDOW_SIZE)
    RX_OP_INIT_STREAM(1, INIT_S_WINDOW_SIZE, 30 * INIT_S_WINDOW_SIZE)

    RX_OP_RX(0, 10, 0)
    RX_OP_CHECK_CWM_CONN(INIT_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(0, INIT_S_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(1, INIT_S_WINDOW_SIZE)
    RX_OP_CHECK_SWM_CONN(10)
    RX_OP_CHECK_SWM_STREAM(0, 10)
    RX_OP_CHECK_SWM_STREAM(1, 0)
    RX_OP_CHECK_RWM_CONN(0)
    RX_OP_CHECK_RWM_STREAM(0, 0)
    RX_OP_CHECK_RWM_STREAM(1, 0)

    RX_OP_RX(1, 42, 0)
    RX_OP_RX(1, 42, 0) /* monotonic; equal or lower values ignored */
    RX_OP_RX(1, 35, 0)
    RX_OP_CHECK_CWM_CONN(INIT_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(0, INIT_S_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(1, INIT_S_WINDOW_SIZE)
    RX_OP_CHECK_SWM_CONN(52)
    RX_OP_CHECK_SWM_STREAM(0, 10)
    RX_OP_CHECK_SWM_STREAM(1, 42)
    RX_OP_CHECK_RWM_CONN(0)
    RX_OP_CHECK_RWM_STREAM(0, 0)
    RX_OP_CHECK_RWM_STREAM(1, 0)

    RX_OP_RETIRE(0, 10, 50 * OSSL_TIME_MS, 0)
    RX_OP_CHECK_RWM_CONN(10)
    RX_OP_CHECK_RWM_STREAM(0, 10)
    RX_OP_CHECK_CWM_CONN(INIT_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(0, INIT_S_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(1, INIT_S_WINDOW_SIZE)

    RX_OP_RETIRE(1, 42, 50 * OSSL_TIME_MS, 0)
    RX_OP_CHECK_RWM_CONN(52)
    RX_OP_CHECK_RWM_STREAM(1, 42)
    RX_OP_CHECK_CWM_CONN(INIT_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(0, INIT_S_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(1, INIT_S_WINDOW_SIZE)

    RX_OP_CHECK_CHANGED_CONN(0, 0)

    /* FC limited by stream but not connection */
    RX_OP_STEP_TIME(1000 * OSSL_TIME_MS)
    RX_OP_RX(0, INIT_S_WINDOW_SIZE, 0)
    RX_OP_CHECK_SWM_CONN(INIT_S_WINDOW_SIZE + 42)
    RX_OP_CHECK_SWM_STREAM(0, INIT_S_WINDOW_SIZE)
    RX_OP_CHECK_SWM_STREAM(1, 42)
    RX_OP_CHECK_CWM_CONN(INIT_WINDOW_SIZE)
    RX_OP_CHECK_CWM_STREAM(0, INIT_S_WINDOW_SIZE)

    /* We bump CWM when more than 1/4 of the window has been retired */
    RX_OP_RETIRE(0, INIT_S_WINDOW_SIZE - 10, 50 * OSSL_TIME_MS, 0)
    RX_OP_CHECK_CWM_STREAM(0, INIT_S_WINDOW_SIZE * 2)
    RX_OP_CHECK_CHANGED_STREAM(0, 1, 0)
    RX_OP_CHECK_CHANGED_STREAM(0, 1, 1)
    RX_OP_CHECK_CHANGED_STREAM(0, 0, 0)

    /*
     * This is more than 1/4 of the connection window, so CWM will
     * be bumped here too.
     */
    RX_OP_CHECK_CWM_CONN(INIT_S_WINDOW_SIZE + INIT_WINDOW_SIZE + 42)
    RX_OP_CHECK_RWM_CONN(INIT_S_WINDOW_SIZE + 42)
    RX_OP_CHECK_RWM_STREAM(0, INIT_S_WINDOW_SIZE)
    RX_OP_CHECK_RWM_STREAM(1, 42)
    RX_OP_CHECK_CHANGED_CONN(1, 0)
    RX_OP_CHECK_CHANGED_CONN(1, 1)
    RX_OP_CHECK_CHANGED_CONN(0, 0)
    RX_OP_CHECK_ERROR_CONN(0, 0)
    RX_OP_CHECK_ERROR_STREAM(0, 0, 0)
    RX_OP_CHECK_ERROR_STREAM(1, 0, 0)

    /* Test exceeding limit at stream level. */
    RX_OP_RX(0, INIT_S_WINDOW_SIZE * 2 + 1, 0)
    RX_OP_CHECK_ERROR_STREAM(0, QUIC_ERR_FLOW_CONTROL_ERROR, 0)
    RX_OP_CHECK_ERROR_STREAM(0, QUIC_ERR_FLOW_CONTROL_ERROR, 1)
    RX_OP_CHECK_ERROR_STREAM(0, 0, 0)
    RX_OP_CHECK_ERROR_CONN(0, 0) /* doesn't affect conn */

    /* Test exceeding limit at connection level. */
    RX_OP_RX(0, INIT_WINDOW_SIZE * 2, 0)
    RX_OP_CHECK_ERROR_CONN(QUIC_ERR_FLOW_CONTROL_ERROR, 0)
    RX_OP_CHECK_ERROR_CONN(QUIC_ERR_FLOW_CONTROL_ERROR, 1)
    RX_OP_CHECK_ERROR_CONN(0, 0)

    RX_OP_END
};

static const struct rx_test_op *rx_scripts[] = {
    rx_script_1,
    rx_script_2
};

static int run_rxfc_script(const struct rx_test_op *script)
{
#define MAX_STREAMS     3
    int testresult = 0;
    const struct rx_test_op *op = script;
    QUIC_RXFC conn_rxfc = {0}, stream_rxfc[MAX_STREAMS] = {0}; /* coverity */
    char stream_init_done[MAX_STREAMS] = {0};
    int conn_init_done = 0;

    cur_time = ossl_time_zero();

    for (; op->op != RX_OPC_END; ++op) {
        switch (op->op) {
            case RX_OPC_INIT_CONN:
                if (!TEST_true(ossl_quic_rxfc_init(&conn_rxfc, 0,
                                                   op->arg0, op->arg1,
                                                   fake_now, NULL)))
                    goto err;

                conn_init_done = 1;
                break;

            case RX_OPC_INIT_STREAM:
                if (!TEST_size_t_lt(op->stream_idx, OSSL_NELEM(stream_rxfc))
                    || !TEST_true(conn_init_done))
                    goto err;

                if (!TEST_true(ossl_quic_rxfc_init(&stream_rxfc[op->stream_idx],
                                                   &conn_rxfc,
                                                   op->arg0, op->arg1,
                                                   fake_now, NULL)))
                    goto err;

                stream_init_done[op->stream_idx] = 1;
                break;

            case RX_OPC_RX:
                if (!TEST_true(conn_init_done && op->stream_idx < OSSL_NELEM(stream_rxfc)
                               && stream_init_done[op->stream_idx]))
                    goto err;

                if (!TEST_true(ossl_quic_rxfc_on_rx_stream_frame(&stream_rxfc[op->stream_idx],
                                                                 op->arg0,
                                                                 (int)op->arg1)))
                    goto err;

                break;

            case RX_OPC_RETIRE:
                if (!TEST_true(conn_init_done && op->stream_idx < OSSL_NELEM(stream_rxfc)
                               && stream_init_done[op->stream_idx]))
                    goto err;

                if (!TEST_int_eq(ossl_quic_rxfc_on_retire(&stream_rxfc[op->stream_idx],
                                                          op->arg0,
                                                          ossl_ticks2time(op->arg1)),
                                 !op->expect_fail))
                    goto err;

                break;
            case RX_OPC_CHECK_CWM_CONN:
                if (!TEST_true(conn_init_done))
                    goto err;
                if (!TEST_uint64_t_eq(ossl_quic_rxfc_get_cwm(&conn_rxfc),
                                      op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_CWM_STREAM:
                if (!TEST_true(op->stream_idx < OSSL_NELEM(stream_rxfc)
                               && stream_init_done[op->stream_idx]))
                    goto err;
                if (!TEST_uint64_t_eq(ossl_quic_rxfc_get_cwm(&stream_rxfc[op->stream_idx]),
                                      op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_SWM_CONN:
                if (!TEST_true(conn_init_done))
                    goto err;
                if (!TEST_uint64_t_eq(ossl_quic_rxfc_get_swm(&conn_rxfc),
                                      op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_SWM_STREAM:
                if (!TEST_true(op->stream_idx < OSSL_NELEM(stream_rxfc)
                               && stream_init_done[op->stream_idx]))
                    goto err;
                if (!TEST_uint64_t_eq(ossl_quic_rxfc_get_swm(&stream_rxfc[op->stream_idx]),
                                      op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_RWM_CONN:
                if (!TEST_true(conn_init_done))
                    goto err;
                if (!TEST_uint64_t_eq(ossl_quic_rxfc_get_rwm(&conn_rxfc),
                                      op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_RWM_STREAM:
                if (!TEST_true(op->stream_idx < OSSL_NELEM(stream_rxfc)
                               && stream_init_done[op->stream_idx]))
                    goto err;
                if (!TEST_uint64_t_eq(ossl_quic_rxfc_get_rwm(&stream_rxfc[op->stream_idx]),
                                      op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_CHANGED_CONN:
                if (!TEST_true(conn_init_done))
                    goto err;
                if (!TEST_int_eq(ossl_quic_rxfc_has_cwm_changed(&conn_rxfc,
                                                                (int)op->arg1),
                                 (int)op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_CHANGED_STREAM:
                if (!TEST_true(op->stream_idx < OSSL_NELEM(stream_rxfc)
                               && stream_init_done[op->stream_idx]))
                    goto err;
                if (!TEST_int_eq(ossl_quic_rxfc_has_cwm_changed(&stream_rxfc[op->stream_idx],
                                                                (int)op->arg1),
                                 (int)op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_ERROR_CONN:
                if (!TEST_true(conn_init_done))
                    goto err;
                if (!TEST_int_eq(ossl_quic_rxfc_get_error(&conn_rxfc,
                                                          (int)op->arg1),
                                 (int)op->arg0))
                    goto err;
                break;
            case RX_OPC_CHECK_ERROR_STREAM:
                if (!TEST_true(op->stream_idx < OSSL_NELEM(stream_rxfc)
                               && stream_init_done[op->stream_idx]))
                    goto err;
                if (!TEST_int_eq(ossl_quic_rxfc_get_error(&stream_rxfc[op->stream_idx],
                                                          (int)op->arg1),
                                 (int)op->arg0))
                    goto err;
                break;
            case RX_OPC_STEP_TIME:
                cur_time = ossl_time_add(cur_time, ossl_ticks2time(op->arg0));
                break;
            case RX_OPC_MSG:
                fprintf(stderr, "# %s\n", op->msg);
                break;
            default:
                goto err;
        }
    }

    testresult = 1;
err:
    return testresult;
}

static int test_rxfc(int idx)
{
    return run_rxfc_script(rx_scripts[idx]);
}

int setup_tests(void)
{
    ADD_ALL_TESTS(test_txfc, 2);
    ADD_ALL_TESTS(test_rxfc, OSSL_NELEM(rx_scripts));
    return 1;
}

ENEA — Copyright (C), ENEA. License: GNU AGPLv3+.
Legal notes  ::  JavaScript license information ::  Web API

back to top