aboutsummaryrefslogtreecommitdiffhomepage
path: root/tdnet/td/net/Wget.cpp
diff options
context:
space:
mode:
authorlevlam <levlam@telegram.org>2021-10-27 20:29:01 +0300
committerlevlam <levlam@telegram.org>2021-10-27 20:29:01 +0300
commit377bd18909b7a602b40e8bb074cdeb2830baef91 (patch)
tree8182b822af99721d673a816dd1e46d4f252cfe9f /tdnet/td/net/Wget.cpp
parenta68d8e77efb03896f3a04fc316c47136b0bab7df (diff)
Pass BufferedFd to HttpConnection.
Diffstat (limited to 'tdnet/td/net/Wget.cpp')
-rw-r--r--tdnet/td/net/Wget.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/tdnet/td/net/Wget.cpp b/tdnet/td/net/Wget.cpp
index 1da982f80..6873aca0e 100644
--- a/tdnet/td/net/Wget.cpp
+++ b/tdnet/td/net/Wget.cpp
@@ -79,14 +79,14 @@ Status Wget::try_init() {
return Status::Error("Sockets are not supported");
}
if (url.protocol_ == HttpUrl::Protocol::Http) {
- connection_ = create_actor<HttpOutboundConnection>("Connect", std::move(fd), SslStream{},
+ connection_ = create_actor<HttpOutboundConnection>("Connect", BufferedFd<SocketFd>(std::move(fd)), SslStream{},
std::numeric_limits<std::size_t>::max(), 0, 0,
ActorOwn<HttpOutboundConnection::Callback>(actor_id(this)));
} else {
TRY_RESULT(ssl_stream, SslStream::create(url.host_, CSlice() /* certificate */, verify_peer_));
- connection_ = create_actor<HttpOutboundConnection>("Connect", std::move(fd), std::move(ssl_stream),
- std::numeric_limits<std::size_t>::max(), 0, 0,
- ActorOwn<HttpOutboundConnection::Callback>(actor_id(this)));
+ connection_ = create_actor<HttpOutboundConnection>(
+ "Connect", BufferedFd<SocketFd>(std::move(fd)), std::move(ssl_stream), std::numeric_limits<std::size_t>::max(),
+ 0, 0, ActorOwn<HttpOutboundConnection::Callback>(actor_id(this)));
}
send_closure(connection_, &HttpOutboundConnection::write_next, BufferSlice(header));