| /third_party/nghttp2/src/ |
| H A D | h2load_http3_session.cc | 55 auto stream_id = submit_request_internal(); in submit_request() local
56 if (stream_id < 0) { in submit_request()
57 if (stream_id == NGTCP2_ERR_STREAM_ID_BLOCKED) { in submit_request()
68 nghttp3_ssize read_data(nghttp3_conn *conn, int64_t stream_id, nghttp3_vec *vec, in read_data() argument
92 int64_t stream_id; in submit_request_internal() local
97 rv = ngtcp2_conn_open_bidi_stream(client_->quic.conn, &stream_id, nullptr); in submit_request_internal()
106 conn_, stream_id, reinterpret_cast<nghttp3_nv *>(nva.data()), nva.size(), in submit_request_internal()
112 client_->on_request(stream_id); in submit_request_internal()
113 auto req_stat = client_->get_req_stat(stream_id); in submit_request_internal()
117 return stream_id; in submit_request_internal()
131 stream_close(nghttp3_conn *conn, int64_t stream_id, uint64_t app_error_code, void *user_data, void *stream_user_data) stream_close() argument
141 stream_close(int64_t stream_id, uint64_t app_error_code) stream_close() argument
151 recv_data(nghttp3_conn *conn, int64_t stream_id, const uint8_t *data, size_t datalen, void *user_data, void *stream_user_data) recv_data() argument
159 recv_data(int64_t stream_id, const uint8_t *data, size_t datalen) recv_data() argument
167 deferred_consume(nghttp3_conn *conn, int64_t stream_id, size_t nconsumed, void *user_data, void *stream_user_data) deferred_consume() argument
175 consume(int64_t stream_id, size_t nconsumed) consume() argument
182 begin_headers(nghttp3_conn *conn, int64_t stream_id, void *user_data, void *stream_user_data) begin_headers() argument
190 begin_headers(int64_t stream_id) begin_headers() argument
198 recv_header(nghttp3_conn *conn, int64_t stream_id, int32_t token, nghttp3_rcbuf *name, nghttp3_rcbuf *value, uint8_t flags, void *user_data, void *stream_user_data) recv_header() argument
209 recv_header(int64_t stream_id, const nghttp3_vec *name, const nghttp3_vec *value) recv_header() argument
216 stop_sending(nghttp3_conn *conn, int64_t stream_id, uint64_t app_error_code, void *user_data, void *stream_user_data) stop_sending() argument
226 stop_sending(int64_t stream_id, uint64_t app_error_code) stop_sending() argument
238 reset_stream(nghttp3_conn *conn, int64_t stream_id, uint64_t app_error_code, void *user_data, void *stream_user_data) reset_stream() argument
248 reset_stream(int64_t stream_id, uint64_t app_error_code) reset_stream() argument
259 close_stream(int64_t stream_id, uint64_t app_error_code) close_stream() argument
275 shutdown_stream_read(int64_t stream_id) shutdown_stream_read() argument
287 auto stream_id = submit_request_internal(); extend_max_local_streams() local
391 read_stream(uint32_t flags, int64_t stream_id, const uint8_t *data, size_t datalen) read_stream() argument
406 write_stream(int64_t &stream_id, int &fin, nghttp3_vec *vec, size_t veccnt) write_stream() argument
419 block_stream(int64_t stream_id) block_stream() argument
423 unblock_stream(int64_t stream_id) unblock_stream() argument
431 shutdown_stream_write(int64_t stream_id) shutdown_stream_write() argument
435 add_write_offset(int64_t stream_id, size_t ndatalen) add_write_offset() argument
446 add_ack_offset(int64_t stream_id, size_t datalen) add_ack_offset() argument
[all...] |
| H A D | h2load_http3_session.h | 48 int stream_close(int64_t stream_id, uint64_t app_error_code);
49 void recv_data(int64_t stream_id, const uint8_t *data, size_t datalen);
50 void consume(int64_t stream_id, size_t nconsumed);
51 void begin_headers(int64_t stream_id);
52 void recv_header(int64_t stream_id, const nghttp3_vec *name,
54 int stop_sending(int64_t stream_id, uint64_t app_error_code);
55 int reset_stream(int64_t stream_id, uint64_t app_error_code);
57 int close_stream(int64_t stream_id, uint64_t app_error_code);
58 int shutdown_stream_read(int64_t stream_id);
62 ssize_t read_stream(uint32_t flags, int64_t stream_id, cons
[all...] |
| H A D | h2load_quic.cc | 60 int recv_stream_data(ngtcp2_conn *conn, uint32_t flags, int64_t stream_id, in recv_stream_data() argument
64 if (c->quic_recv_stream_data(flags, stream_id, data, datalen) != 0) { in recv_stream_data()
74 int Client::quic_recv_stream_data(uint32_t flags, int64_t stream_id, in quic_recv_stream_data() argument
81 auto nconsumed = s->read_stream(flags, stream_id, data, datalen); in quic_recv_stream_data()
86 ngtcp2_conn_extend_max_stream_offset(quic.conn, stream_id, nconsumed); in quic_recv_stream_data()
93 int acked_stream_data_offset(ngtcp2_conn *conn, int64_t stream_id, in acked_stream_data_offset() argument
97 if (c->quic_acked_stream_data_offset(stream_id, datalen) != 0) { in acked_stream_data_offset()
104 int Client::quic_acked_stream_data_offset(int64_t stream_id, size_t datalen) { in quic_acked_stream_data_offset() argument
106 if (s->add_ack_offset(stream_id, datalen) != 0) { in quic_acked_stream_data_offset()
113 int stream_close(ngtcp2_conn *conn, uint32_t flags, int64_t stream_id, in stream_close() argument
129 quic_stream_close(int64_t stream_id, uint64_t app_error_code) quic_stream_close() argument
138 stream_reset(ngtcp2_conn *conn, int64_t stream_id, uint64_t final_size, uint64_t app_error_code, void *user_data, void *stream_user_data) stream_reset() argument
149 quic_stream_reset(int64_t stream_id, uint64_t app_error_code) quic_stream_reset() argument
158 stream_stop_sending(ngtcp2_conn *conn, int64_t stream_id, uint64_t app_error_code, void *user_data, void *stream_user_data) stream_stop_sending() argument
169 quic_stream_stop_sending(int64_t stream_id, uint64_t app_error_code) quic_stream_stop_sending() argument
200 extend_max_stream_data(ngtcp2_conn *conn, int64_t stream_id, uint64_t max_data, void *user_data, void *stream_user_data) extend_max_stream_data() argument
213 quic_extend_max_stream_data(int64_t stream_id) quic_extend_max_stream_data() argument
668 int64_t stream_id = -1; write_quic() local
[all...] |
| H A D | shrpx_http3_upstream.h | 108 int recv_stream_data(uint32_t flags, int64_t stream_id, const uint8_t *data,
110 int acked_stream_data_offset(int64_t stream_id, uint64_t datalen);
111 int extend_max_stream_data(int64_t stream_id);
114 void http_begin_request_headers(int64_t stream_id);
123 int shutdown_stream_read(int64_t stream_id, uint64_t app_error_code);
125 void consume(int64_t stream_id, size_t nconsumed);
127 int stream_close(int64_t stream_id, uint64_t app_error_code);
128 int stream_reset(int64_t stream_id);
132 int http_shutdown_stream_read(int64_t stream_id);
133 int http_reset_stream(int64_t stream_id, uint64_
[all...] |
| /third_party/nghttp2/lib/ |
| H A D | nghttp2_submit.c | 37 * itself. If |stream_id| is -1, we use session->next_stream_id as
46 static int detect_self_dependency(nghttp2_session *session, int32_t stream_id, in detect_self_dependency() argument
50 if (stream_id == -1) { in detect_self_dependency()
51 if ((int32_t)session->next_stream_id == pri_spec->stream_id) { in detect_self_dependency()
57 if (stream_id == pri_spec->stream_id) { in detect_self_dependency()
68 int32_t stream_id, in submit_headers_shared()
100 if (stream_id == -1) { in submit_headers_shared()
106 stream_id = (int32_t)session->next_stream_id; in submit_headers_shared()
117 nghttp2_frame_headers_init(&frame->headers, flags_copy, stream_id, hca in submit_headers_shared()
67 submit_headers_shared(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_priority_spec *pri_spec, nghttp2_nv *nva_copy, size_t nvlen, const nghttp2_data_provider *data_prd, void *stream_user_data) submit_headers_shared() argument
142 submit_headers_shared_nva(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_priority_spec *pri_spec, const nghttp2_nv *nva, size_t nvlen, const nghttp2_data_provider *data_prd, void *stream_user_data) submit_headers_shared_nva() argument
171 nghttp2_submit_trailer(nghttp2_session *session, int32_t stream_id, const nghttp2_nv *nva, size_t nvlen) nghttp2_submit_trailer() argument
182 nghttp2_submit_headers(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_priority_spec *pri_spec, const nghttp2_nv *nva, size_t nvlen, void *stream_user_data) nghttp2_submit_headers() argument
221 nghttp2_submit_priority(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_priority_spec *pri_spec) nghttp2_submit_priority() argument
273 nghttp2_submit_rst_stream(nghttp2_session *session, uint8_t flags, int32_t stream_id, uint32_t error_code) nghttp2_submit_rst_stream() argument
315 nghttp2_submit_push_promise(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_nv *nva, size_t nvlen, void *promised_stream_user_data) nghttp2_submit_push_promise() argument
380 nghttp2_submit_window_update(nghttp2_session *session, uint8_t flags, int32_t stream_id, int32_t window_size_increment) nghttp2_submit_window_update() argument
426 nghttp2_session_set_local_window_size(nghttp2_session *session, uint8_t flags, int32_t stream_id, int32_t window_size) nghttp2_session_set_local_window_size() argument
502 nghttp2_submit_altsvc(nghttp2_session *session, uint8_t flags, int32_t stream_id, const uint8_t *origin, size_t origin_len, const uint8_t *field_value, size_t field_value_len) nghttp2_submit_altsvc() argument
670 nghttp2_submit_priority_update(nghttp2_session *session, uint8_t flags, int32_t stream_id, const uint8_t *field_value, size_t field_value_len) nghttp2_submit_priority_update() argument
792 nghttp2_submit_response(nghttp2_session *session, int32_t stream_id, const nghttp2_nv *nva, size_t nvlen, const nghttp2_data_provider *data_prd) nghttp2_submit_response() argument
810 nghttp2_submit_data(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_data_provider *data_prd) nghttp2_submit_data() argument
865 nghttp2_submit_extension(nghttp2_session *session, uint8_t type, uint8_t flags, int32_t stream_id, void *payload) nghttp2_submit_extension() argument
[all...] |
| H A D | nghttp2_stream.c | 60 void nghttp2_stream_init(nghttp2_stream *stream, int32_t stream_id, in nghttp2_stream_init() argument
67 stream->stream_id = stream_id; in nghttp2_stream_init()
155 DEBUGF("stream: stream=%d obq push cycle=%lu\n", stream->stream_id, in stream_obq_push()
158 DEBUGF("stream: push stream %d to stream %d\n", stream->stream_id, in stream_obq_push()
159 dep_stream->stream_id); in stream_obq_push()
186 DEBUGF("stream: remove stream %d from stream %d\n", stream->stream_id, in stream_obq_remove()
187 dep_stream->stream_id); in stream_obq_remove()
217 DEBUGF("stream: remove stream %d from stream %d (move)\n", stream->stream_id, in stream_obq_move()
218 src->stream_id); in stream_obq_move()
[all...] |
| H A D | nghttp2_session.c | 112 !nghttp2_session_is_my_stream_id(session, stream->stream_id); in state_reserved_remote()
119 nghttp2_session_is_my_stream_id(session, stream->stream_id); in state_reserved_local()
123 * Checks whether received stream_id is valid. This function returns
127 int32_t stream_id) { in session_is_new_peer_stream_id()
128 return stream_id != 0 && in session_is_new_peer_stream_id()
129 !nghttp2_session_is_my_stream_id(session, stream_id) && in session_is_new_peer_stream_id()
130 session->last_recv_stream_id < stream_id; in session_is_new_peer_stream_id()
134 int32_t stream_id) { in session_detect_idle_stream()
135 /* Assume that stream object with stream_id does not exist */ in session_detect_idle_stream()
136 if (nghttp2_session_is_my_stream_id(session, stream_id)) { in session_detect_idle_stream()
126 session_is_new_peer_stream_id(nghttp2_session *session, int32_t stream_id) session_is_new_peer_stream_id() argument
133 session_detect_idle_stream(nghttp2_session *session, int32_t stream_id) session_detect_idle_stream() argument
273 nghttp2_session_is_my_stream_id(nghttp2_session *session, int32_t stream_id) nghttp2_session_is_my_stream_id() argument
286 nghttp2_session_get_stream(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream() argument
300 nghttp2_session_get_stream_raw(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_raw() argument
1212 nghttp2_session_add_rst_stream(nghttp2_session *session, int32_t stream_id, uint32_t error_code) nghttp2_session_add_rst_stream() argument
1290 nghttp2_session_open_stream(nghttp2_session *session, int32_t stream_id, uint8_t flags, nghttp2_priority_spec *pri_spec_in, nghttp2_stream_state initial_state, void *stream_user_data) nghttp2_session_open_stream() argument
1462 nghttp2_session_close_stream(nghttp2_session *session, int32_t stream_id, uint32_t error_code) nghttp2_session_close_stream() argument
2032 session_predicate_window_update_send(nghttp2_session *session, int32_t stream_id) session_predicate_window_update_send() argument
2057 session_predicate_altsvc_send(nghttp2_session *session, int32_t stream_id) session_predicate_altsvc_send() argument
2087 session_predicate_priority_update_send(nghttp2_session *session, int32_t stream_id) session_predicate_priority_update_send() argument
3781 session_handle_invalid_stream2(nghttp2_session *session, int32_t stream_id, nghttp2_frame *frame, int lib_error_code) session_handle_invalid_stream2() argument
4106 int32_t stream_id; session_after_header_block_received() local
5534 session_update_consumed_size(nghttp2_session *session, int32_t *consumed_size_ptr, int32_t *recv_window_size_ptr, uint8_t window_update_queued, int32_t stream_id, size_t delta_size, int32_t local_window_size) session_update_consumed_size() argument
5609 int32_t stream_id; session_on_data_received_fail_fast() local
7483 nghttp2_session_add_window_update(nghttp2_session *session, uint8_t flags, int32_t stream_id, int32_t window_size_increment) nghttp2_session_add_window_update() argument
7785 nghttp2_session_get_stream_user_data(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_user_data() argument
7796 nghttp2_session_set_stream_user_data(nghttp2_session *session, int32_t stream_id, void *stream_user_data) nghttp2_session_set_stream_user_data() argument
7838 nghttp2_session_resume_data(nghttp2_session *session, int32_t stream_id) nghttp2_session_resume_data() argument
7864 nghttp2_session_get_stream_effective_recv_data_length(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_effective_recv_data_length() argument
7875 nghttp2_session_get_stream_effective_local_window_size(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_effective_local_window_size() argument
7885 nghttp2_session_get_stream_local_window_size(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_local_window_size() argument
7919 nghttp2_session_get_stream_remote_window_size(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_remote_window_size() argument
8109 nghttp2_session_get_stream_local_close(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_local_close() argument
8122 nghttp2_session_get_stream_remote_close(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_remote_close() argument
8135 nghttp2_session_consume(nghttp2_session *session, int32_t stream_id, size_t size) nghttp2_session_consume() argument
8185 nghttp2_session_consume_stream(nghttp2_session *session, int32_t stream_id, size_t size) nghttp2_session_consume_stream() argument
8240 nghttp2_session_find_stream(nghttp2_session *session, int32_t stream_id) nghttp2_session_find_stream() argument
8257 nghttp2_session_change_stream_priority( nghttp2_session *session, int32_t stream_id, const nghttp2_priority_spec *pri_spec) nghttp2_session_change_stream_priority() argument
8294 nghttp2_session_create_idle_stream(nghttp2_session *session, int32_t stream_id, const nghttp2_priority_spec *pri_spec) nghttp2_session_create_idle_stream() argument
8346 nghttp2_session_change_extpri_stream_priority( nghttp2_session *session, int32_t stream_id, const nghttp2_extpri *extpri_in, int ignore_client_signal) nghttp2_session_change_extpri_stream_priority() argument
[all...] |
| /third_party/node/deps/nghttp2/lib/ |
| H A D | nghttp2_submit.c | 37 * itself. If |stream_id| is -1, we use session->next_stream_id as
46 static int detect_self_dependency(nghttp2_session *session, int32_t stream_id, in detect_self_dependency() argument
50 if (stream_id == -1) { in detect_self_dependency()
51 if ((int32_t)session->next_stream_id == pri_spec->stream_id) { in detect_self_dependency()
57 if (stream_id == pri_spec->stream_id) { in detect_self_dependency()
68 int32_t stream_id, in submit_headers_shared()
100 if (stream_id == -1) { in submit_headers_shared()
106 stream_id = (int32_t)session->next_stream_id; in submit_headers_shared()
117 nghttp2_frame_headers_init(&frame->headers, flags_copy, stream_id, hca in submit_headers_shared()
67 submit_headers_shared(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_priority_spec *pri_spec, nghttp2_nv *nva_copy, size_t nvlen, const nghttp2_data_provider *data_prd, void *stream_user_data) submit_headers_shared() argument
142 submit_headers_shared_nva(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_priority_spec *pri_spec, const nghttp2_nv *nva, size_t nvlen, const nghttp2_data_provider *data_prd, void *stream_user_data) submit_headers_shared_nva() argument
171 nghttp2_submit_trailer(nghttp2_session *session, int32_t stream_id, const nghttp2_nv *nva, size_t nvlen) nghttp2_submit_trailer() argument
182 nghttp2_submit_headers(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_priority_spec *pri_spec, const nghttp2_nv *nva, size_t nvlen, void *stream_user_data) nghttp2_submit_headers() argument
221 nghttp2_submit_priority(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_priority_spec *pri_spec) nghttp2_submit_priority() argument
273 nghttp2_submit_rst_stream(nghttp2_session *session, uint8_t flags, int32_t stream_id, uint32_t error_code) nghttp2_submit_rst_stream() argument
315 nghttp2_submit_push_promise(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_nv *nva, size_t nvlen, void *promised_stream_user_data) nghttp2_submit_push_promise() argument
380 nghttp2_submit_window_update(nghttp2_session *session, uint8_t flags, int32_t stream_id, int32_t window_size_increment) nghttp2_submit_window_update() argument
426 nghttp2_session_set_local_window_size(nghttp2_session *session, uint8_t flags, int32_t stream_id, int32_t window_size) nghttp2_session_set_local_window_size() argument
502 nghttp2_submit_altsvc(nghttp2_session *session, uint8_t flags, int32_t stream_id, const uint8_t *origin, size_t origin_len, const uint8_t *field_value, size_t field_value_len) nghttp2_submit_altsvc() argument
670 nghttp2_submit_priority_update(nghttp2_session *session, uint8_t flags, int32_t stream_id, const uint8_t *field_value, size_t field_value_len) nghttp2_submit_priority_update() argument
792 nghttp2_submit_response(nghttp2_session *session, int32_t stream_id, const nghttp2_nv *nva, size_t nvlen, const nghttp2_data_provider *data_prd) nghttp2_submit_response() argument
810 nghttp2_submit_data(nghttp2_session *session, uint8_t flags, int32_t stream_id, const nghttp2_data_provider *data_prd) nghttp2_submit_data() argument
865 nghttp2_submit_extension(nghttp2_session *session, uint8_t type, uint8_t flags, int32_t stream_id, void *payload) nghttp2_submit_extension() argument
[all...] |
| H A D | nghttp2_stream.c | 60 void nghttp2_stream_init(nghttp2_stream *stream, int32_t stream_id, in nghttp2_stream_init() argument
67 stream->stream_id = stream_id; in nghttp2_stream_init()
155 DEBUGF("stream: stream=%d obq push cycle=%lu\n", stream->stream_id, in stream_obq_push()
158 DEBUGF("stream: push stream %d to stream %d\n", stream->stream_id, in stream_obq_push()
159 dep_stream->stream_id); in stream_obq_push()
186 DEBUGF("stream: remove stream %d from stream %d\n", stream->stream_id, in stream_obq_remove()
187 dep_stream->stream_id); in stream_obq_remove()
217 DEBUGF("stream: remove stream %d from stream %d (move)\n", stream->stream_id, in stream_obq_move()
218 src->stream_id); in stream_obq_move()
[all...] |
| H A D | nghttp2_session.c | 112 !nghttp2_session_is_my_stream_id(session, stream->stream_id); in state_reserved_remote()
119 nghttp2_session_is_my_stream_id(session, stream->stream_id); in state_reserved_local()
123 * Checks whether received stream_id is valid. This function returns
127 int32_t stream_id) { in session_is_new_peer_stream_id()
128 return stream_id != 0 && in session_is_new_peer_stream_id()
129 !nghttp2_session_is_my_stream_id(session, stream_id) && in session_is_new_peer_stream_id()
130 session->last_recv_stream_id < stream_id; in session_is_new_peer_stream_id()
134 int32_t stream_id) { in session_detect_idle_stream()
135 /* Assume that stream object with stream_id does not exist */ in session_detect_idle_stream()
136 if (nghttp2_session_is_my_stream_id(session, stream_id)) { in session_detect_idle_stream()
126 session_is_new_peer_stream_id(nghttp2_session *session, int32_t stream_id) session_is_new_peer_stream_id() argument
133 session_detect_idle_stream(nghttp2_session *session, int32_t stream_id) session_detect_idle_stream() argument
273 nghttp2_session_is_my_stream_id(nghttp2_session *session, int32_t stream_id) nghttp2_session_is_my_stream_id() argument
286 nghttp2_session_get_stream(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream() argument
300 nghttp2_session_get_stream_raw(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_raw() argument
1207 nghttp2_session_add_rst_stream(nghttp2_session *session, int32_t stream_id, uint32_t error_code) nghttp2_session_add_rst_stream() argument
1285 nghttp2_session_open_stream(nghttp2_session *session, int32_t stream_id, uint8_t flags, nghttp2_priority_spec *pri_spec_in, nghttp2_stream_state initial_state, void *stream_user_data) nghttp2_session_open_stream() argument
1457 nghttp2_session_close_stream(nghttp2_session *session, int32_t stream_id, uint32_t error_code) nghttp2_session_close_stream() argument
2027 session_predicate_window_update_send(nghttp2_session *session, int32_t stream_id) session_predicate_window_update_send() argument
2052 session_predicate_altsvc_send(nghttp2_session *session, int32_t stream_id) session_predicate_altsvc_send() argument
2082 session_predicate_priority_update_send(nghttp2_session *session, int32_t stream_id) session_predicate_priority_update_send() argument
3776 session_handle_invalid_stream2(nghttp2_session *session, int32_t stream_id, nghttp2_frame *frame, int lib_error_code) session_handle_invalid_stream2() argument
4101 int32_t stream_id; session_after_header_block_received() local
5529 session_update_consumed_size(nghttp2_session *session, int32_t *consumed_size_ptr, int32_t *recv_window_size_ptr, uint8_t window_update_queued, int32_t stream_id, size_t delta_size, int32_t local_window_size) session_update_consumed_size() argument
5604 int32_t stream_id; session_on_data_received_fail_fast() local
7472 nghttp2_session_add_window_update(nghttp2_session *session, uint8_t flags, int32_t stream_id, int32_t window_size_increment) nghttp2_session_add_window_update() argument
7774 nghttp2_session_get_stream_user_data(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_user_data() argument
7785 nghttp2_session_set_stream_user_data(nghttp2_session *session, int32_t stream_id, void *stream_user_data) nghttp2_session_set_stream_user_data() argument
7827 nghttp2_session_resume_data(nghttp2_session *session, int32_t stream_id) nghttp2_session_resume_data() argument
7853 nghttp2_session_get_stream_effective_recv_data_length(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_effective_recv_data_length() argument
7864 nghttp2_session_get_stream_effective_local_window_size(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_effective_local_window_size() argument
7874 nghttp2_session_get_stream_local_window_size(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_local_window_size() argument
7908 nghttp2_session_get_stream_remote_window_size(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_remote_window_size() argument
8098 nghttp2_session_get_stream_local_close(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_local_close() argument
8111 nghttp2_session_get_stream_remote_close(nghttp2_session *session, int32_t stream_id) nghttp2_session_get_stream_remote_close() argument
8124 nghttp2_session_consume(nghttp2_session *session, int32_t stream_id, size_t size) nghttp2_session_consume() argument
8174 nghttp2_session_consume_stream(nghttp2_session *session, int32_t stream_id, size_t size) nghttp2_session_consume_stream() argument
8229 nghttp2_session_find_stream(nghttp2_session *session, int32_t stream_id) nghttp2_session_find_stream() argument
8246 nghttp2_session_change_stream_priority( nghttp2_session *session, int32_t stream_id, const nghttp2_priority_spec *pri_spec) nghttp2_session_change_stream_priority() argument
8283 nghttp2_session_create_idle_stream(nghttp2_session *session, int32_t stream_id, const nghttp2_priority_spec *pri_spec) nghttp2_session_create_idle_stream() argument
8335 nghttp2_session_change_extpri_stream_priority( nghttp2_session *session, int32_t stream_id, const nghttp2_extpri *extpri_in, int ignore_client_signal) nghttp2_session_change_extpri_stream_priority() argument
[all...] |
| /third_party/nghttp2/tests/ |
| H A D | nghttp2_test_helper.c | 217 int32_t stream_id, uint8_t flags, const nghttp2_nv *nva, in pack_headers()
225 nghttp2_frame_headers_init(&frame.headers, flags, stream_id, in pack_headers()
235 int32_t stream_id, uint8_t flags, in pack_push_promise()
244 nghttp2_frame_push_promise_init(&frame.push_promise, flags, stream_id, in pack_push_promise()
266 int32_t stream_id, int32_t weight, in open_stream_with_all()
273 dep_stream_id = dep_stream->stream_id; in open_stream_with_all()
280 return nghttp2_session_open_stream(session, stream_id, in open_stream_with_all()
285 nghttp2_stream *open_stream(nghttp2_session *session, int32_t stream_id) { in open_stream() argument
286 return open_stream_with_all(session, stream_id, NGHTTP2_DEFAULT_WEIGHT, 0, in open_stream()
291 int32_t stream_id, in open_stream_with_dep()
216 pack_headers(nghttp2_bufs *bufs, nghttp2_hd_deflater *deflater, int32_t stream_id, uint8_t flags, const nghttp2_nv *nva, size_t nvlen, nghttp2_mem *mem) pack_headers() argument
234 pack_push_promise(nghttp2_bufs *bufs, nghttp2_hd_deflater *deflater, int32_t stream_id, uint8_t flags, int32_t promised_stream_id, const nghttp2_nv *nva, size_t nvlen, nghttp2_mem *mem) pack_push_promise() argument
265 open_stream_with_all(nghttp2_session *session, int32_t stream_id, int32_t weight, uint8_t exclusive, nghttp2_stream *dep_stream) open_stream_with_all() argument
290 open_stream_with_dep(nghttp2_session *session, int32_t stream_id, nghttp2_stream *dep_stream) open_stream_with_dep() argument
297 open_stream_with_dep_weight(nghttp2_session *session, int32_t stream_id, int32_t weight, nghttp2_stream *dep_stream) open_stream_with_dep_weight() argument
303 open_stream_with_dep_excl(nghttp2_session *session, int32_t stream_id, nghttp2_stream *dep_stream) open_stream_with_dep_excl() argument
319 open_sent_stream(nghttp2_session *session, int32_t stream_id) open_sent_stream() argument
327 open_sent_stream2(nghttp2_session *session, int32_t stream_id, nghttp2_stream_state initial_state) open_sent_stream2() argument
336 open_sent_stream3(nghttp2_session *session, int32_t stream_id, uint8_t flags, nghttp2_priority_spec *pri_spec_in, nghttp2_stream_state initial_state, void *stream_user_data) open_sent_stream3() argument
355 open_sent_stream_with_dep(nghttp2_session *session, int32_t stream_id, nghttp2_stream *dep_stream) open_sent_stream_with_dep() argument
362 open_sent_stream_with_dep_weight(nghttp2_session *session, int32_t stream_id, int32_t weight, nghttp2_stream *dep_stream) open_sent_stream_with_dep_weight() argument
380 open_recv_stream(nghttp2_session *session, int32_t stream_id) open_recv_stream() argument
388 open_recv_stream2(nghttp2_session *session, int32_t stream_id, nghttp2_stream_state initial_state) open_recv_stream2() argument
397 open_recv_stream3(nghttp2_session *session, int32_t stream_id, uint8_t flags, nghttp2_priority_spec *pri_spec_in, nghttp2_stream_state initial_state, void *stream_user_data) open_recv_stream3() argument
414 open_recv_stream_with_dep(nghttp2_session *session, int32_t stream_id, nghttp2_stream *dep_stream) open_recv_stream_with_dep() argument
421 open_recv_stream_with_dep_weight(nghttp2_session *session, int32_t stream_id, int32_t weight, nghttp2_stream *dep_stream) open_recv_stream_with_dep_weight() argument
[all...] |
| H A D | nghttp2_test_helper.h | 85 int32_t stream_id, uint8_t flags, const nghttp2_nv *nva,
89 int32_t stream_id, uint8_t flags,
97 nghttp2_stream *open_stream(nghttp2_session *session, int32_t stream_id);
100 int32_t stream_id,
104 int32_t stream_id, int32_t weight,
108 int32_t stream_id,
116 nghttp2_stream *open_sent_stream(nghttp2_session *session, int32_t stream_id);
118 nghttp2_stream *open_sent_stream2(nghttp2_session *session, int32_t stream_id,
121 nghttp2_stream *open_sent_stream3(nghttp2_session *session, int32_t stream_id,
128 int32_t stream_id,
[all...] |
| /third_party/node/deps/ngtcp2/nghttp3/lib/includes/nghttp3/ |
| H A D | nghttp3.h | 1127 * |nva|. |nvlen| is the length of |nva|. |stream_id| is the
1155 nghttp3_buf *ebuf, int64_t stream_id, const nghttp3_nv *nva, size_t nvlen);
1233 * |psctx| must be non-NULL pointer. |stream_id| is stream ID. |mem|
1246 int64_t stream_id, const nghttp3_mem *mem);
1456 * stream denoted by |stream_id|.
1468 int64_t stream_id);
1593 * invoked when data sent on stream denoted by |stream_id| supplied
1602 typedef int (*nghttp3_acked_stream_data)(nghttp3_conn *conn, int64_t stream_id,
1610 * invoked when a stream identified by |stream_id| is closed.
1618 typedef int (*nghttp3_stream_close)(nghttp3_conn *conn, int64_t stream_id,
[all...] |
| /third_party/node/deps/ngtcp2/ngtcp2/lib/ |
| H A D | ngtcp2_idtr.c | 44 * id_from_stream_id translates |stream_id| to id space used by
47 static uint64_t id_from_stream_id(int64_t stream_id) { in id_from_stream_id() argument
48 return (uint64_t)(stream_id >> 2); in id_from_stream_id()
51 int ngtcp2_idtr_open(ngtcp2_idtr *idtr, int64_t stream_id) { in ngtcp2_idtr_open() argument
54 assert((idtr->server && (stream_id % 2)) || in ngtcp2_idtr_open()
55 (!idtr->server && (stream_id % 2)) == 0); in ngtcp2_idtr_open()
57 q = id_from_stream_id(stream_id); in ngtcp2_idtr_open()
66 int ngtcp2_idtr_is_open(ngtcp2_idtr *idtr, int64_t stream_id) { in ngtcp2_idtr_is_open() argument
69 assert((idtr->server && (stream_id % 2)) || in ngtcp2_idtr_is_open()
70 (!idtr->server && (stream_id in ngtcp2_idtr_is_open()
[all...] |
| /third_party/node/deps/ngtcp2/nghttp3/lib/ |
| H A D | nghttp3_idtr.c | 45 * id_from_stream_id translates |stream_id| to id space used by
48 static uint64_t id_from_stream_id(int64_t stream_id) { in id_from_stream_id() argument
49 return (uint64_t)(stream_id >> 2); in id_from_stream_id()
52 int nghttp3_idtr_open(nghttp3_idtr *idtr, int64_t stream_id) { in nghttp3_idtr_open() argument
55 assert((idtr->server && (stream_id % 2)) || in nghttp3_idtr_open()
56 (!idtr->server && (stream_id % 2)) == 0); in nghttp3_idtr_open()
58 q = id_from_stream_id(stream_id); in nghttp3_idtr_open()
67 int nghttp3_idtr_is_open(nghttp3_idtr *idtr, int64_t stream_id) { in nghttp3_idtr_is_open() argument
70 assert((idtr->server && (stream_id % 2)) || in nghttp3_idtr_is_open()
71 (!idtr->server && (stream_id in nghttp3_idtr_is_open()
[all...] |
| H A D | nghttp3_conn.c | 42 * conn_remote_stream_uni returns nonzero if |stream_id| is remote
45 static int conn_remote_stream_uni(nghttp3_conn *conn, int64_t stream_id) { in conn_remote_stream_uni() argument
47 return (stream_id & 0x03) == 0x02; in conn_remote_stream_uni()
49 return (stream_id & 0x03) == 0x03; in conn_remote_stream_uni()
362 static int conn_bidi_idtr_open(nghttp3_conn *conn, int64_t stream_id) { in conn_bidi_idtr_open() argument
365 rv = nghttp3_idtr_open(&conn->remote.bidi.idtr, stream_id); in conn_bidi_idtr_open()
377 nghttp3_ssize nghttp3_conn_read_stream(nghttp3_conn *conn, int64_t stream_id, in nghttp3_conn_read_stream() argument
384 stream = nghttp3_conn_find_stream(conn, stream_id); in nghttp3_conn_read_stream()
389 if (nghttp3_client_stream_bidi(stream_id)) { in nghttp3_conn_read_stream()
390 rv = conn_bidi_idtr_open(conn, stream_id); in nghttp3_conn_read_stream()
1711 int64_t stream_id = fr->pri_elem_id; conn_on_priority_update_stream() local
1771 conn_stream_acked_data(nghttp3_stream *stream, int64_t stream_id, uint64_t datalen, void *user_data) conn_stream_acked_data() argument
1789 nghttp3_conn_create_stream(nghttp3_conn *conn, nghttp3_stream **pstream, int64_t stream_id) nghttp3_conn_create_stream() argument
1819 nghttp3_conn_find_stream(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_find_stream() argument
1824 nghttp3_conn_bind_control_stream(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_bind_control_stream() argument
2020 nghttp3_conn_add_write_offset(nghttp3_conn *conn, int64_t stream_id, size_t n) nghttp3_conn_add_write_offset() argument
2052 nghttp3_conn_add_ack_offset(nghttp3_conn *conn, int64_t stream_id, uint64_t n) nghttp3_conn_add_ack_offset() argument
2134 nghttp3_conn_submit_request(nghttp3_conn *conn, int64_t stream_id, const nghttp3_nv *nva, size_t nvlen, const nghttp3_data_reader *dr, void *stream_user_data) nghttp3_conn_submit_request() argument
2178 nghttp3_conn_submit_info(nghttp3_conn *conn, int64_t stream_id, const nghttp3_nv *nva, size_t nvlen) nghttp3_conn_submit_info() argument
2195 nghttp3_conn_submit_response(nghttp3_conn *conn, int64_t stream_id, const nghttp3_nv *nva, size_t nvlen, const nghttp3_data_reader *dr) nghttp3_conn_submit_response() argument
2216 nghttp3_conn_submit_trailers(nghttp3_conn *conn, int64_t stream_id, const nghttp3_nv *nva, size_t nvlen) nghttp3_conn_submit_trailers() argument
2298 nghttp3_conn_block_stream(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_block_stream() argument
2313 nghttp3_conn_shutdown_stream_write(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_shutdown_stream_write() argument
2328 nghttp3_conn_unblock_stream(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_unblock_stream() argument
2345 nghttp3_conn_is_stream_writable(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_is_stream_writable() argument
2358 nghttp3_conn_resume_stream(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_resume_stream() argument
2375 nghttp3_conn_close_stream(nghttp3_conn *conn, int64_t stream_id, uint64_t app_error_code) nghttp3_conn_close_stream() argument
2401 nghttp3_conn_shutdown_stream_read(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_shutdown_stream_read() argument
2447 nghttp3_conn_set_stream_user_data(nghttp3_conn *conn, int64_t stream_id, void *stream_user_data) nghttp3_conn_set_stream_user_data() argument
2460 nghttp3_conn_get_frame_payload_left(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_get_frame_payload_left() argument
2471 nghttp3_conn_get_stream_priority(nghttp3_conn *conn, nghttp3_pri *dest, int64_t stream_id) nghttp3_conn_get_stream_priority() argument
2492 nghttp3_conn_set_stream_priority(nghttp3_conn *conn, int64_t stream_id, const nghttp3_pri *pri) nghttp3_conn_set_stream_priority() argument
2522 nghttp3_conn_is_remote_qpack_encoder_stream(nghttp3_conn *conn, int64_t stream_id) nghttp3_conn_is_remote_qpack_encoder_stream() argument
[all...] |
| /third_party/skia/third_party/externals/microhttpd/src/microspdy/ |
| H A D | stream.c | 34 uint32_t stream_id; in SPDYF_stream_new() local
51 memcpy(&stream_id, session->read_buffer + session->read_buffer_beginning, 4); in SPDYF_stream_new()
52 stream_id = NTOH31(stream_id); in SPDYF_stream_new()
54 if(stream_id <= session->last_in_stream_id || 0==(stream_id % 2)) in SPDYF_stream_new()
73 session->last_in_stream_id = stream_id; in SPDYF_stream_new()
99 stream->stream_id = stream_id; in SPDYF_stream_new()
159 SPDYF_stream_find(uint32_t stream_id, struc argument
[all...] |
| /third_party/nghttp2/lib/includes/nghttp2/ |
| H A D | nghttp2.h | 818 int32_t stream_id; member
884 * the |source|. The read data is sent in the stream |stream_id|.
944 nghttp2_session *session, int32_t stream_id, uint8_t *buf, size_t length,
1023 int32_t stream_id; member
1491 * received. The |stream_id| is the stream ID this DATA frame belongs
1520 int32_t stream_id,
1605 * Callback function invoked when the stream |stream_id| is closed.
1627 int32_t stream_id,
1676 * Again, use ``frame->push_promise.promised_stream_id`` as stream_id
1753 * Again, use ``frame->push_promise.promised_stream_id`` as stream_id
4891 int32_t stream_id; global() member
[all...] |
| /third_party/node/deps/nghttp2/lib/includes/nghttp2/ |
| H A D | nghttp2.h | 813 int32_t stream_id; member
879 * the |source|. The read data is sent in the stream |stream_id|.
939 nghttp2_session *session, int32_t stream_id, uint8_t *buf, size_t length,
1018 int32_t stream_id; member
1486 * received. The |stream_id| is the stream ID this DATA frame belongs
1515 int32_t stream_id,
1600 * Callback function invoked when the stream |stream_id| is closed.
1622 int32_t stream_id,
1671 * Again, use ``frame->push_promise.promised_stream_id`` as stream_id
1748 * Again, use ``frame->push_promise.promised_stream_id`` as stream_id
4875 int32_t stream_id; global() member
[all...] |
| /third_party/curl/lib/ |
| H A D | cf-h2-proxy.c | 73 int32_t stream_id; member
91 ts->stream_id = -1; in tunnel_stream_init()
138 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'init'", ts->stream_id); in h2_tunnel_go_state()
143 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'connect'", ts->stream_id); in h2_tunnel_go_state()
148 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'response'", ts->stream_id); in h2_tunnel_go_state()
154 ts->stream_id); in h2_tunnel_go_state()
161 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'failed'", ts->stream_id); in h2_tunnel_go_state()
226 tunnel->stream_id, bits); in drain_tunnel()
305 int32_t stream_id,
314 int32_t stream_id,
667 int32_t stream_id = frame->hd.stream_id; proxy_h2_on_frame_recv() local
746 int32_t stream_id = frame->hd.stream_id; proxy_h2_on_header() local
804 tunnel_send_callback(nghttp2_session *session, int32_t stream_id, uint8_t *buf, size_t length, uint32_t *data_flags, nghttp2_data_source *source, void *userp) tunnel_send_callback() argument
844 tunnel_recv_callback(nghttp2_session *session, uint8_t flags, int32_t stream_id, const uint8_t *mem, size_t len, void *userp) tunnel_recv_callback() argument
870 proxy_h2_on_stream_close(nghttp2_session *session, int32_t stream_id, uint32_t error_code, void *userp) proxy_h2_on_stream_close() argument
904 int32_t stream_id = -1; proxy_h2_submit() local
[all...] |
| /third_party/skia/third_party/externals/microhttpd/src/examples/ |
| H A D | mhd2spdy_spdy.c | 67 spdy_cb_data_source_read(spdylay_session *session, int32_t stream_id, uint8_t *buf, size_t length, int *eof, spdylay_data_source *source, void *user_data) in spdy_cb_data_source_read() argument
70 (void)stream_id; in spdy_cb_data_source_read()
158 PRINT_INFO2("ignoring RST_STREAM for stream_id %i %i %i %i", data[8], data[9], data[10], data[11]); in spdy_cb_send()
293 int32_t stream_id; in spdy_cb_before_ctrl_send() local
298 stream_id = frame->syn_stream.stream_id; in spdy_cb_before_ctrl_send()
299 proxy = spdylay_session_get_stream_user_data(session, stream_id); in spdy_cb_before_ctrl_send()
300 proxy->stream_id = stream_id; in spdy_cb_before_ctrl_send()
308 glob_opt.ignore_rst_stream = NULL==spdylay_session_get_stream_user_data(session, frame->rst_stream.stream_id); in spdy_cb_before_ctrl_send()
329 int32_t stream_id; spdy_cb_on_ctrl_recv() local
386 spdy_cb_on_stream_close(spdylay_session *session, int32_t stream_id, spdylay_status_code status_code, void *user_data) spdy_cb_on_stream_close() argument
419 spdy_cb_on_data_chunk_recv(spdylay_session *session, uint8_t flags, int32_t stream_id, const uint8_t *data, size_t len, void *user_data) spdy_cb_on_data_chunk_recv() argument
464 spdy_cb_on_data_recv(spdylay_session *session, uint8_t flags, int32_t stream_id, int32_t length, void *user_data) spdy_cb_on_data_recv() argument
[all...] |
| /third_party/skia/third_party/externals/microhttpd/src/testspdy/ |
| H A D | test_new_connection.c | 128 int32_t stream_id; member
296 int stream_id = frame->syn_stream.stream_id; in before_ctrl_send_callback() local
297 req = spdylay_session_get_stream_user_data(session, stream_id); in before_ctrl_send_callback()
298 if(req && req->stream_id == -1) { in before_ctrl_send_callback()
299 req->stream_id = stream_id; in before_ctrl_send_callback()
300 spdylay_printf("[INFO] Stream ID = %d\n", stream_id); in before_ctrl_send_callback()
313 int32_t stream_id; in on_ctrl_send_callback() local
319 stream_id in on_ctrl_send_callback()
341 int32_t stream_id; on_ctrl_recv_callback() local
376 on_stream_close_callback(spdylay_session *session, int32_t stream_id, spdylay_status_code status_code, void *user_data) on_stream_close_callback() argument
400 on_data_chunk_recv_callback(spdylay_session *session, uint8_t flags, int32_t stream_id, const uint8_t *data, size_t len, void *user_data) on_data_chunk_recv_callback() argument
[all...] |
| H A D | test_notls.c | 107 int32_t stream_id; member
293 int stream_id = frame->syn_stream.stream_id; in before_ctrl_send_callback() local
294 req = spdylay_session_get_stream_user_data(session, stream_id); in before_ctrl_send_callback()
295 if(req && req->stream_id == -1) { in before_ctrl_send_callback()
296 req->stream_id = stream_id; in before_ctrl_send_callback()
297 printf("[INFO] Stream ID = %d\n", stream_id); in before_ctrl_send_callback()
310 int32_t stream_id; in on_ctrl_send_callback() local
316 stream_id in on_ctrl_send_callback()
338 int32_t stream_id; on_ctrl_recv_callback() local
373 on_stream_close_callback(spdylay_session *session, int32_t stream_id, spdylay_status_code status_code, void *user_data) on_stream_close_callback() argument
398 on_data_chunk_recv_callback(spdylay_session *session, uint8_t flags, int32_t stream_id, const uint8_t *data, size_t len, void *user_data) on_data_chunk_recv_callback() argument
[all...] |
| H A D | test_request_response.c | 110 int32_t stream_id; member
278 int stream_id = frame->syn_stream.stream_id; in before_ctrl_send_callback() local
279 req = spdylay_session_get_stream_user_data(session, stream_id); in before_ctrl_send_callback()
280 if(req && req->stream_id == -1) { in before_ctrl_send_callback()
281 req->stream_id = stream_id; in before_ctrl_send_callback()
282 printf("[INFO] Stream ID = %d\n", stream_id); in before_ctrl_send_callback()
295 int32_t stream_id; in on_ctrl_send_callback() local
301 stream_id in on_ctrl_send_callback()
323 int32_t stream_id; on_ctrl_recv_callback() local
358 on_stream_close_callback(spdylay_session *session, int32_t stream_id, spdylay_status_code status_code, void *user_data) on_stream_close_callback() argument
383 on_data_chunk_recv_callback(spdylay_session *session, uint8_t flags, int32_t stream_id, const uint8_t *data, size_t len, void *user_data) on_data_chunk_recv_callback() argument
[all...] |
| /third_party/nghttp2/examples/ |
| H A D | libevent-client.c | 87 int32_t stream_id; member
105 stream_data->stream_id = -1; in create_http2_stream_data()
226 session_data->stream_data->stream_id == frame->hd.stream_id) { in on_header_callback()
246 session_data->stream_data->stream_id == frame->hd.stream_id) { in on_begin_headers_callback()
248 frame->hd.stream_id); in on_begin_headers_callback()
265 session_data->stream_data->stream_id == frame->hd.stream_id) { in on_frame_recv_callback()
279 int32_t stream_id, cons in on_data_chunk_recv_callback()
278 on_data_chunk_recv_callback(nghttp2_session *session, uint8_t flags, int32_t stream_id, const uint8_t *data, size_t len, void *user_data) on_data_chunk_recv_callback() argument
295 on_stream_close_callback(nghttp2_session *session, int32_t stream_id, uint32_t error_code, void *user_data) on_stream_close_callback() argument
416 int32_t stream_id; submit_request() local
[all...] |