X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=go%2Fr3-netstatus%2Fzeromq.go;h=86f42064df22f9805ea81fb95a9c578b091f1925;hp=38d1732702bd29e3afc32d51545b9ec310985da9;hb=ff98cdc53bc87b9d4f3215df248c188a84cb2fb1;hpb=2416b163f05370fcffb2f62bea000265d10aac42

diff --git a/go/r3-netstatus/zeromq.go b/go/r3-netstatus/zeromq.go
index 38d1732..86f4206 100644
--- a/go/r3-netstatus/zeromq.go
+++ b/go/r3-netstatus/zeromq.go
@@ -45,3 +45,34 @@ func zmqsHandleError(chans *zmq.Channels) {
         panic(error)
     }
 }
+
+func ZmqsRequestAnswer(sock *zmq.Socket, request [][]byte) (answer [][]byte) {
+    if err := sock.Send(request); err != nil {
+        panic(err)
+    }
+    parts, err := sock.Recv()
+    if err != nil {
+        panic(err)
+    }
+    return parts
+}
+
+func ZmqsAskQuestionsAndClose(ctx *zmq.Context, addr string, questions [][][]byte) [][][]byte {
+    if len(addr) == 0 || ctx == nil { return nil }
+
+    req_sock, err := ctx.Socket(zmq.Req)
+    if err != nil {
+        return nil
+    }
+    defer req_sock.Close()
+
+    if err = req_sock.Connect(addr); err != nil {
+        return nil
+    }
+
+    rv := make([][][]byte, len(questions))
+    for index, q := range(questions) {
+        rv[index] = ZmqsRequestAnswer(req_sock, q)
+    }
+    return rv
+}
\ No newline at end of file