diff options
author | Ms2ger <Ms2ger@gmail.com> | 2015-11-05 12:23:18 +0100 |
---|---|---|
committer | Ms2ger <Ms2ger@gmail.com> | 2015-11-05 12:23:18 +0100 |
commit | 0a158967e081255d0995403b76559d5ce381244c (patch) | |
tree | 00a311947e033cc8aed853336bb4bd597267757f /components/script/dom/websocket.rs | |
parent | 8b030c5177444a5274b1c329802ae9d998cf5df9 (diff) | |
download | servo-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.rs | 21 |
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 { |