liuxiaolong
2019-08-31 df219a383a31b435f317ba6472cc87929cc052c6
util/util.go
@@ -11,10 +11,16 @@
   "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)
@@ -89,6 +95,10 @@
   socket.Context = ctx
   socket.Cancel = cancel
   socket.Mode = mode
   socket.URL = url
   socket.UseSHM = shm
   if shm {
      var err error
      socket.Sock, err = deliver.NewServerWithError(deliver.Mode(mode), url)