diff options
author | rohan.prinja <rohan.prinja@samsung.com> | 2015-11-14 05:07:55 +0900 |
---|---|---|
committer | Rohan Prinja <rohan.prinja@gmail.com> | 2016-01-10 17:58:13 +0900 |
commit | 1f02c4ebbb7d5ea49051f4391f1418f20c15d7a9 (patch) | |
tree | 7d61e58e746ddca93074ca6bca6849360a098b8c /components/script/dom/storage.rs | |
parent | f00532bab0382d1c24e6086314f26497fb6ffe0f (diff) | |
download | servo-1f02c4ebbb7d5ea49051f4391f1418f20c15d7a9.tar.gz servo-1f02c4ebbb7d5ea49051f4391f1418f20c15d7a9.zip |
task -> thread
Diffstat (limited to 'components/script/dom/storage.rs')
-rw-r--r-- | components/script/dom/storage.rs | 36 |
1 files changed, 19 insertions, 17 deletions
diff --git a/components/script/dom/storage.rs b/components/script/dom/storage.rs index e29c5093f6c..3e2d54e6456 100644 --- a/components/script/dom/storage.rs +++ b/components/script/dom/storage.rs @@ -14,9 +14,9 @@ use dom::event::{Event, EventBubbles, EventCancelable}; use dom::storageevent::StorageEvent; use dom::urlhelper::UrlHelper; use ipc_channel::ipc; -use net_traits::storage_task::{StorageTask, StorageTaskMsg, StorageType}; +use net_traits::storage_thread::{StorageThread, StorageThreadMsg, StorageType}; use page::IterablePage; -use script_task::{MainThreadRunnable, MainThreadScriptMsg, ScriptTask}; +use script_thread::{MainThreadRunnable, MainThreadScriptMsg, ScriptThread}; use std::sync::mpsc::channel; use url::Url; use util::str::DOMString; @@ -47,10 +47,10 @@ impl Storage { global_ref.get_url() } - fn get_storage_task(&self) -> StorageTask { + fn get_storage_thread(&self) -> StorageThread { let global_root = self.global.root(); let global_ref = global_root.r(); - global_ref.as_window().storage_task() + global_ref.as_window().storage_thread() } } @@ -60,7 +60,7 @@ impl StorageMethods for Storage { fn Length(&self) -> u32 { let (sender, receiver) = ipc::channel().unwrap(); - self.get_storage_task().send(StorageTaskMsg::Length(sender, self.get_url(), self.storage_type)).unwrap(); + self.get_storage_thread().send(StorageThreadMsg::Length(sender, self.get_url(), self.storage_type)).unwrap(); receiver.recv().unwrap() as u32 } @@ -68,7 +68,9 @@ impl StorageMethods for Storage { fn Key(&self, index: u32) -> Option<DOMString> { let (sender, receiver) = ipc::channel().unwrap(); - self.get_storage_task().send(StorageTaskMsg::Key(sender, self.get_url(), self.storage_type, index)).unwrap(); + self.get_storage_thread() + .send(StorageThreadMsg::Key(sender, self.get_url(), self.storage_type, index)) + .unwrap(); receiver.recv().unwrap().map(DOMString::from) } @@ -77,8 +79,8 @@ impl StorageMethods for Storage { let (sender, receiver) = ipc::channel().unwrap(); let name = String::from(name); - let msg = StorageTaskMsg::GetItem(sender, self.get_url(), self.storage_type, name); - self.get_storage_task().send(msg).unwrap(); + let msg = StorageThreadMsg::GetItem(sender, self.get_url(), self.storage_type, name); + self.get_storage_thread().send(msg).unwrap(); receiver.recv().unwrap().map(DOMString::from) } @@ -88,8 +90,8 @@ impl StorageMethods for Storage { let name = String::from(name); let value = String::from(value); - let msg = StorageTaskMsg::SetItem(sender, self.get_url(), self.storage_type, name.clone(), value.clone()); - self.get_storage_task().send(msg).unwrap(); + let msg = StorageThreadMsg::SetItem(sender, self.get_url(), self.storage_type, name.clone(), value.clone()); + self.get_storage_thread().send(msg).unwrap(); match receiver.recv().unwrap() { Err(_) => Err(Error::QuotaExceeded), Ok((changed, old_value)) => { @@ -106,8 +108,8 @@ impl StorageMethods for Storage { let (sender, receiver) = ipc::channel().unwrap(); let name = String::from(name); - let msg = StorageTaskMsg::RemoveItem(sender, self.get_url(), self.storage_type, name.clone()); - self.get_storage_task().send(msg).unwrap(); + let msg = StorageThreadMsg::RemoveItem(sender, self.get_url(), self.storage_type, name.clone()); + self.get_storage_thread().send(msg).unwrap(); if let Some(old_value) = receiver.recv().unwrap() { self.broadcast_change_notification(Some(name), Some(old_value), None); } @@ -117,7 +119,7 @@ impl StorageMethods for Storage { fn Clear(&self) { let (sender, receiver) = ipc::channel().unwrap(); - self.get_storage_task().send(StorageTaskMsg::Clear(sender, self.get_url(), self.storage_type)).unwrap(); + self.get_storage_thread().send(StorageThreadMsg::Clear(sender, self.get_url(), self.storage_type)).unwrap(); if receiver.recv().unwrap() { self.broadcast_change_notification(None, None, None); } @@ -127,7 +129,7 @@ impl StorageMethods for Storage { fn SupportedPropertyNames(&self) -> Vec<DOMString> { let (sender, receiver) = ipc::channel().unwrap(); - self.get_storage_task().send(StorageTaskMsg::Keys(sender, self.get_url(), self.storage_type)).unwrap(); + self.get_storage_thread().send(StorageThreadMsg::Keys(sender, self.get_url(), self.storage_type)).unwrap(); receiver.recv().unwrap().iter().cloned().map(DOMString::from).collect() // FIXME: inefficient? } @@ -155,7 +157,7 @@ impl Storage { let global_root = self.global.root(); let global_ref = global_root.r(); let main_script_chan = global_ref.as_window().main_thread_script_chan(); - let script_chan = global_ref.dom_manipulation_task_source(); + let script_chan = global_ref.dom_manipulation_thread_source(); let trusted_storage = Trusted::new(self, script_chan); main_script_chan.send(MainThreadScriptMsg::MainThreadRunnableMsg( box StorageEventRunnable::new(trusted_storage, key, old_value, new_value))).unwrap(); @@ -177,7 +179,7 @@ impl StorageEventRunnable { } impl MainThreadRunnable for StorageEventRunnable { - fn handler(self: Box<StorageEventRunnable>, script_task: &ScriptTask) { + fn handler(self: Box<StorageEventRunnable>, script_thread: &ScriptThread) { let this = *self; let storage_root = this.element.root(); let storage = storage_root.r(); @@ -195,7 +197,7 @@ impl MainThreadRunnable for StorageEventRunnable { Some(storage) ); - let root_page = script_task.root_page(); + let root_page = script_thread.root_page(); for it_page in root_page.iter() { let it_window_root = it_page.window(); let it_window = it_window_root.r(); |