1 files changed, 1 insertions, 19 deletions

diff --git a/src/deal.go b/src/deal.go
index 1dd309c..f2b7d4b 100644
--- a/src/deal.go
+++ b/src/deal.go
@@ -34,6 +34,7 @@ func deal() {
                 "pid":      containerdPid,
                 "cwd":      "/",
                 "children": []bson.M{},
+                "daemon":   true,
         })
         if err != nil {
                 fmt.Printf("Error while initing the mongodb: %v\n", err)
@@ -77,9 +78,6 @@ func deal() {
 }
 
 func deletePid(cooked Event) {
-        if !pidCol.GetLock() {
-                return
-        }
         // 先从老爹那里销户
         pidCol.UpdateOne(bson.M{"pid": cooked.ppid}, bson.M{
                 "$pull": bson.M{
@@ -100,17 +98,9 @@ func deletePid(cooked Event) {
                         "exit_signal":    cooked.exit_signal,
                 },
         })
-        pidCol.Mutex.Unlock()
 }
 
 func dealNewPid(cooked Event) {
-        fmt.Printf("Fork\t%6d\t%6d\t%6d\t%6d\n", cooked.ppid, cooked.parentTgid, cooked.pid, cooked.tgid)
-        // 有无父进程在观察中
-        docRes, err = pidCol.Finddoc(bson.M{"pid": cooked.parentTgid})
-        if err != nil || len(docRes) != 1 {
-                return
-        }
-
         // 自身是否已经记录
         docRes, err = pidCol.Finddoc(bson.M{"pid": cooked.pid})
         if err != nil {
@@ -118,9 +108,6 @@ func dealNewPid(cooked Event) {
                 return
         }
 
-        if !pidCol.GetLock() {
-                return
-        }
         if len(docRes) != 0 {
                 // 进程原本就存在，换言之别的消息先到了
                 // 所有先行抵达的消息必须保留execve/children字段
@@ -157,7 +144,6 @@ func dealNewPid(cooked Event) {
                         "children": cooked.pid,
                 },
         })
-        pidCol.Mutex.Unlock()
 }
 
 func dealExecve(cooked Event) {
@@ -173,9 +159,6 @@ func dealExecve(cooked Event) {
                 return
         }
 
-        if !pidCol.GetLock() {
-                return
-        }
         if len(docRes) == 1 {
                 // 自身已在，直接记录
                 pidCol.UpdateOne(bson.M{"pid": cooked.pid}, bson.M{
@@ -200,7 +183,6 @@ func dealExecve(cooked Event) {
                         },
                 })
         }
-        pidCol.Mutex.Unlock()
 }
 
 func fileOpen(cooked Event) {