aboutsummaryrefslogtreecommitdiffstats
path: root/components/script/dom/websocket.rs
diff options
context:
space:
mode:
authorMs2ger <Ms2ger@gmail.com>2015-11-05 12:23:18 +0100
committerMs2ger <Ms2ger@gmail.com>2015-11-05 12:23:18 +0100
commit0a158967e081255d0995403b76559d5ce381244c (patch)
tree00a311947e033cc8aed853336bb4bd597267757f /components/script/dom/websocket.rs
parent8b030c5177444a5274b1c329802ae9d998cf5df9 (diff)
downloadservo-0a158967e081255d0995403b76559d5ce381244c.tar.gz
servo-0a158967e081255d0995403b76559d5ce381244c.zip
Cleanup WebSocket::Send_Impl.
Diffstat (limited to 'components/script/dom/websocket.rs')
-rw-r--r--components/script/dom/websocket.rs21
1 files changed, 7 insertions, 14 deletions
diff --git a/components/script/dom/websocket.rs b/components/script/dom/websocket.rs
index 8e3cbc9938d..c0ad9e3d253 100644
--- a/components/script/dom/websocket.rs
+++ b/components/script/dom/websocket.rs
@@ -296,18 +296,13 @@ impl WebSocket {
// https://html.spec.whatwg.org/multipage/#dom-websocket-send
fn Send_Impl(&self, data_byte_len: u64) -> Fallible<bool> {
-
- let mut return_after_buffer = false;
-
- match self.ready_state.get() {
+ let return_after_buffer = match self.ready_state.get() {
WebSocketRequestState::Connecting => {
return Err(Error::InvalidState);
},
- WebSocketRequestState::Open => (),
- WebSocketRequestState::Closing | WebSocketRequestState::Closed => {
- return_after_buffer = true;
- }
- }
+ WebSocketRequestState::Open => false,
+ WebSocketRequestState::Closing | WebSocketRequestState::Closed => true,
+ };
let global = self.global.root();
let chan = global.r().script_chan();
@@ -315,23 +310,21 @@ impl WebSocket {
let new_buffer_amount = (self.buffered_amount.get() as u64) + data_byte_len;
if new_buffer_amount > (u32::max_value() as u64) {
-
self.buffered_amount.set(u32::max_value());
self.full.set(true);
let _ = self.Close(None, None);
return Ok(false);
- } else {
- self.buffered_amount.set(new_buffer_amount as u32);
}
+ self.buffered_amount.set(new_buffer_amount as u32);
+
if return_after_buffer {
return Ok(false);
}
- if !self.clearing_buffer.get() &&
- self.ready_state.get() == WebSocketRequestState::Open {
+ if !self.clearing_buffer.get() && self.ready_state.get() == WebSocketRequestState::Open {
self.clearing_buffer.set(true);
let task = box BufferedAmountTask {