Skip to content

Commit

Permalink
[WIP] Fix quic
Browse files Browse the repository at this point in the history
  • Loading branch information
tatsuhiro-t committed May 19, 2024
1 parent 20d21b2 commit 2269c86
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/shrpx_http3_upstream.cc
Original file line number Diff line number Diff line change
Expand Up @@ -894,11 +894,11 @@ int Http3Upstream::write_streams() {
return 0;
}

auto last_pkt = std::begin(buf);
auto last_pkt = buf.data();

buf = buf.subspan(nwrite);

if (last_pkt == std::begin(txbuf)) {
if (last_pkt == txbuf.data()) {
ngtcp2_path_copy(&prev_ps.path, &ps.path);
prev_pi = pi;
gso_size = nwrite;
Expand All @@ -908,7 +908,7 @@ int Http3Upstream::write_streams() {
(gso_size > path_max_udp_payload_size &&
static_cast<size_t>(nwrite) != gso_size)) {
auto faddr = static_cast<UpstreamAddr *>(prev_ps.path.user_data);
auto data = std::span{std::begin(txbuf), last_pkt};
auto data = std::span{txbuf.data(), last_pkt};

auto [rest, rv] =
send_packet(faddr, prev_ps.path.remote.addr,
Expand All @@ -919,7 +919,7 @@ int Http3Upstream::write_streams() {
on_send_blocked(faddr, prev_ps.path.remote, prev_ps.path.local, prev_pi,
rest, gso_size);

data = std::span{last_pkt, std::begin(buf)};
data = std::span{last_pkt, buf.data()};
on_send_blocked(static_cast<UpstreamAddr *>(ps.path.user_data),
ps.path.remote, ps.path.local, pi, data, data.size());

Expand All @@ -928,7 +928,7 @@ int Http3Upstream::write_streams() {
break;
default: {
auto faddr = static_cast<UpstreamAddr *>(ps.path.user_data);
auto data = std::span{last_pkt, std::begin(buf)};
auto data = std::span{last_pkt, buf.data()};

auto [rest, rv] = send_packet(
faddr, ps.path.remote.addr, ps.path.remote.addrlen,
Expand Down

0 comments on commit 2269c86

Please sign in to comment.