/dports/www/nghttp2/nghttp2-1.46.0/src/ |
H A D | shrpx_https_upstream.h | 51 virtual int on_downstream_abort_request(Downstream *downstream, 54 on_downstream_abort_request_with_https_redirect(Downstream *downstream); 62 void attach_downstream(std::unique_ptr<Downstream> downstream); 69 virtual int resume_read(IOCtrlReason reason, Downstream *downstream, 72 virtual int on_downstream_header_complete(Downstream *downstream); 75 virtual int on_downstream_body_complete(Downstream *downstream); 78 virtual int on_downstream_reset(Downstream *downstream, bool no_retry); 79 virtual int send_reply(Downstream *downstream, const uint8_t *body, 86 virtual Downstream *on_downstream_push_promise(Downstream *downstream, 89 on_downstream_push_promise_complete(Downstream *downstream, [all …]
|
/dports/graphics/jogamp-jogl/jogl/src/newt/classes/com/jogamp/newt/event/ |
H A D | TraceKeyAdapter.java | 33 KeyListener downstream; field in TraceKeyAdapter 36 this.downstream = null; in TraceKeyAdapter() 39 public TraceKeyAdapter(final KeyListener downstream) { in TraceKeyAdapter() argument 40 this.downstream = downstream; in TraceKeyAdapter() 46 if(null!=downstream) { downstream.keyPressed(e); } in keyPressed() 51 if(null!=downstream) { downstream.keyReleased(e); } in keyReleased()
|
/dports/www/osrm-backend/osrm-backend-5.26.0/features/testbot/ |
H A D | mode.feature | 7 # 3 river downstream 63 | a | 0 | ab,ab | river downstream,river downstream | 64 | a | b | ab,ab | river downstream,river downstream | 65 | 0 | 1 | ab,ab | river downstream,river downstream | 66 | 0 | b | ab,ab | river downstream,river downstream | 101 | a | b | ab,ab | river downstream,river downstream | 165 … | a,1,b | ab,ab,ab,ab | river downstream,river downstream,river downstream,river downstream | 197 | a | c | Avenue,Avenue,Avenue | driving,river downstream,river downstream | 199 | 1 | 2 | Avenue,Avenue,Avenue | driving,river downstream,river downstream | 252 | 0 | 3 | abc,ce,ce | driving,river downstream,river downstream | [all …]
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/kubernetes/ |
H A D | Makefile | 30 downstream-test-sanity: 31 ./utils/downstream.sh -s 33 downstream-test-integration: 34 ./utils/downstream.sh -i 36 downstream-test-molecule: 37 ./utils/downstream.sh -m 39 downstream-build: 40 ./utils/downstream.sh -b 42 downstream-release: 43 ./utils/downstream.sh -r
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/kubernetes/core/ |
H A D | Makefile | 30 downstream-test-sanity: 31 ./utils/downstream.sh -s 33 downstream-test-integration: 34 ./utils/downstream.sh -i 36 downstream-test-molecule: 37 ./utils/downstream.sh -m 39 downstream-build: 40 ./utils/downstream.sh -b 42 downstream-release: 43 ./utils/downstream.sh -r
|
/dports/net/mpich2/mpich2-1.5/src/pm/hydra/pm/pmiserv/ |
H A D | pmip_cb.c | 40 if (HYD_pmcd_pmip.downstream.out[i] == fd) in stdio_cb() 47 if (HYD_pmcd_pmip.downstream.err[i] == fd) in stdio_cb() 55 hdr.rank = HYD_pmcd_pmip.downstream.pmi_rank[i]; in stdio_cb() 80 if (HYD_pmcd_pmip.downstream.out[i] == fd) in stdio_cb() 231 if (HYD_pmcd_pmip.downstream.pmi_fd[i] == fd) { in pmi_cb() 481 HYDU_MALLOC(HYD_pmcd_pmip.downstream.out, int *, in launch_procs() 483 HYDU_MALLOC(HYD_pmcd_pmip.downstream.err, int *, in launch_procs() 485 HYDU_MALLOC(HYD_pmcd_pmip.downstream.pid, int *, in launch_procs() 499 HYD_pmcd_pmip.downstream.exit_status[i] = -1; in launch_procs() 937 close(HYD_pmcd_pmip.downstream.in); in HYD_pmcd_pmip_control_cmd_cb() [all …]
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/example/unicast/ |
H A D | RangePublisher.java | 90 final Subscriber<? super Integer> downstream; field in RangePublisher.RangeSubscription 119 RangeSubscription(Subscriber<? super Integer> downstream, int start, int end) { in RangeSubscription() argument 120 this.downstream = downstream; in RangeSubscription() 164 Subscriber<? super Integer> downstream = this.downstream; in emit() local 179 downstream.onError(invalidRequest); in emit() 192 downstream.onNext(index); in emit() 211 downstream.onComplete(); in emit() 248 … (new IllegalStateException(downstream + " violated the Reactive Streams rule 2.13 by " + in emit()
|
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/example/unicast/ |
H A D | RangePublisher.java | 90 final Subscriber<? super Integer> downstream; field in RangePublisher.RangeSubscription 119 RangeSubscription(Subscriber<? super Integer> downstream, int start, int end) { in RangeSubscription() argument 120 this.downstream = downstream; in RangeSubscription() 164 Subscriber<? super Integer> downstream = this.downstream; in emit() local 179 downstream.onError(invalidRequest); in emit() 192 downstream.onNext(index); in emit() 211 downstream.onComplete(); in emit() 248 … (new IllegalStateException(downstream + " violated the Reactive Streams rule 2.13 by " + in emit()
|
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/example/unicast/ |
H A D | RangePublisher.java | 90 final Subscriber<? super Integer> downstream; field in RangePublisher.RangeSubscription 119 RangeSubscription(Subscriber<? super Integer> downstream, int start, int end) { in RangeSubscription() argument 120 this.downstream = downstream; in RangeSubscription() 164 Subscriber<? super Integer> downstream = this.downstream; in emit() local 179 downstream.onError(invalidRequest); in emit() 192 downstream.onNext(index); in emit() 211 downstream.onComplete(); in emit() 248 … (new IllegalStateException(downstream + " violated the Reactive Streams rule 2.13 by " + in emit()
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/example/unicast/ |
H A D | RangePublisher.java | 90 final Subscriber<? super Integer> downstream; field in RangePublisher.RangeSubscription 119 RangeSubscription(Subscriber<? super Integer> downstream, int start, int end) { in RangeSubscription() argument 120 this.downstream = downstream; in RangeSubscription() 164 Subscriber<? super Integer> downstream = this.downstream; in emit() local 179 downstream.onError(invalidRequest); in emit() 192 downstream.onNext(index); in emit() 211 downstream.onComplete(); in emit() 248 … (new IllegalStateException(downstream + " violated the Reactive Streams rule 2.13 by " + in emit()
|
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/example/unicast/ |
H A D | RangePublisher.java | 90 final Subscriber<? super Integer> downstream; field in RangePublisher.RangeSubscription 119 RangeSubscription(Subscriber<? super Integer> downstream, int start, int end) { in RangeSubscription() argument 120 this.downstream = downstream; in RangeSubscription() 164 Subscriber<? super Integer> downstream = this.downstream; in emit() local 179 downstream.onError(invalidRequest); in emit() 192 downstream.onNext(index); in emit() 211 downstream.onComplete(); in emit() 248 … (new IllegalStateException(downstream + " violated the Reactive Streams rule 2.13 by " + in emit()
|
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/example/unicast/ |
H A D | RangePublisher.java | 90 final Subscriber<? super Integer> downstream; field in RangePublisher.RangeSubscription 119 RangeSubscription(Subscriber<? super Integer> downstream, int start, int end) { in RangeSubscription() argument 120 this.downstream = downstream; in RangeSubscription() 164 Subscriber<? super Integer> downstream = this.downstream; in emit() local 179 downstream.onError(invalidRequest); in emit() 192 downstream.onNext(index); in emit() 211 downstream.onComplete(); in emit() 248 … (new IllegalStateException(downstream + " violated the Reactive Streams rule 2.13 by " + in emit()
|
/dports/www/libdatachannel/libdatachannel-0.16.1/src/ |
H A D | mediahandlerelement.cpp | 53 upstream->downstream = downstream; in removeFromChain() 55 if (downstream) { in removeFromChain() 56 downstream->upstream = upstream; in removeFromChain() 59 downstream = nullptr; in removeFromChain() 63 if (downstream) { in recursiveRemoveChain() 67 auto strongDownstreamPtr = downstream; in recursiveRemoveChain() 68 downstream->recursiveRemoveChain(); in recursiveRemoveChain() 127 if (downstream) { in formIncomingControlMessage() 144 if (downstream) { in formIncomingBinaryMessage() 213 assert(upstream->downstream == nullptr); in chainWith() [all …]
|
/dports/devel/libvirt/libvirt-7.10.0/tests/qemuxml2argvdata/ |
H A D | pcie-expander-bus.args | 34 -device xio3130-downstream,port=0,chassis=4,id=pci.4,bus=pci.3,addr=0x0 \ 35 -device xio3130-downstream,port=1,chassis=5,id=pci.5,bus=pci.3,addr=0x1 \ 36 -device xio3130-downstream,port=2,chassis=6,id=pci.6,bus=pci.3,addr=0x2 \ 37 -device xio3130-downstream,port=3,chassis=7,id=pci.7,bus=pci.3,addr=0x3 \ 38 -device xio3130-downstream,port=4,chassis=8,id=pci.8,bus=pci.3,addr=0x4 \ 39 -device xio3130-downstream,port=5,chassis=9,id=pci.9,bus=pci.3,addr=0x5 \ 40 -device xio3130-downstream,port=6,chassis=10,id=pci.10,bus=pci.3,addr=0x6 \ 41 -device xio3130-downstream,port=7,chassis=11,id=pci.11,bus=pci.3,addr=0x7 \ 42 -device xio3130-downstream,port=8,chassis=12,id=pci.12,bus=pci.3,addr=0x8 \ 43 -device xio3130-downstream,port=9,chassis=13,id=pci.13,bus=pci.3,addr=0x9 \ [all …]
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/okd/ |
H A D | Makefile | 23 test-sanity: upstream-test-sanity downstream-test-sanity 25 test-integration: upstream-test-integration downstream-test-integration 33 downstream-test-sanity: 34 ./ci/downstream.sh -s 36 downstream-test-integration: 37 ./ci/downstream.sh -i 39 downstream-build: 40 ./ci/downstream.sh -b
|
/dports/mail/lmtp2nntp/lmtp2nntp-1.4.1/lib_l2/ |
H A D | l2_ch_buffer.c | 220 l2_channel_t *downstream; in hook_write() local 226 downstream = NULL; in hook_write() 235 downstream = NULL; in hook_write() 249 downstream = NULL; in hook_write() 250 while (l2_channel_downstream(ch, &downstream) == L2_OK) in hook_write() 269 l2_channel_t *downstream; in hook_flush() local 275 downstream = NULL; in hook_flush() 276 while (l2_channel_downstream(ch, &downstream) == L2_OK) in hook_flush() 295 l2_channel_t *downstream; in hook_close() local 313 downstream = NULL; in hook_close() [all …]
|
/dports/devel/ossp-l2/l2-0.9.13/ |
H A D | l2_ch_buffer.c | 220 l2_channel_t *downstream; in hook_write() local 226 downstream = NULL; in hook_write() 235 downstream = NULL; in hook_write() 249 downstream = NULL; in hook_write() 250 while (l2_channel_downstream(ch, &downstream) == L2_OK) in hook_write() 269 l2_channel_t *downstream; in hook_flush() local 275 downstream = NULL; in hook_flush() 276 while (l2_channel_downstream(ch, &downstream) == L2_OK) in hook_flush() 295 l2_channel_t *downstream; in hook_close() local 313 downstream = NULL; in hook_close() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/pm/hydra/pm/pmiserv/ |
H A D | pmip_cb.c | 38 if (HYD_pmcd_pmip.downstream.out[i] == fd) in stdoe_cb() 44 if (HYD_pmcd_pmip.downstream.err[i] == fd) in stdoe_cb() 52 hdr.rank = HYD_pmcd_pmip.downstream.pmi_rank[i]; in stdoe_cb() 77 if (HYD_pmcd_pmip.downstream.out[i] == fd) in stdoe_cb() 81 if (HYD_pmcd_pmip.downstream.err[i] == fd) in stdoe_cb() 279 if (HYD_pmcd_pmip.downstream.pmi_fd[i] == fd) { in pmi_cb() 358 HYD_pmcd_pmip.downstream.pmi_fd_active[pid] = 1; in pmi_cb() 513 HYD_pmcd_pmip.downstream.exit_status[i] = -1; in launch_procs() 522 HYD_pmcd_pmip.downstream.pmi_fd_active[i] = 0; in launch_procs() 940 close(HYD_pmcd_pmip.downstream.in); in HYD_pmcd_pmip_control_cmd_cb() [all …]
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-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/openjdk13/jdk13u-jdk-13.0.10-1-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/openjdk11-jre/jdk11u-jdk-11.0.13-8-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 | Collectors.java | 468 return new CollectorImpl<>(downstream.supplier(), 470 downstream.combiner(), downstream.finisher(), 513 return new CollectorImpl<>(downstream.supplier(), 520 downstream.combiner(), downstream.finisher(), 521 downstream.characteristics()); 563 return new CollectorImpl<>(downstream.supplier(), 569 downstream.combiner(), downstream.finisher(), 604 return new CollectorImpl<>(downstream.supplier(), 605 downstream.accumulator(), 606 downstream.combiner(), [all …]
|
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.base/share/classes/java/util/stream/ |
H A D | Collectors.java | 468 return new CollectorImpl<>(downstream.supplier(), 470 downstream.combiner(), downstream.finisher(), 513 return new CollectorImpl<>(downstream.supplier(), 520 downstream.combiner(), downstream.finisher(), 521 downstream.characteristics()); 563 return new CollectorImpl<>(downstream.supplier(), 569 downstream.combiner(), downstream.finisher(), 604 return new CollectorImpl<>(downstream.supplier(), 605 downstream.accumulator(), 606 downstream.combiner(), [all …]
|
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/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/openjdk15/jdk15u-jdk-15.0.6-1-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 …]
|