1cac7dca0Sopenharmony_ci// Copyright (c) 2023 Huawei Device Co., Ltd. 2cac7dca0Sopenharmony_ci// Licensed under the Apache License, Version 2.0 (the "License"); 3cac7dca0Sopenharmony_ci// you may not use this file except in compliance with the License. 4cac7dca0Sopenharmony_ci// You may obtain a copy of the License at 5cac7dca0Sopenharmony_ci// 6cac7dca0Sopenharmony_ci// http://www.apache.org/licenses/LICENSE-2.0 7cac7dca0Sopenharmony_ci// 8cac7dca0Sopenharmony_ci// Unless required by applicable law or agreed to in writing, software 9cac7dca0Sopenharmony_ci// distributed under the License is distributed on an "AS IS" BASIS, 10cac7dca0Sopenharmony_ci// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 11cac7dca0Sopenharmony_ci// See the License for the specific language governing permissions and 12cac7dca0Sopenharmony_ci// limitations under the License. 13cac7dca0Sopenharmony_ci 14cac7dca0Sopenharmony_ciuse std::io; 15cac7dca0Sopenharmony_ciuse std::sync::Arc; 16cac7dca0Sopenharmony_ci 17cac7dca0Sopenharmony_ciuse crate::sys::windows::iocp::CompletionPort; 18cac7dca0Sopenharmony_ciuse crate::{Selector, Token}; 19cac7dca0Sopenharmony_ci 20cac7dca0Sopenharmony_ci#[derive(Debug)] 21cac7dca0Sopenharmony_cipub(crate) struct WakerInner { 22cac7dca0Sopenharmony_ci token: Token, 23cac7dca0Sopenharmony_ci completion_port: Arc<CompletionPort>, 24cac7dca0Sopenharmony_ci} 25cac7dca0Sopenharmony_ci 26cac7dca0Sopenharmony_ciimpl WakerInner { 27cac7dca0Sopenharmony_ci /// Creates a new WakerInner. 28cac7dca0Sopenharmony_ci pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> { 29cac7dca0Sopenharmony_ci Ok(WakerInner { 30cac7dca0Sopenharmony_ci token, 31cac7dca0Sopenharmony_ci completion_port: selector.clone_cp(), 32cac7dca0Sopenharmony_ci }) 33cac7dca0Sopenharmony_ci } 34cac7dca0Sopenharmony_ci 35cac7dca0Sopenharmony_ci /// Waker allows cross-thread waking of Poll. 36cac7dca0Sopenharmony_ci pub(crate) fn wake(&self) -> io::Result<()> { 37cac7dca0Sopenharmony_ci self.completion_port.post(self.token) 38cac7dca0Sopenharmony_ci } 39cac7dca0Sopenharmony_ci} 40