aboutsummaryrefslogtreecommitdiffstats
path: root/components/script/dom
diff options
context:
space:
mode:
authorbors-servo <lbergstrom+bors@mozilla.com>2015-11-27 10:47:00 +0530
committerbors-servo <lbergstrom+bors@mozilla.com>2015-11-27 10:47:00 +0530
commitf13c72d68e1e7f49e241938bfd6e8a588c68e86b (patch)
tree5a4f80662d4c7b5b18adc49a325015e971380225 /components/script/dom
parentbc618b0d535e0e67a7ea845c026678113f000d64 (diff)
parentdc0e467945e7fb8eaf93f9e40e7ebcb2d5f52b0c (diff)
downloadservo-f13c72d68e1e7f49e241938bfd6e8a588c68e86b.tar.gz
servo-f13c72d68e1e7f49e241938bfd6e8a588c68e86b.zip
Auto merge of #8446 - servo:rustup_20151110, r=SimonSapin+Ms2ger+jdm+Manishearth
Rust upgrade to rustc 1.6.0-nightly (5b4986fa5 2015-11-08) <s>DO NOT r+ or try+ this</s> <s>It causes an OOM (https://github.com/rust-lang/rust/issues/29740) and can crash the OS. Probably will set our CI on fire. </s> <!-- Reviewable:start --> [<img src="https://reviewable.io/review_button.png" height=40 alt="Review on Reviewable"/>](https://reviewable.io/reviews/servo/servo/8446) <!-- Reviewable:end -->
Diffstat (limited to 'components/script/dom')
-rw-r--r--components/script/dom/document.rs2
-rw-r--r--components/script/dom/websocket.rs30
2 files changed, 18 insertions, 14 deletions
diff --git a/components/script/dom/document.rs b/components/script/dom/document.rs
index 19adfbd490d..a3874f9b64f 100644
--- a/components/script/dom/document.rs
+++ b/components/script/dom/document.rs
@@ -1659,7 +1659,7 @@ impl DocumentMethods for Document {
if let Some(&Host::Ipv6(ipv6)) = origin.host() {
// Omit square brackets for IPv6 addresses.
- return DOMString::from(ipv6.serialize());
+ return DOMString::from(ipv6.to_string());
}
DOMString::from(origin.serialize_host().unwrap_or_else(|| "".to_owned()))
diff --git a/components/script/dom/websocket.rs b/components/script/dom/websocket.rs
index d96ee00311d..f2060566877 100644
--- a/components/script/dom/websocket.rs
+++ b/components/script/dom/websocket.rs
@@ -39,7 +39,7 @@ use websocket::client::receiver::Receiver;
use websocket::client::request::Url;
use websocket::client::sender::Sender;
use websocket::header::Origin;
-use websocket::message::CloseData;
+use websocket::message::Type;
use websocket::result::WebSocketResult;
use websocket::stream::WebSocketStream;
use websocket::ws::receiver::Receiver as WSReceiver;
@@ -264,23 +264,27 @@ impl WebSocket {
sender.send(CommonScriptMsg::RunnableMsg(WebSocketEvent, open_task)).unwrap();
for message in receiver.incoming_messages() {
- let message = match message {
- Ok(Message::Text(text)) => MessageData::Text(text),
- Ok(Message::Binary(data)) => MessageData::Binary(data),
- Ok(Message::Ping(data)) => {
- ws_sender.lock().unwrap().send_message(Message::Pong(data)).unwrap();
+ let message: Message = match message {
+ Ok(m) => m,
+ Err(_) => break,
+ };
+ let message = match message.opcode {
+ Type::Text => MessageData::Text(String::from_utf8_lossy(&message.payload).into_owned()),
+ Type::Binary => MessageData::Binary(message.payload.into_owned()),
+ Type::Ping => {
+ let pong = Message::pong(message.payload);
+ ws_sender.lock().unwrap().send_message(&pong).unwrap();
continue;
},
- Ok(Message::Pong(_)) => continue,
- Ok(Message::Close(data)) => {
- ws_sender.lock().unwrap().send_message(Message::Close(data)).unwrap();
+ Type::Pong => continue,
+ Type::Close => {
+ ws_sender.lock().unwrap().send_message(&message).unwrap();
let task = box CloseTask {
addr: address,
};
sender.send(CommonScriptMsg::RunnableMsg(WebSocketEvent, task)).unwrap();
break;
},
- Err(_) => break,
};
let message_task = box MessageReceivedTask {
address: address.clone(),
@@ -385,7 +389,7 @@ impl WebSocketMethods for WebSocket {
if send_data {
let mut other_sender = self.sender.borrow_mut();
let my_sender = other_sender.as_mut().unwrap();
- let _ = my_sender.lock().unwrap().send_message(Message::Text(data.0));
+ let _ = my_sender.lock().unwrap().send_message(&Message::text(data.0));
}
Ok(())
@@ -404,7 +408,7 @@ impl WebSocketMethods for WebSocket {
if send_data {
let mut other_sender = self.sender.borrow_mut();
let my_sender = other_sender.as_mut().unwrap();
- let _ = my_sender.lock().unwrap().send_message(Message::Binary(data.clone_bytes()));
+ let _ = my_sender.lock().unwrap().send_message(&Message::binary(data.clone_bytes()));
}
Ok(())
@@ -420,7 +424,7 @@ impl WebSocketMethods for WebSocket {
if let Some(sender) = sender.as_mut() {
let code: u16 = this.code.get();
let reason = this.reason.borrow().clone();
- let _ = sender.lock().unwrap().send_message(Message::Close(Some(CloseData::new(code, reason))));
+ let _ = sender.lock().unwrap().send_message(&Message::close_because(code, reason));
}
}