diff --git a/.github/workflows/go-c-cpp.yml b/.github/workflows/go-c-cpp.yml
index eeefd42b5..cd5850e6c 100644
--- a/.github/workflows/go-c-cpp.yml
+++ b/.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
diff --git a/pkg/event_processor/http_request.go b/pkg/event_processor/http_request.go
index bdc8a83a6..6b5e96ecc 100644
--- a/pkg/event_processor/http_request.go
+++ b/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
 }
 
diff --git a/pkg/event_processor/http_response.go b/pkg/event_processor/http_response.go
index dc7f321cf..811990966 100644
--- a/pkg/event_processor/http_response.go
+++ b/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
 }
 
diff --git a/pkg/event_processor/processor.go b/pkg/event_processor/processor.go
index 7137fd12b..8c33749a5 100644
--- a/pkg/event_processor/processor.go
+++ b/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))
 	}