From 8b01b7da5277da95813e33bcbf54881e00923467 Mon Sep 17 00:00:00 2001 From: Seungsoo Lee Date: Thu, 12 Aug 2021 02:03:01 +0000 Subject: [PATCH] Updated minor --- src/conf/local.yaml | 2 +- src/networkpolicy/helperFunctions.go | 2 +- src/server/grpcServer.go | 10 +++++----- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/src/conf/local.yaml b/src/conf/local.yaml index 7f621cd8..56d0398c 100644 --- a/src/conf/local.yaml +++ b/src/conf/local.yaml @@ -9,7 +9,7 @@ application: network-policy-to: "db|file" # db, file network-policy-dir: "./" system: - operation-mode: 2 # 1: cronjob | 2: one-time-job + operation-mode: 1 # 1: cronjob | 2: one-time-job cron-job-time-interval: "0h0m10s" # format: XhYmZs operation-trigger: 100 system-log-from: "db" # db|kubearmor diff --git a/src/networkpolicy/helperFunctions.go b/src/networkpolicy/helperFunctions.go index de63e2be..b5a3b62b 100644 --- a/src/networkpolicy/helperFunctions.go +++ b/src/networkpolicy/helperFunctions.go @@ -211,7 +211,7 @@ func getNetworkLogs() []types.KnoxNetworkLog { // get flows from hubble relay flows := plugin.GetCiliumFlowsFromHubble(OperationTrigger) - if len(flows) == 0 { + if len(flows) == 0 || len(flows) < OperationTrigger { return nil } diff --git a/src/server/grpcServer.go b/src/server/grpcServer.go index c8803271..114b0856 100644 --- a/src/server/grpcServer.go +++ b/src/server/grpcServer.go @@ -240,13 +240,13 @@ func GetNewServer() *grpc.Server { if cfg.GetCurrentCfg().ConfigClusterMgmt.ClusterInfoFrom != "k8sclient" { // start consumer automatically feedconsumer.StartConsumer() + } - // start net worker automatically - networker.StartNetworkWorker() + // start net worker automatically + networker.StartNetworkWorker() - // start sys worker automatically - sysworker.StartSystemWorker() - } + // start sys worker automatically + sysworker.StartSystemWorker() return s }