arashpayan / chirp Goto Github PK

This block of code from *Listener.listen occasionally causes a 'concurrent map writes' panic inside of l.handlePublish, and probably l.handleRemoval too.

    received := make(chan *message)
    for msg := range received {
        if msg.SenderID == l.id {
            continue
        }
        switch msg.Type {
        case messageTypePublishService:
            l.handlePublish(msg)
        case messageTypeRemoveService:
            l.handleRemoval(msg)
        }
    }

When a service is discovered by a browser/listener, a removal event should happen after the TTL has expired.

so dropped UDP packets are less of a problem

... Publishers can inspect the new_listener message and avoid sending an announcement when the interested service name isn't the same as their own.