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 18:06:50 +08:00
parent 58fa1b92e5
commit 8668cf7686
2 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/stat/src/common/types.rs
View File

@ -1,6 +1,7 @@
use std::sync::Arc;
use std::sync::Mutex;
use actix::dev::MessageResponse;
use actix::Message;
pub struct DownStreamPack {
holder: Option<Arc::<std::sync::Mutex::<Self>>>,
@ -9,6 +10,12 @@ pub struct DownStreamPack {
pub entry: Arc::<std::sync::Mutex::<r9::ListHeadLock<Self>>>,
}
#[derive(Message)]
#[rtype(result = "()")]
pub struct DownStreamMessage {
pub data: actix_web::web::Bytes,
}
impl DownStreamPack {
pub fn new(socket_handle: u16, data: bytes::BytesMut) -> Arc<Mutex<Self>> {

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

@ -21,7 +21,7 @@ use crate::app::UserApp;
use crate::constant;
use tokio::net::TcpStream;
use tokio::runtime::Runtime;
use crate::common::types::DownStreamPack;
use crate::common::types::{DownStreamPack, DownStreamMessage};
use tokio::io::{AsyncWriteExt};
use std::sync::OnceLock;
use std::sync::atomic::{AtomicU16, Ordering};
@ -42,12 +42,6 @@ pub struct WsListener {
static WsListenerInstance: OnceLock<WsListener> = OnceLock::new();
#[derive(Message)]
#[rtype(result = "()")]
pub struct DownStreamMessage {
data: actix_web::web::Bytes,
}
/// Define HTTP actor
pub struct WsConn {
socket_handle: u16,