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
147
148
149
150
151
152
153
154
155
156
|
// SPDX-License-Identifier: GPL-2.0-or-later
/*
* September 9 2024, Christian Hopps <chopps@labn.net>
*
* Copyright (c) 2024, LabN Consulting, L.L.C.
*/
#include <lib/libfrr.h>
#include <lib/zebra.h>
#include <lib/privs.h>
#include <lib/version.h>
#include "mgmt_be_client.h"
extern void *_rust_preinit(struct frr_daemon_info *daemon);
extern void *_rust_init(struct event_loop *master, void *arg);
extern void *_rust_run(struct event_loop *master, void *arg);
extern void _rust_fini(struct event_loop *master, void *arg);
extern void bridge_rust_logging(void);
extern struct frr_daemon_info *rust_get_daemon_info(void);
static void sighup(void);
static void sigint(void);
static void sigusr1(void);
struct event_loop *master;
struct mgmt_be_client *mgmt_be_client;
void *rust_fini_arg;
static struct option __longopts[] = { { 0 } };
static zebra_capabilities_t __caps_p[] = {ZCAP_NET_RAW, ZCAP_BIND, ZCAP_SYS_ADMIN};
static struct zebra_privs_t __privs = {
#if defined(FRR_USER)
.user = FRR_USER,
#endif
#if defined FRR_GROUP
.group = FRR_GROUP,
#endif
#ifdef VTY_GROUP
.vty_group = VTY_GROUP,
#endif
.caps_p = __caps_p,
.cap_num_p = array_size(__caps_p),
.cap_num_i = 0
};
static struct frr_signal_t __signals[] = {
{
.signal = SIGHUP,
.handler = &sighup,
},
{
.signal = SIGUSR1,
.handler = &sigusr1,
},
{
.signal = SIGINT,
.handler = &sigint,
},
{
.signal = SIGTERM,
.handler = &sigint,
},
};
static const struct frr_yang_module_info *const __yang_modules[] = {};
/* clang-format off */
FRR_DAEMON_INFO(rustlibd, RUST,
.vty_port = RUSTLIBD_VTY_PORT,
.proghelp = "Implementation of the RUST daemon template.",
.signals = __signals,
.n_signals = array_size(__signals),
.privs = &__privs,
.yang_modules = __yang_modules,
.n_yang_modules = array_size(__yang_modules),
/* mgmtd will load the per-daemon config file now */
.flags = FRR_NO_SPLIT_CONFIG,
);
/* clang-format on */
struct frr_daemon_info *rust_get_daemon_info(void)
{
return &rustlibd_di;
}
static void sighup(void)
{
zlog_info("SIGHUP received and ignored");
}
static void sigint(void)
{
zlog_notice("Terminating on signal");
nb_oper_cancel_all_walks();
_rust_fini(master, rust_fini_arg);
mgmt_be_client_destroy(mgmt_be_client);
mgmt_be_client = NULL;
frr_fini();
exit(0);
}
static void sigusr1(void)
{
zlog_rotate();
}
/* Main routine of ripd. */
int main(int argc, char **argv)
{
void *rust_arg;
frr_preinit(&rustlibd_di, argc, argv);
bridge_rust_logging();
rust_arg = _rust_preinit(&rustlibd_di);
frr_opt_add("", __longopts, "");
/* Command line option parse. */
while (1) {
int opt;
opt = frr_getopt(argc, argv, NULL);
if (opt == EOF)
break;
switch (opt) {
case 0:
break;
default:
frr_help_exit(1);
}
}
/* Prepare master thread. */
master = frr_init();
rust_arg = _rust_init(master, rust_arg);
mgmt_be_client = mgmt_be_client_create("rustlibd", NULL, 0, master);
frr_config_fork();
rust_fini_arg = _rust_run(master, rust_arg);
frr_run(master);
/* Not reached. */
return 0;
}
|
