Commit 42f47c19 authored by Tatsuhiro Tsujikawa's avatar Tatsuhiro Tsujikawa

Handle sending just fine

parent 327a7adb
...@@ -631,8 +631,8 @@ int Client::write_quic() { ...@@ -631,8 +631,8 @@ int Client::write_quic() {
auto s = static_cast<Http3Session *>(session.get()); auto s = static_cast<Http3Session *>(session.get());
for (;;) { for (;;) {
int64_t stream_id; int64_t stream_id = -1;
int fin; int fin = 0;
ssize_t sveccnt = 0; ssize_t sveccnt = 0;
if (ngtcp2_conn_get_max_data_left(quic.conn)) { if (ngtcp2_conn_get_max_data_left(quic.conn)) {
...@@ -643,7 +643,7 @@ int Client::write_quic() { ...@@ -643,7 +643,7 @@ int Client::write_quic() {
} }
ssize_t ndatalen; ssize_t ndatalen;
if (sveccnt == 0) { if (sveccnt == 0 && stream_id == -1) {
auto nwrite = auto nwrite =
ngtcp2_conn_write_pkt(quic.conn, &ps.path, buf.data(), ngtcp2_conn_write_pkt(quic.conn, &ps.path, buf.data(),
quic.max_pktlen, timestamp(worker->loop)); quic.max_pktlen, timestamp(worker->loop));
...@@ -714,7 +714,7 @@ int Client::write_quic() { ...@@ -714,7 +714,7 @@ int Client::write_quic() {
return 0; return 0;
} }
if (ndatalen > 0) { if (ndatalen >= 0) {
if (s->add_write_offset(stream_id, ndatalen) != 0) { if (s->add_write_offset(stream_id, ndatalen) != 0) {
return -1; return -1;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment