walkero
/
nghttp2
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

Revert "Ensure complete packet is written" 

This reverts commit c19046b09f8e66713f0e067f986ed92d676eb6b6.
This commit is contained in:
Tatsuhiro Tsujikawa 2020-04-04 16:10:04 +09:00
parent 749015eb86
commit a60a34331b
1 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/h2load_quic.cc
View File

@ -647,13 +647,7 @@ int Client::write_quic() {
case NGTCP2_ERR_STREAM_SHUT_WR: case NGTCP2_ERR_STREAM_SHUT_WR:
if (nwrite == NGTCP2_ERR_STREAM_DATA_BLOCKED && if (nwrite == NGTCP2_ERR_STREAM_DATA_BLOCKED &&
ngtcp2_conn_get_max_data_left(quic.conn) == 0) { ngtcp2_conn_get_max_data_left(quic.conn) == 0) {
/* Call ngtcp2_conn_writev_stream to ensure that a complete return 0;
packet is written to the buffer. */
nwrite = ngtcp2_conn_writev_stream(
quic.conn, &ps.path, buf.data(), quic.max_pktlen, nullptr,
NGTCP2_WRITE_STREAM_FLAG_NONE, /* stream_id = */ 0, /* fin = */ 0,
nullptr, 0, timestamp(worker->loop));
break;
} }
if (s->block_stream(stream_id) != 0) { if (s->block_stream(stream_id) != 0) {
@ -668,10 +662,8 @@ int Client::write_quic() {
continue; continue;
} }
if (nwrite < 0) { quic.last_error = quic::err_transport(nwrite);
quic.last_error = quic::err_transport(nwrite); return -1;
return -1;
}
} }
quic_restart_pkt_timer(); quic_restart_pkt_timer();