Home
last modified time | relevance | path

Searched refs:downstream (Results 101 – 125 of 10478) sorted by relevance

12345678910>>...420

/dports/www/nghttp2/nghttp2-1.46.0/src/
H A Dshrpx_https_upstream.h51 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 DTraceKeyAdapter.java33 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 Dmode.feature7 # 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 DMakefile30 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 DMakefile30 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 Dpmip_cb.c40 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 DRangePublisher.java90 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 DRangePublisher.java90 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 DRangePublisher.java90 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 DRangePublisher.java90 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 DRangePublisher.java90 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 DRangePublisher.java90 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 Dmediahandlerelement.cpp53 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 Dpcie-expander-bus.args34 -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 DMakefile23 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 Dl2_ch_buffer.c220 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 Dl2_ch_buffer.c220 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 Dpmip_cb.c38 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 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/openjdk13/jdk13u-jdk-13.0.10-1-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/openjdk11-jre/jdk11u-jdk-11.0.13-8-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 DCollectors.java468 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 DCollectors.java468 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 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/openjdk15/jdk15u-jdk-15.0.6-1-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 …]

12345678910>>...420