Constant parameter notice

pkg/event_processor/base_event.go

@@ -137,7 +137,7 @@ func (be *BaseEvent) StringHex() string {
 	var prefix, connInfo string
 	switch AttachType(be.DataType) {
 	case ProbeEntry:
-		connInfo = fmt.Sprintf("Recived %d bytes", be.DataLen)
+		connInfo = fmt.Sprintf("Received %d bytes", be.DataLen)
 	case ProbeRet:
 		connInfo = fmt.Sprintf("Send %d bytes", be.DataLen)
 	default:
@@ -156,7 +156,7 @@ func (be *BaseEvent) String() string {
 	var connInfo string
 	switch AttachType(be.DataType) {
 	case ProbeEntry:
-		connInfo = fmt.Sprintf("Recived %dbytes", be.DataLen)
+		connInfo = fmt.Sprintf("Received %dbytes", be.DataLen)
 	case ProbeRet:
 		connInfo = fmt.Sprintf("Send %d bytes", be.DataLen)
 	default:

pkg/event_processor/iworker.go

@@ -156,7 +156,7 @@ func (ew *eventWorker) Run() {
 				ew.processor.delWorkerByUUID(ew)
 
 				/*
-					When returned from delWorkerByUUID(), there are two possiblities:
+					When returned from delWorkerByUUID(), there are two possibilities:
 					1) no routine can touch it.
 					2) one routine can still touch ew because getWorkerByUUID()
 					*happen before* delWorkerByUUID()

pkg/event_processor/processor_test.go

@@ -44,13 +44,15 @@ func TestEventProcessor_Serve(t *testing.T) {
 		var err error
 		err = ep.Serve()
 		if err != nil {
-			log.Fatalf(err.Error())
+			//log.Fatalf(err.Error())
+			t.Error(err)
+			return
 		}
 	}()
 	content, err := os.ReadFile(testFile)
 	if err != nil {
 		//Do something
-		log.Fatalf("open file error: %s, file:%s", err.Error(), testFile)
+		t.Fatalf("open file error: %s, file:%s", err.Error(), testFile)
 	}
 	lines := strings.Split(string(content), "\n")
 

user/module/imodule.go

@@ -117,6 +117,7 @@ func (m *Module) Init(ctx context.Context, logger *zerolog.Logger, conf config.I
 		if kv < kernel.VersionCode(5, 2, 0) {
 			m.isKernelLess5_2 = true
 		}
+		m.logger.Warn().Str("kernel", kv.String()).Msg("Kernel version is less than 5.2, Process filtering parameters do not take effect such as pid/uid.")
 	}
 
 	logger.Info().Int("Pid", os.Getpid()).Str("Kernel Info", kv.String()).Send()

user/module/probe_openssl_lib.go

@@ -197,9 +197,9 @@ func (m *MOpenSSLProbe) detectOpenssl(soPath string) error {
 			break
 		}
 
-		// Substracting OpenSslVersionLen from totalReadCount,
+		// Subtracting OpenSslVersionLen from totalReadCount,
 		// to cover the edge-case in which openssl version string
-		// could be split into two buffers. Substraction will,
+		// could be split into two buffers. Subtraction will,
 		// makes sure that last 30 bytes of previous buffer are considered.
 		totalReadCount += readCount - OpenSslVersionLen
 
@@ -212,8 +212,8 @@ func (m *MOpenSSLProbe) detectOpenssl(soPath string) error {
 
 	}
 
-	f.Close()
-	buf = nil
+	_ = f.Close()
+	//buf = buf[:0]
 
 	var bpfFile string
 	var found bool

user/module/probe_pcap.go

@@ -112,7 +112,7 @@ func (t *MTCProbe) writePid(tcEvent *event.TcSkbEvent) (error, []byte) {
 
 	oldEthLayer := ethPacket.Layers()[0].(*layers.Ethernet)
 
-	// subtract oldethelayer from the begining of ethpacket
+	// subtract oldethelayer from the beginning of ethpacket
 	restOfLayers := ethPacket.Layers()[1:]
 	remainder := []byte{}
 	for _, layer := range restOfLayers {