X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fdoor_daemon_zmq%2Fmain.go;h=606c3646794af980c393aad0df55b92f565374cb;hb=59b5b0d11e44853e93a5a66dc66133254f844753;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..606c364 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,95 @@ import ( // ---------- Main Code ------------- -func usage() { - fmt.Fprintf(os.Stderr, "Usage: door_daemon_0mq \n") - flag.PrintDefaults() +var ( + cmd_port_ string + pub_port_ string + door_tty_path_ string + use_syslog_ bool + Syslog_ *log.Logger +) + +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.Parse() } func main() { - flag.Usage = usage - flag.Parse() + zmqctx, cmd_chans, pub_chans := ZmqsInit(cmd_port_, pub_port_) + defer cmd_chans.Close() + defer pub_chans.Close() + defer zmqctx.Close() - 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()) + 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 string(incoming_request[0]) == "log" { + if len(incoming_request) < 2 { + cmd_chans.Out() <- [][]byte{[]byte("ERROR"), []byte("argument missing")} + continue + } + if Syslog_ == nil { + cmd_chans.Out() <- [][]byte{[]byte("ERROR"), []byte("syslog logging not enabled")} + continue + } + Syslog_.Printf("Log: %s",incoming_request[1:]) + cmd_chans.Out() <- [][]byte{[]byte("Ok")} + continue + } + 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;}() + } + } } }