ns_game 0.2.26

ns_game lib.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use crate::GAME;
use anyhow::{Context, Result};
use netxclient::prelude::*;

use super::interface::*;

///服务器调度控制器
pub struct MasterController {
    server_id: u32,
    server: NetxClientArcDef,
}

impl MasterController {
    pub fn new(server_id: u32, server: NetxClientArcDef) -> Self {
        Self { server_id, server }
    }
}

///服务器调度控制器
#[build(MasterController)]
pub trait IMasterController {
    #[tag(connect)]
    async fn connected(&self) -> Result<()>;
    #[tag(disconnect)]
    async fn disconnect(&self) -> Result<()>;
    /// ping
    #[tag(1000)]
    async fn ping(&self, time: i64) -> Result<i64>;
}

#[build_impl]
impl IMasterController for MasterController {
    #[inline]
    async fn connected(&self) -> Result<()> {
        let server = impl_ref!(self.server=>IMaster);
        if server.register_slot_server(self.server_id).await? {
            log::info!("connect master server Ok");
        } else {
            panic!("register server id fail,check server id!!")
        }
        Ok(())
    }

    #[inline]
    async fn disconnect(&self) -> Result<()> {
        //和大厅断线处理
        //清除所有的token 和peer
        GAME.get()
            .context("not found GAME?")?
            .peers
            .clear_all()
            .await;
        Ok(())
    }

    /// ping
    #[inline]
    async fn ping(&self, time: i64) -> Result<i64> {
        log::debug!("master ping:{time}");
        Ok(time)
    }
}