From c2bbe31e7c6c9f83f7bcce26dea98bc18ed8f39c Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期三, 22 五月 2019 13:35:09 +0800
Subject: [PATCH] fix crash and add NewServerWithError return error
---
nng.go | 9 ++++++++-
1 files changed, 8 insertions(+), 1 deletions(-)
diff --git a/nng.go b/nng.go
index 751feac..fa3e409 100644
--- a/nng.go
+++ b/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 {
@@ -74,7 +81,7 @@
// Close impl interface Deliver
func (n *NNG) Close() {
- if n.sock != nil {
+ if n != nil && n.sock != nil {
n.sock.Close()
n.sock = nil
}
--
Gitblit v1.8.0