summaryrefslogtreecommitdiffstats
path: root/serial/manager.c
diff options
context:
space:
mode:
authorClaudio Takahasi <claudio.takahasi@openbossa.org>2007-05-17 13:12:05 +0000
committerClaudio Takahasi <claudio.takahasi@openbossa.org>2007-05-17 13:12:05 +0000
commit3a3580f78fbe363f357abec73bacd89416e4f8f0 (patch)
treea3c8100df3e41047fac9b84f1e961f61d628a1b6 /serial/manager.c
parent5caf7e18f9534e9cd16264026169016ccbcdb1fa (diff)
serial: Removed PortCreated signal when calling ConnectService
Diffstat (limited to 'serial/manager.c')
-rw-r--r--serial/manager.c33
1 files changed, 22 insertions, 11 deletions
diff --git a/serial/manager.c b/serial/manager.c
index c33f51cb..538931a9 100644
--- a/serial/manager.c
+++ b/serial/manager.c
@@ -189,9 +189,7 @@ static int rfcomm_bind(bdaddr_t *src, bdaddr_t *dst, uint8_t ch)
static void open_notify(int fd, int err, void *data)
{
char port_name[16];
- char path[MAX_PATH_LENGTH];
const char *pname = port_name;
- const char *ppath = path;
const char *owner;
DBusMessage *reply;
struct pending_connect *pc = data;
@@ -208,7 +206,7 @@ static void open_notify(int fd, int err, void *data)
return;
}
- /* Check if the caller is still present */
+ /* FIXME: it must be a per request listener */
owner = dbus_message_get_sender(pc->msg);
if (!dbus_bus_name_has_owner(pc->conn, owner, NULL)) {
error("Connect requestor %s exited", owner);
@@ -226,17 +224,12 @@ static void open_notify(int fd, int err, void *data)
send_message_and_unref(pc->conn, reply);
/* Send the D-Bus signal */
- port_register(pc->conn, pc->id, fd, pname, owner, path);
- dbus_connection_emit_signal(pc->conn, SERIAL_MANAGER_PATH,
- SERIAL_MANAGER_INTERFACE, "PortCreated" ,
- DBUS_TYPE_STRING, &ppath,
- DBUS_TYPE_INVALID);
-
dbus_connection_emit_signal(pc->conn, SERIAL_MANAGER_PATH,
SERIAL_MANAGER_INTERFACE, "ServiceConnected" ,
DBUS_TYPE_STRING, &pname,
DBUS_TYPE_INVALID);
+ port_add_listener(pc->conn, pc->id, fd, port_name, owner);
}
static gboolean rfcomm_connect_cb(GIOChannel *chan,
@@ -453,7 +446,7 @@ static void record_reply(DBusPendingCall *call, void *data)
}
snprintf(port_name, sizeof(port_name), "/dev/rfcomm%d", err);
- port_register(pc->conn, err, -1, port_name, NULL, path);
+ port_register(pc->conn, err, port_name, path);
reply = dbus_message_new_method_return(pc->msg);
dbus_message_append_args(reply,
@@ -728,7 +721,7 @@ static DBusHandlerResult create_port(DBusConnection *conn,
return err_failed(conn, msg, strerror(-err));
snprintf(port_name, sizeof(port_name), "/dev/rfcomm%d", err);
- port_register(conn, err, -1, port_name, NULL, path);
+ port_register(conn, err, port_name, path);
reply = dbus_message_new_method_return(msg);
if (!reply)
@@ -920,12 +913,30 @@ static DBusHandlerResult cancel_connect_service(DBusConnection *conn,
static void manager_unregister(DBusConnection *conn, void *data)
{
+ char **dev;
+ int i;
+
if (pending_connects) {
g_slist_foreach(pending_connects,
(GFunc) pending_connect_free, NULL);
g_slist_free(pending_connects);
pending_connects = NULL;
}
+
+ /* Unregister all paths in serial hierarchy */
+ if (!dbus_connection_list_registered(conn, SERIAL_MANAGER_PATH, &dev))
+ return;
+
+ for (i = 0; dev[i]; i++) {
+ char dev_path[MAX_PATH_LENGTH];
+
+ snprintf(dev_path, sizeof(dev_path), "%s/%s", SERIAL_MANAGER_PATH,
+ dev[i]);
+
+ dbus_connection_destroy_object_path(conn, dev_path);
+ }
+
+ dbus_free_string_array(dev);
}
static DBusMethodVTable manager_methods[] = {