From 1df33ffacf98f09a33969a8c8ed4078247524d29 Mon Sep 17 00:00:00 2001
From: chenshijun <chenshijun@aiotlink.com>
Date: 星期五, 09 十月 2020 14:27:45 +0800
Subject: [PATCH] attach增加超时
---
shmqueue.go | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
diff --git a/shmqueue.go b/shmqueue.go
index 16d8b2e..9c4f16c 100644
--- a/shmqueue.go
+++ b/shmqueue.go
@@ -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
}
--
Gitblit v1.8.0