run nomally

zhangmeng

2019-08-27 8c7dd4313817f6854461a64a7cadb7d970fb3e88

 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"
)
@@ -87,7 +90,11 @@
   socket.Cancel = cancel

   if shm{
      socket.Sock = deliver.NewServer(deliver.Mode(mode), url)
      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)
   }