Home
last modified time | relevance | path

Searched refs:faddr (Results 1 - 24 of 24) sorted by relevance

/third_party/nghttp2/src/
H A Dshrpx_worker.cc500 wev.client_addrlen, wev.faddr); in process_events()
543 const UpstreamAddr *faddr; in process_events() local
546 faddr = find_quic_upstream_addr(wev.quic_pkt->local_addr); in process_events()
547 if (faddr == nullptr) { in process_events()
558 faddr = &quic_upstream_addrs_[wev.quic_pkt->upstream_addr_index]; in process_events()
562 faddr, wev.quic_pkt->remote_addr, wev.quic_pkt->local_addr, in process_events()
736 int Worker::create_quic_server_socket(UpstreamAddr &faddr) { in create_quic_server_socket() argument
741 auto service = util::utos(faddr.port); in create_quic_server_socket()
743 hints.ai_family = faddr.family; in create_quic_server_socket()
751 faddr in create_quic_server_socket()
[all...]
H A Dshrpx_quic_connection_handler.cc61 int QUICConnectionHandler::handle_packet(const UpstreamAddr *faddr, in handle_packet() argument
74 send_version_negotiation(faddr, vc.version, vc.dcid, vc.dcidlen, vc.scid, in handle_packet()
99 cw->handle_packet(faddr, remote_addr, local_addr, pi, data, datalen); in handle_packet()
116 cw->handle_packet(faddr, remote_addr, local_addr, pi, data, datalen); in handle_packet()
201 send_connection_close(faddr, hd.version, hd.dcid, hd.scid, remote_addr, in handle_packet()
209 send_retry(faddr, vc.version, vc.dcid, vc.dcidlen, vc.scid, in handle_packet()
239 send_connection_close(faddr, hd.version, hd.dcid, hd.scid, in handle_packet()
271 send_retry(faddr, vc.version, vc.dcid, vc.dcidlen, vc.scid, in handle_packet()
292 send_retry(faddr, vc.version, vc.dcid, vc.dcidlen, vc.scid, in handle_packet()
314 send_retry(faddr, v in handle_packet()
367 handle_new_connection( const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_hd &hd, const ngtcp2_cid *odcid, const uint8_t *token, size_t tokenlen, ngtcp2_token_type token_type) handle_new_connection() argument
458 send_retry( const UpstreamAddr *faddr, uint32_t version, const uint8_t *ini_dcid, size_t ini_dcidlen, const uint8_t *ini_scid, size_t ini_scidlen, const Address &remote_addr, const Address &local_addr, size_t max_pktlen) send_retry() argument
537 send_version_negotiation( const UpstreamAddr *faddr, uint32_t version, const uint8_t *ini_dcid, size_t ini_dcidlen, const uint8_t *ini_scid, size_t ini_scidlen, const Address &remote_addr, const Address &local_addr) send_version_negotiation() argument
565 send_stateless_reset(const UpstreamAddr *faddr, const uint8_t *dcid, size_t dcidlen, const Address &remote_addr, const Address &local_addr) send_stateless_reset() argument
628 send_connection_close( const UpstreamAddr *faddr, uint32_t version, const ngtcp2_cid &ini_dcid, const ngtcp2_cid &ini_scid, const Address &remote_addr, const Address &local_addr, uint64_t error_code, size_t max_pktlen) send_connection_close() argument
731 handle_packet(const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen) handle_packet() argument
[all...]
H A Dshrpx_quic_connection_handler.h57 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.h90 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; member
H A Dshrpx_http3_upstream.cc568 int Http3Upstream::init(const UpstreamAddr *faddr, const Address &remote_addr, in init() argument
739 const_cast<UpstreamAddr *>(faddr), in init()
891 auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data); in write_streams() local
895 rv = send_packet(faddr, prev_ps.path.remote.addr, in write_streams()
900 on_send_blocked(faddr, prev_ps.path.remote, prev_ps.path.local, in write_streams()
903 signal_write_upstream_addr(faddr); in write_streams()
924 auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data); in write_streams() local
928 rv = send_packet(faddr, prev_ps.path.remote.addr, in write_streams()
934 on_send_blocked(faddr, prev_ps.path.remote, prev_ps.path.local, prev_pi, in write_streams()
941 signal_write_upstream_addr(faddr); in write_streams()
945 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data); write_streams() local
966 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data); write_streams() local
985 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data); write_streams() local
1783 on_read(const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen) on_read() argument
1855 send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa, size_t remote_salen, const sockaddr *local_sa, size_t local_salen, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen, size_t gso_size) send_packet() argument
1883 on_send_blocked(const UpstreamAddr *faddr, const ngtcp2_addr &remote_addr, const ngtcp2_addr &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen, size_t gso_size) on_send_blocked() argument
1933 signal_write_upstream_addr(const UpstreamAddr *faddr) signal_write_upstream_addr() argument
2248 auto faddr = handler_->get_upstream_addr(); http_end_request_headers() local
[all...]
H A Dshrpx.cc724 int create_unix_domain_server_socket(UpstreamAddr &faddr, in create_unix_domain_server_socket() argument
728 std::begin(iaddrs), std::end(iaddrs), [&faddr](const InheritedAddr &ia) { in create_unix_domain_server_socket()
729 return !ia.used && ia.host_unix && ia.host == faddr.host; in create_unix_domain_server_socket()
733 LOG(NOTICE) << "Listening on UNIX domain socket " << faddr.host in create_unix_domain_server_socket()
734 << (faddr.tls ? ", tls" : ""); in create_unix_domain_server_socket()
736 faddr.fd = (*found).fd; in create_unix_domain_server_socket()
737 faddr.hostport = StringRef::from_lit("localhost"); in create_unix_domain_server_socket()
772 if (faddr.host.size() + 1 > sizeof(addr.un.sun_path)) { in create_unix_domain_server_socket()
773 LOG(FATAL) << "UNIX domain socket path " << faddr.host << " is too long > " in create_unix_domain_server_socket()
779 std::copy_n(faddr in create_unix_domain_server_socket()
813 create_tcp_server_socket(UpstreamAddr &faddr, std::vector<InheritedAddr> &iaddrs) create_tcp_server_socket() argument
[all...]
H A Dshrpx_accept_handler.cc49 AcceptHandler::AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h) in AcceptHandler() argument
50 : conn_hnr_(h), faddr_(faddr) { in AcceptHandler()
H A Dshrpx_mruby_module_env.cc103 auto faddr = handler->get_upstream_addr(); in env_get_server_port() local
105 return mrb_fixnum_value(faddr->port); in env_get_server_port()
115 auto faddr = handler->get_upstream_addr(); in env_get_server_addr() local
117 return mrb_str_new(mrb, faddr->host.c_str(), faddr->host.size()); in env_get_server_addr()
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,
H A Dshrpx_quic_listener.cc39 QUICListener::QUICListener(const UpstreamAddr *faddr, Worker *worker) in QUICListener() argument
40 : faddr_{faddr}, worker_{worker} { in QUICListener()
H A Dshrpx_connection_handler.cc474 const UpstreamAddr *faddr) { in handle_connection()
497 tls::accept_connection(single_worker_.get(), fd, addr, addrlen, faddr); in handle_connection()
510 if (faddr->alt_mode == UpstreamAltMode::API) { in handle_connection()
539 wev.faddr = faddr; in handle_connection()
1021 const UpstreamAddr *faddr, const Address &remote_addr, in forward_quic_packet()
1034 wev.quic_pkt = std::make_unique<QUICPacket>(faddr->index, remote_addr, in forward_quic_packet()
1270 auto faddr = single_worker_->find_quic_upstream_addr(pkt->local_addr); in quic_ipc_read() local
1271 if (faddr == nullptr) { in quic_ipc_read()
1280 quic_conn_handler->handle_packet(faddr, pk in quic_ipc_read()
473 handle_connection(int fd, sockaddr *addr, int addrlen, const UpstreamAddr *faddr) handle_connection() argument
1020 forward_quic_packet( const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *cid_prefix, const uint8_t *data, size_t datalen) forward_quic_packet() argument
[all...]
H A Dshrpx_quic_listener.h39 QUICListener(const UpstreamAddr *faddr, Worker *worker);
H A Dshrpx_accept_handler.h39 AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h);
H A Dshrpx_connection_handler.h140 const UpstreamAddr *faddr);
198 int forward_quic_packet(const UpstreamAddr *faddr, const Address &remote_addr,
H A Dshrpx_http2_upstream.cc362 auto faddr = handler_->get_upstream_addr(); in on_request_headers() local
366 faddr->alt_mode == UpstreamAltMode::NONE && !authority) { in on_request_headers()
391 faddr->alt_mode == UpstreamAltMode::NONE) { in on_request_headers()
1035 auto faddr = handler_->get_upstream_addr(); in Http2Upstream() local
1039 faddr->alt_mode != UpstreamAltMode::NONE in Http2Upstream()
1055 if (faddr->alt_mode != UpstreamAltMode::NONE) { in Http2Upstream()
1084 auto window_size = faddr->alt_mode != UpstreamAltMode::NONE in Http2Upstream()
1199 auto faddr = handler_->get_upstream_addr(); in on_write() local
1200 if (faddr->alt_mode == UpstreamAltMode::NONE) { in on_write()
2009 auto faddr in consume() local
[all...]
H A Dshrpx_client_handler.cc322 int ClientHandler::read_quic(const UpstreamAddr *faddr, in read_quic() argument
329 return upstream->on_read(faddr, remote_addr, local_addr, pi, data, datalen); in read_quic()
435 int family, const UpstreamAddr *faddr) in ClientHandler()
452 faddr->quic ? Proto::HTTP3 : Proto::NONE), in ClientHandler()
455 faddr_(faddr), in ClientHandler()
468 if (!faddr->quic) { in ClientHandler()
475 if (!faddr->quic) { in ClientHandler()
433 ClientHandler(Worker *worker, int fd, SSL *ssl, const StringRef &ipaddr, const StringRef &port, int family, const UpstreamAddr *faddr) ClientHandler() argument
H A Dshrpx_quic.h83 int quic_send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa,
H A Dshrpx_quic.cc58 int quic_send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa, in quic_send_packet() argument
153 nwrite = sendmsg(faddr->fd, &msg, 0); in quic_send_packet()
H A Dshrpx_tls.h116 int addrlen, const UpstreamAddr *faddr);
H A Dshrpx_worker.h299 const UpstreamAddr *faddr; member
H A Dshrpx_https_upstream.cc432 auto faddr = handler->get_upstream_addr(); in htp_hdrs_completecb() local
489 faddr->alt_mode == UpstreamAltMode::NONE) { in htp_hdrs_completecb()
543 if (faddr->alt_mode != UpstreamAltMode::NONE) { in htp_hdrs_completecb()
H A Dshrpx_tls.cc1694 int addrlen, const UpstreamAddr *faddr) { in accept_connection()
1717 if (faddr->tls) { in accept_connection()
1734 StringRef{service.data()}, addr->sa_family, faddr); in accept_connection()
2247 [](const UpstreamAddr &faddr) { return faddr.tls; }); in upstream_tls_enabled()
1693 accept_connection(Worker *worker, int fd, sockaddr *addr, int addrlen, const UpstreamAddr *faddr) accept_connection() argument
H A Dshrpx_downstream.cc634 auto faddr = handler->get_upstream_addr(); in request_buf_full() local
638 if (faddr->alt_mode == UpstreamAltMode::API) { in request_buf_full()
/third_party/toybox/toys/pending/
H A Dmke2fs.c197 uint32_t faddr; // Last block in file member
538 // in->faddr in fill_inode()

Completed in 33 milliseconds