Home
last modified time | relevance | path

Searched refs:sstream (Results 1 – 10 of 10) sorted by relevance

/openssl/test/
H A Dquic_stream_test.c43 QUIC_SSTREAM *sstream = NULL; in test_sstream_simple() local
48 if (!TEST_ptr(sstream = ossl_quic_sstream_new(init_size))) in test_sstream_simple()
52 if (!TEST_true(ossl_quic_sstream_is_totally_acked(sstream))) in test_sstream_simple()
68 if (!TEST_false(ossl_quic_sstream_is_totally_acked(sstream))) in test_sstream_simple()
111 if (!TEST_true(ossl_quic_sstream_mark_lost(sstream, 4, 6))) in test_sstream_simple()
155 ossl_quic_sstream_fin(sstream); in test_sstream_simple()
179 if (!TEST_true(ossl_quic_sstream_mark_lost_fin(sstream))) in test_sstream_simple()
204 if (!TEST_true(ossl_quic_sstream_mark_acked_fin(sstream))) in test_sstream_simple()
212 ossl_quic_sstream_free(sstream); in test_sstream_simple()
219 QUIC_SSTREAM *sstream = NULL; in test_sstream_bulk() local
[all …]
H A Dquic_fifd_test.c57 QUIC_SSTREAM *sstream[4]; member
75 return cur_info->sstream[stream_id - 42]; in sstream_expect()
132 if (!TEST_true(ossl_quic_sstream_append(info->sstream[i], in test_generic()
139 ossl_quic_sstream_fin(info->sstream[i]); in test_generic()
141 if (!TEST_true(ossl_quic_sstream_get_stream_frame(info->sstream[i], 0, in test_generic()
147 || !TEST_true(ossl_quic_sstream_mark_transmitted(info->sstream[i], in test_generic()
213 if (!TEST_false(ossl_quic_sstream_mark_lost_fin(info->sstream[1]))) in test_generic()
345 for (i = 0; i < OSSL_NELEM(info.sstream); ++i) in test_fifd()
346 if (!TEST_ptr(info.sstream[i] = ossl_quic_sstream_new(1024))) in test_fifd()
364 for (i = 0; i < OSSL_NELEM(info.sstream); ++i) in test_fifd()
[all …]
H A Dquic_txp_test.c1491 if (!TEST_ptr(s->sstream = ossl_quic_sstream_new(512 * 1024)) in run_script()
1499 ossl_quic_sstream_free(s->sstream); in run_script()
1514 if (!TEST_true(ossl_quic_sstream_append(s->sstream, op->buf, in run_script()
1532 ossl_quic_sstream_fin(s->sstream); in run_script()
/openssl/ssl/quic/
H A Dquic_fifd.c73 QUIC_SSTREAM *sstream; in on_acked() local
81 if (sstream == NULL) in on_acked()
86 ossl_quic_sstream_mark_acked(sstream, in on_acked()
90 ossl_quic_sstream_mark_acked_fin(sstream); in on_acked()
102 if (ossl_quic_sstream_is_totally_acked(sstream)) in on_acked()
129 QUIC_SSTREAM *sstream; in on_lost() local
140 if (sstream == NULL) in on_lost()
152 ossl_quic_sstream_mark_lost(sstream, in on_lost()
158 ossl_quic_sstream_mark_lost_fin(sstream); in on_lost()
257 QUIC_SSTREAM *sstream; in ossl_quic_fifd_pkt_commit() local
[all …]
H A Dquic_stream_map.c187 ossl_quic_sstream_free(stream->sstream); in ossl_quic_stream_map_release()
188 stream->sstream = NULL; in ossl_quic_stream_map_release()
269 if (!ossl_quic_sstream_get_stream_frame(s->sstream, 0, &shdr, iov, in stream_has_data_to_send()
343 && ossl_quic_sstream_is_totally_acked(s->sstream)) in ossl_quic_stream_map_update_state()
347 && ossl_quic_sstream_is_totally_acked(s->sstream)) in ossl_quic_stream_map_update_state()
412 if (!ossl_quic_sstream_get_final_size(qs->sstream, &qs->send_final_size)) in ossl_quic_stream_map_notify_all_data_sent()
443 ossl_quic_sstream_free(qs->sstream); in ossl_quic_stream_map_notify_totally_acked()
444 qs->sstream = NULL; in ossl_quic_stream_map_notify_totally_acked()
495 ossl_quic_sstream_free(qs->sstream); in ossl_quic_stream_map_reset_stream_send_part()
496 qs->sstream = NULL; in ossl_quic_stream_map_reset_stream_send_part()
[all …]
H A Dquic_impl.c713 if (xso->stream->sstream != NULL) in xso_update_options()
2191 ossl_quic_sstream_fin(xso->stream->sstream); in quic_post_write()
2225 size_t cur_sz = ossl_quic_sstream_get_buffer_size(sstream); in sstream_ensure_spare()
2226 size_t avail = ossl_quic_sstream_get_buffer_avail(sstream); in sstream_ensure_spare()
2239 return ossl_quic_sstream_set_buffer_size(sstream, new_sz); in sstream_ensure_spare()
2250 QUIC_SSTREAM *sstream = xso->stream->sstream; in xso_sstream_append() local
2251 uint64_t cur = ossl_quic_sstream_get_cur_size(sstream); in xso_sstream_append()
2258 if (!sstream_ensure_spare(sstream, len)) in xso_sstream_append()
2932 if (ossl_quic_sstream_get_final_size(qs->sstream, NULL)) { in ossl_quic_conn_stream_conclude()
2937 ossl_quic_sstream_fin(qs->sstream); in ossl_quic_conn_stream_conclude()
[all …]
H A Dquic_tserver.c376 if (!ossl_quic_sstream_append(qs->sstream, in ossl_quic_tserver_write()
404 if (!ossl_quic_sstream_get_final_size(qs->sstream, NULL)) { in ossl_quic_tserver_conclude()
405 ossl_quic_sstream_fin(qs->sstream); in ossl_quic_tserver_conclude()
503 return ossl_quic_sstream_is_totally_acked(qs->sstream); in ossl_quic_tserver_is_stream_totally_acked()
H A Dquic_txp.c425 static int sstream_is_pending(QUIC_SSTREAM *sstream);
1485 static int sstream_is_pending(QUIC_SSTREAM *sstream) in sstream_is_pending() argument
1491 return ossl_quic_sstream_get_stream_frame(sstream, 0, &hdr, iov, &num_iov); in sstream_is_pending()
1538 return s->sstream; in get_sstream_by_id()
2132 QUIC_SSTREAM *sstream, in txp_plan_stream_chunk() argument
2141 chunk->valid = ossl_quic_sstream_get_stream_frame(sstream, skip, in txp_plan_stream_chunk()
2186 QUIC_SSTREAM *sstream, in txp_generate_stream_frames() argument
2258 if (!txp_plan_stream_chunk(txp, h, sstream, stream_txfc, i + 1, in txp_generate_stream_frames()
2540 stream->id, stream->sstream, in txp_generate_stream_related()
2991 && !ossl_quic_sstream_has_pending(stream->sstream) in txp_pkt_commit()
[all …]
H A Dquic_channel.c868 QUIC_SSTREAM *sstream = ch->crypto_send[pn_space]; in ch_on_crypto_send() local
870 if (!ossl_assert(sstream != NULL)) in ch_on_crypto_send()
873 ret = ossl_quic_sstream_append(sstream, buf, buf_len, consumed); in ch_on_crypto_send()
3398 if ((qs->sstream = ossl_quic_sstream_new(INIT_APP_BUF_LEN)) == NULL) in ch_init_new_stream()
3448 ossl_quic_sstream_free(qs->sstream); in ch_init_new_stream()
3449 qs->sstream = NULL; in ch_init_new_stream()
/openssl/include/internal/
H A Dquic_stream_map.h151 QUIC_SSTREAM *sstream; /* NULL if RX-only */ member
468 return ossl_quic_sstream_get_final_size(s->sstream, final_size); in ossl_quic_stream_send_get_final_size()

Completed in 79 milliseconds