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=6db3ea81c9d3e5edc79ce87c2a45f0e60c5ee18e;hp=805368e008e29a9fb2e5e05010976e8606d1759e;hb=9a37d1b81db952b8026ce0eeefeff871ea0075a7;hpb=f2a09928c3c1d406452098cb15f663a62611fc95 diff --git a/go/door_daemon_zmq/zeromq.go b/go/door_daemon_zmq/zeromq.go index 805368e..6db3ea8 100644 --- a/go/door_daemon_zmq/zeromq.go +++ b/go/door_daemon_zmq/zeromq.go @@ -32,7 +32,7 @@ func ZmqsInit(cmd_port, pub_port string) (ctx *zmq.Context, cmd_chans, pub_chan if err = cmd_sock.Bind(cmd_port); err != nil { panic(err) } - + cmd_chans = cmd_sock.ChannelsBuffer(10) go zmqsHandleError(cmd_chans) } else { @@ -62,6 +62,6 @@ func ZmqsInit(cmd_port, pub_port string) (ctx *zmq.Context, cmd_chans, pub_chan func zmqsHandleError(chans *zmq.Channels) { for error := range(chans.Errors()) { chans.Close() - panic(error) + panic(error) } } \ No newline at end of file