diff options
| author | Hugo Landau <hlandau@openssl.org> | 2023-04-28 17:56:33 +0200 |
|---|---|---|
| committer | Hugo Landau <hlandau@openssl.org> | 2023-05-24 11:34:47 +0200 |
| commit | 274bb489cb800552cdf6d15ef5e7481551c14544 (patch) | |
| tree | feeb70c6bb5fc379b8aa0ed469ad22d2b2e332b8 | |
| parent | QUIC MSMT: Revise tests to support multithreading (diff) | |
| download | openssl-274bb489cb800552cdf6d15ef5e7481551c14544.tar.xz openssl-274bb489cb800552cdf6d15ef5e7481551c14544.zip | |
QUIC MSMT: Add a basic multithreading test
Reviewed-by: Matt Caswell <matt@openssl.org>
Reviewed-by: Tomas Mraz <tomas@openssl.org>
(Merged from https://github.com/openssl/openssl/pull/20856)
| -rw-r--r-- | test/quic_multistream_test.c | 77 |
1 files changed, 77 insertions, 0 deletions
diff --git a/test/quic_multistream_test.c b/test/quic_multistream_test.c index 1da6ef31fe..2e70f2eb71 100644 --- a/test/quic_multistream_test.c +++ b/test/quic_multistream_test.c @@ -1473,6 +1473,81 @@ static const struct script_op script_10[] = { OP_END }; +/* 11. Many threads accepting on the same client connection */ +static const struct script_op script_11_child[] = { + OP_C_ACCEPT_STREAM_WAIT (a) + OP_C_READ_EXPECT (a, "foo", 3) + OP_C_EXPECT_FIN (a) + + OP_END +}; + +static const struct script_op script_11[] = { + OP_C_SET_ALPN ("ossltest") + OP_C_CONNECT_WAIT () + OP_C_SET_DEFAULT_STREAM_MODE(SSL_DEFAULT_STREAM_MODE_NONE) + + OP_S_NEW_STREAM_BIDI (a, S_BIDI_ID(0)) + OP_S_WRITE (a, "foo", 3) + OP_S_CONCLUDE (a) + + OP_S_NEW_STREAM_BIDI (b, S_BIDI_ID(1)) + OP_S_WRITE (b, "foo", 3) + OP_S_CONCLUDE (b) + + OP_S_NEW_STREAM_BIDI (c, S_BIDI_ID(2)) + OP_S_WRITE (c, "foo", 3) + OP_S_CONCLUDE (c) + + OP_S_NEW_STREAM_BIDI (d, S_BIDI_ID(3)) + OP_S_WRITE (d, "foo", 3) + OP_S_CONCLUDE (d) + + OP_S_NEW_STREAM_BIDI (e, S_BIDI_ID(4)) + OP_S_WRITE (e, "foo", 3) + OP_S_CONCLUDE (e) + + OP_NEW_THREAD (5, script_11_child) + + OP_END +}; + +/* 12. Many threads initiating on the same client connection */ +static const struct script_op script_12_child[] = { + OP_C_NEW_STREAM_BIDI (a, ANY_ID) + OP_C_WRITE (a, "foo", 3) + OP_C_CONCLUDE (a) + OP_C_FREE_STREAM (a) + + OP_END +}; + +static const struct script_op script_12[] = { + OP_C_SET_ALPN ("ossltest") + OP_C_CONNECT_WAIT () + OP_C_SET_DEFAULT_STREAM_MODE(SSL_DEFAULT_STREAM_MODE_NONE) + + OP_NEW_THREAD (5, script_12_child) + + OP_S_BIND_STREAM_ID (a, C_BIDI_ID(0)) + OP_S_READ_EXPECT (a, "foo", 3) + OP_S_EXPECT_FIN (a) + OP_S_BIND_STREAM_ID (b, C_BIDI_ID(1)) + OP_S_READ_EXPECT (b, "foo", 3) + OP_S_EXPECT_FIN (b) + OP_S_BIND_STREAM_ID (c, C_BIDI_ID(2)) + OP_S_READ_EXPECT (c, "foo", 3) + OP_S_EXPECT_FIN (c) + OP_S_BIND_STREAM_ID (d, C_BIDI_ID(3)) + OP_S_READ_EXPECT (d, "foo", 3) + OP_S_EXPECT_FIN (d) + OP_S_BIND_STREAM_ID (e, C_BIDI_ID(4)) + OP_S_READ_EXPECT (e, "foo", 3) + OP_S_EXPECT_FIN (e) + + OP_END +}; + static const struct script_op *const scripts[] = { script_1, script_2, @@ -1484,6 +1559,8 @@ static const struct script_op *const scripts[] = { script_8, script_9, script_10, + script_11, + script_12, }; static int test_script(int idx) |