chenshijun
2019-09-11 a45d5a83c5a283444a407d648432e9dd08f89478
util/util.go
@@ -1,14 +1,11 @@
package util
import (
   "basic.com/valib/deliver.git"
   "context"
   "errors"
   "fmt"
   "basic.com/valib/deliver.git"
   // "github.com/pierrec/lz4"
   "taskpubsub/logger"
   "basic.com/valib/logger.git"
)
const SHMMaxTryCount = 3
@@ -103,7 +100,7 @@
      var err error
      socket.Sock, err = deliver.NewServerWithError(deliver.Mode(mode), url)
      if err != nil {
         fmt.Println("TASK CREATE SERVER SHM ERROR: ", err)
         logger.Info("TASK CREATE SERVER SHM ERROR: ", err)
      }
   } else {
      socket.Sock = deliver.NewServer(deliver.Mode(mode), url)