Home
last modified time | relevance | path

Searched refs:downstream (Results 126 – 150 of 11886) sorted by relevance

12345678910>>...476

/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.base/share/classes/java/util/stream/
H A DCollectors.java460 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 DReferencePipeline.java173 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 DReferencePipeline.java173 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 Dshrpx_downstream_queue.h47 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 Dshrpx_http2_downstream_connection.cc102 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 Dshrpx_downstream_queue.h47 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 Dshrpx_http2_downstream_connection.cc102 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 Dshrpx_downstream_queue.h47 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 Dshrpx_http2_downstream_connection.cc102 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 Dshrpx_downstream_queue.h47 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 Dshrpx_http2_downstream_connection.cc102 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 Dshrpx_downstream_queue.h47 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 Dshrpx_http2_downstream_connection.cc102 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 Dterminal_test.go17 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 Dshrpx_downstream_queue.h47 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 Dshrpx_http2_downstream_connection.cc102 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 DDockerfile.downstream2 # 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 DCollectors.java354 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 DCollectors.java354 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 Dmpiexec.c855 &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 Dt5150-request-pull.sh130 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 Dt5150-request-pull.sh130 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 Dt5150-request-pull.sh130 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 Dt5150-request-pull.sh130 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 Dt5150-request-pull.sh130 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 …]

12345678910>>...476