bus-slot.c revision cc65fe5e14770d0116e0f475c5dc2ef57113bc98
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier/***
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier This file is part of systemd.
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier Copyright 2013 Lennart Poettering
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier systemd is free software; you can redistribute it and/or modify it
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier under the terms of the GNU Lesser General Public License as published by
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier the Free Software Foundation; either version 2.1 of the License, or
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier (at your option) any later version.
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier systemd is distributed in the hope that it will be useful, but
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier WITHOUT ANY WARRANTY; without even the implied warranty of
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier Lesser General Public License for more details.
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier You should have received a copy of the GNU Lesser General Public License
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier along with systemd; If not, see <http://www.gnu.org/licenses/>.
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier***/
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier#include "sd-bus.h"
cf0fbc49e67b55f8d346fc94de28c90113505297Thomas Hindoe Paaboel Andersen#include "bus-control.h"
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier#include "bus-objects.h"
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier#include "bus-slot.h"
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevaliersd_bus_slot *bus_slot_allocate(
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier sd_bus *bus,
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier bool floating,
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier BusSlotType type,
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier size_t extra,
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier void *userdata) {
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier sd_bus_slot *slot;
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier assert(bus);
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier slot = malloc0(offsetof(sd_bus_slot, reply_callback) + extra);
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier if (!slot)
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier return NULL;
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier slot->n_ref = 1;
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier slot->type = type;
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier slot->bus = bus;
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier slot->floating = floating;
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier slot->userdata = userdata;
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier if (!floating)
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier sd_bus_ref(bus);
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier LIST_PREPEND(slots, bus->slots, slot);
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier return slot;
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier}
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier_public_ sd_bus_slot* sd_bus_slot_ref(sd_bus_slot *slot) {
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier assert_return(slot, NULL);
2b89a960604d44ea1483c0d99bfb567dab9c3aa1Ronny Chevalier
assert(slot->n_ref > 0);
slot->n_ref++;
return slot;
}
void bus_slot_disconnect(sd_bus_slot *slot) {
sd_bus *bus;
assert(slot);
if (!slot->bus)
return;
switch (slot->type) {
case BUS_REPLY_CALLBACK:
if (slot->reply_callback.cookie != 0)
ordered_hashmap_remove(slot->bus->reply_callbacks, &slot->reply_callback.cookie);
if (slot->reply_callback.timeout != 0)
prioq_remove(slot->bus->reply_callbacks_prioq, &slot->reply_callback, &slot->reply_callback.prioq_idx);
break;
case BUS_FILTER_CALLBACK:
slot->bus->filter_callbacks_modified = true;
LIST_REMOVE(callbacks, slot->bus->filter_callbacks, &slot->filter_callback);
break;
case BUS_MATCH_CALLBACK:
if (slot->match_added)
bus_remove_match_internal(slot->bus, slot->match_callback.match_string, slot->match_callback.cookie);
slot->bus->match_callbacks_modified = true;
bus_match_remove(&slot->bus->match_callbacks, &slot->match_callback);
free(slot->match_callback.match_string);
break;
case BUS_NODE_CALLBACK:
if (slot->node_callback.node) {
LIST_REMOVE(callbacks, slot->node_callback.node->callbacks, &slot->node_callback);
slot->bus->nodes_modified = true;
bus_node_gc(slot->bus, slot->node_callback.node);
}
break;
case BUS_NODE_ENUMERATOR:
if (slot->node_enumerator.node) {
LIST_REMOVE(enumerators, slot->node_enumerator.node->enumerators, &slot->node_enumerator);
slot->bus->nodes_modified = true;
bus_node_gc(slot->bus, slot->node_enumerator.node);
}
break;
case BUS_NODE_OBJECT_MANAGER:
if (slot->node_object_manager.node) {
LIST_REMOVE(object_managers, slot->node_object_manager.node->object_managers, &slot->node_object_manager);
slot->bus->nodes_modified = true;
bus_node_gc(slot->bus, slot->node_object_manager.node);
}
break;
case BUS_NODE_VTABLE:
if (slot->node_vtable.node && slot->node_vtable.interface && slot->node_vtable.vtable) {
const sd_bus_vtable *v;
for (v = slot->node_vtable.vtable; v->type != _SD_BUS_VTABLE_END; v++) {
struct vtable_member *x = NULL;
switch (v->type) {
case _SD_BUS_VTABLE_METHOD: {
struct vtable_member key;
key.path = slot->node_vtable.node->path;
key.interface = slot->node_vtable.interface;
key.member = v->x.method.member;
x = hashmap_remove(slot->bus->vtable_methods, &key);
break;
}
case _SD_BUS_VTABLE_PROPERTY:
case _SD_BUS_VTABLE_WRITABLE_PROPERTY: {
struct vtable_member key;
key.path = slot->node_vtable.node->path;
key.interface = slot->node_vtable.interface;
key.member = v->x.method.member;
x = hashmap_remove(slot->bus->vtable_properties, &key);
break;
}}
free(x);
}
}
free(slot->node_vtable.interface);
if (slot->node_vtable.node) {
LIST_REMOVE(vtables, slot->node_vtable.node->vtables, &slot->node_vtable);
slot->bus->nodes_modified = true;
bus_node_gc(slot->bus, slot->node_vtable.node);
}
break;
default:
assert_not_reached("Wut? Unknown slot type?");
}
bus = slot->bus;
slot->type = _BUS_SLOT_INVALID;
slot->bus = NULL;
LIST_REMOVE(slots, bus->slots, slot);
if (!slot->floating)
sd_bus_unref(bus);
}
_public_ sd_bus_slot* sd_bus_slot_unref(sd_bus_slot *slot) {
if (!slot)
return NULL;
assert(slot->n_ref > 0);
if (slot->n_ref > 1) {
slot->n_ref --;
return NULL;
}
bus_slot_disconnect(slot);
free(slot->description);
free(slot);
return NULL;
}
_public_ sd_bus* sd_bus_slot_get_bus(sd_bus_slot *slot) {
assert_return(slot, NULL);
return slot->bus;
}
_public_ void *sd_bus_slot_get_userdata(sd_bus_slot *slot) {
assert_return(slot, NULL);
return slot->userdata;
}
_public_ void *sd_bus_slot_set_userdata(sd_bus_slot *slot, void *userdata) {
void *ret;
assert_return(slot, NULL);
ret = slot->userdata;
slot->userdata = userdata;
return ret;
}
_public_ sd_bus_message *sd_bus_slot_get_current_message(sd_bus_slot *slot) {
assert_return(slot, NULL);
assert_return(slot->type >= 0, NULL);
if (slot->bus->current_slot != slot)
return NULL;
return slot->bus->current_message;
}
_public_ sd_bus_message_handler_t sd_bus_slot_get_current_handler(sd_bus_slot *slot) {
assert_return(slot, NULL);
assert_return(slot->type >= 0, NULL);
if (slot->bus->current_slot != slot)
return NULL;
return slot->bus->current_handler;
}
_public_ void* sd_bus_slot_get_current_userdata(sd_bus_slot *slot) {
assert_return(slot, NULL);
assert_return(slot->type >= 0, NULL);
if (slot->bus->current_slot != slot)
return NULL;
return slot->bus->current_userdata;
}
_public_ int sd_bus_slot_set_description(sd_bus_slot *slot, const char *description) {
assert_return(slot, -EINVAL);
return free_and_strdup(&slot->description, description);
}
_public_ int sd_bus_slot_get_description(sd_bus_slot *slot, char **description) {
assert_return(slot, -EINVAL);
assert_return(description, -EINVAL);
assert_return(slot->description, -ENXIO);
*description = slot->description;
return 0;
}