I'm working on a clean shutdown procedure for the client / resolver, and I'm unsure how to proceed because I'm a bit confused by the API.
To start a mDNS client, you first create a new resolver, and then call Lookup or Browse:
r, _ := NewResolver()
entries := make(chan *ServiceEntry)
err := r.Browse(ctx, "service", "domain", entries)
This raises 2 problems:
- Both
Browse and Lookup return immediately. The go routines started by these methods (including the Go routine that reads from the connection) is stopped eventually after the context is done, but there's no way to deterministically tell when this happened.
- Although the API seems to suggest otherwise, it's only possible to call
Lookup / Browse once per Resolver instance, as both of them start reading from the UDPConn (and it only makes sense to read from a connection with a single Go routine).
I can see 2 fundamentally different ways to resolve this:
- Change the API in a way that doesn't suggest that
Browse and Lookup can be called multiple times.
- This would probably mean to remove the
Resolver, and expose Browse and Lookup as top-level functions.
- Make
Browse and Lookup block until all Go routines have stopped.
- Make it possible to call
Browse and Lookup concurrently. This would require us to have some demultiplexing logic, to associate received message with a particular lookup. This is easy for responses to a query (they come with an ID), but I'm not sure how one would implement this for the unrequested announcements that servers send out regularly.
Any thoughts, @grandcat and @Stebalien?
I'm working on a clean shutdown procedure for the client / resolver, and I'm unsure how to proceed because I'm a bit confused by the API.
To start a mDNS client, you first create a new resolver, and then call
LookuporBrowse:This raises 2 problems:
BrowseandLookupreturn immediately. The go routines started by these methods (including the Go routine that reads from the connection) is stopped eventually after the context is done, but there's no way to deterministically tell when this happened.Lookup/Browseonce perResolverinstance, as both of them start reading from theUDPConn(and it only makes sense to read from a connection with a single Go routine).I can see 2 fundamentally different ways to resolve this:
BrowseandLookupcan be called multiple times.Resolver, and exposeBrowseandLookupas top-level functions.BrowseandLookupblock until all Go routines have stopped.BrowseandLookupconcurrently. This would require us to have some demultiplexing logic, to associate received message with a particular lookup. This is easy for responses to a query (they come with an ID), but I'm not sure how one would implement this for the unrequested announcements that servers send out regularly.Any thoughts, @grandcat and @Stebalien?