1 // (c) Bernhard Tittelbach, 2013
13 //~ func StringArrayToByteArray(ss []string) [][]byte {
14 //~ bb := make([][]byte, len(ss))
15 //~ for index, s := range(ss) {
16 //~ bb[index] = []byte(s)
21 // ---------- Main Code -------------
29 fmt.Fprintf(os.Stderr, "Usage: door_daemon_0mq <door tty device>\n")
34 flag.StringVar(&cmd_port_, "cmdport", "tcp://127.0.01:3232", "zmq command socket path")
35 flag.StringVar(&pub_port_, "pubport", "pgm://233.252.1.42:4242", "zmq public/listen socket path")
43 fmt.Fprintf(os.Stderr, "Input file is missing!\n");
48 zmqctx, cmd_chans, pub_chans := ZmqsInit(cmd_port_, pub_port_)
49 defer cmd_chans.Close()
50 defer pub_chans.Close()
53 serial_wr, serial_rd, err := OpenAndHandleSerial(args[0])
54 defer close(serial_wr)
60 //~ firmware_version := <- serial_rd
61 //~ log.Print("Firmware version:", firmware_version)
62 var next_incoming_serial_is_client_reply bool
63 timeout_chan := make(chan bool)
64 defer close(timeout_chan)
67 case incoming_ser_line, is_notclosed := <- serial_rd:
69 if next_incoming_serial_is_client_reply {
70 next_incoming_serial_is_client_reply = false
71 cmd_chans.Out() <- incoming_ser_line
73 pub_chans.Out() <- incoming_ser_line
77 case tv, timeout_notclosed := <- timeout_chan:
78 if timeout_notclosed && tv && next_incoming_serial_is_client_reply {
79 next_incoming_serial_is_client_reply = false
80 cmd_chans.Out() <- [][]byte{[]byte("ERROR"), []byte("No reply from firmware")}
82 case incoming_request, ic_notclosed := <- cmd_chans.In():
83 if ! ic_notclosed {os.Exit(2)}
84 //~ log.Print(incoming_request)
85 if err := HandleCommand(incoming_request, serial_wr, serial_rd); err != nil {
87 out_msg := [][]byte{[]byte("ERROR"), []byte(err.Error())}
88 cmd_chans.Out() <- out_msg
89 //~ log.Print("sent error")
92 pub_chans.Out() <- incoming_request
93 next_incoming_serial_is_client_reply = true
94 go func(){time.Sleep(3*time.Second); timeout_chan <- true;}()
95 //~ log.Print("sent reply")