bios-basic 0.2.0

An embeddable message queue system
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

//! SPI macros

#[macro_export]
macro_rules! spi_service_call {
    ($mod:path, $fun:ident, $funs:ident, $ctx:ident, $inst:ident, @args: {$($args: ident),*}) => {
        {
            use $mod::*;
            $fun($($args,)* $funs, $ctx, $inst).await
        }
    };
}

#[macro_export]
macro_rules! spi_dispatch_function {
    (
        $service:ident,
        $funs:ident, $ctx:ident, $inst:ident,
        @dispatch: {
            $(
                $(#[$attr:meta])*
                $code:pat=>$mod:path,
            )*
        },
        @args: $args: tt
    ) => {
        match $inst.kind_code() {
            $(
                $(#[$attr])*
                $code => $crate::spi_service_call!($mod, $service, $funs, $ctx, $inst, @args: $args),
            )*
            kind_code => Err($funs.bs_not_implemented(kind_code)),
        }

    };
}

/// SPI request dispatch macro
///
/// SPI请求分发宏
///
/// Used to generate request dispatch code in the SPI service
///
/// 用于批量生成请求分发代码
#[macro_export]
macro_rules! spi_dispatch_service {
    (
        /// Whether it is a managed request
        /// 是否是管理模式
        @mgr: $mgr: expr,
        /// Backend service initialization method, called when the backend service instance is not initialized
        ///
        /// 后端服务初始化方法，当后端服务实例未初始化时调用
        @init: $init: expr,
        /// Service object to dispatch to
        ///
        /// 分发到的服务对象
        @dispatch: $dispatch:tt,
        /// Collection of request methods
        ///
        /// 请求的方法集合
        @method: {
            $(
                $(#[$attr:meta])*
                $service:ident($($arg: ident: $type: ty),*) -> $ret:ty;
            )*
        }

    ) => {
        $(
            $(#[$attr])*
            pub async fn $service($($arg: $type,)* funs: &tardis::TardisFunsInst, ctx: &tardis::basic::dto::TardisContext) -> $ret {
                let arc_inst = funs.init(None, ctx, $mgr, $init).await?;
                let inst = arc_inst.as_ref();
                $crate::spi_dispatch_service!(@dispatch $service, funs, ctx, inst, @dispatch: $dispatch, @args: {$($arg),*})
            }
        )*
    };
    (@dispatch
        $service:ident,
        $funs:ident, $ctx:ident, $inst:ident,
        @dispatch: {
            $(
                $(#[$attr:meta])*
                $code:pat=>$mod:path,
            )*
        },
        @args: $args: tt
    ) => {
        match $inst.kind_code() {
            $(
                $(#[$attr])*
                $code => $crate::spi_dispatch_service!(@call $mod, $service, $funs, $ctx, $inst, @args: $args),
            )*
            kind_code => Err($funs.bs_not_implemented(kind_code)),
        }
    };
    (@call
        $mod:path, $fun:ident, $funs:ident, $ctx:ident, $inst:ident, @args: {$($args: ident),*}) => {
        {
            use $mod::*;
            $fun($($args,)* $funs, $ctx, $inst).await
        }
    };
}