server/game2006rust
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
azw 2024-05-12 08:26:32 +08:00
parent e0d85a137a
commit 32e21d71ba
2 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
server/stat/src/app/user_app.rs
View File

@ -80,6 +80,7 @@ impl f9::app::UserApp for UserApp {
impl UserApp { impl UserApp {
pub fn add_down_stream_pack(&self, socket_handle: u16, data: bytes::BytesMut) { pub fn add_down_stream_pack(&self, socket_handle: u16, data: bytes::BytesMut) {
println!("add_down_stream_pack1 len:{0}", data.len());
let node = Rc::new(RefCell::new(DownStreamPack{ let node = Rc::new(RefCell::new(DownStreamPack{
holder: Default::default(), holder: Default::default(),
socket_handle: socket_handle, socket_handle: socket_handle,

13
server/stat/src/listener/wslistener.rs
View File

@ -227,12 +227,13 @@ async fn upstream_enter(stream_arc: Arc<Mutex<TcpStream>>, down_pack_queue: Arc<
let node = &work_list.borrow().first_entry(); let node = &work_list.borrow().first_entry();
node.upgrade().unwrap().borrow_mut().entry.borrow_mut().del_init(); node.upgrade().unwrap().borrow_mut().entry.borrow_mut().del_init();
data = node.upgrade().unwrap().borrow().data.clone(); data = node.upgrade().unwrap().borrow().data.clone();
break;
//stream.write_all(node.upgrade().unwrap().borrow().data.as_ref()).await; //stream.write_all(node.upgrade().unwrap().borrow().data.as_ref()).await;
//stream.write_all(data.as_ref()).await; //stream.write_all(data.as_ref()).await;
} }
} }
if data.len() > 0 { if data.len() > 0 {
println!("write_all len:{0}", data.len()); println!("write_all2 len:{0}", data.len());
stream.write_all(data.as_ref()).await; stream.write_all(data.as_ref()).await;
} }
} }
@ -318,15 +319,9 @@ impl WsListener {
} }
pub fn add_down_stream_pack(&self, data: Weak::<RefCell::<DownStreamPack>>) { pub fn add_down_stream_pack(&self, data: Weak::<RefCell::<DownStreamPack>>) {
println!("add_down_stream_pack2 len:{0}", data.upgrade().unwrap().borrow().data.len());
let socket_handle = data.upgrade().unwrap().borrow().socket_handle; let socket_handle = data.upgrade().unwrap().borrow().socket_handle;
match self.socket_hash.get(&socket_handle) { self.down_pack_queue.lock().as_ref().unwrap().push(&data.upgrade().unwrap().borrow().entry);
Some(socket) => {
let a = 0;
}
None => {
let a = 0;
}
}
} }
fn on_connect(&mut self, conn: &mut WsConn, socket: Recipient<DownStreamMessage>) { fn on_connect(&mut self, conn: &mut WsConn, socket: Recipient<DownStreamMessage>) {
self.cur_socket_handle += 1; self.cur_socket_handle += 1;