From c62e1b006f2b832f7f6c190c14549bd58ef0fdfb Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期三, 25 三月 2020 14:45:11 +0800
Subject: [PATCH] delete debug info
---
shmqueue.go | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/shmqueue.go b/shmqueue.go
index c01257f..3495406 100644
--- a/shmqueue.go
+++ b/shmqueue.go
@@ -89,13 +89,12 @@
cache.getNo = q.capacity
cache.putNo = q.capacity
- fmt.Println("NewQueue EsCaches:", eqi.EsCaches)
+ //fmt.Println("NewQueue EsCaches:", eqi.EsCaches)
eqi.ShmData = data
eqi.ShmID = shmid
eqi.ShmKey = key
eqi.Queue = q
- time.Sleep(10 * time.Second)
return &eqi
}
@@ -107,7 +106,7 @@
data, shmid := AttachRawShm(ctx, key)
shmdata := bytes2shmEsQueue(data)
eqi.EsCaches = ptr2esCache(unsafe.Pointer(&shmdata.cache), int(shmdata.capacity))
- fmt.Println("AttachQueue EsCaches:", eqi.EsCaches)
+ //fmt.Println("AttachQueue EsCaches:", eqi.EsCaches)
eqi.Queue = shmdata
eqi.ShmKey = key
@@ -120,7 +119,7 @@
// ReleaseQueue detach an exist shm queue
func (eqi *EsQueueInfo) ReleaseQueue() {
fmt.Printf("ReleaseQueue: key=%x\n", eqi.ShmKey)
- DestroyShm(eqi.ShmData)
+ DetachShm(eqi.ShmData)
}
// RemoveShmId remove an exist shm queue (ipcrm -m shmid)
--
Gitblit v1.8.0