broker.go

@@ -37,7 +37,7 @@ func (b *Broker) Subscribe(name string) (ch chan skylab.BusEvent, err error) {
 	if ok {
 		return nil, errors.New("name already in use")
 	}
-	b.logger.Info("subscribe", "name", name)
+	b.logger.Info("new subscriber", "name", name)
 	ch = make(chan skylab.BusEvent, b.bufsize)
 
 	b.subs[name] = ch
@@ -51,7 +51,6 @@ func (b *Broker) Unsubscribe(name string) {
 	// remove the channel from the map. We don't need to close it.
 	b.lock.Lock()
 	defer b.lock.Unlock()
-	b.logger.Debug("unsubscribe", "name", name)
 	delete(b.subs, name)
 }
 
@@ -60,7 +59,6 @@ func (b *Broker) Unsubscribe(name string) {
 func (b *Broker) Publish(sender string, message skylab.BusEvent) {
 	b.lock.RLock()
 	defer b.lock.RUnlock()
-	b.logger.Debug("publish", "sender", sender, "message", message)
 	for name, ch := range b.subs {
 		if name == sender {
 			continue
@@ -68,6 +66,7 @@ func (b *Broker) Publish(sender string, message skylab.BusEvent) {
 		// non blocking send.
 		select {
 		case ch <- message:
+			b.logger.Debug("sent message", "dest", name, "src", sender)
 		default:
 			b.logger.Warn("recipient buffer full", "dest", name)
 		}

cmd/gotelem/cli/server.go

@@ -92,7 +92,7 @@ func serve(cCtx *cli.Context) error {
 	broker := gotelem.NewBroker(20, logger.WithGroup("broker"))
 
 	// open database
-	dbPath := "gotelem.db"
+	dbPath := "file::memory:?cache=shared"
 	if cCtx.IsSet("db") {
 		dbPath = cCtx.Path("db")
 	}

socketcan/socketcan.go

@@ -144,8 +144,6 @@ func (sck *CanSocket) Send(msg *can.Frame) error {
 		idToWrite |= unix.CAN_RTR_FLAG
 	case can.CanErrFrame:
 		return errors.New("you can't send error frames")
-	case can.CanDataFrame:
-
 	default:
 		return errors.New("unknown frame type")
 	}

socketcan/socketcan_test.go

@@ -51,7 +51,7 @@ func TestCanSocket(t *testing.T) {
 		err := sock.Send(testFrame)
 
 		if err != nil {
-			t.Fatal(err)
+			t.Error(err)
 		}
 	})