@@ -62,6 +62,13 @@ func main() {
62
62
63
63
logger .Info ("Hello, Starting db-controller." )
64
64
65
+ // for controlling the traffics that they're to the DB server port.
66
+ // the function returns nil if the expected chain is already exist.
67
+ nftConnect := nftables .NewDefaultConnector (logger )
68
+ if err := nftConnect .CreateChain (chainNameForDBAclFlag ); err != nil {
69
+ panic (err )
70
+ }
71
+
65
72
// get my global ip address
66
73
myHostAddress , err := getNetIFAddress (globalInterfaceNameFlag )
67
74
if err != nil {
@@ -74,13 +81,6 @@ func main() {
74
81
panic (err )
75
82
}
76
83
77
- // for controlling the traffics that they're to the DB server port.
78
- // the function returns nil if the expected chain is already exist.
79
- nftConnect := nftables .NewDefaultConnector (logger )
80
- if err := nftConnect .CreateChain (chainNameForDBAclFlag ); err != nil {
81
- panic (err )
82
- }
83
-
84
84
var bgpPeers []bgpserver.Peer
85
85
for v := range strings .SplitSeq (bgpPeerAddressesFlag , "," ) {
86
86
bgpPeers = append (bgpPeers , bgpserver.Peer {
@@ -100,10 +100,6 @@ func main() {
100
100
bgpserver .WithPeers (bgpPeers ),
101
101
)
102
102
103
- // create context
104
- ctx , cancel := context .WithCancel (context .Background ())
105
- defer cancel ()
106
-
107
103
c := controller .NewController (
108
104
logger ,
109
105
controller .WithGlobalInterfaceName (globalInterfaceNameFlag ),
@@ -117,7 +113,11 @@ func main() {
117
113
)
118
114
119
115
// start goroutines
116
+ ctx , cancel := context .WithCancel (context .Background ())
117
+ defer cancel ()
118
+
120
119
wg := new (sync.WaitGroup )
120
+
121
121
wg .Add (1 )
122
122
go func (ctx context.Context , wg * sync.WaitGroup , c * controller.Controller ) {
123
123
defer wg .Done ()
0 commit comments