diff --git a/Spike/Program.cs b/Spike/Program.cs index 7347750..e6659d9 100644 --- a/Spike/Program.cs +++ b/Spike/Program.cs @@ -55,7 +55,7 @@ static void Main(string[] args) var sd = new ServiceDiscovery(mdns); sd.Advertise(new ServiceProfile("x1", "_xservice._tcp", 5011)); sd.Advertise(new ServiceProfile("x2", "_xservice._tcp", 666)); - var z1 = new ServiceProfile("z1", "_zservice._tcp", 5012); + var z1 = new ServiceProfile("z1", "_zservice.udp", 5012); z1.AddProperty("foo", "bar"); sd.Advertise(z1); diff --git a/src/Mdns.csproj b/src/Mdns.csproj index 0f232db..f7e9b7f 100644 --- a/src/Mdns.csproj +++ b/src/Mdns.csproj @@ -31,7 +31,7 @@ - + diff --git a/src/ServiceDiscovery.cs b/src/ServiceDiscovery.cs index 079c4ac..8f5574a 100644 --- a/src/ServiceDiscovery.cs +++ b/src/ServiceDiscovery.cs @@ -1,4 +1,5 @@ -using Makaretu.Dns.Resolving; +using Common.Logging; +using Makaretu.Dns.Resolving; using System; using System.Collections.Generic; using System.Linq; @@ -13,6 +14,8 @@ namespace Makaretu.Dns /// RFC 6763 DNS-Based Service Discovery public class ServiceDiscovery : IDisposable { + static readonly ILog log = LogManager.GetLogger(typeof(ServiceDiscovery)); + /// /// The service discovery service name. /// @@ -136,6 +139,9 @@ void OnAnswer(object sender, MessageEventArgs e) void OnQuery(object sender, MessageEventArgs e) { var request = e.Message; + + if (log.IsDebugEnabled) + log.Debug($"got query for {request.Questions[0].Name} {request.Questions[0].Type}"); var response = NameServer.ResolveAsync(request).Result; if (response.Status == MessageStatus.NoError) { @@ -147,6 +153,8 @@ void OnQuery(object sender, MessageEventArgs e) } Mdns.SendAnswer(response); + if (log.IsDebugEnabled) + log.Debug($"sent answer {response.Answers[0]}"); //Console.WriteLine($"Response time {(DateTime.Now - request.CreationTime).TotalMilliseconds}ms"); } }