Skip to content

Commit a1cc6bf

Browse files
minor fixes so rebase still works
1 parent 94306fc commit a1cc6bf

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

pkg/sdn/plugin/networkpolicy.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,9 @@ func (np *networkPolicyPlugin) Start(node *OsdnNode) error {
7777
}
7878

7979
otx := node.oc.NewTransaction()
80-
otx.AddFlow("table=21, priority=200, ip, nw_dst=%s, actions=ct(commit,table=30)", np.node.networkInfo.ClusterNetwork.String())
80+
for _, cidr := range np.node.networkInfo.ClusterNetwork {
81+
otx.AddFlow("table=21, priority=200, ip, nw_dst=%s, actions=ct(commit,table=30)", cidr.String())
82+
}
8183
otx.AddFlow("table=80, priority=200, ip, ct_state=+rpl, actions=output:NXM_NX_REG2[]")
8284
if err := otx.EndTransaction(); err != nil {
8385
return err

pkg/sdn/plugin/node.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,7 @@ func (node *OsdnNode) Start() error {
247247
for _, cidr := range node.networkInfo.ClusterNetwork {
248248
cidrList = append(cidrList, cidr.String())
249249
}
250-
nodeIPTables := newNodeIPTables(cidrList, node.iptablesSyncPeriod)
250+
nodeIPTables := newNodeIPTables(cidrList, node.iptablesSyncPeriod, !node.useConnTrack)
251251

252252
if err = nodeIPTables.Setup(); err != nil {
253253
return fmt.Errorf("failed to set up iptables: %v", err)

0 commit comments

Comments
 (0)