// // Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2023 // // Distributed under the Boost Software License, Version 1.0. (See accompanying // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) // #include "td/utils/port/detail/Iocp.h" char disable_linker_warning_about_empty_file_iocp_cpp TD_UNUSED; #ifdef TD_PORT_WINDOWS #include "td/utils/logging.h" namespace td { namespace detail { Iocp::~Iocp() { clear(); } void Iocp::loop() { Iocp::Guard guard(this); while (true) { DWORD bytes = 0; ULONG_PTR key = 0; WSAOVERLAPPED *overlapped = nullptr; BOOL ok = GetQueuedCompletionStatus(iocp_handle_->fd(), &bytes, &key, reinterpret_cast(&overlapped), 1000); if (bytes || key || overlapped) { // LOG(ERROR) << "Receive IOCP completion status: " << bytes << ' ' << key << ' ' << overlapped; } if (ok) { auto callback = reinterpret_cast(key); if (callback == nullptr) { // LOG(ERROR) << "Interrupt IOCP loop"; return; } callback->on_iocp(bytes, overlapped); } else { if (overlapped != nullptr) { auto error = OS_ERROR("Received from IOCP"); auto callback = reinterpret_cast(key); CHECK(callback != nullptr); callback->on_iocp(std::move(error), overlapped); } } } } void Iocp::interrupt_loop() { post(0, nullptr, nullptr); } void Iocp::init() { CHECK(!iocp_handle_); auto res = CreateIoCompletionPort(INVALID_HANDLE_VALUE, nullptr, 0, 0); if (res == nullptr) { auto error = OS_ERROR("IOCP creation failed"); LOG(FATAL) << error; } iocp_handle_ = std::make_shared(res); } void Iocp::clear() { iocp_handle_.reset(); } void Iocp::subscribe(const NativeFd &native_fd, Callback *callback) { CHECK(iocp_handle_); auto iocp_handle = CreateIoCompletionPort(native_fd.fd(), iocp_handle_->fd(), reinterpret_cast(callback), 0); if (iocp_handle == nullptr) { auto error = OS_ERROR("CreateIoCompletionPort"); LOG(FATAL) << error; } LOG_CHECK(iocp_handle == iocp_handle_->fd()) << iocp_handle << " " << iocp_handle_->fd(); } IocpRef Iocp::get_ref() const { return IocpRef(iocp_handle_); } static void iocp_post(NativeFd &iocp_handle, size_t size, Iocp::Callback *callback, WSAOVERLAPPED *overlapped) { if (PostQueuedCompletionStatus(iocp_handle.fd(), DWORD(size), reinterpret_cast(callback), reinterpret_cast(overlapped)) == 0) { auto error = OS_ERROR("IOCP post failed"); LOG(FATAL) << error; } } void Iocp::post(size_t size, Callback *callback, WSAOVERLAPPED *overlapped) { iocp_post(*iocp_handle_, size, callback, overlapped); } IocpRef::IocpRef(std::weak_ptr iocp_handle) : iocp_handle_(std::move(iocp_handle)) { } bool IocpRef::post(size_t size, Iocp::Callback *callback, WSAOVERLAPPED *overlapped) { auto iocp_handle = iocp_handle_.lock(); if (!iocp_handle) { return false; } iocp_post(*iocp_handle, size, callback, overlapped); return true; } } // namespace detail } // namespace td #endif