remove exist ipc

zhangmeng

2019-09-27 2d390df9ede39c9d7c34bd8190b9329cfc371325

 nng.go

@@ -28,8 +28,6 @@
   mode Mode
   url  string

   sendMsg *mangos.Message

   arguments []interface{}
}

@@ -51,17 +49,9 @@
      time.Sleep(time.Duration(surveyorTime*2) * time.Second)
   }

   // msg := mangos.NewMessage(len(data))
   // msg.Body = data
   // return n.sock.SendMsg(msg)

   if n.sendMsg == nil {
      n.sendMsg = &mangos.Message{}
      n.sendMsg.Header = make([]byte, 32)
   }
   n.sendMsg.Body = data
   return n.sock.SendMsg(n.sendMsg)

   msg := mangos.NewMessage(1)
   msg.Body = data
   return n.sock.SendMsg(msg)
}

// Recv impl interface Diliver
@@ -158,6 +148,8 @@
   if s[0] == "ipc" {
      if _, err := os.Stat(s[1]); err == nil {
         os.Remove(s[1])
      } else if !os.IsNotExist(err) {
         os.Remove(s[1])
      }
   }
}