1 /* -*- mode: C; c-file-style: "gnu" -*- */
2 /* services.c Service management
4 * Copyright (C) 2003 Red Hat, Inc.
5 * Copyright (C) 2003 CodeFactory AB
7 * Licensed under the Academic Free License version 1.2
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
24 #include <dbus/dbus-hash.h>
25 #include <dbus/dbus-list.h>
26 #include <dbus/dbus-mempool.h>
30 #include "connection.h"
35 BusRegistry *registry;
39 unsigned int prohibit_replacement : 1;
46 DBusHashTable *service_hash;
47 DBusMemPool *service_pool;
51 bus_registry_new (void)
53 BusRegistry *registry;
55 registry = dbus_new0 (BusRegistry, 1);
59 registry->refcount = 1;
61 registry->service_hash = _dbus_hash_table_new (DBUS_HASH_STRING,
63 if (registry->service_hash == NULL)
66 registry->service_pool = _dbus_mem_pool_new (sizeof (BusService),
68 if (registry->service_pool == NULL)
74 bus_registry_unref (registry);
79 bus_registry_ref (BusRegistry *registry)
81 _dbus_assert (registry->refcount > 0);
82 registry->refcount += 1;
86 bus_registry_unref (BusRegistry *registry)
88 _dbus_assert (registry->refcount > 0);
89 registry->refcount -= 1;
91 if (registry->refcount == 0)
93 if (registry->service_hash)
94 _dbus_hash_table_unref (registry->service_hash);
95 if (registry->service_pool)
96 _dbus_mem_pool_free (registry->service_pool);
103 bus_registry_lookup (BusRegistry *registry,
104 const DBusString *service_name)
109 _dbus_string_get_const_data (service_name, &c_name);
111 service = _dbus_hash_table_lookup_string (registry->service_hash,
118 bus_registry_ensure (BusRegistry *registry,
119 const DBusString *service_name,
120 DBusConnection *owner_if_created,
121 BusTransaction *transaction,
127 _dbus_assert (owner_if_created != NULL);
128 _dbus_assert (transaction != NULL);
130 _dbus_string_get_const_data (service_name, &c_name);
132 service = _dbus_hash_table_lookup_string (registry->service_hash,
137 service = _dbus_mem_pool_alloc (registry->service_pool);
144 service->registry = registry;
146 service->name = _dbus_strdup (c_name);
147 if (service->name == NULL)
149 _dbus_mem_pool_dealloc (registry->service_pool, service);
154 if (!bus_driver_send_service_created (service->name, transaction, error))
156 dbus_free (service->name);
157 _dbus_mem_pool_dealloc (registry->service_pool, service);
161 if (!bus_service_add_owner (service, owner_if_created,
164 dbus_free (service->name);
165 _dbus_mem_pool_dealloc (registry->service_pool, service);
169 if (!_dbus_hash_table_insert_string (registry->service_hash,
173 _dbus_list_clear (&service->owners);
174 dbus_free (service->name);
175 _dbus_mem_pool_dealloc (registry->service_pool, service);
184 bus_registry_foreach (BusRegistry *registry,
185 BusServiceForeachFunction function,
190 _dbus_hash_iter_init (registry->service_hash, &iter);
191 while (_dbus_hash_iter_next (&iter))
193 BusService *service = _dbus_hash_iter_get_value (&iter);
195 (* function) (service, data);
200 bus_registry_list_services (BusRegistry *registry,
208 len = _dbus_hash_table_get_n_entries (registry->service_hash);
209 retval = dbus_new (char *, len + 1);
214 _dbus_hash_iter_init (registry->service_hash, &iter);
216 while (_dbus_hash_iter_next (&iter))
218 BusService *service = _dbus_hash_iter_get_value (&iter);
220 retval[i] = _dbus_strdup (service->name);
221 if (retval[i] == NULL)
236 for (j = 0; j < i; j++)
237 dbus_free (retval[i]);
244 bus_service_add_owner (BusService *service,
245 DBusConnection *owner,
246 BusTransaction *transaction,
249 /* Send service acquired message first, OOM will result
250 * in cancelling the transaction
252 if (service->owners == NULL)
254 if (!bus_driver_send_service_acquired (owner, service->name, transaction, error))
258 if (!_dbus_list_append (&service->owners,
265 if (!bus_connection_add_owned_service (owner, service))
267 _dbus_list_remove_last (&service->owners, owner);
276 bus_service_remove_owner (BusService *service,
277 DBusConnection *owner,
278 BusTransaction *transaction,
281 /* We send out notifications before we do any work we
282 * might have to undo if the notification-sending failed
285 /* Send service lost message */
286 if (bus_service_get_primary_owner (service) == owner)
288 if (!bus_driver_send_service_lost (owner, service->name,
293 if (_dbus_list_length_is_one (&service->owners))
295 /* We are the only owner - send service deleted */
296 if (!bus_driver_send_service_deleted (service->name,
303 link = _dbus_list_get_first (&service->owners);
304 link = _dbus_list_get_next_link (&service->owners, link);
308 /* This will be our new owner */
309 if (!bus_driver_send_service_acquired (link->data,
317 _dbus_list_remove_last (&service->owners, owner);
318 bus_connection_remove_owned_service (owner, service);
320 if (service->owners == NULL)
322 /* Delete service (already sent message that it was deleted above) */
323 _dbus_hash_table_remove_string (service->registry->service_hash, service->name);
325 dbus_free (service->name);
326 _dbus_mem_pool_dealloc (service->registry->service_pool, service);
333 bus_service_get_primary_owner (BusService *service)
335 return _dbus_list_get_first (&service->owners);
339 bus_service_get_name (BusService *service)
341 return service->name;
345 bus_service_set_prohibit_replacement (BusService *service,
346 dbus_bool_t prohibit_replacement)
348 service->prohibit_replacement = prohibit_replacement != FALSE;
352 bus_service_get_prohibit_replacement (BusService *service)
354 return service->prohibit_replacement;
358 bus_service_has_owner (BusService *service,
359 DBusConnection *owner)
363 link = _dbus_list_get_first_link (&service->owners);
367 if (link->data == owner)
370 link = _dbus_list_get_next_link (&service->owners, link);