X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fdoor_daemon_zmq%2Fmain.go;h=e295c4ed551b6c73188fe6decba0a86d1e6a7a55;hb=845254e617b714552edbf860632f0e763a40d1a5;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..e295c4e 100644 --- a/go/door_daemon_zmq/main.go +++ b/go/door_daemon_zmq/main.go @@ -6,6 +6,8 @@ import ( "fmt" "os" "flag" + "time" + "log/syslog" "log" ) @@ -19,41 +21,88 @@ import ( // ---------- Main Code ------------- +var ( + cmd_port_ string + pub_port_ string + door_tty_path_ string + use_syslog_ bool + syslog_ *log.Logger +) + func usage() { fmt.Fprintf(os.Stderr, "Usage: door_daemon_0mq \n") flag.PrintDefaults() } -func main() { +func init() { + flag.StringVar(&cmd_port_, "cmdport", "ipc:///run/tuer/door_cmd.ipc", "zmq command socket path") + flag.StringVar(&pub_port_, "pubport", "tcp://*:4242", "zmq public/listen socket path") + flag.StringVar(&door_tty_path_, "device", "/dev/door", "door tty device path") + flag.BoolVar(&use_syslog_, "syslog", false, "log to syslog local1 facility") flag.Usage = usage flag.Parse() +} - 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") - - serial_wr, serial_rd, err := OpenAndHandleSerial(args[0], pub_chans.Out()) +func main() { + zmqctx, cmd_chans, pub_chans := ZmqsInit(cmd_port_, pub_port_) + defer cmd_chans.Close() + defer pub_chans.Close() + defer zmqctx.Close() + + serial_wr, serial_rd, err := OpenAndHandleSerial(door_tty_path_) + defer close(serial_wr) if err != nil { - close(serial_wr) panic(err) } - - serial_wr <- "f" - firmware_version := <- serial_rd - log.Print("Firmware version:", firmware_version) - - for incoming_request := range cmd_chans.In() { - reply, err := HandleCommand(incoming_request, pub_chans.Out(), serial_wr, serial_rd) - if err != nil { - cmd_chans.Out() <- [][]byte{[]byte("ERROR"), []byte(err.Error())} - log.Print(err) - } else { - cmd_chans.Out() <- reply - } + + if use_syslog_ { + var logerr error + syslog_, logerr = syslog.NewLogger(syslog.LOG_INFO | syslog.LOG_LOCAL1, 0) + if logerr != nil { panic(logerr) } + syslog_.Print("started") + defer syslog_.Print("exiting") + } + + //~ serial_wr <- "f" + //~ firmware_version := <- serial_rd + //~ log.Print("Firmware version:", firmware_version) + var next_incoming_serial_is_client_reply bool + timeout_chan := make(chan bool) + defer close(timeout_chan) + for { + select { + case incoming_ser_line, is_notclosed := <- serial_rd: + if is_notclosed { + //~ if syslog_ != nil { syslog_.Print(ByteArrayToString(incoming_ser_line)) } + if syslog_ != nil { syslog_.Printf("%s",incoming_ser_line) } + if next_incoming_serial_is_client_reply { + next_incoming_serial_is_client_reply = false + cmd_chans.Out() <- incoming_ser_line + } + pub_chans.Out() <- incoming_ser_line + } else { + syslog_.Print("serial device disappeared, exiting") + os.Exit(1) + } + case tv, timeout_notclosed := <- timeout_chan: + if timeout_notclosed && tv && next_incoming_serial_is_client_reply { + next_incoming_serial_is_client_reply = false + cmd_chans.Out() <- [][]byte{[]byte("ERROR"), []byte("No reply from firmware")} + } + case incoming_request, ic_notclosed := <- cmd_chans.In(): + if ! ic_notclosed { + syslog_.Print("zmq socket died, exiting") + os.Exit(2) + } + if syslog_ != nil { syslog_.Printf("%s",incoming_request) } + if err := HandleCommand(incoming_request, serial_wr, serial_rd); err != nil { + out_msg := [][]byte{[]byte("ERROR"), []byte(err.Error())} + cmd_chans.Out() <- out_msg + } else { + pub_chans.Out() <- incoming_request + next_incoming_serial_is_client_reply = true + go func(){time.Sleep(3*time.Second); timeout_chan <- true;}() + } + } } }