add recv2 return len

zhangmeng

2019-08-27 fa924718b1e8d5f566f7655807e77df1bcfe8f86

 nng.go

@@ -33,6 +33,9 @@

// Send impl interface Diliver
func (n *NNG) Send(data []byte) error {
   if n == nil {
      return errors.New("please init NNG first")
   }
   var err error
   if n.sock == nil {
      n.sock, err = n.makeNNG(agent)
@@ -54,6 +57,10 @@

// Recv impl interface Diliver
func (n *NNG) Recv() ([]byte, error) {
   if n == nil {
      return nil, errors.New("please init NNG first")
   }

   var err error

   if n.sock == nil {
@@ -72,9 +79,15 @@

}

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

// Close impl interface Deliver
func (n *NNG) Close() {
   if n.sock != nil {
   if n != nil && n.sock != nil {
      n.sock.Close()
      n.sock = nil
   }
@@ -120,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)