1 // Copyright (c) 2023 Huawei Device Co., Ltd. 2 // Licensed under the Apache License, Version 2.0 (the "License"); 3 // you may not use this file except in compliance with the License. 4 // You may obtain a copy of the License at 5 // 6 // http://www.apache.org/licenses/LICENSE-2.0 7 // 8 // Unless required by applicable law or agreed to in writing, software 9 // distributed under the License is distributed on an "AS IS" BASIS, 10 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 11 // See the License for the specific language governing permissions and 12 // limitations under the License. 13 14 use std::io; 15 16 use crate::{Interest, Selector, Token}; 17 18 /// Fd type on Linux 19 #[cfg(unix)] 20 pub type Fd = i32; 21 22 /// RawSocket on Windows 23 #[cfg(target_os = "windows")] 24 pub type Fd = std::os::windows::io::RawSocket; 25 26 /// Source Trait that every connection requires async polling in [`crate::Poll`] 27 /// needs to implement. [`crate::Poll`] will asynchronously poll out 28 /// connections, and handle it. 29 pub trait Source { 30 /// Registers the connection into [`crate::Poll`] register( &mut self, selector: &Selector, token: Token, interests: Interest, ) -> io::Result<()>31 fn register( 32 &mut self, 33 selector: &Selector, 34 token: Token, 35 interests: Interest, 36 ) -> io::Result<()>; 37 38 /// Deregisters the connection from [`crate::Poll`]. deregister(&mut self, selector: &Selector) -> io::Result<()>39 fn deregister(&mut self, selector: &Selector) -> io::Result<()>; 40 41 /// Returns the raw fd of this IO. get_fd(&self) -> Fd42 fn get_fd(&self) -> Fd; 43 } 44