add error判断

zhangmeng

2019-05-16 a6b23c5eaf5a8b9265e13d3db370d45cfcd5bc21

add error判断

 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