/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.base/share/classes/java/util/stream/ |
H A D | Collectors.java | 460 return new CollectorImpl<>(downstream.supplier(), 462 downstream.combiner(), downstream.finisher(), 505 return new CollectorImpl<>(downstream.supplier(), 512 downstream.combiner(), downstream.finisher(), 513 downstream.characteristics()); 555 return new CollectorImpl<>(downstream.supplier(), 561 downstream.combiner(), downstream.finisher(), 596 return new CollectorImpl<>(downstream.supplier(), 597 downstream.accumulator(), 598 downstream.combiner(), [all …]
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/java/util/stream/ |
H A D | ReferencePipeline.java | 173 downstream.begin(-1); 268 downstream.begin(-1); 280 … do { } while (!downstream.cancellationRequested() && s.tryAdvance(downstream)); 316 downstream.begin(-1); 360 downstream.begin(-1); 405 downstream.begin(-1); 444 downstream.begin(-1); 468 downstream.begin(-1); 492 downstream.begin(-1); 517 downstream.begin(-1); [all …]
|
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.base/share/classes/java/util/stream/ |
H A D | ReferencePipeline.java | 173 downstream.begin(-1); 268 downstream.begin(-1); 280 … do { } while (!downstream.cancellationRequested() && s.tryAdvance(downstream)); 316 downstream.begin(-1); 360 downstream.begin(-1); 405 downstream.begin(-1); 444 downstream.begin(-1); 468 downstream.begin(-1); 492 downstream.begin(-1); 517 downstream.begin(-1); [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_downstream_queue.h | 47 Downstream *downstream; member 77 void add_pending(std::unique_ptr<Downstream> downstream); 80 void mark_failure(Downstream *downstream); 83 void mark_active(Downstream *downstream); 86 void mark_blocked(Downstream *downstream); 95 Downstream *remove_and_get_blocked(Downstream *downstream, 100 StringRef make_host_key(Downstream *downstream) const;
|
H A D | shrpx_http2_downstream_connection.cc | 102 downstream_ = downstream; in attach_downstream() 123 if (submit_rst_stream(downstream) == 0) { in detach_downstream() 135 downstream->disable_downstream_rtimer(); in detach_downstream() 136 downstream->disable_downstream_wtimer(); in detach_downstream() 145 switch (downstream->get_response_state()) { in submit_rst_stream() 176 auto downstream = dconn->get_downstream(); in http2_data_read_callback() local 177 if (!downstream) { in http2_data_read_callback() 182 const auto &req = downstream->request(); in http2_data_read_callback() 183 auto input = downstream->get_request_buf(); in http2_data_read_callback() 197 !downstream->get_upgraded()))) { in http2_data_read_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_downstream_queue.h | 47 Downstream *downstream; member 77 void add_pending(std::unique_ptr<Downstream> downstream); 80 void mark_failure(Downstream *downstream); 83 void mark_active(Downstream *downstream); 86 void mark_blocked(Downstream *downstream); 95 Downstream *remove_and_get_blocked(Downstream *downstream, 100 StringRef make_host_key(Downstream *downstream) const;
|
H A D | shrpx_http2_downstream_connection.cc | 102 downstream_ = downstream; in attach_downstream() 123 if (submit_rst_stream(downstream) == 0) { in detach_downstream() 135 downstream->disable_downstream_rtimer(); in detach_downstream() 136 downstream->disable_downstream_wtimer(); in detach_downstream() 145 switch (downstream->get_response_state()) { in submit_rst_stream() 176 auto downstream = dconn->get_downstream(); in http2_data_read_callback() local 177 if (!downstream) { in http2_data_read_callback() 182 const auto &req = downstream->request(); in http2_data_read_callback() 183 auto input = downstream->get_request_buf(); in http2_data_read_callback() 197 !downstream->get_upgraded()))) { in http2_data_read_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_downstream_queue.h | 47 Downstream *downstream; member 77 void add_pending(std::unique_ptr<Downstream> downstream); 80 void mark_failure(Downstream *downstream); 83 void mark_active(Downstream *downstream); 86 void mark_blocked(Downstream *downstream); 95 Downstream *remove_and_get_blocked(Downstream *downstream, 100 StringRef make_host_key(Downstream *downstream) const;
|
H A D | shrpx_http2_downstream_connection.cc | 102 downstream_ = downstream; in attach_downstream() 123 if (submit_rst_stream(downstream) == 0) { in detach_downstream() 135 downstream->disable_downstream_rtimer(); in detach_downstream() 136 downstream->disable_downstream_wtimer(); in detach_downstream() 145 switch (downstream->get_response_state()) { in submit_rst_stream() 176 auto downstream = dconn->get_downstream(); in http2_data_read_callback() local 177 if (!downstream) { in http2_data_read_callback() 182 const auto &req = downstream->request(); in http2_data_read_callback() 183 auto input = downstream->get_request_buf(); in http2_data_read_callback() 197 !downstream->get_upgraded()))) { in http2_data_read_callback() [all …]
|
/dports/www/libnghttp2/nghttp2-1.46.0/src/ |
H A D | shrpx_downstream_queue.h | 47 Downstream *downstream; member 77 void add_pending(std::unique_ptr<Downstream> downstream); 80 void mark_failure(Downstream *downstream); 83 void mark_active(Downstream *downstream); 86 void mark_blocked(Downstream *downstream); 95 Downstream *remove_and_get_blocked(Downstream *downstream, 100 StringRef make_host_key(Downstream *downstream) const;
|
H A D | shrpx_http2_downstream_connection.cc | 102 downstream_ = downstream; in attach_downstream() 123 if (submit_rst_stream(downstream) == 0) { in detach_downstream() 135 downstream->disable_downstream_rtimer(); in detach_downstream() 136 downstream->disable_downstream_wtimer(); in detach_downstream() 145 switch (downstream->get_response_state()) { in submit_rst_stream() 176 auto downstream = dconn->get_downstream(); in http2_data_read_callback() local 177 if (!downstream) { in http2_data_read_callback() 182 const auto &req = downstream->request(); in http2_data_read_callback() 183 auto input = downstream->get_request_buf(); in http2_data_read_callback() 197 !downstream->get_upgraded()))) { in http2_data_read_callback() [all …]
|
/dports/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/src/ |
H A D | shrpx_downstream_queue.h | 47 Downstream *downstream; member 77 void add_pending(std::unique_ptr<Downstream> downstream); 80 void mark_failure(Downstream *downstream); 83 void mark_active(Downstream *downstream); 86 void mark_blocked(Downstream *downstream); 95 Downstream *remove_and_get_blocked(Downstream *downstream, 100 StringRef make_host_key(Downstream *downstream) const;
|
H A D | shrpx_http2_downstream_connection.cc | 102 downstream_ = downstream; in attach_downstream() 123 if (submit_rst_stream(downstream) == 0) { in detach_downstream() 135 downstream->disable_downstream_rtimer(); in detach_downstream() 136 downstream->disable_downstream_wtimer(); in detach_downstream() 145 switch (downstream->get_response_state()) { in submit_rst_stream() 176 auto downstream = dconn->get_downstream(); in http2_data_read_callback() local 177 if (!downstream) { in http2_data_read_callback() 182 const auto &req = downstream->request(); in http2_data_read_callback() 183 auto input = downstream->get_request_buf(); in http2_data_read_callback() 197 !downstream->get_upgraded()))) { in http2_data_read_callback() [all …]
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gitlab.com/gitlab-org/gitlab-terminal/gitlab-terminal-2a71b03b44621289b28493d8bf3eaa9f64dbb6c9/ |
H A D | terminal_test.go | 17 downstream := bufferCloser{} 18 downstream.Write([]byte(StreamMessage)) 21 downstream: downstream, 33 _, err = downstream.Read(b) 45 downstream bufferCloser member 50 ProxyStream(w, r, &d.downstream, proxy)
|
/dports/www/nghttp2/nghttp2-1.46.0/src/ |
H A D | shrpx_downstream_queue.h | 47 Downstream *downstream; member 77 void add_pending(std::unique_ptr<Downstream> downstream); 80 void mark_failure(Downstream *downstream); 83 void mark_active(Downstream *downstream); 86 void mark_blocked(Downstream *downstream); 95 Downstream *remove_and_get_blocked(Downstream *downstream, 100 StringRef make_host_key(Downstream *downstream) const;
|
H A D | shrpx_http2_downstream_connection.cc | 102 downstream_ = downstream; in attach_downstream() 123 if (submit_rst_stream(downstream) == 0) { in detach_downstream() 135 downstream->disable_downstream_rtimer(); in detach_downstream() 136 downstream->disable_downstream_wtimer(); in detach_downstream() 145 switch (downstream->get_response_state()) { in submit_rst_stream() 176 auto downstream = dconn->get_downstream(); in http2_data_read_callback() local 177 if (!downstream) { in http2_data_read_callback() 182 const auto &req = downstream->request(); in http2_data_read_callback() 183 auto input = downstream->get_request_buf(); in http2_data_read_callback() 197 !downstream->get_upgraded()))) { in http2_data_read_callback() [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/infra/integration-image/ |
H A D | Dockerfile.downstream | 2 # docker build --no-cache -t vic-downstream -f Dockerfile.downstream . 3 # docker tag vic-downstream gcr.io/eminent-nation-87317/vic-downstream-trigger:1.x 5 # gcloud docker -- push gcr.io/eminent-nation-87317/vic-downstream-trigger:1.x 7 # docker tag vic-downstream wdc-harbor-ci.eng.vmware.com/default-project/vic-downstream-trigger:1.x 8 # docker push wdc-harbor-ci.eng.vmware.com/default-project/vic-downstream-trigger:1.x
|
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/util/stream/ |
H A D | Collectors.java | 354 return new CollectorImpl<>(downstream.supplier(), 356 downstream.combiner(), downstream.finisher(), 357 downstream.characteristics()); 390 return new CollectorImpl<>(downstream.supplier(), 391 downstream.accumulator(), 392 downstream.combiner(), 904 Supplier<A> downstreamSupplier = downstream.supplier(); 1055 Supplier<A> downstreamSupplier = downstream.supplier(); 1140 BinaryOperator<A> op = downstream.combiner(); 1145 new Partition<>(downstream.supplier().get(), [all …]
|
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/util/stream/ |
H A D | Collectors.java | 354 return new CollectorImpl<>(downstream.supplier(), 356 downstream.combiner(), downstream.finisher(), 357 downstream.characteristics()); 390 return new CollectorImpl<>(downstream.supplier(), 391 downstream.accumulator(), 392 downstream.combiner(), 904 Supplier<A> downstreamSupplier = downstream.supplier(); 1055 Supplier<A> downstreamSupplier = downstream.supplier(); 1140 BinaryOperator<A> op = downstream.combiner(); 1145 new Partition<>(downstream.supplier().get(), [all …]
|
/dports/net/mpich/mpich-3.4.3/src/pm/hydra2/mpiexec/ |
H A D | mpiexec.c | 855 &pg->downstream.fd_stdin, &pg->downstream.fd_stdout_hash, in main() 856 &pg->downstream.fd_stderr_hash, &pg->downstream.fd_control_hash, in main() 857 &pg->downstream.proxy_id, &pg->downstream.pid, mpiexec_params.debug, in main() 875 pg->downstream.kvcache[i] = NULL; in main() 876 pg->downstream.kvcache_size[i] = 0; in main() 938 waitpid(pg->downstream.pid[i], &ret, 0); in main() 1034 MPL_free(pg->downstream.proxy_id); in main() 1035 MPL_free(pg->downstream.pid); in main() 1043 MPL_free(pg->downstream.kvcache[i]); in main() 1044 MPL_free(pg->downstream.kvcache); in main() [all …]
|
/dports/devel/git-p4/git-2.34.1/t/ |
H A D | t5150-request-pull.sh | 130 rm -fr downstream.git && 131 git init --bare downstream.git && 146 rm -fr downstream.git && 147 git init --bare downstream.git && 173 rm -fr downstream.git && 174 git init --bare downstream.git && 195 rm -fr downstream.git && 196 git init --bare downstream.git && 258 rm -fr downstream.git && 276 rm -fr downstream.git && [all …]
|
/dports/devel/git-svn/git-2.34.1/t/ |
H A D | t5150-request-pull.sh | 130 rm -fr downstream.git && 131 git init --bare downstream.git && 146 rm -fr downstream.git && 147 git init --bare downstream.git && 173 rm -fr downstream.git && 174 git init --bare downstream.git && 195 rm -fr downstream.git && 196 git init --bare downstream.git && 258 rm -fr downstream.git && 276 rm -fr downstream.git && [all …]
|
/dports/devel/git/git-2.34.1/t/ |
H A D | t5150-request-pull.sh | 130 rm -fr downstream.git && 131 git init --bare downstream.git && 146 rm -fr downstream.git && 147 git init --bare downstream.git && 173 rm -fr downstream.git && 174 git init --bare downstream.git && 195 rm -fr downstream.git && 196 git init --bare downstream.git && 258 rm -fr downstream.git && 276 rm -fr downstream.git && [all …]
|
/dports/devel/git-gui/git-2.34.1/t/ |
H A D | t5150-request-pull.sh | 130 rm -fr downstream.git && 131 git init --bare downstream.git && 146 rm -fr downstream.git && 147 git init --bare downstream.git && 173 rm -fr downstream.git && 174 git init --bare downstream.git && 195 rm -fr downstream.git && 196 git init --bare downstream.git && 258 rm -fr downstream.git && 276 rm -fr downstream.git && [all …]
|
/dports/devel/git-cvs/git-2.34.1/t/ |
H A D | t5150-request-pull.sh | 130 rm -fr downstream.git && 131 git init --bare downstream.git && 146 rm -fr downstream.git && 147 git init --bare downstream.git && 173 rm -fr downstream.git && 174 git init --bare downstream.git && 195 rm -fr downstream.git && 196 git init --bare downstream.git && 258 rm -fr downstream.git && 276 rm -fr downstream.git && [all …]
|