chenshijun
2020-03-25 c62e1b006f2b832f7f6c190c14549bd58ef0fdfb
delete debug info
1个文件已修改
5 ■■■■■ 已修改文件
shmqueue.go 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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