X-Git-Url: https://code.octet-stream.net/broadcaster/blobdiff_plain/c94fef11f43279165f39680fa0b0922c86702687..33a19d553807d171f6ba9f4dafe30f43bc4bab5e:/server/status.go?ds=inline diff --git a/server/status.go b/server/status.go deleted file mode 100644 index accbcc9..0000000 --- a/server/status.go +++ /dev/null @@ -1,42 +0,0 @@ -package main - -import ( - "code.octet-stream.net/broadcaster/protocol" -) - -type ServerStatus struct { - statuses map[int]protocol.StatusMessage - changeWait chan bool -} - -var status ServerStatus - -func InitServerStatus() { - status = ServerStatus{ - statuses: make(map[int]protocol.StatusMessage), - changeWait: make(chan bool), - } -} - -func (s *ServerStatus) MergeStatus(radioId int, status protocol.StatusMessage) { - s.statuses[radioId] = status - s.TriggerChange() -} - -func (s *ServerStatus) RadioDisconnected(radioId int) { - delete(s.statuses, radioId) - s.TriggerChange() -} - -func (s *ServerStatus) TriggerChange() { - close(s.changeWait) - s.changeWait = make(chan bool) -} - -func (s *ServerStatus) Statuses() map[int]protocol.StatusMessage { - return s.statuses -} - -func (s *ServerStatus) ChangeChannel() chan bool { - return s.changeWait -}