ACQUIRE_S
if (!TEST_true(ossl_quic_tserver_write(ACQUIRE_S(), s_stream_id,
ossl_quic_tserver_conclude(ACQUIRE_S(), s_stream_id);
if (!TEST_true(ossl_quic_tserver_read(ACQUIRE_S(), s_stream_id,
if (!ossl_quic_tserver_has_read_ended(ACQUIRE_S(), s_stream_id))
if (!TEST_true(ossl_quic_tserver_stream_new(ACQUIRE_S(),
new_stream_id = ossl_quic_tserver_pop_incoming_stream(ACQUIRE_S());
ossl_quic_tserver_shutdown(ACQUIRE_S(), op->arg1);
if (!ossl_quic_tserver_is_term_any(ACQUIRE_S())) {
ossl_quic_tserver_ping(ACQUIRE_S());
if (!TEST_ptr(tc = ossl_quic_tserver_get_terminate_cause(ACQUIRE_S())))
if (!TEST_false(ossl_quic_tserver_write(ACQUIRE_S(), s_stream_id,
ret = ossl_quic_tserver_read(ACQUIRE_S(), s_stream_id,
ACQUIRE_S();
if (!TEST_true(ossl_quic_tserver_new_ticket(ACQUIRE_S())))
ossl_quic_tserver_set_msg_callback(ACQUIRE_S(), script_41_trace, h);
QUIC_CHANNEL *ch = ossl_quic_tserver_get_channel(ACQUIRE_S());
if (!ossl_quic_tserver_stream_has_peer_stop_sending(ACQUIRE_S(), stream_id, NULL)
if (!TEST_true(ossl_quic_tserver_ping(ACQUIRE_S())))
|| !ossl_quic_tserver_stream_has_peer_reset_stream(ACQUIRE_S(), stream_id, NULL)) {
QUIC_CHANNEL *ch = ossl_quic_tserver_get_channel(ACQUIRE_S());
if (!ossl_quic_tserver_stream_has_peer_reset_stream(ACQUIRE_S(), stream_id, &aec)) {
if (!ossl_quic_tserver_stream_has_peer_stop_sending(ACQUIRE_S(), stream_id, NULL)) {
const QUIC_TERMINATE_CAUSE *tc = ossl_quic_tserver_get_terminate_cause(ACQUIRE_S());
if (!TEST_true(ossl_quic_tserver_set_max_early_data(ACQUIRE_S(),
if (!TEST_true(ossl_quic_tserver_new_ticket(ACQUIRE_S())))