diff options
author | bors-servo <lbergstrom+bors@mozilla.com> | 2016-04-20 05:30:59 +0530 |
---|---|---|
committer | bors-servo <lbergstrom+bors@mozilla.com> | 2016-04-20 05:30:59 +0530 |
commit | bebc1dc859192d7fdcfc53e550cbf51343f4375a (patch) | |
tree | 0dd1f3a98fe14d55f0bcc642f301ec0c20ed8582 /components/net/resource_thread.rs | |
parent | 82873d688e9260b5fc755ec16eec959d94a5cb14 (diff) | |
parent | f0a640321134ab21eaf06d85cdd3c37cb48b50d9 (diff) | |
download | servo-bebc1dc859192d7fdcfc53e550cbf51343f4375a.tar.gz servo-bebc1dc859192d7fdcfc53e550cbf51343f4375a.zip |
Auto merge of #10725 - frewsxcv:net-cleanup, r=KiChjang
A few minor `net` component cleanups.
<!-- Reviewable:start -->
This change is [<img src="https://reviewable.io/review_button.svg" height="35" align="absmiddle" alt="Reviewable"/>](https://reviewable.io/reviews/servo/servo/10725)
<!-- Reviewable:end -->
Diffstat (limited to 'components/net/resource_thread.rs')
-rw-r--r-- | components/net/resource_thread.rs | 22 |
1 files changed, 10 insertions, 12 deletions
diff --git a/components/net/resource_thread.rs b/components/net/resource_thread.rs index bb839176b14..0bc6f19e053 100644 --- a/components/net/resource_thread.rs +++ b/components/net/resource_thread.rs @@ -133,7 +133,7 @@ fn start_sending_opt(start_chan: LoadConsumer, metadata: Metadata) -> Result<Pro /// Create a ResourceThread pub fn new_resource_thread(user_agent: String, - devtools_chan: Option<Sender<DevtoolsControlMsg>>) -> ResourceThread { + devtools_chan: Option<Sender<DevtoolsControlMsg>>) -> ResourceThread { let hsts_preload = HstsList::from_servo_preload(); let (setup_chan, setup_port) = ipc::channel().unwrap(); let setup_chan_clone = setup_chan.clone(); @@ -227,17 +227,15 @@ impl CancellationListener { } pub fn is_cancelled(&self) -> bool { - match self.cancel_resource { - Some(ref resource) => { - match resource.cancel_receiver.try_recv() { - Ok(_) => { - self.cancel_status.set(true); - true - }, - Err(_) => self.cancel_status.get(), - } - }, - None => false, // channel doesn't exist! + let resource = match self.cancel_resource { + Some(ref resource) => resource, + None => return false, // channel doesn't exist! + }; + if resource.cancel_receiver.try_recv().is_ok() { + self.cancel_status.set(true); + true + } else { + self.cancel_status.get() } } } |