diff --git a/kernel/aster-nix/src/fs/utils/channel.rs b/kernel/aster-nix/src/fs/utils/channel.rs index 024ea0cc5..f3c2e9928 100644 --- a/kernel/aster-nix/src/fs/utils/channel.rs +++ b/kernel/aster-nix/src/fs/utils/channel.rs @@ -1,7 +1,5 @@ // SPDX-License-Identifier: MPL-2.0 -#![allow(dead_code)] - use core::sync::atomic::{AtomicBool, AtomicU32, Ordering}; use aster_rights::{Read, ReadOp, TRights, Write, WriteOp}; @@ -29,8 +27,8 @@ impl Channel { pub fn with_capacity_and_flags(capacity: usize, flags: StatusFlags) -> Result { let common = Arc::new(Common::with_capacity_and_flags(capacity, flags)?); - let producer = Producer(EndPoint::new(common.clone(), WriteOp::new())); - let consumer = Consumer(EndPoint::new(common, ReadOp::new())); + let producer = Producer(EndPoint::new(common.clone())); + let consumer = Consumer(EndPoint::new(common)); Ok(Self { producer, consumer }) } @@ -387,12 +385,15 @@ impl Drop for Consumer { struct EndPoint { common: Arc>, - rights: R, + _rights: R, } impl EndPoint { - pub fn new(common: Arc>, rights: R) -> Self { - Self { common, rights } + pub fn new(common: Arc>) -> Self { + Self { + common, + _rights: R::new(), + } } }