From 8c7dd4313817f6854461a64a7cadb7d970fb3e88 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 27 八月 2019 09:56:37 +0800
Subject: [PATCH] run nomally
---
util/util.go | 15 +++++++++++----
1 files changed, 11 insertions(+), 4 deletions(-)
diff --git a/util/util.go b/util/util.go
index 4c92331..264880a 100644
--- a/util/util.go
+++ b/util/util.go
@@ -1,9 +1,12 @@
package util
import (
- "basic.com/valib/deliver.git"
"context"
"errors"
+ "fmt"
+
+ "basic.com/valib/deliver.git"
+
// "github.com/pierrec/lz4"
"taskpubsub/logger"
)
@@ -86,9 +89,13 @@
socket.Context = ctx
socket.Cancel = cancel
- if shm{
- socket.Sock = deliver.NewServer(deliver.Mode(mode), url)
- }else{
+ if shm {
+ var err error
+ socket.Sock, err = deliver.NewServerWithError(deliver.Mode(mode), url)
+ if err != nil {
+ fmt.Println("TASK CREATE SERVER SHM ERROR: ", err)
+ }
+ } else {
socket.Sock = deliver.NewServer(deliver.Mode(mode), url)
}
--
Gitblit v1.8.0