Home
last modified time | relevance | path

Searched refs:UpstreamAddr (Results 1 - 21 of 21) sorted by relevance

/third_party/nghttp2/src/
H A Dshrpx_quic_connection_handler.h46 struct UpstreamAddr;
57 int handle_packet(const UpstreamAddr *faddr, const Address &remote_addr,
84 int handle_packet(const UpstreamAddr *faddr, const Address &remote_addr,
91 int send_retry(const UpstreamAddr *faddr, uint32_t version,
101 int send_version_negotiation(const UpstreamAddr *faddr, uint32_t version,
106 int send_stateless_reset(const UpstreamAddr *faddr, const uint8_t *dcid,
113 int send_connection_close(const UpstreamAddr *faddr, uint32_t version,
120 handle_new_connection(const UpstreamAddr *faddr, const Address &remote_addr,
H A Dshrpx_http3_upstream.h42 struct UpstreamAddr;
90 int init(const UpstreamAddr *faddr, const Address &remote_addr,
95 int on_read(const UpstreamAddr *faddr, const Address &remote_addr,
141 int send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa,
149 void on_send_blocked(const UpstreamAddr *faddr,
154 void signal_write_upstream_addr(const UpstreamAddr *faddr);
180 const UpstreamAddr *faddr;
H A Dshrpx_quic_listener.h34 struct UpstreamAddr;
39 QUICListener(const UpstreamAddr *faddr, Worker *worker);
44 const UpstreamAddr *faddr_;
H A Dshrpx_accept_handler.h35 struct UpstreamAddr;
39 AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h);
49 const UpstreamAddr *faddr_;
H A Dshrpx_client_handler.h64 const StringRef &port, int family, const UpstreamAddr *faddr);
154 int read_quic(const UpstreamAddr *faddr, const Address &remote_addr,
180 const UpstreamAddr *get_upstream_addr() const;
223 const UpstreamAddr *faddr_;
H A Dshrpx_worker.h66 struct UpstreamAddr;
299 const UpstreamAddr *faddr;
390 int create_quic_server_socket(UpstreamAddr &addr);
392 // Returns a pointer to UpstreamAddr which matches |local_addr|.
393 const UpstreamAddr *find_quic_upstream_addr(const Address &local_addr);
418 std::vector<UpstreamAddr> quic_upstream_addrs_;
H A Dshrpx_connection_handler.h68 struct UpstreamAddr;
140 const UpstreamAddr *faddr);
198 int forward_quic_packet(const UpstreamAddr *faddr, const Address &remote_addr,
H A Dshrpx_quic.h62 struct UpstreamAddr;
83 int quic_send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa,
H A Dshrpx_quic_connection_handler.cc61 int QUICConnectionHandler::handle_packet(const UpstreamAddr *faddr, in handle_packet()
368 const UpstreamAddr *faddr, const Address &remote_addr, in handle_new_connection()
459 const UpstreamAddr *faddr, uint32_t version, const uint8_t *ini_dcid, in send_retry()
538 const UpstreamAddr *faddr, uint32_t version, const uint8_t *ini_dcid, in send_version_negotiation()
565 int QUICConnectionHandler::send_stateless_reset(const UpstreamAddr *faddr, in send_stateless_reset()
629 const UpstreamAddr *faddr, uint32_t version, const ngtcp2_cid &ini_dcid, in send_connection_close()
731 int CloseWait::handle_packet(const UpstreamAddr *faddr, in handle_packet()
H A Dshrpx_http3_upstream.cc568 int Http3Upstream::init(const UpstreamAddr *faddr, const Address &remote_addr, in init()
739 const_cast<UpstreamAddr *>(faddr), in init()
891 auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data); in write_streams()
924 auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data); in write_streams()
937 on_send_blocked(static_cast<UpstreamAddr *>(ps.path.user_data), in write_streams()
945 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data); in write_streams()
966 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data); in write_streams()
985 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data); in write_streams()
1565 send_packet(static_cast<UpstreamAddr *>(ps.path.user_data), in on_handler_delete()
1783 int Http3Upstream::on_read(const UpstreamAddr *fadd
[all...]
H A Dshrpx_tls.h52 struct UpstreamAddr;
116 int addrlen, const UpstreamAddr *faddr);
H A Dshrpx_accept_handler.cc49 AcceptHandler::AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h) in AcceptHandler()
H A Dshrpx_quic_listener.cc39 QUICListener::QUICListener(const UpstreamAddr *faddr, Worker *worker) in QUICListener()
H A Dshrpx_worker.cc543 const UpstreamAddr *faddr; in process_events()
736 int Worker::create_quic_server_socket(UpstreamAddr &faddr) { in create_quic_server_socket()
1082 const UpstreamAddr *Worker::find_quic_upstream_addr(const Address &local_addr) { in find_quic_upstream_addr()
1113 const UpstreamAddr *fallback_faddr = nullptr; in find_quic_upstream_addr()
H A Dshrpx_config.h494 struct UpstreamAddr { struct
1030 std::vector<UpstreamAddr> addrs;
1039 std::vector<UpstreamAddr> addrs;
1056 // Deprecated. See UpstreamAddr.accept_proxy_protocol.
1066 // true if at least one of UpstreamAddr has api enabled
H A Dshrpx_client_handler.cc322 int ClientHandler::read_quic(const UpstreamAddr *faddr, in read_quic()
435 int family, const UpstreamAddr *faddr) in ClientHandler()
1689 const UpstreamAddr *ClientHandler::get_upstream_addr() const { return faddr_; } in get_upstream_addr()
H A Dshrpx_quic.cc58 int quic_send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa, in quic_send_packet()
H A Dshrpx_connection_handler.cc474 const UpstreamAddr *faddr) { in handle_connection()
1021 const UpstreamAddr *faddr, const Address &remote_addr, in forward_quic_packet()
1252 // At the moment, UpstreamAddr index is unknown. in quic_ipc_read()
H A Dshrpx.cc724 int create_unix_domain_server_socket(UpstreamAddr &faddr, in create_unix_domain_server_socket()
813 int create_tcp_server_socket(UpstreamAddr &faddr, in create_tcp_server_socket()
3783 UpstreamAddr addr{}; in process_options()
H A Dshrpx_tls.cc1694 int addrlen, const UpstreamAddr *faddr) { in accept_connection()
2247 [](const UpstreamAddr &faddr) { return faddr.tls; }); in upstream_tls_enabled()
H A Dshrpx_config.cc2890 UpstreamAddr addr{}; in parse_config()

Completed in 49 milliseconds