Home
last modified time | relevance | path

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

123

/freebsd/crypto/openssl/ssl/quic/
H A Dquic_fifd.c21 QUIC_SSTREAM *(*get_sstream_by_id)(uint64_t stream_id, in ossl_quic_fifd_init() argument
27 uint64_t stream_id, in ossl_quic_fifd_init()
32 uint64_t stream_id, in ossl_quic_fifd_init()
36 void (*sstream_updated)(uint64_t stream_id, in ossl_quic_fifd_init() argument
78 sstream = fifd->get_sstream_by_id(chunks[i].stream_id, in on_acked()
89 if (chunks[i].has_fin && chunks[i].stream_id != UINT64_MAX) in on_acked()
92 if (chunks[i].has_stop_sending && chunks[i].stream_id != UINT64_MAX) in on_acked()
94 chunks[i].stream_id, pkt, in on_acked()
97 if (chunks[i].has_reset_stream && chunks[i].stream_id != UINT64_MAX) in on_acked()
99 chunks[i].stream_id, pkt, in on_acked()
[all …]
H A Dquic_tserver.c254 uint64_t stream_id, in ossl_quic_tserver_read() argument
263 stream_id); in ossl_quic_tserver_read()
266 = ((stream_id & QUIC_STREAM_INITIATOR_MASK) in ossl_quic_tserver_read()
316 int ossl_quic_tserver_has_read_ended(QUIC_TSERVER *srv, uint64_t stream_id) in ossl_quic_tserver_has_read_ended() argument
324 stream_id); in ossl_quic_tserver_has_read_ended()
365 uint64_t stream_id, in ossl_quic_tserver_write() argument
376 stream_id); in ossl_quic_tserver_write()
396 int ossl_quic_tserver_conclude(QUIC_TSERVER *srv, uint64_t stream_id) in ossl_quic_tserver_conclude() argument
404 stream_id); in ossl_quic_tserver_conclude()
419 uint64_t *stream_id) in ossl_quic_tserver_stream_new() argument
[all …]
H A Dquic_rx_depack.c33 uint64_t stream_id,
158 if (!depack_do_implicit_stream_create(ch, frame_data.stream_id, in depack_do_frame_reset_stream()
233 if (!depack_do_implicit_stream_create(ch, frame_data.stream_id, in depack_do_frame_stop_sending()
368 uint64_t stream_id, in depack_do_implicit_stream_create() argument
378 stream = ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id); in depack_do_implicit_stream_create()
406 is_remote_init = ((stream_id & QUIC_STREAM_INITIATOR_MASK) == peer_role); in depack_do_implicit_stream_create()
407 is_uni = ((stream_id & QUIC_STREAM_DIR_MASK) == QUIC_STREAM_DIR_UNI); in depack_do_implicit_stream_create()
409 stream_ordinal = stream_id >> 2; in depack_do_implicit_stream_create()
450 …uint64_t cur_stream_id = (*p_next_ordinal_remote << 2) | (stream_id & (QUIC_STREAM_DIR_MASK | QUIC… in depack_do_implicit_stream_create()
518 if (!depack_do_implicit_stream_create(ch, frame_data.stream_id, in depack_do_frame_stream()
[all …]
H A Dqlog_event_helpers.c272 QLOG_U64("stream_id", f.stream_id); in log_frame_actual()
283 QLOG_U64("stream_id", f.stream_id); in log_frame_actual()
311 QLOG_U64("stream_id", f.stream_id); in log_frame_actual()
345 uint64_t stream_id, max_data; in log_frame_actual() local
347 if (!ossl_quic_wire_decode_frame_max_stream_data(pkt, &stream_id, in log_frame_actual()
352 QLOG_U64("stream_id", stream_id); in log_frame_actual()
426 uint64_t stream_id, x; in log_frame_actual() local
429 &stream_id, in log_frame_actual()
434 QLOG_U64("stream_id", stream_id); in log_frame_actual()
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()
261 uint64_t stream_id, in ossl_quic_wire_encode_frame_max_stream_data() argument
265 || !WPACKET_quic_write_vlint(pkt, stream_id) in ossl_quic_wire_encode_frame_max_stream_data()
294 uint64_t stream_id, in ossl_quic_wire_encode_frame_stream_data_blocked() argument
298 || !WPACKET_quic_write_vlint(pkt, stream_id) in ossl_quic_wire_encode_frame_stream_data_blocked()
603 || !PACKET_get_quic_vlint(pkt, &f->stream_id) in ossl_quic_wire_decode_frame_reset_stream()
615 || !PACKET_get_quic_vlint(pkt, &f->stream_id) in ossl_quic_wire_decode_frame_stop_sending()
[all …]
H A Dquic_trace.c136 (unsigned long long)frame_data.stream_id); in frame_reset_stream()
153 (unsigned long long)frame_data.stream_id); in frame_stop_sending()
235 (unsigned long long)frame_data.stream_id); in frame_stream()
264 uint64_t stream_id = 0; in frame_max_stream_data() local
267 if (!ossl_quic_wire_decode_frame_max_stream_data(pkt, &stream_id, in frame_max_stream_data()
303 uint64_t stream_id = 0; in frame_stream_data_blocked() local
306 if (!ossl_quic_wire_decode_frame_stream_data_blocked(pkt, &stream_id, in frame_stream_data_blocked()
310 BIO_printf(bio, " Stream id: %llu\n", (unsigned long long)stream_id); in frame_stream_data_blocked()
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.c420 static QUIC_SSTREAM *get_sstream_by_id(uint64_t stream_id, uint32_t pn_space,
422 static void on_regen_notify(uint64_t frame_type, uint64_t stream_id,
424 static void on_confirm_notify(uint64_t frame_type, uint64_t stream_id,
426 static void on_sstream_updated(uint64_t stream_id, void *arg);
1620 static QUIC_SSTREAM *get_sstream_by_id(uint64_t stream_id, uint32_t pn_space, in get_sstream_by_id() argument
1626 if (stream_id == UINT64_MAX) in get_sstream_by_id()
1629 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in get_sstream_by_id()
1636 static void on_regen_notify(uint64_t frame_type, uint64_t stream_id, in on_regen_notify() argument
1659 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_regen_notify()
1669 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_regen_notify()
[all …]
H A Dquic_stream_map.c139 uint64_t stream_id, in ossl_quic_stream_map_alloc() argument
145 key.id = stream_id; in ossl_quic_stream_map_alloc()
155 s->id = stream_id; in ossl_quic_stream_map_alloc()
196 uint64_t stream_id) in ossl_quic_stream_map_get_by_id() argument
200 key.id = stream_id; in ossl_quic_stream_map_get_by_id()
/freebsd/crypto/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.h97 uint64_t stream_id,
105 int ossl_quic_tserver_has_read_ended(QUIC_TSERVER *srv, uint64_t stream_id);
119 uint64_t stream_id,
127 int ossl_quic_tserver_conclude(QUIC_TSERVER *srv, uint64_t stream_id);
135 uint64_t *stream_id);
146 uint64_t stream_id,
154 uint64_t stream_id,
173 uint64_t stream_id);
H A Dquic_wire.h157 uint64_t stream_id; /* Stream ID */ member
186 uint64_t stream_id; member
193 uint64_t stream_id; member
348 uint64_t stream_id,
372 uint64_t stream_id,
613 uint64_t *stream_id,
638 uint64_t *stream_id,
H A Dquic_channel.h335 uint64_t stream_id);
382 uint64_t stream_id);
H A Dquic_txpim.h53 uint64_t stream_id; member
/freebsd/crypto/openssl/test/
H A Dquic_fifd_test.c27 static QUIC_SSTREAM *(*get_sstream_by_id_p)(uint64_t stream_id, uint32_t pn_space,
30 static QUIC_SSTREAM *get_sstream_by_id(uint64_t stream_id, uint32_t pn_space, in get_sstream_by_id() argument
33 return get_sstream_by_id_p(stream_id, pn_space, arg); in get_sstream_by_id()
36 static void (*regen_frame_p)(uint64_t frame_type, uint64_t stream_id,
39 static void regen_frame(uint64_t frame_type, uint64_t stream_id, in regen_frame() argument
42 regen_frame_p(frame_type, stream_id, pkt, arg); in regen_frame()
45 static void confirm_frame(uint64_t frame_type, uint64_t stream_id, in confirm_frame() argument
50 static void sstream_updated(uint64_t stream_id, void *arg) in sstream_updated() argument
75 static QUIC_SSTREAM *sstream_expect(uint64_t stream_id, uint32_t pn_space, in sstream_expect() argument
78 if (stream_id == 42 || stream_id == 43) in sstream_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.c241 #define RX_OP_CHECK_CWM_STREAM(stream_id, expected) \ argument
242 { RX_OPC_CHECK_CWM_STREAM, (stream_id), (expected) },
245 #define RX_OP_CHECK_SWM_STREAM(stream_id, expected) \ argument
246 { RX_OPC_CHECK_SWM_STREAM, (stream_id), (expected) },
249 #define RX_OP_CHECK_RWM_STREAM(stream_id, expected) \ argument
250 { RX_OPC_CHECK_RWM_STREAM, (stream_id), (expected) },
253 #define RX_OP_CHECK_CHANGED_STREAM(stream_id, expected, clear) \ argument
254 { RX_OPC_CHECK_CHANGED_STREAM, (stream_id), (expected), (clear) },
257 #define RX_OP_CHECK_ERROR_STREAM(stream_id, expected, clear) \ argument
258 { RX_OPC_CHECK_ERROR_STREAM, (stream_id), (expected), (clear) },
H A Dquic_wire_test.c388 if (!TEST_uint64_t_eq(f.stream_id, 0x1234)) in encode_case_8_dec()
443 if (!TEST_uint64_t_eq(f.stream_id, 0x1234)) in encode_case_9_dec()
511 uint64_t stream_id = 0, max_data = 0; in encode_case_11_dec() local
514 &stream_id, in encode_case_11_dec()
522 if (!TEST_uint64_t_eq(stream_id, 0x1234)) in encode_case_11_dec()
666 uint64_t stream_id = 0, max_data = 0; in encode_case_14_dec() local
669 &stream_id, in encode_case_14_dec()
677 if (!TEST_uint64_t_eq(stream_id, 0x1234)) in encode_case_14_dec()
/freebsd/crypto/openssl/demos/http3/
H A Dossl-nghttp3.c148 static int h3_conn_recv_data(nghttp3_conn *h3conn, int64_t stream_id, in h3_conn_recv_data() argument
158 return conn->recv_data_cb(h3conn, stream_id, data, datalen, in h3_conn_recv_data()
162 static int h3_conn_stream_close(nghttp3_conn *h3conn, int64_t stream_id, in h3_conn_stream_close() argument
171 ret = conn->stream_close_cb(h3conn, stream_id, app_error_code, in h3_conn_stream_close()
178 static int h3_conn_stop_sending(nghttp3_conn *h3conn, int64_t stream_id, in h3_conn_stop_sending() argument
187 ret = conn->stop_sending_cb(h3conn, stream_id, app_error_code, in h3_conn_stop_sending()
195 static int h3_conn_reset_stream(nghttp3_conn *h3conn, int64_t stream_id, in h3_conn_reset_stream() argument
205 ret = conn->reset_stream_cb(h3conn, stream_id, app_error_code, in h3_conn_reset_stream()
218 static int h3_conn_deferred_consume(nghttp3_conn *h3conn, int64_t stream_id, in h3_conn_deferred_consume() argument
226 ret = conn->deferred_consume_cb(h3conn, stream_id, consumed, in h3_conn_deferred_consume()
[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
/freebsd/contrib/unbound/services/
H A Dlisten_dnsport.c2532 int32_t stream_id, uint8_t* buf, size_t length, uint32_t* data_flags, in http2_submit_response_read_callback() argument
2539 h2_session->session, stream_id))) { in http2_submit_response_read_callback()
2583 NGHTTP2_FLAG_NONE, h2_stream->stream_id, in http2_submit_rst_stream()
2672 ret = nghttp2_submit_response(h2_session->session, h2_stream->stream_id, in http2_submit_dns_response()
2714 int32_t stream_id, uint8_t* buf, size_t length, uint32_t* data_flags, in http2_submit_error_read_callback() argument
2721 h2_session->session, stream_id))) { in http2_submit_error_read_callback()
2763 ret = nghttp2_submit_response(h2_session->session, h2_stream->stream_id, in http2_submit_error()
2841 session, frame->hd.stream_id))) in http2_req_frame_recv_cb()
2926 if(!(h2_stream = http2_stream_create(frame->hd.stream_id))) { in http2_req_begin_headers_cb()
2932 frame->hd.stream_id, h2_stream); in http2_req_begin_headers_cb()
[all …]
/freebsd/contrib/unbound/testcode/
H A Ddoqclient.c185 int64_t stream_id; member
367 str->stream_id = -1; in client_stream_create()
384 client_stream_start_setup(struct doq_client_stream* str, int64_t stream_id) in client_stream_start_setup() argument
387 str->stream_id = stream_id; in client_stream_start_setup()
761 int64_t stream_id; in client_bidi_stream() local
765 rv = ngtcp2_conn_open_bidi_stream(data->conn, &stream_id, in client_bidi_stream()
775 *ret_stream_id = stream_id; in client_bidi_stream()
786 int64_t stream_id = 0; in query_streams_start() local
787 if(!client_bidi_stream(data, &stream_id, str)) { in query_streams_start()
794 logs, (long long int)stream_id); in query_streams_start()
[all …]
/freebsd/lib/libusb/
H A Dlibusb10_io.c792 uint32_t stream_id, unsigned char *buffer, int length, in libusb_fill_bulk_stream_transfer() argument
799 libusb_transfer_set_stream_id(transfer, stream_id); in libusb_fill_bulk_stream_transfer()
836 libusb_transfer_set_stream_id(struct libusb_transfer *transfer, uint32_t stream_id) in libusb_transfer_set_stream_id() argument
847 sxfer->stream_id = stream_id; in libusb_transfer_set_stream_id()
862 return (sxfer->stream_id); in libusb_transfer_get_stream_id()
/freebsd/contrib/unbound/util/
H A Dnetevent.h971 int32_t stream_id; member
1009 int http2_stream_close_cb(nghttp2_session* session, int32_t stream_id,
1018 struct http2_stream* http2_stream_create(int32_t stream_id);
/freebsd/sys/dev/usb/controller/
H A Dxhci.c944 uint16_t stream_id = 0; in xhci_check_transfer() local
988 stream_id == (XHCI_MAX_STREAMS - 1)) in xhci_check_transfer()
990 stream_id++; in xhci_check_transfer()
992 DPRINTFN(5, "stream_id=%u\n", stream_id); in xhci_check_transfer()
995 xfer = pepext->xfer[i + (XHCI_MAX_TRANSFERS * stream_id)]; in xhci_check_transfer()
1621 uint16_t stream_id, uint8_t ep_id, uint8_t slot_id) in xhci_cmd_set_tr_dequeue_ptr() argument
1630 temp = XHCI_TRB_2_STREAM_SET(stream_id); in xhci_cmd_set_tr_dequeue_ptr()
2890 epno | XHCI_DB_SID_SET(xfer->stream_id)); in xhci_endpoint_doorbell()
2905 pepext->trb_used[xfer->stream_id]--; in xhci_transfer_remove()
2931 id = xfer->stream_id; in xhci_transfer_insert()
[all …]

123