fs/rpc_bind_server.py at master · saalweachter/fs · GitHub

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
"""
RPC bind server.

"""

from rpc_bind import *


@rpc_program(prog=100000)
class RPCBPROG(object):
    def __init__(self):
        self.RPCBVERS = RPCBPROG.RPCBVERS()
        self.RPCBVERS4 = RPCBPROG.RPCBVERS4()

    @rpc_version(vers=3)
    class RPCBVERS(object):
        def __init__(self):
            pass
        @rpc_procedure(proc=1, args=rpcb, ret=xdr_bool)
        def RPCBPROC_SET(self, arg):
            pass
        @rpc_procedure(proc=2, args=rpcb, ret=xdr_bool)
        def RPCBPROC_UNSET(self, arg):
            pass
        @rpc_procedure(proc=3, args=rpcb, ret=xdr_string)
        def RPCBPROC_GETADDR(self, arg):
            pass
        @rpc_procedure(proc=4, args=xdr_void, ret=rpcblist_ptr)
        def RPCBPROC_DUMP(self, arg):
            pass
        @rpc_procedure(proc=5, args=rpcb_rmtcallargs, ret=rpcb_rmtcallres)
        def RPCBPROC_CALLIT(self, arg):
            pass
        @rpc_procedure(proc=6, args=xdr_void, ret=xdr_uint)
        def RPCBPROC_GETTIME(self, arg):
            pass
        @rpc_procedure(proc=7, args=xdr_string, ret=netbuf)
        def RPCBPROC_UADDR2TADDR(self, arg):
            pass
        @rpc_procedure(proc=1, args=netbuf, ret=xdr_string)
        def RPCBPROC_TADDR2UADDR(self, arg):
            pass

    @rpc_version(vers=4)
    class RPCBVERS4(object):
        def __init__(self):
            pass
        @rpc_procedure(proc=1, args=rpcb, ret=xdr_bool)
        def RPCBPROC_SET(self, arg):
            pass
        @rpc_procedure(proc=2, args=rpcb, ret=xdr_bool)
        def RPCBPROC_UNSET(self, arg):
            pass
        @rpc_procedure(proc=3, args=rpcb, ret=xdr_string)
        def RPCBPROC_GETADDR(self, arg):
            pass
        @rpc_procedure(proc=4, args=xdr_void, ret=rpcblist_ptr)
        def RPCBPROC_DUMP(self):
            pass
        @rpc_procedure(proc=5, args=rpcb_rmtcallargs, ret=rpcb_rmtcallres)
        def RPCBPROC_BCAST(self, arg):
            """
            NOTE: RPCBPROC_BCAST has the same functionality as CALLIT;
            the new name is intended to indicate that this
            procedure should be used for broadcast RPC, and
            RPCBPROC_INDIRECT should be used for indirect calls.
            """
            pass
        @rpc_procedure(proc=6, args=xdr_void, ret=xdr_uint)
        def RPCBPROC_GETTIME(self):
            pass
        @rpc_procedure(proc=7, args=xdr_string, ret=netbuf)
        def RPCBPROC_UADDR2TADDR(self, arg):
            pass
        @rpc_procedure(proc=8, args=netbuf, ret=xdr_string)
        def RPCBPROC_TADDR2UADDR(self, arg):
            pass
        @rpc_procedure(proc=9, args=rpcb, ret=xdr_string)
        def RPCBPROC_GETVERSADDR(self, arg):
            pass
        @rpc_procedure(proc=10, args=rpcb_rmtcallargs, ret=rpcb_rmtcallres)
        def RPCBPROC_INDIRECT(self, arg):
            pass
        @rpc_procedure(proc=11, args=rpcb, ret=rpcb_entry_list_ptr)
        def RPCBPROC_GETADDRLIST(self, arg):
            pass
        @rpc_procedure(proc=12, args=xdr_void, ret=rpcb_stat_byvers)
        def RPCBPROC_GETSTAT(self):
            pass


if __name__ == "__main__":
    from rpc import rpc_server
    server = rpc_server(111)
    server.add_program(RPCBPROG())
    for i in range(60):
        print("loop.")
        server.cycle(1000.0)
    import sys
    sys.exit(0)