summaryrefslogtreecommitdiff
path: root/src/rhctl/playout_server.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/rhctl/playout_server.go')
-rw-r--r--src/rhctl/playout_server.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rhctl/playout_server.go b/src/rhctl/playout_server.go
index 5fc1dfd..9589065 100644
--- a/src/rhctl/playout_server.go
+++ b/src/rhctl/playout_server.go
@@ -65,7 +65,6 @@ type PlayoutServer struct {
}
func (srv *PlayoutServer) handleHeartbeat() {
- rhdl.Printf("Server(%s): got heartbeat message", srv.name)
srv.hbtimer.Reset(srv.hbtimeout)
if (srv.hbcnt + 1) < srv.hbthreshold {
srv.hbcnt++
@@ -85,12 +84,13 @@ func (srv *PlayoutServer) handleHeartbeat() {
}
func (srv *PlayoutServer) handleMessage(data string) {
- rhdl.Printf("Server(%s): got message: %q", srv.name, data)
-
if data == "hb" {
+ // rhdl.Printf("Server(%s): got heartbeat message", srv.name)
srv.handleHeartbeat()
return
}
+
+ rhdl.Printf("Server(%s): got message: %q", srv.name, data)
if strings.HasPrefix(data, "channel ") {
if len(data) <= 8 {
rhl.Printf("Server(%s) sent empty channel name", srv.name)