chenshijun
2020-10-09 1df33ffacf98f09a33969a8c8ed4078247524d29
shmqueue.go
@@ -3,7 +3,7 @@
import (
   "context"
   "fmt"
   "github.com/gen2brain/shm"
   shm "basic.com/valib/goshm.git"
   "reflect"
   "runtime"
   "sync/atomic"
@@ -106,7 +106,7 @@
func AttachQueue(ctx context.Context, key int) *EsQueueInfo {
   var eqi EsQueueInfo
   data, shmid := AttachRawShm(ctx, key)
   data, shmid := AttachRawShmTimeout(ctx, key)
   if shmid == -1 {
      return nil
   }