Commit f7bbbf4e authored by Kenton Varda's avatar Kenton Varda

Try to fix builds.

parent 2751b577
......@@ -2579,12 +2579,15 @@ KJ_TEST("HttpClient connection management") {
.wait(io.waitScope);
KJ_EXPECT(count == 0);
#if !_WIN32 // TODO(soon): Figure out why this doesn't work on Windows. Probably a bug in
// Win32IocpEventPort::poll().
// If the server times out the connection, we figure it out on the client.
doRequest().wait(io.waitScope);
KJ_EXPECT(count == 1);
serverTimer.advanceTo(serverTimer.now() + serverSettings.pipelineTimeout * 2);
io.waitScope.poll();
KJ_EXPECT(count == 0);
#endif
// Can still make requests.
doRequest().wait(io.waitScope);
......
......@@ -2798,7 +2798,7 @@ public:
kj::Maybe<kj::Own<AsyncOutputStream>> stream;
};
class AttachmentOutputStream: public kj::AsyncOutputStream {
class AttachmentOutputStream final: public kj::AsyncOutputStream {
// An AsyncOutputStream which also owns some separate object, released when the stream is freed.
public:
......@@ -2821,7 +2821,7 @@ private:
kj::Own<kj::Refcounted> attachment;
};
class AttachmentInputStream: public kj::AsyncInputStream {
class AttachmentInputStream final: public kj::AsyncInputStream {
// An AsyncInputStream which also owns some separate object, released when the stream is freed.
public:
......@@ -2921,7 +2921,7 @@ private:
std::deque<AvailableClient> availableClients;
struct RefcountedClient: public kj::Refcounted {
struct RefcountedClient final: public kj::Refcounted {
RefcountedClient(NetworkAddressHttpClient& parent, kj::Own<HttpClientImpl> client)
: parent(parent), client(kj::mv(client)) {
++parent.activeConnectionCount;
......
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