| /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_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 …]
|
| H A D | shrpx_http_downstream_connection.cc | 64 auto &resp = downstream->response(); in timeoutcb()
83 downstream->add_retry(); in retry_downstream_connection()
85 if (downstream->no_more_retry()) { in retry_downstream_connection()
159 backend_retry(downstream); in readcb()
179 backend_retry(downstream); in writecb()
195 backend_retry(downstream); in connectcb()
242 downstream_ = downstream; in attach_downstream()
984 if (downstream->get_upgraded()) { in htp_hdrs_completecb()
1056 DLOG(INFO, downstream) in ensure_max_header_fields()
1147 downstream->reset_response(); in htp_msg_completecb()
[all …]
|
| H A D | shrpx_upstream.h | 45 virtual int on_timeout(Downstream *downstream) { return 0; }; in on_timeout() argument
46 virtual int on_downstream_abort_request(Downstream *downstream,
51 on_downstream_abort_request_with_https_redirect(Downstream *downstream) = 0;
58 virtual int on_downstream_header_complete(Downstream *downstream) = 0;
59 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
61 virtual int on_downstream_body_complete(Downstream *downstream) = 0;
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstream, const uint8_t *body,
94 on_downstream_push_promise(Downstream *downstream,
[all …]
|
| 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/www/libnghttp2/nghttp2-1.46.0/src/ |
| 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 …]
|
| H A D | shrpx_http_downstream_connection.cc | 66 auto &resp = downstream->response(); in timeoutcb()
85 downstream->add_retry(); in retry_downstream_connection()
87 if (downstream->no_more_retry()) { in retry_downstream_connection()
161 backend_retry(downstream); in readcb()
181 backend_retry(downstream); in writecb()
197 backend_retry(downstream); in connectcb()
244 downstream_ = downstream; in attach_downstream()
988 if (downstream->get_upgraded()) { in htp_hdrs_completecb()
1060 DLOG(INFO, downstream) in ensure_max_header_fields()
1151 downstream->reset_response(); in htp_msg_completecb()
[all …]
|
| H A D | shrpx_upstream.h | 45 virtual int on_timeout(Downstream *downstream) { return 0; }; in on_timeout() argument
46 virtual int on_downstream_abort_request(Downstream *downstream,
51 on_downstream_abort_request_with_https_redirect(Downstream *downstream) = 0;
58 virtual int on_downstream_header_complete(Downstream *downstream) = 0;
59 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
61 virtual int on_downstream_body_complete(Downstream *downstream) = 0;
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstream, const uint8_t *body,
94 on_downstream_push_promise(Downstream *downstream,
[all …]
|
| 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/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/src/ |
| 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 …]
|
| H A D | shrpx_http_downstream_connection.cc | 64 auto &resp = downstream->response(); in timeoutcb()
83 downstream->add_retry(); in retry_downstream_connection()
85 if (downstream->no_more_retry()) { in retry_downstream_connection()
159 backend_retry(downstream); in readcb()
179 backend_retry(downstream); in writecb()
195 backend_retry(downstream); in connectcb()
242 downstream_ = downstream; in attach_downstream()
984 if (downstream->get_upgraded()) { in htp_hdrs_completecb()
1056 DLOG(INFO, downstream) in ensure_max_header_fields()
1147 downstream->reset_response(); in htp_msg_completecb()
[all …]
|
| H A D | shrpx_upstream.h | 45 virtual int on_timeout(Downstream *downstream) { return 0; }; in on_timeout() argument
46 virtual int on_downstream_abort_request(Downstream *downstream,
51 on_downstream_abort_request_with_https_redirect(Downstream *downstream) = 0;
58 virtual int on_downstream_header_complete(Downstream *downstream) = 0;
59 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
61 virtual int on_downstream_body_complete(Downstream *downstream) = 0;
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstream, const uint8_t *body,
94 on_downstream_push_promise(Downstream *downstream,
[all …]
|
| 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/www/nghttp2/nghttp2-1.46.0/src/ |
| 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 …]
|
| H A D | shrpx_http_downstream_connection.cc | 66 auto &resp = downstream->response(); in timeoutcb()
85 downstream->add_retry(); in retry_downstream_connection()
87 if (downstream->no_more_retry()) { in retry_downstream_connection()
161 backend_retry(downstream); in readcb()
181 backend_retry(downstream); in writecb()
197 backend_retry(downstream); in connectcb()
244 downstream_ = downstream; in attach_downstream()
988 if (downstream->get_upgraded()) { in htp_hdrs_completecb()
1060 DLOG(INFO, downstream) in ensure_max_header_fields()
1151 downstream->reset_response(); in htp_msg_completecb()
[all …]
|
| H A D | shrpx_upstream.h | 45 virtual int on_timeout(Downstream *downstream) { return 0; }; in on_timeout() argument
46 virtual int on_downstream_abort_request(Downstream *downstream,
51 on_downstream_abort_request_with_https_redirect(Downstream *downstream) = 0;
58 virtual int on_downstream_header_complete(Downstream *downstream) = 0;
59 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
61 virtual int on_downstream_body_complete(Downstream *downstream) = 0;
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstream, const uint8_t *body,
94 on_downstream_push_promise(Downstream *downstream,
[all …]
|
| /dports/comms/py-fritzconnection/fritzconnection-1.7.2/fritzconnection/lib/ |
| H A D | fritzstatus.py | 154 downstream = status["NewByteReceiveRate"]
155 return upstream, downstream
190 return upstream, downstream
197 upstream, downstream = self.max_bit_rate
198 return upstream / 8.0, downstream / 8.0
210 format_rate(downstream, unit="bits"),
220 upstream, downstream = self.max_bit_rate
260 return upstream, downstream
268 upstream, downstream = self.noise_margin
280 return upstream, downstream
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/pm/hydra2/mpiexec/ |
| H A D | mpiexec_pmi.c | 28 kvcache_num_blocks += pg->downstream.kvcache_num_blocks[i]; in mpiexec_pmi_barrier()
29 kvcache_size += pg->downstream.kvcache_size[i]; in mpiexec_pmi_barrier()
33 HASH_ITER(hh, pg->downstream.fd_control_hash, hash, thash) { in mpiexec_pmi_barrier()
47 if (pg->downstream.kvcache_num_blocks[i]) { in mpiexec_pmi_barrier()
49 HYD_sock_write(hash->key, pg->downstream.kvcache[i], in mpiexec_pmi_barrier()
58 if (pg->downstream.kvcache_num_blocks[i]) { in mpiexec_pmi_barrier()
63 pg->downstream.kvcache_size[i] - in mpiexec_pmi_barrier()
81 pg->downstream.kvcache_num_blocks[i] = 0; in mpiexec_pmi_barrier()
82 pg->downstream.kvcache_size[i] = 0; in mpiexec_pmi_barrier()
83 MPL_free(pg->downstream.kvcache[i]); in mpiexec_pmi_barrier()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/pm/hydra/pm/pmiserv/ |
| H A D | pmip.c | 35 HYD_pmcd_pmip.downstream.out = NULL; in init_params()
36 HYD_pmcd_pmip.downstream.err = NULL; in init_params()
37 HYD_pmcd_pmip.downstream.in = HYD_FD_UNSET; in init_params()
38 HYD_pmcd_pmip.downstream.pid = NULL; in init_params()
39 HYD_pmcd_pmip.downstream.exit_status = NULL; in init_params()
40 HYD_pmcd_pmip.downstream.pmi_rank = NULL; in init_params()
41 HYD_pmcd_pmip.downstream.pmi_fd = NULL; in init_params()
74 MPL_free(HYD_pmcd_pmip.downstream.out); in cleanup_params()
75 MPL_free(HYD_pmcd_pmip.downstream.err); in cleanup_params()
76 MPL_free(HYD_pmcd_pmip.downstream.pid); in cleanup_params()
[all …]
|
| /dports/sysutils/ansible/ansible-4.7.0/ansible_collections/dellemc/os10/roles/os10_uplink/templates/ |
| H A D | os10_uplink.j2 | 14 - type: "downstream"
17 downstream:
28 - type: "downstream"
31 downstream:
52 {% if uplink_val.downstream is defined and uplink_val.downstream %}
55 downstream auto-recover
57 no downstream auto-recover
62 downstream disable-links {{ uplink_val.downstream.disable_links }}
64 no downstream disable-links
74 no downstream {{ uplink.intf }}
[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_http_downstream_connection.cc | 66 auto &resp = downstream->response(); in timeoutcb()
85 downstream->add_retry(); in retry_downstream_connection()
87 if (downstream->no_more_retry()) { in retry_downstream_connection()
161 backend_retry(downstream); in readcb()
181 backend_retry(downstream); in writecb()
197 backend_retry(downstream); in connectcb()
244 downstream_ = downstream; in attach_downstream()
988 if (downstream->get_upgraded()) { in htp_hdrs_completecb()
1060 DLOG(INFO, downstream) in ensure_max_header_fields()
1151 downstream->reset_response(); in htp_msg_completecb()
[all …]
|
| H A D | shrpx_upstream.h | 45 virtual int on_timeout(Downstream *downstream) { return 0; }; in on_timeout() argument
46 virtual int on_downstream_abort_request(Downstream *downstream,
51 on_downstream_abort_request_with_https_redirect(Downstream *downstream) = 0;
58 virtual int on_downstream_header_complete(Downstream *downstream) = 0;
59 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
61 virtual int on_downstream_body_complete(Downstream *downstream) = 0;
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstream, const uint8_t *body,
94 on_downstream_push_promise(Downstream *downstream,
[all …]
|
| 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/net/proby/proby-1.0.2/cargo-crates/libnghttp2-sys-0.1.4+1.41.0/nghttp2/src/ |
| H A D | shrpx_http_downstream_connection.cc | 64 auto &resp = downstream->response(); in timeoutcb()
83 downstream->add_retry(); in retry_downstream_connection()
85 if (downstream->no_more_retry()) { in retry_downstream_connection()
159 backend_retry(downstream); in readcb()
179 backend_retry(downstream); in writecb()
195 backend_retry(downstream); in connectcb()
242 downstream_ = downstream; in attach_downstream()
984 if (downstream->get_upgraded()) { in htp_hdrs_completecb()
1056 DLOG(INFO, downstream) in ensure_max_header_fields()
1147 downstream->reset_response(); in htp_msg_completecb()
[all …]
|
| H A D | shrpx_upstream.h | 45 virtual int on_timeout(Downstream *downstream) { return 0; }; in on_timeout() argument
46 virtual int on_downstream_abort_request(Downstream *downstream,
51 on_downstream_abort_request_with_https_redirect(Downstream *downstream) = 0;
58 virtual int on_downstream_header_complete(Downstream *downstream) = 0;
59 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
61 virtual int on_downstream_body_complete(Downstream *downstream) = 0;
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstream, const uint8_t *body,
94 on_downstream_push_promise(Downstream *downstream,
[all …]
|
| 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 …]
|