realtimetraffic/realtimetrafficd/hub.go

75 lines
1.8 KiB
Go
Raw Normal View History

2014-03-09 16:53:21 +01:00
/*
2017-05-22 14:58:47 +02:00
* Copyright (C) 2014-2017 struktur AG
* http://www.strukturag.com
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
2014-03-09 16:53:21 +01:00
*/
2017-05-22 14:58:47 +02:00
2014-03-09 16:53:21 +01:00
package main
2017-05-22 16:07:58 +02:00
import (
"github.com/longsleep/realtimetraffic"
)
2014-03-09 16:53:21 +01:00
type hub struct {
2017-05-22 16:07:58 +02:00
grabbers map[string]*realtimetraffic.Grabber
2014-03-09 16:53:21 +01:00
connections map[*connection]bool
2017-05-22 16:07:58 +02:00
broadcast chan *realtimetraffic.Interfacedata
2014-03-09 16:53:21 +01:00
register chan *connection
unregister chan *connection
}
var h = hub{
2017-05-22 16:07:58 +02:00
broadcast: make(chan *realtimetraffic.Interfacedata),
2014-03-09 16:53:21 +01:00
register: make(chan *connection),
unregister: make(chan *connection),
connections: make(map[*connection]bool),
2017-05-22 16:07:58 +02:00
grabbers: make(map[string]*realtimetraffic.Grabber),
2014-03-09 16:53:21 +01:00
}
func (h *hub) run() {
2017-05-22 16:07:58 +02:00
var eg *realtimetraffic.Grabber
2014-03-09 16:53:21 +01:00
var ok bool
for {
select {
case c := <-h.register:
h.connections[c] = true
if eg, ok = h.grabbers[c.iface]; !ok {
2017-05-22 16:07:58 +02:00
eg = realtimetraffic.NewGrabber(c.iface)
2014-03-09 16:53:21 +01:00
h.grabbers[c.iface] = eg
}
2017-05-22 16:07:58 +02:00
eg.Start(h.broadcast)
2014-03-09 16:53:21 +01:00
case c := <-h.unregister:
delete(h.connections, c)
close(c.send)
if eg, ok = h.grabbers[c.iface]; ok {
2017-05-22 16:07:58 +02:00
eg.Stop()
2014-03-09 16:53:21 +01:00
}
case d := <-h.broadcast:
for c := range h.connections {
2017-05-22 16:07:58 +02:00
if c.iface == d.Name() {
if m, err := d.JSON(); err == nil {
2014-03-09 16:53:21 +01:00
select {
case c.send <- m:
default:
close(c.send)
delete(h.connections, c)
}
}
}
}
}
}
}