1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
| package deliver
|
| import "nanomsg.org/go-mangos"
|
| func commonMake(n *NNG, p protocol, opts map[string]interface{}) (mangos.Socket, error) {
| var sock mangos.Socket
| var err error
|
| if sock, err = newSocket(p); err != nil {
| return nil, err
| }
|
| if err = setSocketOptions(sock, opts); err != nil {
| sock.Close()
| sock = nil
| }
| if n.typ == agent {
| if err = sock.Listen(n.url); err != nil {
| sock.Close()
| sock = nil
| }
| } else {
| if err = sock.Dial(n.url); err != nil {
| sock.Close()
| sock = nil
| }
| }
| return sock, err
| }
|
| func (n *NNG) ppMakeNNG(typ td) (mangos.Socket, error) {
|
| p := proto(typ, n.mode)
| opts := optOther(p, optRaw(optDefault()), n.arguments...)
|
| return commonMake(n, p, opts)
| }
|
| func (n *NNG) rrMakeNNG(typ td) (mangos.Socket, error) {
|
| p := proto(typ, n.mode)
| opts := optDefault()
|
| return commonMake(n, p, opts)
| }
|
| func (n *NNG) busMakeNNG(typ td) (mangos.Socket, error) {
| var sock mangos.Socket
| var err error
| if sock, err = newSocket(BUS); err != nil {
| return nil, err
| }
| if err = sock.Listen(n.url); err != nil {
| sock.Close()
| sock = nil
| }
| // arguments are bus clients
| for _, arg := range n.arguments {
| switch arg.(type) {
| case string:
| url := arg.(string)
| if err = sock.Dial(url); err != nil {
| sock.Close()
| sock = nil
| break
| }
| default:
| }
| }
| if err = setSocketOptions(sock, nil); err != nil {
| return nil, err
| }
| return sock, err
| }
|
|
