Basically fixed info lost

As previous envisioned, the lost is caused by slow consumption. So
I make several changes:

- Delete all the mutexs, especially those in the mongodb. There seems
  to have no necessity to use thread mutex, because execve, fork
  and exit has no conflicton(really?)
- Insert all pid info into db, just ws what we do to file infos. So
  we should filter out useful info from them, but this does works
  to decrease lost infos.

Besides, the problem that recvfrom is always blocked may got solved.
When the machine is just started, it's blocked; but after i run the
C program to connect to ketlink connector and listen to it, both C
program and godo can recv infos well.

Also, left questions:

- Now i use many coroutine in 2nd and 3rd coroutines in the hope that
  there will be less time to deal info and hear the kernel again as
  quick as possible. But does it work? As we know, too much thread
  will slower the program, because too frequent switch between threads
  or processes.
- Sometimes the eventTable has bugs, when eoe is recvd, the pointer
  in it is null. It may be out of thread confliction? But it's
  unreasonable, there's only one place to delete the event, that's
  just in eoe, after it's sent. Or the eoe info is got more than once?
- For some processes, when i look into /proc to find cwd and cmeline,
  it has exited. If i go back to use audit for pid info, it will be hard
  to distinguish between thread and process. Anyway, It doesn't matter
  now, but what if?

Next step: Figure out the root fs of a docker, and its name.

1 files changed, 0 insertions, 16 deletions

diff --git a/src/mongo.go b/src/mongo.go
index 764f877..1d9f74f 100644
--- a/src/mongo.go
+++ b/src/mongo.go
@@ -2,8 +2,6 @@ package main
 
 import (
         "context"
-        "fmt"
-        "sync"
         "time"
 
         "go.mongodb.org/mongo-driver/bson"
@@ -15,8 +13,6 @@ type mongoClient struct {
         dbName, colName string
         client          *mongo.Client
         col             *mongo.Collection
-        Mutex           sync.Mutex
-        // Attention: 这把锁是否有必要？
 }
 
 func (mc *mongoClient) init(dbName, colName string) error {
@@ -100,15 +96,3 @@ func (mc *mongoClient) Disconnect() error {
         mc.colName = ""
         return nil
 }
-
-func (mc *mongoClient) GetLock() bool {
-        for i := 0; i < 200000; {
-                if !mc.Mutex.TryLock() {
-                        i++
-                } else {
-                        return true
-                }
-        }
-        fmt.Printf("Die...\n")
-        return false
-}