remove exist ipc

zhangmeng

2019-09-27 2d390df9ede39c9d7c34bd8190b9329cfc371325

 nng.go

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

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

}

// Recv impl interface Diliver
@@ -77,6 +76,13 @@
   }
   return msg.Body, nil

}

// Recv2 impl interface
func (n *NNG) Recv2(data []byte) (l int, err error) {
   data, err = n.Recv()
   l = len(data)
   return l, err
}

// Close impl interface Deliver
@@ -127,7 +133,7 @@
   switch n.mode {
   case Bus:
      sock, err = n.busMakeNNG(typ)
   case ReqRep:
   case ReqRep, SurvResp:
      sock, err = n.rrMakeNNG(typ)
   default:
      sock, err = n.ppMakeNNG(typ)
@@ -142,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])
      }
   }
}