mirror of https://github.com/adamdruppe/arsd.git
should trigger the complete handler consistently
This commit is contained in:
parent
15a29d49dd
commit
dfeae3c53c
2
http2.d
2
http2.d
|
@ -2042,13 +2042,11 @@ class HttpRequest {
|
||||||
inactive[inactiveCount++] = sock;
|
inactive[inactiveCount++] = sock;
|
||||||
sock.close();
|
sock.close();
|
||||||
loseSocket(request.requestParameters.host, request.requestParameters.port, request.requestParameters.ssl, sock);
|
loseSocket(request.requestParameters.host, request.requestParameters.port, request.requestParameters.ssl, sock);
|
||||||
continue;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if(!stillAlive || request.state == HttpRequest.State.complete || request.state == HttpRequest.State.aborted) {
|
if(!stillAlive || request.state == HttpRequest.State.complete || request.state == HttpRequest.State.aborted) {
|
||||||
//import std.stdio; writeln(cast(void*) sock, " ", stillAlive, " ", request.state);
|
//import std.stdio; writeln(cast(void*) sock, " ", stillAlive, " ", request.state);
|
||||||
inactive[inactiveCount++] = sock;
|
inactive[inactiveCount++] = sock;
|
||||||
continue;
|
|
||||||
// reuse the socket for another pending request, if we can
|
// reuse the socket for another pending request, if we can
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue