zhangmeng
2019-05-16 162fe98d7728445b72528283e1bfdddc432d2676
nng.go
@@ -76,6 +76,8 @@
   rmExistedIpcName(url)
   if sock, err := newSocket(protoProducer(m)); err == nil {
      if err = setSocketOptions(sock, args); err != nil {
         sock.Close()
         sock = nil
         return nil
      }
      if err = sock.Listen(url); err != nil {
@@ -96,6 +98,8 @@
   if sock, err := newSocket(protoConsumer(m)); err == nil {
      if err = setSocketOptions(sock, args); err != nil {
         sock.Close()
         sock = nil
         return nil
      }