update dbapi

zhangmeng

2019-09-05 a464ae7f01e47395f3a5386d1b1d0b5f4223a29a

 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)