jlengrand/vert.x
1
0
Fork 0
mirror of https://github.com/jlengrand/vert.x.git synced 2026-03-10 08:51:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

HTTP/1 stream should synchronise when updating the connection stream - see #3196

Browse Source
This commit is contained in:
Julien Viet
2019-11-15 11:46:47 +01:00
parent 8374efd9e9
commit c4fec42922
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/io/vertx/core/http/impl/Http1xClientConnection.java
View File

@@ -301,18 +301,20 @@ class Http1xClientConnection extends Http1xConnectionBase<WebSocketImpl> impleme
@Override
public void writeHead(HttpMethod method, String rawMethod, String uri, MultiMap headers, String hostHeader, boolean chunked, ByteBuf buf, boolean end, StreamPriority priority, Handler<Void> contHandler, Handler<AsyncResult<Void>> handler) {
synchronized (conn) {
if (buf != null) {
bytesWritten += buf.readableBytes();
}
continueHandler = contHandler;
if (conn.responseInProgress == null) {
conn.responseInProgress = this;
} else {
conn.responseInProgress.append(this);
}
next = null;
}
HttpRequest request = conn.createRequest(method, rawMethod, uri, headers, hostHeader, chunked);
conn.sendRequest(request, buf, end, handler);
if (buf != null) {
bytesWritten += buf.readableBytes();
}
continueHandler = contHandler;
if (conn.responseInProgress == null) {
conn.responseInProgress = this;
} else {
conn.responseInProgress.append(this);
}
next = null;
}
private boolean handleChunk(Buffer buff) {