Lines Matching refs:path
500 auto path = ngtcp2_conn_get_path(conn_);
502 return send_new_token(&path->remote);
506 int path_validation(ngtcp2_conn *conn, uint32_t flags, const ngtcp2_path *path,
515 if (upstream->send_new_token(&path->remote) != 0) {
730 auto path = ngtcp2_path{
742 rv = ngtcp2_conn_server_new(&conn_, &initial_hd.scid, &scid, &path,
843 conn_, &ps.path, &pi, bufpos, max_udp_payload_size, &ndatalen, flags,
891 auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data);
895 rv = send_packet(faddr, prev_ps.path.remote.addr,
896 prev_ps.path.remote.addrlen, prev_ps.path.local.addr,
897 prev_ps.path.local.addrlen, prev_pi, data, datalen,
900 on_send_blocked(faddr, prev_ps.path.remote, prev_ps.path.local,
916 ngtcp2_path_copy(&prev_ps.path, &ps.path);
919 } else if (!ngtcp2_path_eq(&prev_ps.path, &ps.path) ||
924 auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data);
928 rv = send_packet(faddr, prev_ps.path.remote.addr,
929 prev_ps.path.remote.addrlen, prev_ps.path.local.addr,
930 prev_ps.path.local.addrlen, prev_pi, data, datalen,
934 on_send_blocked(faddr, prev_ps.path.remote, prev_ps.path.local, prev_pi,
937 on_send_blocked(static_cast<UpstreamAddr *>(ps.path.user_data),
938 ps.path.remote, ps.path.local, pi, bufpos - nwrite,
945 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data);
948 rv = send_packet(faddr, ps.path.remote.addr, ps.path.remote.addrlen,
949 ps.path.local.addr, ps.path.local.addrlen, pi, data,
952 on_send_blocked(faddr, ps.path.remote, ps.path.local, pi, data,
966 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data);
970 rv = send_packet(faddr, ps.path.remote.addr, ps.path.remote.addrlen,
971 ps.path.local.addr, ps.path.local.addrlen, pi, data,
974 on_send_blocked(faddr, ps.path.remote, ps.path.local, pi, data, datalen,
985 auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data);
989 rv = send_packet(faddr, ps.path.remote.addr, ps.path.remote.addrlen,
990 ps.path.local.addr, ps.path.local.addrlen, pi, data,
993 on_send_blocked(faddr, ps.path.remote, ps.path.local, pi, data, datalen,
1392 balloc, cookieconf.name, affinity_cookie, cookieconf.path, secure);
1552 conn_, &ps.path, &pi, conn_close_.data(), conn_close_.size(), &ccerr,
1565 send_packet(static_cast<UpstreamAddr *>(ps.path.user_data),
1566 ps.path.remote.addr, ps.path.remote.addrlen, ps.path.local.addr,
1567 ps.path.local.addrlen, pi, conn_close_.data(), nwrite, 0);
1789 auto path = ngtcp2_path{
1801 rv = ngtcp2_conn_read_pkt(conn_, &path, &pi, data, datalen, quic_timestamp());
1963 conn_, &ps.path, &pi, conn_close_.data(), conn_close_.size(),
1977 send_packet(static_cast<UpstreamAddr *>(ps.path.user_data),
1978 ps.path.remote.addr, ps.path.remote.addrlen, ps.path.local.addr,
1979 ps.path.local.addrlen, pi, conn_close_.data(), nwrite, 0);
2236 auto path = req.fs.header(http2::HD__PATH);
2274 if (path) {
2276 path->value == StringRef::from_lit("*")) {
2280 req.path = path->value;
2282 req.path = http2::rewrite_clean_path(downstream->get_block_allocator(),
2283 path->value);
2868 auto path = dir.str();
2869 path += '/';
2870 path +=
2872 path += '-';
2873 path += util::format_hex(scid.data, scid.datalen);
2874 path += ".sqlog";
2879 while ((fd = open(path.c_str(), O_WRONLY | O_CREAT | O_TRUNC | O_CLOEXEC,
2884 while ((fd = open(path.c_str(), O_WRONLY | O_CREAT | O_TRUNC,
2896 ULOG(ERROR, this) << "Failed to open qlog file " << path