add error判断

zhangmeng

2019-05-16 a6b23c5eaf5a8b9265e13d3db370d45cfcd5bc21

 nng.go

@@ -52,8 +52,10 @@
      return nil, errors.New("please init NNG first")
   }
   if _, err := n.sock.GetOption(mangos.OptionRaw); err == nil {
      msg, err := n.sock.RecvMsg()
      return msg.Body, err
      if msg, err := n.sock.RecvMsg(); err == nil {
         return msg.Body, err
      }
      return nil, err
   }
   return n.sock.Recv()
}
@@ -126,14 +128,14 @@
      sock.Close()
      return err
   }
   // if err = sock.SetOption(mangos.OptionRecvDeadline, time.Second); err != nil {
   //    sock.Close()
   //    return err
   // }
   // if err = sock.SetOption(mangos.OptionSendDeadline, time.Second); err != nil {
   //    sock.Close()
   //    return err
   // }
   if err = sock.SetOption(mangos.OptionRecvDeadline, time.Second); err != nil {
      sock.Close()
      return err
   }
   if err = sock.SetOption(mangos.OptionSendDeadline, time.Second); err != nil {
      sock.Close()
      return err
   }
   if err = sock.SetOption(mangos.OptionRaw, true); err != nil {
      sock.Close()
      return err