| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/util/stream/ |
| H A D | SortedOps.java | 311 super(downstream); in AbstractRefSortingSink()
363 downstream.end(); in end()
403 downstream.end(); in end()
421 super(downstream); in AbstractIntSortingSink()
439 super(downstream); in SizedIntSortingSink()
461 downstream.end(); in end()
503 downstream.end(); in end()
560 downstream.end(); in end()
602 downstream.end(); in end()
659 downstream.end(); in end()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/java/util/stream/ |
| H A D | SortedOps.java | 311 super(downstream); in AbstractRefSortingSink()
363 downstream.end(); in end()
403 downstream.end(); in end()
421 super(downstream); in AbstractIntSortingSink()
439 super(downstream); in SizedIntSortingSink()
461 downstream.end(); in end()
503 downstream.end(); in end()
560 downstream.end(); in end()
602 downstream.end(); in end()
659 downstream.end(); in end()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.base/share/classes/java/util/stream/ |
| H A D | SortedOps.java | 311 super(downstream); in AbstractRefSortingSink()
363 downstream.end(); in end()
403 downstream.end(); in end()
421 super(downstream); in AbstractIntSortingSink()
439 super(downstream); in SizedIntSortingSink()
461 downstream.end(); in end()
503 downstream.end(); in end()
560 downstream.end(); in end()
602 downstream.end(); in end()
659 downstream.end(); in end()
[all …]
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.base/share/classes/java/util/stream/ |
| H A D | SortedOps.java | 311 super(downstream); in AbstractRefSortingSink()
363 downstream.end(); in end()
403 downstream.end(); in end()
421 super(downstream); in AbstractIntSortingSink()
439 super(downstream); in SizedIntSortingSink()
461 downstream.end(); in end()
503 downstream.end(); in end()
560 downstream.end(); in end()
602 downstream.end(); in end()
659 downstream.end(); in end()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.base/share/classes/java/util/stream/ |
| H A D | SortedOps.java | 311 super(downstream); in AbstractRefSortingSink()
363 downstream.end(); in end()
403 downstream.end(); in end()
421 super(downstream); in AbstractIntSortingSink()
439 super(downstream); in SizedIntSortingSink()
461 downstream.end(); in end()
503 downstream.end(); in end()
560 downstream.end(); in end()
602 downstream.end(); in end()
659 downstream.end(); in end()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.base/share/classes/java/util/stream/ |
| H A D | SortedOps.java | 311 super(downstream); in AbstractRefSortingSink()
363 downstream.end(); in end()
403 downstream.end(); in end()
421 super(downstream); in AbstractIntSortingSink()
439 super(downstream); in SizedIntSortingSink()
461 downstream.end(); in end()
503 downstream.end(); in end()
560 downstream.end(); in end()
602 downstream.end(); in end()
659 downstream.end(); in end()
[all …]
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/util/stream/ |
| H A D | SortedOps.java | 311 super(downstream); in AbstractRefSortingSink()
363 downstream.end(); in end()
403 downstream.end(); in end()
421 super(downstream); in AbstractIntSortingSink()
439 super(downstream); in SizedIntSortingSink()
461 downstream.end(); in end()
503 downstream.end(); in end()
560 downstream.end(); in end()
602 downstream.end(); in end()
659 downstream.end(); in end()
[all …]
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libnghttp2-sys-0.1.7+1.45.0/nghttp2/src/ |
| H A D | shrpx_mruby_module_response.cc | 52 auto downstream = data->downstream; in response_get_http_version_major() local
61 auto downstream = data->downstream; in response_get_http_version_minor() local
70 auto downstream = data->downstream; in response_get_status() local
79 auto downstream = data->downstream; in response_set_status() local
80 auto &resp = downstream->response(); in response_set_status()
99 auto downstream = data->downstream; in response_get_headers() local
109 auto downstream = data->downstream; in response_mod_header() local
193 auto downstream = data->downstream; in response_clear_headers() local
205 auto downstream = data->downstream; in response_return() local
206 auto &req = downstream->request(); in response_return()
[all …]
|
| H A D | shrpx_http3_upstream.h | 51 virtual int on_timeout(Downstream *downstream);
52 virtual int on_downstream_abort_request(Downstream *downstream,
65 virtual int on_downstream_body_complete(Downstream *downstream);
85 on_downstream_push_promise_complete(Downstream *downstream,
127 int http_end_request_headers(Downstream *downstream);
128 int http_end_stream(Downstream *downstream);
129 void start_downstream(Downstream *downstream);
130 void initiate_downstream(Downstream *downstream);
133 int redirect_to_https(Downstream *downstream);
136 void remove_downstream(Downstream *downstream);
[all …]
|
| H A D | shrpx_downstream_queue.cc | 52 downstream->set_dispatch_state(DispatchState::PENDING); in add_pending()
53 downstreams_.append(downstream.release()); in add_pending()
57 downstream->set_dispatch_state(DispatchState::FAILURE); in mark_failure()
83 return make_host_key(downstream->request().authority); in make_host_key()
90 downstream->set_dispatch_state(DispatchState::ACTIVE); in mark_active()
99 downstream->attach_blocked_link(link); in mark_blocked()
127 auto delptr = std::unique_ptr<Downstream>(downstream); in remove_and_get_blocked()
129 downstreams_.remove(downstream); in remove_and_get_blocked()
131 auto host = make_host_key(downstream); in remove_and_get_blocked()
138 auto link = downstream->detach_blocked_link(); in remove_and_get_blocked()
[all …]
|
| H A D | shrpx_http2_session.cc | 842 if (downstream->get_upgraded() && downstream->get_response_state() == in on_stream_close_callback()
847 downstream->get_upstream()->on_downstream_body_complete(downstream); in on_stream_close_callback()
914 DLOG(INFO, downstream) in on_header_callback2()
932 downstream->add_rcbuf(name); in on_header_callback2()
933 downstream->add_rcbuf(value); in on_header_callback2()
971 DLOG(INFO, downstream) in on_header_callback2()
1064 assert(downstream); in on_begin_headers_callback()
1144 if (downstream->get_upgraded()) { in on_response_headers()
1351 assert(downstream); in on_frame_recv_callback()
1590 if (downstream->get_upstream()->resume_read(SHRPX_NO_BUFFER, downstream, in send_data_callback()
[all …]
|
| /dports/net/proby/proby-1.0.2/cargo-crates/libnghttp2-sys-0.1.4+1.41.0/nghttp2/src/ |
| H A D | shrpx_mruby_module_response.cc | 52 auto downstream = data->downstream; in response_get_http_version_major() local
61 auto downstream = data->downstream; in response_get_http_version_minor() local
70 auto downstream = data->downstream; in response_get_status() local
79 auto downstream = data->downstream; in response_set_status() local
80 auto &resp = downstream->response(); in response_set_status()
99 auto downstream = data->downstream; in response_get_headers() local
109 auto downstream = data->downstream; in response_mod_header() local
193 auto downstream = data->downstream; in response_clear_headers() local
205 auto downstream = data->downstream; in response_return() local
206 auto &req = downstream->request(); in response_return()
[all …]
|
| H A D | shrpx_downstream_queue.cc | 52 downstream->set_dispatch_state(DispatchState::PENDING); in add_pending()
53 downstreams_.append(downstream.release()); in add_pending()
57 downstream->set_dispatch_state(DispatchState::FAILURE); in mark_failure()
83 return make_host_key(downstream->request().authority); in make_host_key()
90 downstream->set_dispatch_state(DispatchState::ACTIVE); in mark_active()
99 downstream->attach_blocked_link(link); in mark_blocked()
127 auto delptr = std::unique_ptr<Downstream>(downstream); in remove_and_get_blocked()
129 downstreams_.remove(downstream); in remove_and_get_blocked()
131 auto host = make_host_key(downstream); in remove_and_get_blocked()
138 auto link = downstream->detach_blocked_link(); in remove_and_get_blocked()
[all …]
|
| H A D | shrpx_http2_session.cc | 842 if (downstream->get_upgraded() && downstream->get_response_state() == in on_stream_close_callback()
847 downstream->get_upstream()->on_downstream_body_complete(downstream); in on_stream_close_callback()
914 DLOG(INFO, downstream) in on_header_callback2()
932 downstream->add_rcbuf(name); in on_header_callback2()
933 downstream->add_rcbuf(value); in on_header_callback2()
971 DLOG(INFO, downstream) in on_header_callback2()
1064 assert(downstream); in on_begin_headers_callback()
1144 if (downstream->get_upgraded()) { in on_response_headers()
1351 assert(downstream); in on_frame_recv_callback()
1590 if (downstream->get_upstream()->resume_read(SHRPX_NO_BUFFER, downstream, in send_data_callback()
[all …]
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libnghttp2-sys-0.1.6+1.43.0/nghttp2/src/ |
| H A D | shrpx_mruby_module_response.cc | 52 auto downstream = data->downstream; in response_get_http_version_major() local
61 auto downstream = data->downstream; in response_get_http_version_minor() local
70 auto downstream = data->downstream; in response_get_status() local
79 auto downstream = data->downstream; in response_set_status() local
80 auto &resp = downstream->response(); in response_set_status()
99 auto downstream = data->downstream; in response_get_headers() local
109 auto downstream = data->downstream; in response_mod_header() local
193 auto downstream = data->downstream; in response_clear_headers() local
205 auto downstream = data->downstream; in response_return() local
206 auto &req = downstream->request(); in response_return()
[all …]
|
| H A D | shrpx_downstream_queue.cc | 52 downstream->set_dispatch_state(DispatchState::PENDING); in add_pending()
53 downstreams_.append(downstream.release()); in add_pending()
57 downstream->set_dispatch_state(DispatchState::FAILURE); in mark_failure()
83 return make_host_key(downstream->request().authority); in make_host_key()
90 downstream->set_dispatch_state(DispatchState::ACTIVE); in mark_active()
99 downstream->attach_blocked_link(link); in mark_blocked()
127 auto delptr = std::unique_ptr<Downstream>(downstream); in remove_and_get_blocked()
129 downstreams_.remove(downstream); in remove_and_get_blocked()
131 auto host = make_host_key(downstream); in remove_and_get_blocked()
138 auto link = downstream->detach_blocked_link(); in remove_and_get_blocked()
[all …]
|
| /dports/www/libnghttp2/nghttp2-1.46.0/src/ |
| H A D | shrpx_mruby_module_response.cc | 52 auto downstream = data->downstream; in response_get_http_version_major() local
61 auto downstream = data->downstream; in response_get_http_version_minor() local
70 auto downstream = data->downstream; in response_get_status() local
79 auto downstream = data->downstream; in response_set_status() local
80 auto &resp = downstream->response(); in response_set_status()
99 auto downstream = data->downstream; in response_get_headers() local
109 auto downstream = data->downstream; in response_mod_header() local
193 auto downstream = data->downstream; in response_clear_headers() local
205 auto downstream = data->downstream; in response_return() local
206 auto &req = downstream->request(); in response_return()
[all …]
|
| H A D | shrpx_http3_upstream.h | 51 virtual int on_timeout(Downstream *downstream);
52 virtual int on_downstream_abort_request(Downstream *downstream,
65 virtual int on_downstream_body_complete(Downstream *downstream);
85 on_downstream_push_promise_complete(Downstream *downstream,
127 int http_end_request_headers(Downstream *downstream);
128 int http_end_stream(Downstream *downstream);
129 void start_downstream(Downstream *downstream);
130 void initiate_downstream(Downstream *downstream);
133 int redirect_to_https(Downstream *downstream);
136 void remove_downstream(Downstream *downstream);
[all …]
|
| H A D | shrpx_downstream_queue.cc | 52 downstream->set_dispatch_state(DispatchState::PENDING); in add_pending()
53 downstreams_.append(downstream.release()); in add_pending()
57 downstream->set_dispatch_state(DispatchState::FAILURE); in mark_failure()
83 return make_host_key(downstream->request().authority); in make_host_key()
90 downstream->set_dispatch_state(DispatchState::ACTIVE); in mark_active()
99 downstream->attach_blocked_link(link); in mark_blocked()
127 auto delptr = std::unique_ptr<Downstream>(downstream); in remove_and_get_blocked()
129 downstreams_.remove(downstream); in remove_and_get_blocked()
131 auto host = make_host_key(downstream); in remove_and_get_blocked()
138 auto link = downstream->detach_blocked_link(); in remove_and_get_blocked()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/src/ |
| H A D | shrpx_mruby_module_response.cc | 52 auto downstream = data->downstream; in response_get_http_version_major() local
61 auto downstream = data->downstream; in response_get_http_version_minor() local
70 auto downstream = data->downstream; in response_get_status() local
79 auto downstream = data->downstream; in response_set_status() local
80 auto &resp = downstream->response(); in response_set_status()
99 auto downstream = data->downstream; in response_get_headers() local
109 auto downstream = data->downstream; in response_mod_header() local
193 auto downstream = data->downstream; in response_clear_headers() local
205 auto downstream = data->downstream; in response_return() local
206 auto &req = downstream->request(); in response_return()
[all …]
|
| H A D | shrpx_downstream_queue.cc | 52 downstream->set_dispatch_state(DispatchState::PENDING); in add_pending()
53 downstreams_.append(downstream.release()); in add_pending()
57 downstream->set_dispatch_state(DispatchState::FAILURE); in mark_failure()
83 return make_host_key(downstream->request().authority); in make_host_key()
90 downstream->set_dispatch_state(DispatchState::ACTIVE); in mark_active()
99 downstream->attach_blocked_link(link); in mark_blocked()
127 auto delptr = std::unique_ptr<Downstream>(downstream); in remove_and_get_blocked()
129 downstreams_.remove(downstream); in remove_and_get_blocked()
131 auto host = make_host_key(downstream); in remove_and_get_blocked()
138 auto link = downstream->detach_blocked_link(); in remove_and_get_blocked()
[all …]
|
| /dports/www/nghttp2/nghttp2-1.46.0/src/ |
| H A D | shrpx_mruby_module_response.cc | 52 auto downstream = data->downstream; in response_get_http_version_major() local
61 auto downstream = data->downstream; in response_get_http_version_minor() local
70 auto downstream = data->downstream; in response_get_status() local
79 auto downstream = data->downstream; in response_set_status() local
80 auto &resp = downstream->response(); in response_set_status()
99 auto downstream = data->downstream; in response_get_headers() local
109 auto downstream = data->downstream; in response_mod_header() local
193 auto downstream = data->downstream; in response_clear_headers() local
205 auto downstream = data->downstream; in response_return() local
206 auto &req = downstream->request(); in response_return()
[all …]
|
| H A D | shrpx_http3_upstream.h | 51 virtual int on_timeout(Downstream *downstream);
52 virtual int on_downstream_abort_request(Downstream *downstream,
65 virtual int on_downstream_body_complete(Downstream *downstream);
85 on_downstream_push_promise_complete(Downstream *downstream,
127 int http_end_request_headers(Downstream *downstream);
128 int http_end_stream(Downstream *downstream);
129 void start_downstream(Downstream *downstream);
130 void initiate_downstream(Downstream *downstream);
133 int redirect_to_https(Downstream *downstream);
136 void remove_downstream(Downstream *downstream);
[all …]
|
| H A D | shrpx_downstream_queue.cc | 52 downstream->set_dispatch_state(DispatchState::PENDING); in add_pending()
53 downstreams_.append(downstream.release()); in add_pending()
57 downstream->set_dispatch_state(DispatchState::FAILURE); in mark_failure()
83 return make_host_key(downstream->request().authority); in make_host_key()
90 downstream->set_dispatch_state(DispatchState::ACTIVE); in mark_active()
99 downstream->attach_blocked_link(link); in mark_blocked()
127 auto delptr = std::unique_ptr<Downstream>(downstream); in remove_and_get_blocked()
129 downstreams_.remove(downstream); in remove_and_get_blocked()
131 auto host = make_host_key(downstream); in remove_and_get_blocked()
138 auto link = downstream->detach_blocked_link(); in remove_and_get_blocked()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/pm/hydra/pm/pmiserv/ |
| H A D | pmip.c | 38 HYD_pmcd_pmip.downstream.out = NULL; in init_params()
39 HYD_pmcd_pmip.downstream.err = NULL; in init_params()
40 HYD_pmcd_pmip.downstream.in = HYD_FD_UNSET; in init_params()
41 HYD_pmcd_pmip.downstream.pid = NULL; in init_params()
43 HYD_pmcd_pmip.downstream.pmi_rank = NULL; in init_params()
44 HYD_pmcd_pmip.downstream.pmi_fd = NULL; in init_params()
87 if (HYD_pmcd_pmip.downstream.out) in cleanup_params()
90 if (HYD_pmcd_pmip.downstream.err) in cleanup_params()
93 if (HYD_pmcd_pmip.downstream.pid) in cleanup_params()
99 if (HYD_pmcd_pmip.downstream.pmi_rank) in cleanup_params()
[all …]
|