X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fdoor_daemon_zmq%2Fmain.go;h=9fa453160a1c9f004321cb7f461321ce299c3a44;hb=05f5975f0266e628e89cf0f60f84f47d43136747;hp=28be188a1df4d35b69106ea53514481cc3dc9555;hpb=88e758b4025ef2a84acafc7b832a41028280c296;p=svn42.git diff --git a/go/door_daemon_zmq/main.go b/go/door_daemon_zmq/main.go index 28be188..9fa4531 100644 --- a/go/door_daemon_zmq/main.go +++ b/go/door_daemon_zmq/main.go @@ -19,30 +19,39 @@ import ( // ---------- Main Code ------------- +var ( + cmd_port_ string + pub_port_ string +) + func usage() { fmt.Fprintf(os.Stderr, "Usage: door_daemon_0mq \n") flag.PrintDefaults() } -func main() { +func init() { + flag.StringVar(&cmd_port_, "cmdport", "tcp://localhost:5555", "zmq command socket path") + flag.StringVar(&pub_port_, "pubport", "gmp://*:6666", "zmq public/listen socket path") flag.Usage = usage flag.Parse() +} +func main() { args := flag.Args() if len(args) < 1 { fmt.Fprintf(os.Stderr, "Input file is missing!\n"); usage() os.Exit(1); } - - cmd_chans, pub_chans := ZmqsInit("tcp://localhost:5555", "gmp://*:6666") - + + cmd_chans, pub_chans := ZmqsInit(cmd_port_, pub_port_) + serial_wr, serial_rd, err := OpenAndHandleSerial(args[0], pub_chans.Out()) if err != nil { close(serial_wr) panic(err) } - + serial_wr <- "f" firmware_version := <- serial_rd log.Print("Firmware version:", firmware_version) @@ -54,6 +63,6 @@ func main() { log.Print(err) } else { cmd_chans.Out() <- reply - } + } } }