Updated minor

accuknox · Aug 12, 2021 · 8b01b7d · 8b01b7d
1 parent d34c414
commit 8b01b7d
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git 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
@@ -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
@@ -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
 }