go/uc_sensor_node_zmq/main.go

   1 // (c) Bernhard Tittelbach, 2013
   2
   3 package main
   4
   5 import (
   6     "flag"
   7 )
   8
   9
  10 // ---------- Main Code -------------
  11
  12 var (
  13     tty_dev_ string
  14     pub_addr string
  15     use_syslog_ bool
  16 )
  17
  18 func init() {
  19     flag.StringVar(&pub_addr, "brokeraddr", "tcp://torwaechter.realraum.at:4244", "zmq address to send stuff to")
  20     flag.StringVar(&tty_dev_, "ttydev", "/dev/ttyACM0", "path do tty uc device")
  21     flag.BoolVar(&use_syslog_, "syslog", false, "log to syslog local1 facility")
  22     flag.Parse()
  23 }
  24
  25 func main() {
  26     zmqctx, pub_sock := ZmqsInit(pub_addr)
  27     defer zmqctx.Close()
  28     defer pub_sock.Close()
  29
  30     if use_syslog_ {
  31         LogEnableSyslog()
  32         Syslog_.Print("started")
  33     }
  34
  35     serial_wr, serial_rd, err := OpenAndHandleSerial(tty_dev_)
  36     if err != nil { panic(err) }
  37     defer close(serial_wr)
  38
  39     for incoming_ser_line := range(serial_rd) {
  40         Syslog_.Printf("%s",incoming_ser_line)
  41         if err := pub_sock.Send(incoming_ser_line); err != nil { panic(err) }
  42     }
  43 }