X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=go%2Fdoor_daemon_zmq%2Fzeromq.go;fp=go%2Fdoor_daemon_zmq%2Fzeromq.go;h=70fe7951b3e8bdcaf00ca08fb55b7e73dfd268d0;hp=0000000000000000000000000000000000000000;hb=88e758b4025ef2a84acafc7b832a41028280c296;hpb=70bd6ea215fdd1dbd2eb9556ff4aa0a2acde24bc diff --git a/go/door_daemon_zmq/zeromq.go b/go/door_daemon_zmq/zeromq.go new file mode 100644 index 0000000..70fe795 --- /dev/null +++ b/go/door_daemon_zmq/zeromq.go @@ -0,0 +1,65 @@ +// (c) Bernhard Tittelbach, 2013 + +package main + +import ( + zmq "github.com/vaughan0/go-zmq" + ) + +// ---------- ZeroMQ Code ------------- + +func ZmqsInit(cmd_port, pub_port string) (cmd_chans, pub_chans *zmq.Channels) { + + cmd_ctx, err := zmq.NewContext() + if err != nil { + panic(err) + } + //close only on panic, otherwise leave open: + defer func(){ if r:= recover(); r != nil { cmd_ctx.Close(); panic(r) } }() + + pub_ctx, err := zmq.NewContext() + if err != nil { + panic(err) + } + defer func() { if r:= recover(); r != nil { pub_ctx.Close(); panic(r) } }() + + cmd_sock, err := cmd_ctx.Socket(zmq.Rep) + if err != nil { + panic(err) + } + defer func() { if r:= recover(); r != nil { cmd_sock.Close(); panic(r) } }() + + pub_sock, err := pub_ctx.Socket(zmq.Pub) + if err != nil { + panic(err) + } + defer func() { if r:= recover(); r != nil { pub_sock.Close(); panic(r) } }() + + if err = cmd_sock.Bind(cmd_port); err != nil { // "tcp://*:5555" + panic(err) + } + + if err = pub_sock.Bind(pub_port); err != nil { // "tcp://*:5556" + panic(err) + } + + cmd_chans = cmd_sock.Channels() + pub_chans = cmd_sock.Channels() + go zmqsHandleError(cmd_chans, pub_chans) + return +} + +func zmqsHandleError(cmd_chans, pub_chans *zmq.Channels) { + for { + select { + case cmd_error := <- cmd_chans.Errors(): + cmd_chans.Close() + pub_chans.Close() + panic(cmd_error) + case pub_error := <- pub_chans.Errors(): + cmd_chans.Close() + pub_chans.Close() + panic(pub_error) + } + } +} \ No newline at end of file