nng.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
nng.go
@@ -76,6 +76,8 @@ rmExistedIpcName(url) if sock, err := newSocket(protoProducer(m)); err == nil { if err = setSocketOptions(sock, args); err != nil { sock.Close() sock = nil return nil } if err = sock.Listen(url); err != nil { @@ -96,6 +98,8 @@ if sock, err := newSocket(protoConsumer(m)); err == nil { if err = setSocketOptions(sock, args); err != nil { sock.Close() sock = nil return nil }