diff options
author | bors-servo <metajack+bors@gmail.com> | 2015-01-21 03:48:49 -0700 |
---|---|---|
committer | bors-servo <metajack+bors@gmail.com> | 2015-01-21 03:48:49 -0700 |
commit | 8df0ee2bb5d40e4b22db1666982e2e5ea36513f6 (patch) | |
tree | 6bed465dae6bda2340db62dec1c40f0fd1d77513 | |
parent | 94ebc7c32d5ce58ada3f9d8ffdb60cc025eb5997 (diff) | |
parent | 808315926cf5fd49c26fcbbc4e2a2d281b3fca46 (diff) | |
download | servo-8df0ee2bb5d40e4b22db1666982e2e5ea36513f6.tar.gz servo-8df0ee2bb5d40e4b22db1666982e2e5ea36513f6.zip |
auto merge of #4703 : servo/servo/task, r=saneyuki
IntoString has been removed from Rust, and named() will take a String, so
there is no good reason to do otherwise here.
-rw-r--r-- | components/canvas/canvas_paint_task.rs | 3 | ||||
-rw-r--r-- | components/compositing/constellation.rs | 3 | ||||
-rw-r--r-- | components/devtools/lib.rs | 5 | ||||
-rw-r--r-- | components/gfx/font_cache_task.rs | 3 | ||||
-rw-r--r-- | components/net/file_loader.rs | 3 | ||||
-rw-r--r-- | components/net/http_loader.rs | 2 | ||||
-rw-r--r-- | components/net/image_cache_task.rs | 9 | ||||
-rw-r--r-- | components/net/local_image_cache.rs | 3 | ||||
-rw-r--r-- | components/net/resource_task.rs | 2 | ||||
-rw-r--r-- | components/net/storage_task.rs | 3 | ||||
-rw-r--r-- | components/script/dom/xmlhttprequest.rs | 6 | ||||
-rw-r--r-- | components/script/timers.rs | 3 | ||||
-rw-r--r-- | components/util/memory.rs | 7 | ||||
-rw-r--r-- | components/util/task.rs | 2 | ||||
-rw-r--r-- | components/util/time.rs | 7 |
15 files changed, 36 insertions, 25 deletions
diff --git a/components/canvas/canvas_paint_task.rs b/components/canvas/canvas_paint_task.rs index 6f9898c4c26..b5cdd3be777 100644 --- a/components/canvas/canvas_paint_task.rs +++ b/components/canvas/canvas_paint_task.rs @@ -8,6 +8,7 @@ use geom::rect::Rect; use geom::size::Size2D; use servo_util::task::spawn_named; +use std::borrow::ToOwned; use std::comm; #[deriving(Clone)] @@ -39,7 +40,7 @@ impl CanvasPaintTask { pub fn start(size: Size2D<i32>) -> Sender<CanvasMsg> { let (chan, port) = comm::channel::<CanvasMsg>(); - spawn_named("CanvasTask", proc() { + spawn_named("CanvasTask".to_owned(), proc() { let mut painter = CanvasPaintTask::new(size); loop { diff --git a/components/compositing/constellation.rs b/components/compositing/constellation.rs index febc1f884d7..2aa1b9688ee 100644 --- a/components/compositing/constellation.rs +++ b/components/compositing/constellation.rs @@ -33,6 +33,7 @@ use servo_util::geometry::{PagePx, ViewportPx}; use servo_util::opts; use servo_util::task::spawn_named; use servo_util::time::TimeProfilerChan; +use std::borrow::ToOwned; use std::cell::{Cell, RefCell}; use std::collections::{HashMap, HashSet}; use std::io; @@ -349,7 +350,7 @@ impl<LTF: LayoutTaskFactory, STF: ScriptTaskFactory> Constellation<LTF, STF> { -> ConstellationChan { let (constellation_port, constellation_chan) = ConstellationChan::new(); let constellation_chan_clone = constellation_chan.clone(); - spawn_named("Constellation", proc() { + spawn_named("Constellation".to_owned(), proc() { let mut constellation: Constellation<LTF, STF> = Constellation { chan: constellation_chan_clone, request_port: constellation_port, diff --git a/components/devtools/lib.rs b/components/devtools/lib.rs index 7e09a53c65e..fd4b57aa0d6 100644 --- a/components/devtools/lib.rs +++ b/components/devtools/lib.rs @@ -36,6 +36,7 @@ use devtools_traits::{ServerExitMsg, DevtoolsControlMsg, NewGlobal, DevtoolScrip use servo_msg::constellation_msg::PipelineId; use servo_util::task::spawn_named; +use std::borrow::ToOwned; use std::cell::RefCell; use std::collections::HashMap; use std::comm; @@ -57,7 +58,7 @@ mod protocol; /// Spin up a devtools server that listens for connections on the specified port. pub fn start_server(port: u16) -> Sender<DevtoolsControlMsg> { let (sender, receiver) = comm::channel(); - spawn_named("Devtools", proc() { + spawn_named("Devtools".to_owned(), proc() { run_server(receiver, port) }); sender @@ -184,7 +185,7 @@ fn run_server(receiver: Receiver<DevtoolsControlMsg>, port: u16) { Ok(stream) => { let actors = actors.clone(); accepted_connections.push(stream.clone()); - spawn_named("DevtoolsClientHandler", proc() { + spawn_named("DevtoolsClientHandler".to_owned(), proc() { // connection succeeded handle_client(actors, stream.clone()) }) diff --git a/components/gfx/font_cache_task.rs b/components/gfx/font_cache_task.rs index 4321cd5e613..5bb3a209d68 100644 --- a/components/gfx/font_cache_task.rs +++ b/components/gfx/font_cache_task.rs @@ -9,6 +9,7 @@ use platform::font_list::get_last_resort_font_families; use platform::font_context::FontContextHandle; use collections::str::Str; +use std::borrow::ToOwned; use std::collections::HashMap; use std::sync::Arc; use font_template::{FontTemplate, FontTemplateDescriptor}; @@ -252,7 +253,7 @@ impl FontCacheTask { pub fn new(resource_task: ResourceTask) -> FontCacheTask { let (chan, port) = channel(); - spawn_named("FontCacheTask", proc() { + spawn_named("FontCacheTask".to_owned(), proc() { // TODO: Allow users to specify these. let mut generic_fonts = HashMap::with_capacity(5); add_generic_font(&mut generic_fonts, "serif", "Times New Roman"); diff --git a/components/net/file_loader.rs b/components/net/file_loader.rs index aa127f806d6..73bab50c54d 100644 --- a/components/net/file_loader.rs +++ b/components/net/file_loader.rs @@ -5,6 +5,7 @@ use resource_task::{ProgressMsg, Metadata, LoadData, start_sending, TargetedLoadResponse, ResponseSenders}; use resource_task::ProgressMsg::{Payload, Done}; +use std::borrow::ToOwned; use std::io; use std::io::File; use servo_util::task::spawn_named; @@ -38,7 +39,7 @@ pub fn factory(load_data: LoadData, start_chan: Sender<TargetedLoadResponse>) { eventual_consumer: load_data.consumer, }; let progress_chan = start_sending(senders, Metadata::default(url.clone())); - spawn_named("file_loader", proc() { + spawn_named("file_loader".to_owned(), proc() { let file_path: Result<Path, ()> = url.to_file_path(); match file_path { Ok(file_path) => { diff --git a/components/net/http_loader.rs b/components/net/http_loader.rs index 86f2dbf0d38..c2f34a1849a 100644 --- a/components/net/http_loader.rs +++ b/components/net/http_loader.rs @@ -18,7 +18,7 @@ use url::{Url, UrlParser}; use std::borrow::ToOwned; pub fn factory(load_data: LoadData, start_chan: Sender<TargetedLoadResponse>) { - spawn_named("http_loader", proc() load(load_data, start_chan)) + spawn_named("http_loader".to_owned(), proc() load(load_data, start_chan)) } fn send_error(url: Url, err: String, senders: ResponseSenders) { diff --git a/components/net/image_cache_task.rs b/components/net/image_cache_task.rs index 46f238b0a00..3197389caa5 100644 --- a/components/net/image_cache_task.rs +++ b/components/net/image_cache_task.rs @@ -9,6 +9,7 @@ use resource_task::ProgressMsg::{Payload, Done}; use servo_util::task::spawn_named; use servo_util::taskpool::TaskPool; +use std::borrow::ToOwned; use std::comm::{channel, Receiver, Sender}; use std::collections::HashMap; use std::collections::hash_map::{Occupied, Vacant}; @@ -85,7 +86,7 @@ impl ImageCacheTask { let (chan, port) = channel(); let chan_clone = chan.clone(); - spawn_named("ImageCacheTask", proc() { + spawn_named("ImageCacheTask".to_owned(), proc() { let mut cache = ImageCache { resource_task: resource_task, port: port, @@ -106,7 +107,7 @@ impl ImageCacheTask { pub fn new_sync(resource_task: ResourceTask, task_pool: TaskPool) -> ImageCacheTask { let (chan, port) = channel(); - spawn_named("ImageCacheTask (sync)", proc() { + spawn_named("ImageCacheTask (sync)".to_owned(), proc() { let inner_cache = ImageCacheTask::new(resource_task, task_pool); loop { @@ -248,7 +249,7 @@ impl ImageCache { let resource_task = self.resource_task.clone(); let url_clone = url.clone(); - spawn_named("ImageCacheTask (prefetch)", proc() { + spawn_named("ImageCacheTask (prefetch)".to_owned(), proc() { let url = url_clone; debug!("image_cache_task: started fetch for {}", url.serialize()); @@ -469,7 +470,7 @@ fn load_image_data(url: Url, resource_task: ResourceTask) -> Result<Vec<u8>, ()> pub fn spawn_listener<A: Send>(f: proc(Receiver<A>):Send) -> Sender<A> { let (setup_chan, setup_port) = channel(); - spawn_named("ImageCacheTask (listener)", proc() { + spawn_named("ImageCacheTask (listener)".to_owned(), proc() { let (chan, port) = channel(); setup_chan.send(chan); f(port); diff --git a/components/net/local_image_cache.rs b/components/net/local_image_cache.rs index aca13a6d405..51a4ccce7c6 100644 --- a/components/net/local_image_cache.rs +++ b/components/net/local_image_cache.rs @@ -10,6 +10,7 @@ multiple times and thus triggering reflows multiple times. use image_cache_task::{ImageCacheTask, ImageResponseMsg, Msg}; +use std::borrow::ToOwned; use std::comm::{Receiver, channel}; use std::collections::HashMap; use std::collections::hash_map::{Occupied, Vacant}; @@ -130,7 +131,7 @@ impl<NodeAddress: Send> LocalImageCache<NodeAddress> { let on_image_available: proc(ImageResponseMsg, NodeAddress):Send = self.on_image_available.as_ref().unwrap().respond(); let url = (*url).clone(); - spawn_named("LocalImageCache", proc() { + spawn_named("LocalImageCache".to_owned(), proc() { let (response_chan, response_port) = channel(); image_cache_task.send(Msg::WaitForImage(url, response_chan)); on_image_available(response_port.recv(), node_address); diff --git a/components/net/resource_task.rs b/components/net/resource_task.rs index 8c23db5e3ae..b33665ba6c8 100644 --- a/components/net/resource_task.rs +++ b/components/net/resource_task.rs @@ -184,7 +184,7 @@ pub type ResourceTask = Sender<ControlMsg>; pub fn new_resource_task(user_agent: Option<String>) -> ResourceTask { let (setup_chan, setup_port) = channel(); let sniffer_task = sniffer_task::new_sniffer_task(); - spawn_named("ResourceManager", proc() { + spawn_named("ResourceManager".to_owned(), proc() { ResourceManager::new(setup_port, user_agent, sniffer_task).start(); }); setup_chan diff --git a/components/net/storage_task.rs b/components/net/storage_task.rs index d83a5c6f43c..aafe0885992 100644 --- a/components/net/storage_task.rs +++ b/components/net/storage_task.rs @@ -2,6 +2,7 @@ * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ +use std::borrow::ToOwned; use std::comm::{channel, Receiver, Sender}; use std::collections::HashMap; use std::collections::TreeMap; @@ -46,7 +47,7 @@ impl StorageTaskFactory for StorageTask { /// Create a StorageTask fn new() -> StorageTask { let (chan, port) = channel(); - spawn_named("StorageManager", proc() { + spawn_named("StorageManager".to_owned(), proc() { StorageManager::new(port).start(); }); chan diff --git a/components/script/dom/xmlhttprequest.rs b/components/script/dom/xmlhttprequest.rs index 4572d3221c7..191d3cf6dde 100644 --- a/components/script/dom/xmlhttprequest.rs +++ b/components/script/dom/xmlhttprequest.rs @@ -257,7 +257,7 @@ impl XMLHttpRequest { let req2 = req.clone(); // TODO: this exists only to make preflight check non-blocking // perhaps should be handled by the resource_loader? - spawn_named("XHR:Cors", proc() { + spawn_named("XHR:Cors".to_owned(), proc() { let response = req2.http_fetch(); chan.send(response); }); @@ -624,7 +624,7 @@ impl<'a> XMLHttpRequestMethods for JSRef<'a, XMLHttpRequest> { // inflight events queued up in the script task's port. let addr = Trusted::new(self.global.root().r().get_cx(), self, script_chan.clone()); - spawn_named("XHRTask", proc() { + spawn_named("XHRTask".to_owned(), proc() { let _ = XMLHttpRequest::fetch(&mut SyncOrAsync::Async(addr, script_chan), resource_task, load_data, @@ -936,7 +936,7 @@ impl<'a> PrivateXMLHttpRequestHelpers for JSRef<'a, XMLHttpRequest> { let oneshot = self.timer.borrow_mut() .oneshot(Duration::milliseconds(timeout as i64)); let terminate_sender = (*self.terminate_sender.borrow()).clone(); - spawn_named("XHR:Timer", proc () { + spawn_named("XHR:Timer".to_owned(), proc () { match oneshot.recv_opt() { Ok(_) => { terminate_sender.map(|s| s.send_opt(TerminateReason::TimedOut)); diff --git a/components/script/timers.rs b/components/script/timers.rs index 9c6ec47ffef..ef86c8ccd13 100644 --- a/components/script/timers.rs +++ b/components/script/timers.rs @@ -17,6 +17,7 @@ use servo_util::str::DOMString; use js::jsval::JSVal; +use std::borrow::ToOwned; use std::cell::Cell; use std::cmp; use std::collections::HashMap; @@ -127,7 +128,7 @@ impl TimerManager { TimerSource::FromWorker if is_interval == IsInterval::Interval => "Worker:SetInterval", TimerSource::FromWindow(_) => "Window:SetTimeout", TimerSource::FromWorker => "Worker:SetTimeout", - }; + }.to_owned(); spawn_named(spawn_name, proc() { let mut tm = tm; let duration = Duration::milliseconds(timeout as i64); diff --git a/components/util/memory.rs b/components/util/memory.rs index 0c1d1dac3b1..278a5a448fb 100644 --- a/components/util/memory.rs +++ b/components/util/memory.rs @@ -5,6 +5,7 @@ //! Memory profiling functions. use libc::{c_char,c_int,c_void,size_t}; +use std::borrow::ToOwned; use std::io::timer::sleep; #[cfg(target_os="linux")] use std::io::File; @@ -44,7 +45,7 @@ impl MemoryProfiler { Some(period) => { let period = Duration::milliseconds((period * 1000f64) as i64); let chan = chan.clone(); - spawn_named("Memory profiler timer", proc() { + spawn_named("Memory profiler timer".to_owned(), proc() { loop { sleep(period); if chan.send_opt(MemoryProfilerMsg::Print).is_err() { @@ -53,7 +54,7 @@ impl MemoryProfiler { } }); // Spawn the memory profiler. - spawn_named("Memory profiler", proc() { + spawn_named("Memory profiler".to_owned(), proc() { let memory_profiler = MemoryProfiler::new(port); memory_profiler.start(); }); @@ -61,7 +62,7 @@ impl MemoryProfiler { None => { // No-op to handle messages when the memory profiler is // inactive. - spawn_named("Memory profiler", proc() { + spawn_named("Memory profiler".to_owned(), proc() { loop { match port.recv_opt() { Err(_) | Ok(MemoryProfilerMsg::Exit) => break, diff --git a/components/util/task.rs b/components/util/task.rs index c6dc3547fb4..fbfe13078b3 100644 --- a/components/util/task.rs +++ b/components/util/task.rs @@ -9,7 +9,7 @@ use std::task::TaskBuilder; // use rtinstrument; use task_state; -pub fn spawn_named<S: IntoCow<'static, String, str>>(name: S, f: proc():Send) { +pub fn spawn_named(name: String, f: proc():Send) { let builder = task::TaskBuilder::new().named(name); builder.spawn(proc() { // rtinstrument::instrument(f); diff --git a/components/util/time.rs b/components/util/time.rs index 96d037c520a..abe35633e92 100644 --- a/components/util/time.rs +++ b/components/util/time.rs @@ -5,6 +5,7 @@ //! Timing functions. use collections::TreeMap; +use std::borrow::ToOwned; use std::comm::{Sender, channel, Receiver}; use std::f64; use std::io::timer::sleep; @@ -144,7 +145,7 @@ impl TimeProfiler { Some(period) => { let period = Duration::milliseconds((period * 1000f64) as i64); let chan = chan.clone(); - spawn_named("Time profiler timer", proc() { + spawn_named("Time profiler timer".to_owned(), proc() { loop { sleep(period); if chan.send_opt(TimeProfilerMsg::Print).is_err() { @@ -153,14 +154,14 @@ impl TimeProfiler { } }); // Spawn the time profiler. - spawn_named("Time profiler", proc() { + spawn_named("Time profiler".to_owned(), proc() { let mut profiler = TimeProfiler::new(port); profiler.start(); }); } None => { // No-op to handle messages when the time profiler is inactive. - spawn_named("Time profiler", proc() { + spawn_named("Time profiler".to_owned(), proc() { loop { match port.recv_opt() { Err(_) | Ok(TimeProfilerMsg::Exit) => break, |