diff options
Diffstat (limited to 'components/net_traits/lib.rs')
-rw-r--r-- | components/net_traits/lib.rs | 22 |
1 files changed, 21 insertions, 1 deletions
diff --git a/components/net_traits/lib.rs b/components/net_traits/lib.rs index c338002c19a..dcd85c3af72 100644 --- a/components/net_traits/lib.rs +++ b/components/net_traits/lib.rs @@ -28,6 +28,7 @@ extern crate util; extern crate uuid; extern crate websocket; +use filemanager_thread::FileManagerThreadMsg; use heapsize::HeapSizeOf; use hyper::header::{ContentType, Headers}; use hyper::http::RawStatus; @@ -217,8 +218,13 @@ pub type CoreResourceThread = IpcSender<CoreResourceMsg>; pub type IpcSendResult = Result<(), IOError>; +/// Abstraction of the ability to send a particular type of message, +/// used by net_traits::ResourceThreads to ease the use its IpcSender sub-fields +/// XXX: If this trait will be used more in future, some auto derive might be appealing pub trait IpcSend<T> where T: serde::Serialize + serde::Deserialize { + /// send message T fn send(&self, T) -> IpcSendResult; + /// get underlying sender fn sender(&self) -> IpcSender<T>; } @@ -231,13 +237,17 @@ pub trait IpcSend<T> where T: serde::Serialize + serde::Deserialize { pub struct ResourceThreads { core_thread: CoreResourceThread, storage_thread: IpcSender<StorageThreadMsg>, + filemanager_thread: IpcSender<FileManagerThreadMsg>, } impl ResourceThreads { - pub fn new(c: CoreResourceThread, s: IpcSender<StorageThreadMsg>) -> ResourceThreads { + pub fn new(c: CoreResourceThread, + s: IpcSender<StorageThreadMsg>, + f: IpcSender<FileManagerThreadMsg>) -> ResourceThreads { ResourceThreads { core_thread: c, storage_thread: s, + filemanager_thread: f, } } } @@ -262,6 +272,16 @@ impl IpcSend<StorageThreadMsg> for ResourceThreads { } } +impl IpcSend<FileManagerThreadMsg> for ResourceThreads { + fn send(&self, msg: FileManagerThreadMsg) -> IpcSendResult { + self.filemanager_thread.send(msg) + } + + fn sender(&self) -> IpcSender<FileManagerThreadMsg> { + self.filemanager_thread.clone() + } +} + // Ignore the sub-fields impl HeapSizeOf for ResourceThreads { fn heap_size_of_children(&self) -> usize { 0 } |