Merge branch 'master' of ssh://192.168.1.14:29418/pubsub/task

zhangmeng

2019-09-02 9307cbbe2720d833739721bf6f178cfe041e17e6

 util/util.go

@@ -1,17 +1,26 @@
package util

import (
   "basic.com/valib/deliver.git"
   "context"
   "errors"
   "fmt"

   "basic.com/valib/deliver.git"

   // "github.com/pierrec/lz4"
   "taskpubsub/logger"
)

const SHMMaxTryCount = 3

type SocketContext struct {
   Sock    deliver.Deliver
   Context context.Context
   Cancel  context.CancelFunc

   Mode   int
   URL    string
   UseSHM bool
}

//  1. oldstring element is not in new  : abandon(delete)
@@ -86,9 +95,17 @@
   socket.Context = ctx
   socket.Cancel = cancel

   if shm{
      socket.Sock = deliver.NewServer(deliver.Mode(mode), url)
   }else{
   socket.Mode = mode
   socket.URL = url
   socket.UseSHM = shm

   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)
   }