X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;ds=sidebyside;f=avahi-sharp%2FEntryGroup.cs;h=142029a22a8ec19e4bb18f70cb5d0732b9112dd4;hb=264700bf97de2e4430494cb41201950162fba020;hp=74a127cfe64b0c94558beca6e2ee1b04e8bc8b9b;hpb=ba12decc4413dedf22c06545d1ec5938efa8954a;p=catta diff --git a/avahi-sharp/EntryGroup.cs b/avahi-sharp/EntryGroup.cs index 74a127c..142029a 100644 --- a/avahi-sharp/EntryGroup.cs +++ b/avahi-sharp/EntryGroup.cs @@ -1,3 +1,24 @@ +/* $Id$ */ + +/*** + This file is part of avahi. + + avahi is free software; you can redistribute it and/or modify it + under the terms of the GNU Lesser General Public License as + published by the Free Software Foundation; either version 2.1 of the + License, or (at your option) any later version. + + avahi is distributed in the hope that it will be useful, but WITHOUT + ANY WARRANTY; without even the implied warranty of MERCHANTABILITY + or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General + Public License for more details. + + You should have received a copy of the GNU Lesser General Public + License along with avahi; if not, write to the Free Software + Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 + USA. +***/ + using System; using System.Runtime.InteropServices; @@ -19,6 +40,7 @@ namespace Avahi { private Client client; private IntPtr handle; + private EntryGroupCallback cb; [DllImport ("avahi-client")] private static extern IntPtr avahi_entry_group_new (IntPtr client, EntryGroupCallback cb, IntPtr userdata); @@ -47,7 +69,7 @@ namespace Avahi private static extern IntPtr avahi_string_list_new (IntPtr txt); [DllImport ("avahi-common")] - private static extern void avahi_string_list_add (IntPtr list, IntPtr txt); + private static extern IntPtr avahi_string_list_add (IntPtr list, IntPtr txt); [DllImport ("avahi-common")] private static extern void avahi_string_list_free (IntPtr list); @@ -56,19 +78,31 @@ namespace Avahi public EntryGroupState State { - get { return avahi_entry_group_get_state (handle); } + get { + lock (client) { + return avahi_entry_group_get_state (handle); + } + } } public bool IsEmpty { - get { return avahi_entry_group_is_empty (handle); } + get { + lock (client) { + return avahi_entry_group_is_empty (handle); + } + } } public EntryGroup (Client client) { this.client = client; - handle = avahi_entry_group_new (client.Handle, OnEntryGroupCallback, IntPtr.Zero); - client.CheckError (); + cb = OnEntryGroupCallback; + + lock (client) { + handle = avahi_entry_group_new (client.Handle, cb, IntPtr.Zero); + client.CheckError (); + } } ~EntryGroup () @@ -78,39 +112,45 @@ namespace Avahi public void Dispose () { - if (handle != IntPtr.Zero) { - avahi_entry_group_free (handle); - handle = IntPtr.Zero; + if (client.Handle != IntPtr.Zero && handle != IntPtr.Zero) { + lock (client) { + avahi_entry_group_free (handle); + handle = IntPtr.Zero; + } } } public void Commit () { - avahi_entry_group_commit (handle); - client.CheckError (); + lock (client) { + avahi_entry_group_commit (handle); + client.CheckError (); + } } public void Reset () { - avahi_entry_group_reset (handle); - client.CheckError (); + lock (client) { + avahi_entry_group_reset (handle); + client.CheckError (); + } } public void AddService (string name, string type, string domain, - UInt16 port, string[] txt) + UInt16 port, params string[] txt) { AddService (-1, Protocol.Unspecified, name, type, domain, null, port, txt); } public void AddService (int iface, Protocol proto, string name, string type, string domain, - string host, UInt16 port, string[] txt) + string host, UInt16 port, params string[] txt) { IntPtr list = avahi_string_list_new (IntPtr.Zero); if (txt != null) { foreach (string item in txt) { IntPtr itemPtr = Utility.StringToPtr (item); - avahi_string_list_add (list, itemPtr); + list = avahi_string_list_add (list, itemPtr); Utility.Free (itemPtr); } } @@ -119,13 +159,15 @@ namespace Avahi IntPtr typePtr = Utility.StringToPtr (type); IntPtr domainPtr = Utility.StringToPtr (domain); IntPtr hostPtr = Utility.StringToPtr (host); - avahi_entry_group_add_service_strlst (handle, iface, proto, namePtr, typePtr, domainPtr, - hostPtr, port, list); + + lock (client) { + avahi_entry_group_add_service_strlst (handle, iface, proto, namePtr, typePtr, domainPtr, + hostPtr, port, list); + } + avahi_string_list_free (list); client.CheckError (); - - Console.WriteLine ("Added service: {0}, {1}, {2}, {3}, {4}", name, type, domain, host, port); } private void OnEntryGroupCallback (IntPtr group, EntryGroupState state, IntPtr userdata)