Skip to content

Commit 7827e75

Browse files
authored
Merge pull request #88 from DeNA/fix_http2_output_stream_flush
HTTP2のOutputStreamがflushされてなくて処理が遅くなっていたのを修正
2 parents 67ba904 + 2d8fdec commit 7827e75

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/main/java/core/packetproxy/http2/FlowControlManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -100,12 +100,14 @@ public void write(Frame frame) throws Exception {
100100
if (frame.getType() == Frame.Type.HEADERS) {
101101
/* TODO: maximum concurrent streams is not implemented yet */
102102
outputForFlowControl.write(frame.toByteArray());
103+
outputForFlowControl.flush();
103104
} else if (frame.getType() == Frame.Type.DATA) {
104105
FlowControl flow = getFlow(frame.getStreamId());
105106
flow.enqueue(frame);
106107
writeData(flow);
107108
} else {
108109
outputForFlowControl.write(frame.toByteArray());
110+
outputForFlowControl.flush();
109111
}
110112
}
111113

0 commit comments

Comments
 (0)