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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
/* ISC license. */
#ifndef SKABUS_RPCD_H
#define SKABUS_RPCD_H
#include <sys/types.h>
#include <stdint.h>
#include <regex.h>
#include <skalibs/uint64.h>
#include <skalibs/tai.h>
#include <skalibs/iopause.h>
#include <skalibs/genalloc.h>
#include <skalibs/genset.h>
#include <skalibs/gensetdyn.h>
#include <skalibs/unixmessage.h>
#include <skalibs/unixconnection.h>
#include <skabus/rpc.h>
#define X() strerr_dief1x(101, "unexpected error - please submit a bug-report.") ;
/*
query: queries accepted from client, sent to interface
The list is stored in a gensetdyn.
Looked up by serial for answers or cancels.
*/
typedef struct query_s query_t, *query_t_ref ;
struct query_s
{
uint64_t serial ;
tain deadline ;
uint32_t client ;
uint32_t clientindex ;
uint32_t interface ;
uint32_t interfaceindex ;
} ;
#define QUERY_ZERO \
{ \
.serial = 0, \
.deadline = TAIN_ZERO, \
.client = 0, \
.clientindex = 0, \
.interface = 0, \
.interfaceindex = 0 \
}
/*
interfaces: registered R interfaces.
The list is stored in a gensetdyn.
Looked up by name.
*/
typedef struct interface_s interface_t, *interface_t_ref ;
struct interface_s
{
char name[SKABUS_RPC_INTERFACE_MAXLEN+1] ;
regex_t re ; /* clients who can access that interface */
uint32_t id ;
uint32_t client ;
uint32_t index ; /* in the owner's interfaces list */
gensetdyn queries ; /* uint32_t */
} ;
#define INTERFACE_ZERO { .name = "", .id = 0, .client = 0, .index = 0, .queries = GENSETDYN_ZERO }
/*
client: client connections.
The list is stored in a genset.
List browsed at every iopause iteration, so needs a next field.
*/
typedef struct client_s client_t, *client_t_ref ;
struct client_s
{
uint32_t next ;
uid_t uid ;
gid_t gid ;
tain deadline ;
genalloc interfaces ; /* uint32_t */
gensetdyn queries ; /* uint32_t */
unixconnection sync ;
unixconnection async ;
uint32_t xindex[2] ;
regex_t idstr_re ;
regex_t interfaces_re ;
} ;
#define CLIENT_ZERO \
{ \
.next = 0, \
.uid = (uid_t)-1, \
.gid = (gid_t)-1, \
.deadline = TAIN_ZERO, \
.interfaces = GENALLOC_ZERO, \
.queries = GENALLOC_ZERO, \
.sync = UNIXCONNECTION_ZERO, \
.async = UNIXCONNECTION_ZERO, \
.xindex = { 0, 0 }, \
}
extern gensetdyn queries ;
#define QUERY(i) GENSETDYN_P(query_t, &queries, (i))
#define queries_pending() gensetdyn_n(&queries)
extern gensetdyn interfaces ;
#define INTERFACE(i) GENSETDYN_P(interface_t, &interfaces, (i))
extern genset *clients ;
extern unsigned int sentinel ;
#define CLIENT(i) genset_p(client_t, clients, (i))
#define numconn (genset_n(clients) - 1)
extern void query_remove (uint32_t) ;
extern void query_fail (uint32_t, unsigned char) ;
extern int query_cancel (uint32_t, unsigned char) ;
extern int query_cancelremove (uint32_t, unsigned char) ;
extern int query_lookup_by_serial (uint64_t, uint32_t *) ;
extern int query_lookup_by_mindeadline (uint32_t *) ;
extern void query_get_mindeadline (tain *) ;
extern int query_add (uint32_t *, tain const *, uint32_t, uint32_t) ;
extern int query_send (uint32_t, unixmessage const *) ;
extern int query_sendpm (uint32_t, unixmessage const *) ;
extern void query_reply (uint32_t, char, unixmessage const *) ;
extern void interface_remove (uint32_t) ;
extern int interface_lookup_by_name (char const *, uint32_t *) ;
extern int interface_add (uint32_t *, char const *, size_t, uint32_t, char const *, uint32_t) ;
#define client_isregistered(cc) genalloc_len(uint32_t, &CLIENT(cc)->interfaces)
#define client_idstr(c) (INTERFACE(genalloc_s(uint32_t, &(c)->interfaces)[0])->name + 1)
extern void client_remove (uint32_t, uint32_t) ;
extern void client_add (uint32_t *, regex_t const *, regex_t const *, uid_t, gid_t, int, uint32_t) ;
extern void client_nextdeadline (uint32_t, tain *) ;
extern void client_setdeadline (client_t *) ;
extern int client_prepare_iopause (uint32_t, tain *, iopause_fd *, uint32_t *, int) ;
extern int client_flush (uint32_t, iopause_fd const *) ;
extern int client_read (uint32_t, iopause_fd const *) ;
extern int parse_protocol_sync (unixmessage const *, void *) ;
extern int parse_protocol_async (unixmessage const *, void *) ;
extern tain answertto ;
#endif
|
