Mirrors/servo
1
0
Fork 0
mirror of https://github.com/servo/servo.git synced 2025-08-02 12:10:29 +01:00
Code Issues Projects Releases Packages Wiki Activity

Format components debugger and deny_public_fields #21373

Browse source
This commit is contained in:
kingdido999 2018-09-01 09:44:53 +08:00
parent 577830de90
commit e203cde9be
2 changed files with 24 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

36
components/debugger/lib.rs
View file

@ -18,7 +18,7 @@ enum Message {
pub struct Sender(mpsc::Sender<Message>);
struct Connection {
sender: ws::Sender
sender: ws::Sender,
}
impl Handler for Connection {
@ -39,23 +39,27 @@ impl Handler for Connection {
pub fn start_server(port: u16) -> Sender {
debug!("Starting server.");
let (sender, receiver) = channel();
thread::Builder::new().name("debugger".to_owned()).spawn(move || {
let socket = Builder::new().build(|sender: ws::Sender| {
Connection { sender: sender }
}).unwrap();
let sender = socket.broadcaster();
thread::Builder::new().name("debugger-websocket".to_owned()).spawn(move || {
socket.listen(("127.0.0.1", port)).unwrap();
}).expect("Thread spawning failed");
while let Ok(message) = receiver.recv() {
match message {
Message::ShutdownServer => {
break;
thread::Builder::new()
.name("debugger".to_owned())
.spawn(move || {
let socket = Builder::new()
.build(|sender: ws::Sender| Connection { sender: sender })
.unwrap();
let sender = socket.broadcaster();
thread::Builder::new()
.name("debugger-websocket".to_owned())
.spawn(move || {
socket.listen(("127.0.0.1", port)).unwrap();
}).expect("Thread spawning failed");
while let Ok(message) = receiver.recv() {
match message {
Message::ShutdownServer => {
break;
},
}
}
}
sender.shutdown().unwrap();
}).expect("Thread spawning failed");
sender.shutdown().unwrap();
}).expect("Thread spawning failed");
Sender(sender)
}