| /third_party/nghttp2/src/ |
| D | shrpx_quic_connection_handler.cc | 61 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()
200 send_connection_close(faddr, hd.version, hd.dcid, hd.scid, remote_addr, in handle_packet()
208 send_retry(faddr, vc.version, vc.dcid, vc.dcidlen, vc.scid, in handle_packet()
238 send_connection_close(faddr, hd.version, hd.dcid, hd.scid, in handle_packet()
269 send_retry(faddr, vc.version, vc.dcid, vc.dcidlen, vc.scid, in handle_packet()
290 send_retry(faddr, vc.version, vc.dcid, vc.dcidlen, vc.scid, in handle_packet()
311 send_retry(faddr, vc.version, vc.dcid, vc.dcidlen, vc.scid, in handle_packet()
[all …]
|
| D | shrpx_quic_connection_handler.h | 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,
119 ClientHandler *handle_new_connection(const UpstreamAddr *faddr,
|
| D | shrpx_worker.cc | 500 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.host == StringRef::from_lit("*") ? nullptr : faddr.host.c_str(); in create_quic_server_socket()
[all …]
|
| D | shrpx_http3_upstream.h | 90 int init(const UpstreamAddr *faddr, const Address &remote_addr,
94 int on_read(const UpstreamAddr *faddr, const Address &remote_addr,
139 int send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa,
147 void on_send_blocked(const UpstreamAddr *faddr,
152 void signal_write_upstream_addr(const UpstreamAddr *faddr);
178 const UpstreamAddr *faddr; member
|
| D | shrpx_http3_upstream.cc | 550 int Http3Upstream::init(const UpstreamAddr *faddr, const Address &remote_addr, in init() argument
720 const_cast<UpstreamAddr *>(faddr), in init()
872 auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data); in write_streams() local
876 rv = send_packet(faddr, prev_ps.path.remote.addr, in write_streams()
881 on_send_blocked(faddr, prev_ps.path.remote, prev_ps.path.local, in write_streams()
884 signal_write_upstream_addr(faddr); in write_streams()
905 auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data); in write_streams() local
909 rv = send_packet(faddr, prev_ps.path.remote.addr, in write_streams()
915 on_send_blocked(faddr, prev_ps.path.remote, prev_ps.path.local, prev_pi, in write_streams()
922 signal_write_upstream_addr(faddr); in write_streams()
[all …]
|
| D | shrpx.cc | 724 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.host.c_str(), faddr.host.size() + 1, addr.un.sun_path); in create_unix_domain_server_socket()
[all …]
|
| D | shrpx_accept_handler.cc | 49 AcceptHandler::AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h) in AcceptHandler() argument
50 : conn_hnr_(h), faddr_(faddr) { in AcceptHandler()
|
| D | shrpx_connection_handler.cc | 474 const UpstreamAddr *faddr) { in handle_connection() argument
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() argument
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, pkt->remote_addr, pkt->local_addr, in quic_ipc_read()
|
| D | shrpx_quic_listener.cc | 39 QUICListener::QUICListener(const UpstreamAddr *faddr, Worker *worker) in QUICListener() argument
40 : faddr_{faddr}, worker_{worker} { in QUICListener()
|
| D | shrpx_mruby_module_env.cc | 103 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()
|
| D | shrpx_client_handler.h | 64 const StringRef &port, int family, const UpstreamAddr *faddr);
154 int read_quic(const UpstreamAddr *faddr, const Address &remote_addr,
|
| D | shrpx_quic.cc | 58 int quic_send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa, in quic_send_packet() argument
126 util::fd_set_send_ecn(faddr->fd, local_sa->sa_family, pi.ecn); in quic_send_packet()
131 nwrite = sendmsg(faddr->fd, &msg, 0); in quic_send_packet()
|
| D | shrpx_quic_listener.h | 39 QUICListener(const UpstreamAddr *faddr, Worker *worker);
|
| D | shrpx_accept_handler.h | 39 AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h);
|
| D | shrpx_connection_handler.h | 140 const UpstreamAddr *faddr);
198 int forward_quic_packet(const UpstreamAddr *faddr, const Address &remote_addr,
|
| D | shrpx_http2_upstream.cc | 362 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 = handler_->get_upstream_addr(); in consume() local
[all …]
|
| D | shrpx_client_handler.cc | 322 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() argument
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()
|
| D | shrpx_quic.h | 83 int quic_send_packet(const UpstreamAddr *faddr, const sockaddr *remote_sa,
|
| D | shrpx_tls.h | 116 int addrlen, const UpstreamAddr *faddr);
|
| D | shrpx_worker.h | 299 const UpstreamAddr *faddr; member
|
| D | shrpx_https_upstream.cc | 417 auto faddr = handler->get_upstream_addr(); in htp_hdrs_completecb() local
474 faddr->alt_mode == UpstreamAltMode::NONE) { in htp_hdrs_completecb()
528 if (faddr->alt_mode != UpstreamAltMode::NONE) { in htp_hdrs_completecb()
|
| D | shrpx_tls.cc | 1694 int addrlen, const UpstreamAddr *faddr) { in accept_connection() argument
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() argument
|
| D | shrpx_downstream.cc | 634 auto faddr = handler->get_upstream_addr(); in request_buf_full() local
638 if (faddr->alt_mode == UpstreamAltMode::API) { in request_buf_full()
|
| /third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/ |
| D | user_inpcb.h | 271 #define INP_PCBHASH(faddr, lport, fport, mask) \ argument
272 (((faddr) ^ ((faddr) >> 16) ^ ntohs((lport) ^ (fport))) & (mask))
|
| /third_party/lwip/ |
| D | 0080-enable-ipv6.patch | 333 -#define TUPLE4_HASH_FN(laddr, lport, faddr, fport) jhash_3words(laddr, faddr,lport|(fport<<16))
347 +#define TUPLE4_HASH_FN(laddr, lport, faddr, fport) \
348 + (IP_IS_V4(laddr) ? jhash_3words(ip_2_ip4(laddr)->addr, ip_2_ip4(faddr)->addr, lport|(fport<<…
349 + : jhash_3words6(ip_2_ip6(laddr)->addr, ip_2_ip6(faddr)->addr, lport|(fport<<16)))
351 +#define TUPLE4_HASH_FN(laddr, lport, faddr, fport) \
352 + jhash_3words(ip_2_ip4(laddr)->addr, ip_2_ip4(faddr)->addr, lport|(fport<<16))
|