diff options
| author | levlam <levlam@telegram.org> | 2021-10-27 20:29:01 +0300 |
|---|---|---|
| committer | levlam <levlam@telegram.org> | 2021-10-27 20:29:01 +0300 |
| commit | 377bd18909b7a602b40e8bb074cdeb2830baef91 (patch) | |
| tree | 8182b822af99721d673a816dd1e46d4f252cfe9f /tdnet/td/net/Wget.cpp | |
| parent | a68d8e77efb03896f3a04fc316c47136b0bab7df (diff) | |
Pass BufferedFd to HttpConnection.
Diffstat (limited to 'tdnet/td/net/Wget.cpp')
| -rw-r--r-- | tdnet/td/net/Wget.cpp | 8 |
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)); |
