Home
last modified time | relevance | path

Searched refs:stream_id (Results 1 – 25 of 25) sorted by relevance

/openssl/ssl/quic/
H A Dquic_fifd.c27 uint64_t stream_id, in ossl_quic_fifd_init()
32 uint64_t stream_id, in ossl_quic_fifd_init()
78 sstream = fifd->get_sstream_by_id(chunks[i].stream_id, in on_acked()
94 chunks[i].stream_id, pkt, in on_acked()
99 chunks[i].stream_id, pkt, in on_acked()
137 sstream = fifd->get_sstream_by_id(chunks[i].stream_id, in on_lost()
164 chunks[i].stream_id, pkt, in on_lost()
169 chunks[i].stream_id, pkt, in on_lost()
183 chunks[i].stream_id, in on_lost()
188 fifd->sstream_updated(chunks[i].stream_id, in on_lost()
[all …]
H A Dquic_tserver.c250 uint64_t stream_id, in ossl_quic_tserver_read() argument
259 stream_id); in ossl_quic_tserver_read()
320 stream_id); in ossl_quic_tserver_has_read_ended()
361 uint64_t stream_id, in ossl_quic_tserver_write() argument
372 stream_id); in ossl_quic_tserver_write()
400 stream_id); in ossl_quic_tserver_conclude()
415 uint64_t *stream_id) in ossl_quic_tserver_stream_new() argument
425 *stream_id = qs->id; in ossl_quic_tserver_stream_new()
446 stream_id); in ossl_quic_tserver_stream_has_peer_stop_sending()
463 stream_id); in ossl_quic_tserver_stream_has_peer_reset_stream()
[all …]
H A Dquic_rx_depack.c33 uint64_t stream_id,
157 if (!depack_do_implicit_stream_create(ch, frame_data.stream_id, in depack_do_frame_reset_stream()
232 if (!depack_do_implicit_stream_create(ch, frame_data.stream_id, in depack_do_frame_stop_sending()
364 uint64_t stream_id, in depack_do_implicit_stream_create() argument
374 stream = ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id); in depack_do_implicit_stream_create()
405 stream_ordinal = stream_id >> 2; in depack_do_implicit_stream_create()
447 (stream_id in depack_do_implicit_stream_create()
691 uint64_t stream_id = 0; in depack_do_frame_max_stream_data() local
704 if (!depack_do_implicit_stream_create(ch, stream_id, in depack_do_frame_max_stream_data()
797 uint64_t stream_id = 0; in depack_do_frame_stream_data_blocked() local
[all …]
H A Dqlog_event_helpers.c271 QLOG_U64("stream_id", f.stream_id); in log_frame_actual()
284 QLOG_U64("stream_id", f.stream_id); in log_frame_actual()
316 QLOG_U64("stream_id", f.stream_id); in log_frame_actual()
354 uint64_t stream_id, max_data; in log_frame_actual() local
356 if (!ossl_quic_wire_decode_frame_max_stream_data(pkt, &stream_id, in log_frame_actual()
361 QLOG_U64("stream_id", stream_id); in log_frame_actual()
451 uint64_t stream_id, x; in log_frame_actual() local
454 &stream_id, in log_frame_actual()
459 QLOG_U64("stream_id", stream_id); in log_frame_actual()
H A Dquic_trace.c130 (unsigned long long)frame_data.stream_id); in frame_reset_stream()
147 (unsigned long long)frame_data.stream_id); in frame_stop_sending()
229 (unsigned long long)frame_data.stream_id); in frame_stream()
258 uint64_t stream_id = 0; in frame_max_stream_data() local
261 if (!ossl_quic_wire_decode_frame_max_stream_data(pkt, &stream_id, in frame_max_stream_data()
297 uint64_t stream_id = 0; in frame_stream_data_blocked() local
300 if (!ossl_quic_wire_decode_frame_stream_data_blocked(pkt, &stream_id, in frame_stream_data_blocked()
304 BIO_printf(bio, " Stream id: %llu\n", (unsigned long long)stream_id); in frame_stream_data_blocked()
H A Dquic_wire.c107 || !WPACKET_quic_write_vlint(pkt, f->stream_id) in ossl_quic_wire_encode_frame_reset_stream()
119 || !WPACKET_quic_write_vlint(pkt, f->stream_id) in ossl_quic_wire_encode_frame_stop_sending()
191 || !WPACKET_quic_write_vlint(pkt, f->stream_id)) in ossl_quic_wire_encode_frame_stream_hdr()
208 b = ossl_quic_vlint_encode_len(f->stream_id); in ossl_quic_wire_get_encoded_frame_len_stream_hdr()
265 || !WPACKET_quic_write_vlint(pkt, stream_id) in ossl_quic_wire_encode_frame_max_stream_data()
300 || !WPACKET_quic_write_vlint(pkt, stream_id) in ossl_quic_wire_encode_frame_stream_data_blocked()
605 || !PACKET_get_quic_vlint(pkt, &f->stream_id) in ossl_quic_wire_decode_frame_reset_stream()
617 || !PACKET_get_quic_vlint(pkt, &f->stream_id) in ossl_quic_wire_decode_frame_stop_sending()
685 || !PACKET_get_quic_vlint(pkt, &f->stream_id)) in ossl_quic_wire_decode_frame_stream()
744 || !PACKET_get_quic_vlint(pkt, stream_id) in ossl_quic_wire_decode_frame_max_stream_data()
[all …]
H A Dquic_txpim.c190 if (ac->stream_id < bc->stream_id) in compare()
192 else if (ac->stream_id > bc->stream_id) in compare()
H A Dquic_txp.c424 static void on_sstream_updated(uint64_t stream_id, void *arg);
1531 if (stream_id == UINT64_MAX) in get_sstream_by_id()
1534 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in get_sstream_by_id()
1766 static void on_sstream_updated(uint64_t stream_id, void *arg) in on_sstream_updated() argument
1771 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_sstream_updated()
2113 chunk.stream_id = UINT64_MAX; /* crypto stream */ in txp_generate_crypto_frames()
2229 chunks[i].shdr.stream_id = id; in txp_generate_stream_frames()
2369 chunk.stream_id = shdr->stream_id; in txp_generate_stream_frames()
2432 f.stream_id = stream->id; in txp_generate_stream_related()
2458 f.stream_id = stream->id; in txp_generate_stream_related()
[all …]
H A Dquic_stream_map.c141 uint64_t stream_id, in ossl_quic_stream_map_alloc() argument
147 key.id = stream_id; in ossl_quic_stream_map_alloc()
157 s->id = stream_id; in ossl_quic_stream_map_alloc()
198 uint64_t stream_id) in ossl_quic_stream_map_get_by_id() argument
202 key.id = stream_id; in ossl_quic_stream_map_get_by_id()
H A Dquic_channel.c513 uint64_t stream_id) in ossl_quic_channel_get_stream_by_id() argument
515 return ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id); in ossl_quic_channel_get_stream_by_id()
3508 uint64_t stream_id; in ossl_quic_channel_new_stream_local() local
3524 stream_id = ((*p_next_ordinal) << 2) | type; in ossl_quic_channel_new_stream_local()
3526 if ((qs = ossl_quic_stream_map_alloc(&ch->qsm, stream_id, type)) == NULL) in ossl_quic_channel_new_stream_local()
3542 uint64_t stream_id) in ossl_quic_channel_new_stream_remote() argument
3552 if ((stream_id & QUIC_STREAM_INITIATOR_MASK) != peer_role) in ossl_quic_channel_new_stream_remote()
3555 is_uni = ((stream_id & QUIC_STREAM_DIR_MASK) == QUIC_STREAM_DIR_UNI); in ossl_quic_channel_new_stream_remote()
3557 qs = ossl_quic_stream_map_alloc(&ch->qsm, stream_id, in ossl_quic_channel_new_stream_remote()
3558 stream_id & (QUIC_STREAM_INITIATOR_MASK in ossl_quic_channel_new_stream_remote()
/openssl/include/internal/
H A Dquic_fifd.h32 QUIC_SSTREAM *(*get_sstream_by_id)(uint64_t stream_id,
37 uint64_t stream_id,
42 uint64_t stream_id,
46 void (*sstream_updated)(uint64_t stream_id,
58 QUIC_SSTREAM *(*get_sstream_by_id)(uint64_t stream_id,
64 uint64_t stream_id,
69 uint64_t stream_id,
73 void (*sstream_updated)(uint64_t stream_id,
H A Dquic_tserver.h94 uint64_t stream_id,
102 int ossl_quic_tserver_has_read_ended(QUIC_TSERVER *srv, uint64_t stream_id);
116 uint64_t stream_id,
124 int ossl_quic_tserver_conclude(QUIC_TSERVER *srv, uint64_t stream_id);
132 uint64_t *stream_id);
143 uint64_t stream_id,
151 uint64_t stream_id,
170 uint64_t stream_id);
H A Dquic_wire.h169 uint64_t stream_id; /* Stream ID */ member
198 uint64_t stream_id; member
205 uint64_t stream_id; member
360 uint64_t stream_id,
384 uint64_t stream_id,
625 uint64_t *stream_id,
650 uint64_t *stream_id,
H A Dquic_channel.h316 uint64_t stream_id);
363 uint64_t stream_id);
H A Dquic_txpim.h53 uint64_t stream_id; member
H A Dquic_stream_map.h603 uint64_t stream_id,
624 uint64_t stream_id);
/openssl/test/
H A Dquic_fifd_test.c31 return get_sstream_by_id_p(stream_id, pn_space, arg); in get_sstream_by_id()
34 static void (*regen_frame_p)(uint64_t frame_type, uint64_t stream_id,
37 static void regen_frame(uint64_t frame_type, uint64_t stream_id, in regen_frame() argument
40 regen_frame_p(frame_type, stream_id, pkt, arg); in regen_frame()
43 static void confirm_frame(uint64_t frame_type, uint64_t stream_id, in confirm_frame() argument
47 static void sstream_updated(uint64_t stream_id, void *arg) in sstream_updated() argument
74 if (stream_id == 42 || stream_id == 43) in sstream_expect()
75 return cur_info->sstream[stream_id - 42]; in sstream_expect()
85 static void regen_expect(uint64_t frame_type, uint64_t stream_id, in regen_expect() argument
89 regen_stream_id[regen_count] = stream_id; in regen_expect()
[all …]
H A Dquic_txpim_test.c34 chunks[j].stream_id = 100 - j; in test_txpim()
47 if (!TEST_uint64_t_eq(rchunks[0].stream_id, 98) in test_txpim()
48 || !TEST_uint64_t_eq(rchunks[1].stream_id, 99) in test_txpim()
49 || !TEST_uint64_t_eq(rchunks[2].stream_id, 100)) in test_txpim()
H A Dquic_fc_test.c244 #define RX_OP_CHECK_CWM_STREAM(stream_id, expected) \ argument
245 { RX_OPC_CHECK_CWM_STREAM, (stream_id), (expected) },
248 #define RX_OP_CHECK_SWM_STREAM(stream_id, expected) \ argument
249 { RX_OPC_CHECK_SWM_STREAM, (stream_id), (expected) },
252 #define RX_OP_CHECK_RWM_STREAM(stream_id, expected) \ argument
253 { RX_OPC_CHECK_RWM_STREAM, (stream_id), (expected) },
256 #define RX_OP_CHECK_CHANGED_STREAM(stream_id, expected, clear) \ argument
257 { RX_OPC_CHECK_CHANGED_STREAM, (stream_id), (expected), (clear) },
260 #define RX_OP_CHECK_ERROR_STREAM(stream_id, expected, clear) \ argument
261 { RX_OPC_CHECK_ERROR_STREAM, (stream_id), (expected), (clear) },
H A Dquic_wire_test.c374 if (!TEST_uint64_t_eq(f.stream_id, 0x1234)) in encode_case_8_dec()
429 if (!TEST_uint64_t_eq(f.stream_id, 0x1234)) in encode_case_9_dec()
495 uint64_t stream_id = 0, max_data = 0; in encode_case_11_dec() local
498 &stream_id, in encode_case_11_dec()
505 if (!TEST_uint64_t_eq(stream_id, 0x1234)) in encode_case_11_dec()
638 uint64_t stream_id = 0, max_data = 0; in encode_case_14_dec() local
641 &stream_id, in encode_case_14_dec()
648 if (!TEST_uint64_t_eq(stream_id, 0x1234)) in encode_case_14_dec()
H A Dquic_multistream_test.c275 #define OP_S_BIND_STREAM_ID(stream_name, stream_id) \ argument
276 {OPK_S_BIND_STREAM_ID, NULL, 0, NULL, #stream_name, (stream_id)},
373 uint64_t stream_id = hl->check_op->arg2; in check_rejected() local
375 if (!ossl_quic_tserver_stream_has_peer_stop_sending(ACQUIRE_S(), stream_id, NULL) in check_rejected()
386 uint64_t stream_id = hl->check_op->arg2, aec = 0; in check_stream_reset() local
388 if (!ossl_quic_tserver_stream_has_peer_reset_stream(ACQUIRE_S(), stream_id, &aec)) { in check_stream_reset()
398 uint64_t stream_id = hl->check_op->arg2; in check_stream_stopped() local
1533 uint64_t stream_id = UINT64_MAX; in run_script_worker() local
1543 &stream_id))) in run_script_worker()
1547 && !TEST_uint64_t_eq(stream_id, op->arg2)) in run_script_worker()
[all …]
H A Dquic_txp_test.c1017 if (!TEST_uint64_t_eq(h->frame.stop_sending.stream_id, 42) in check_stream_12()
1049 if (!TEST_uint64_t_eq(h->frame.reset_stream.stream_id, 42) in check_stream_13()
/openssl/demos/http3/
H A Dossl-nghttp3.c146 static int h3_conn_recv_data(nghttp3_conn *h3conn, int64_t stream_id, in h3_conn_recv_data() argument
156 return conn->recv_data_cb(h3conn, stream_id, data, datalen, in h3_conn_recv_data()
160 static int h3_conn_stream_close(nghttp3_conn *h3conn, int64_t stream_id, in h3_conn_stream_close() argument
169 ret = conn->stream_close_cb(h3conn, stream_id, app_error_code, in h3_conn_stream_close()
176 static int h3_conn_stop_sending(nghttp3_conn *h3conn, int64_t stream_id, in h3_conn_stop_sending() argument
185 ret = conn->stop_sending_cb(h3conn, stream_id, app_error_code, in h3_conn_stop_sending()
203 ret = conn->reset_stream_cb(h3conn, stream_id, app_error_code, in h3_conn_reset_stream()
224 ret = conn->deferred_consume_cb(h3conn, stream_id, consumed, in h3_conn_deferred_consume()
569 int64_t stream_id; in OSSL_DEMO_H3_CONN_handle_events() local
624 key.id = stream_id; in OSSL_DEMO_H3_CONN_handle_events()
[all …]
H A Dossl-nghttp3-demo.c23 static int on_recv_header(nghttp3_conn *h3conn, int64_t stream_id, in on_recv_header() argument
44 static int on_end_headers(nghttp3_conn *h3conn, int64_t stream_id, in on_end_headers() argument
52 static int on_recv_data(nghttp3_conn *h3conn, int64_t stream_id, in on_recv_data() argument
71 static int on_end_stream(nghttp3_conn *h3conn, int64_t stream_id, in on_end_stream() argument
/openssl/doc/designs/quic-design/
H A Dquic-fifm.md343 uint64_t stream_id;
387 * The chunks are sorted by (stream_id, start) in ascending order.
450 /* stream_id is UINT64_MAX for the crypto stream */
451 OSSL_QSS *(*get_qss_by_id)(uint64_t stream_id,
454 /* stream_id is UINT64_MAX if not applicable */
456 uint64_t stream_id,

Completed in 79 milliseconds