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 }