diff options
Diffstat (limited to 'src/rhctl/playout_server.go')
| -rw-r--r-- | src/rhctl/playout_server.go | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/rhctl/playout_server.go b/src/rhctl/playout_server.go index 118d69f..5491b23 100644 --- a/src/rhctl/playout_server.go +++ b/src/rhctl/playout_server.go @@ -23,6 +23,7 @@ package main import ( "fmt" + "time" ) type ServerHealth bool @@ -44,19 +45,21 @@ func (srv *PlayoutServer) Run() { rhdl.Printf("running playout server: %s", srv.name) srv.control.tx <- fmt.Sprintf("hello %s", srv.name) srv.heartbeat.tx <- fmt.Sprintf("beat %s", srv.name) + + time.Sleep(5 * time.Second) } -func ServerInit(name string, ctrldev, hbdev string, rate Baudrate) (srv *PlayoutServer, err error) { +func ServerInit(name string, conf *Config) (srv *PlayoutServer, err error) { srv = &PlayoutServer{} srv.name = name srv.health = Dead srv.channel = "music" - if srv.control, err = SerialOpenAndHandle(ctrldev, rate, "\r\n"); err != nil { + if srv.control, err = SerialOpenAndHandle(conf.Servers[name].ControlDevice, conf.Servers[name].ControlBaudrate, "\r\n"); err != nil { err = fmt.Errorf("Error opening control port(%s): %s", srv.name, err) return } - if srv.heartbeat, err = SerialOpenAndHandle(hbdev, rate, "\r\n"); err != nil { + if srv.heartbeat, err = SerialOpenAndHandle(conf.Servers[name].HeartbeatDevice, conf.Servers[name].HeartbeatBaudrate, "\r\n"); err != nil { err = fmt.Errorf("Error opening control port(%s): %s", srv.name, err) return } |