X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=avahi-sharp%2FAddressResolver.cs;h=3231cbf492efa6c6f404890af982adaadfe02e16;hb=5f50418bcedca75028597dfa6504e5be9a549c26;hp=c462346452e48067a84750ed58e23be155117b08;hpb=264700bf97de2e4430494cb41201950162fba020;p=catta diff --git a/avahi-sharp/AddressResolver.cs b/avahi-sharp/AddressResolver.cs index c462346..3231cbf 100644 --- a/avahi-sharp/AddressResolver.cs +++ b/avahi-sharp/AddressResolver.cs @@ -29,18 +29,19 @@ namespace Avahi { internal delegate void AddressResolverCallback (IntPtr resolver, int iface, Protocol proto, - ResolverEvent revent, Protocol aproto, IntPtr address, - IntPtr hostname, IntPtr userdata); + ResolverEvent revent, IntPtr address, + IntPtr hostname, LookupResultFlags flags, IntPtr userdata); public delegate void HostAddressHandler (object o, string host, IPAddress address); - public class AddressResolver : IDisposable + public class AddressResolver : ResolverBase, IDisposable { private IntPtr handle; private Client client; private int iface; private Protocol proto; private IPAddress address; + private LookupFlags flags; private AddressResolverCallback cb; private IPAddress currentAddress; @@ -51,7 +52,8 @@ namespace Avahi [DllImport ("avahi-client")] private static extern IntPtr avahi_address_resolver_new (IntPtr client, int iface, Protocol proto, - IntPtr address, AddressResolverCallback cb, + IntPtr address, LookupFlags flags, + AddressResolverCallback cb, IntPtr userdata); [DllImport ("avahi-client")] @@ -91,16 +93,18 @@ namespace Avahi get { return currentHost; } } - public AddressResolver (Client client, IPAddress address) : this (client, -1, Protocol.Unspecified, address) + public AddressResolver (Client client, IPAddress address) : this (client, -1, Protocol.Unspecified, + address, LookupFlags.None) { } - public AddressResolver (Client client, int iface, Protocol proto, IPAddress address) + public AddressResolver (Client client, int iface, Protocol proto, IPAddress address, LookupFlags flags) { this.client = client; this.iface = iface; this.proto = proto; this.address = address; + this.flags = flags; cb = OnAddressResolverCallback; } @@ -120,10 +124,10 @@ namespace Avahi (foundListeners.Count == 0 && timeoutListeners.Count == 0)) return; - IntPtr addrPtr = Utility.StringToPtr (address.ToString ()); + IntPtr addrPtr = Utility.AddressToPtr (address); lock (client) { - handle = avahi_address_resolver_new (client.Handle, iface, proto, addrPtr, + handle = avahi_address_resolver_new (client.Handle, iface, proto, addrPtr, flags, cb, IntPtr.Zero); } @@ -143,21 +147,20 @@ namespace Avahi } private void OnAddressResolverCallback (IntPtr resolver, int iface, Protocol proto, - ResolverEvent revent, Protocol aproto, IntPtr address, - IntPtr hostname, IntPtr userdata) + ResolverEvent revent, IntPtr address, + IntPtr hostname, LookupResultFlags flags, IntPtr userdata) { - if (revent == ResolverEvent.Found) { + switch (revent) { + case ResolverEvent.Found: currentAddress = Utility.PtrToAddress (address); currentHost = Utility.PtrToString (hostname); foreach (HostAddressHandler handler in foundListeners) handler (this, currentHost, currentAddress); - } else { - currentAddress = null; - currentHost = null; - - foreach (EventHandler handler in timeoutListeners) - handler (this, new EventArgs ()); + break; + case ResolverEvent.Failure: + EmitFailure (client.LastError); + break; } } }