aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorbors-servo <metajack+bors@gmail.com>2014-11-17 07:57:29 -0700
committerbors-servo <metajack+bors@gmail.com>2014-11-17 07:57:29 -0700
commit9833cfbbffa79c74d9ee794e836c8007cd802c10 (patch)
treeb2a7c00eb4e56a9bd1f05ac918eac241f6a8ad01
parentb9dcaa34c32333ae16da7a5f11835c7d905da4d3 (diff)
parentd8b0f973b0dea54736b1d3d4bb13494f9a605ee7 (diff)
downloadservo-9833cfbbffa79c74d9ee794e836c8007cd802c10.tar.gz
servo-9833cfbbffa79c74d9ee794e836c8007cd802c10.zip
auto merge of #4017 : Ms2ger/servo/sniffertask, r=jdm
-rw-r--r--components/net/sniffer_task.rs39
1 files changed, 18 insertions, 21 deletions
diff --git a/components/net/sniffer_task.rs b/components/net/sniffer_task.rs
index a39e6fc2beb..9df39e59a51 100644
--- a/components/net/sniffer_task.rs
+++ b/components/net/sniffer_task.rs
@@ -10,37 +10,34 @@ use resource_task::{LoadResponse};
pub type SnifferTask = Sender<LoadResponse>;
pub fn new_sniffer_task(next_rx: Sender<LoadResponse>) -> SnifferTask {
- let(sen, rec) = channel();
- let builder = TaskBuilder::new().named("SnifferManager");
- builder.spawn(proc(){
- SnifferManager::new(rec).start(next_rx);
- });
- sen
+ let (sen, rec) = channel();
+ let builder = TaskBuilder::new().named("SnifferManager");
+ builder.spawn(proc() {
+ SnifferManager::new(rec).start(next_rx);
+ });
+ sen
}
struct SnifferManager {
- data_receiver: Receiver<LoadResponse>,
+ data_receiver: Receiver<LoadResponse>,
}
impl SnifferManager {
- fn new(data_receiver: Receiver <LoadResponse>) -> SnifferManager {
- SnifferManager {
- data_receiver: data_receiver,
+ fn new(data_receiver: Receiver<LoadResponse>) -> SnifferManager {
+ SnifferManager {
+ data_receiver: data_receiver,
+ }
}
- }
}
impl SnifferManager {
- fn start(&self, next_rx: Sender<LoadResponse>) {
- loop {
- match self.data_receiver.try_recv() {
- Ok(snif_data) => next_rx.send(snif_data),
- Err(e) => {
- if e == Disconnected {
- break
- }
+ fn start(&self, next_rx: Sender<LoadResponse>) {
+ loop {
+ match self.data_receiver.try_recv() {
+ Ok(snif_data) => next_rx.send(snif_data),
+ Err(Disconnected) => break,
+ Err(_) => (),
+ }
}
- }
}
- }
}