Handling mutex lock/unlock

Signed-off-by: Eswar Rajan Subramanian <eswar@accuknox.com>
accuknox · Aug 11, 2022 · 7d33584 · 7d33584
1 parent 7564b94
commit 7d33584
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/src/observability/cilium.go b/src/observability/cilium.go
@@ -166,14 +166,14 @@ func convertFlowLogToCiliumLog(flowLog *flow.Flow) (types.CiliumLog, error) {
 func ProcessNetworkLogs() {
 
 	if len(NetworkLogs) > 0 {
-		ObsMutex.Lock()
-		res := []types.CiliumLog{}
-
 		NetworkLogsMutex.Lock()
 		locNetLogs := NetworkLogs
 		NetworkLogs = []*flow.Flow{} //reset
 		NetworkLogsMutex.Unlock()
 
+		ObsMutex.Lock()
+		res := []types.CiliumLog{}
+
 		for _, flowLog := range locNetLogs {
 			netLog, err := convertFlowLogToCiliumLog(flowLog)
 			if err != nil {

diff --git a/src/observability/kubearmor.go b/src/observability/kubearmor.go
@@ -40,14 +40,14 @@ func convertKubearmorPbLogToKubearmorLog(pbLog pb.Log) types.KubeArmorLog {
 func ProcessSystemLogs() {
 
 	if len(SystemLogs) > 0 {
-		ObsMutex.Lock()
-		res := []types.KubeArmorLog{}
-
 		SystemLogsMutex.Lock()
 		locSysLogs := SystemLogs
 		SystemLogs = []*pb.Log{} //reset
 		SystemLogsMutex.Unlock()
 
+		ObsMutex.Lock()
+		res := []types.KubeArmorLog{}
+
 		for _, kubearmorLog := range locSysLogs {
 			locPbLog := pb.Log{}
 			locLog := types.KubeArmorLog{}