aboutsummaryrefslogtreecommitdiffstats
path: root/components/net/resource_task.rs
diff options
context:
space:
mode:
Diffstat (limited to 'components/net/resource_task.rs')
-rw-r--r--components/net/resource_task.rs23
1 files changed, 13 insertions, 10 deletions
diff --git a/components/net/resource_task.rs b/components/net/resource_task.rs
index 15c48d111d9..ac463503a1b 100644
--- a/components/net/resource_task.rs
+++ b/components/net/resource_task.rs
@@ -18,11 +18,12 @@ use net_traits::ProgressMsg::Done;
use util::opts;
use util::task::spawn_named;
+use devtools_traits::{DevtoolsControlMsg};
use hyper::header::{ContentType, Header, SetCookie, UserAgent};
use hyper::mime::{Mime, TopLevel, SubLevel};
use std::borrow::ToOwned;
-use std::boxed;
+use std::boxed::{self, FnBox};
use std::collections::HashMap;
use std::env;
use std::fs::File;
@@ -30,7 +31,7 @@ use std::io::{BufReader, Read};
use std::str::FromStr;
use std::sync::Arc;
use std::sync::mpsc::{channel, Receiver, Sender};
-use std::thunk::Invoke;
+
static mut HOST_TABLE: Option<*mut HashMap<String, String>> = None;
@@ -48,7 +49,7 @@ pub fn global_init() {
let mut lines = String::new();
match file.read_to_string(&mut lines) {
- Ok(()) => (),
+ Ok(_) => (),
Err(_) => return,
};
@@ -137,11 +138,11 @@ pub fn start_sending_opt(start_chan: LoadConsumer, metadata: Metadata) -> Result
}
/// Create a ResourceTask
-pub fn new_resource_task(user_agent: Option<String>) -> ResourceTask {
+pub fn new_resource_task(user_agent: Option<String>, devtools_chan: Option<Sender<DevtoolsControlMsg>>) -> ResourceTask {
let (setup_chan, setup_port) = channel();
let setup_chan_clone = setup_chan.clone();
spawn_named("ResourceManager".to_owned(), move || {
- ResourceManager::new(setup_port, user_agent, setup_chan_clone).start();
+ ResourceManager::new(setup_port, user_agent, setup_chan_clone, devtools_chan).start();
});
setup_chan
}
@@ -186,17 +187,19 @@ struct ResourceManager {
cookie_storage: CookieStorage,
resource_task: Sender<ControlMsg>,
mime_classifier: Arc<MIMEClassifier>,
+ devtools_chan: Option<Sender<DevtoolsControlMsg>>
}
impl ResourceManager {
fn new(from_client: Receiver<ControlMsg>, user_agent: Option<String>,
- resource_task: Sender<ControlMsg>) -> ResourceManager {
+ resource_task: Sender<ControlMsg>, devtools_channel: Option<Sender<DevtoolsControlMsg>>) -> ResourceManager {
ResourceManager {
from_client: from_client,
user_agent: user_agent,
cookie_storage: CookieStorage::new(),
resource_task: resource_task,
mime_classifier: Arc::new(MIMEClassifier::new()),
+ devtools_chan: devtools_channel
}
}
}
@@ -239,15 +242,15 @@ impl ResourceManager {
self.user_agent.as_ref().map(|ua| load_data.headers.set(UserAgent(ua.clone())));
fn from_factory(factory: fn(LoadData, LoadConsumer, Arc<MIMEClassifier>))
- -> Box<Invoke<(LoadData, LoadConsumer, Arc<MIMEClassifier>)> + Send> {
- box move |(load_data, senders, classifier)| {
+ -> Box<FnBox(LoadData, LoadConsumer, Arc<MIMEClassifier>) + Send> {
+ box move |load_data, senders, classifier| {
factory(load_data, senders, classifier)
}
}
let loader = match &*load_data.url.scheme {
"file" => from_factory(file_loader::factory),
- "http" | "https" | "view-source" => http_loader::factory(self.resource_task.clone()),
+ "http" | "https" | "view-source" => http_loader::factory(self.resource_task.clone(), self.devtools_chan.clone()),
"data" => from_factory(data_loader::factory),
"about" => from_factory(about_loader::factory),
_ => {
@@ -259,6 +262,6 @@ impl ResourceManager {
};
debug!("resource_task: loading url: {}", load_data.url.serialize());
- loader.invoke((load_data, consumer, self.mime_classifier.clone()));
+ loader.call_box((load_data, consumer, self.mime_classifier.clone()));
}
}