add -race flags for go test and fix data race warning

Signed-off-by: ruitianzhong <ruitian-zhong@outlook.com>

.github/workflows/go-c-cpp.yml

@@ -48,7 +48,7 @@ jobs:
           make env
           make nocore
       - name: Test
-        run: go test -v ./...
+        run: go test -v -race ./...
 
   build-on-ubuntu2204:
     runs-on: ubuntu-22.04
@@ -91,7 +91,7 @@ jobs:
           make env
           make nocore
       - name: Test
-        run: go test -v ./...
+        run: go test -v -race ./...
 
   build-on-ubuntu2004-arm64:
     runs-on: ubuntu-22.04

pkg/event_processor/http_request.go

@@ -81,11 +81,10 @@ func (hr *HTTPRequest) detect(payload []byte) error {
 	//hr.Init()
 	rd := bytes.NewReader(payload)
 	buf := bufio.NewReader(rd)
-	req, err := http.ReadRequest(buf)
+	_, err := http.ReadRequest(buf)
 	if err != nil {
 		return err
 	}
-	hr.request = req
 	return nil
 }
 

pkg/event_processor/http_response.go

@@ -97,11 +97,10 @@ func (hr *HTTPResponse) Write(b []byte) (int, error) {
 func (hr *HTTPResponse) detect(payload []byte) error {
 	rd := bytes.NewReader(payload)
 	buf := bufio.NewReader(rd)
-	res, err := http.ReadResponse(buf, nil)
+	_, err := http.ReadResponse(buf, nil)
 	if err != nil {
 		return err
 	}
-	hr.response = res
 	return nil
 }
 

pkg/event_processor/processor.go

@@ -115,6 +115,8 @@ func (this *EventProcessor) Write(e event.IEventStruct) {
 }
 
 func (this *EventProcessor) Close() error {
+	this.Lock()
+	defer this.Unlock()
 	if len(this.workerQueue) > 0 {
 		return fmt.Errorf("EventProcessor.Close(): workerQueue is not empty:%d", len(this.workerQueue))
 	}