X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=bus%2Fdriver.c;h=a664517394df10898fb28f1cbdee64a51180d1f4;hb=bd6d8d261df61ed8b396434e5a80285d43184d6c;hp=9ecfd55ff7dc8cad93e0b398636aa955cbd86e6c;hpb=2121ff07d5e180e5537418c8d0e69d59eafefdfc;p=platform%2Fupstream%2Fdbus.git diff --git a/bus/driver.c b/bus/driver.c index 9ecfd55..a664517 100644 --- a/bus/driver.c +++ b/bus/driver.c @@ -32,12 +32,61 @@ #include "signals.h" #include "stats.h" #include "utils.h" + +#include #include #include #include #include #include +#include "kdbus-d.h" +#include +#include +#include + +static DBusConnection * +bus_driver_get_conn_helper (DBusConnection *connection, + DBusMessage *message, + const char *what_we_want, + const char **name_p, + DBusError *error) +{ + const char *name; + BusRegistry *registry; + BusService *serv; + DBusString str; + DBusConnection *conn; + + if (!dbus_message_get_args (message, error, + DBUS_TYPE_STRING, &name, + DBUS_TYPE_INVALID)) + return NULL; + + _dbus_assert (name != NULL); + _dbus_verbose ("asked for %s of connection %s\n", what_we_want, name); + + registry = bus_connection_get_registry (connection); + _dbus_string_init_const (&str, name); + serv = bus_registry_lookup (registry, &str); + + if (serv == NULL) + { + dbus_set_error (error, DBUS_ERROR_NAME_HAS_NO_OWNER, + "Could not get %s of name '%s': no such name", + what_we_want, name); + return NULL; + } + + conn = bus_service_get_primary_owners_connection (serv); + _dbus_assert (conn != NULL); + + if (name_p != NULL) + *name_p = name; + + return conn; +} + static dbus_bool_t bus_driver_send_welcome_message (DBusConnection *connection, DBusMessage *hello_message, BusTransaction *transaction, @@ -54,6 +103,9 @@ bus_driver_send_service_owner_changed (const char *service_name, dbus_bool_t retval; const char *null_service; + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + return TRUE; + _DBUS_ASSERT_ERROR_IS_CLEAR (error); null_service = ""; @@ -103,6 +155,9 @@ bus_driver_send_service_lost (DBusConnection *connection, { DBusMessage *message; + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + return TRUE; + _DBUS_ASSERT_ERROR_IS_CLEAR (error); message = dbus_message_new_signal (DBUS_PATH_DBUS, @@ -146,6 +201,9 @@ bus_driver_send_service_acquired (DBusConnection *connection, { DBusMessage *message; + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + return TRUE; + _DBUS_ASSERT_ERROR_IS_CLEAR (error); message = dbus_message_new_signal (DBUS_PATH_DBUS, @@ -393,6 +451,17 @@ bus_driver_handle_list_services (DBusConnection *connection, return FALSE; } + + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + if(!kdbus_list_services (connection, &services, &len)) + { + dbus_message_unref (reply); + BUS_SET_OOM (error); + return FALSE; + } + } + else if (!bus_registry_list_services (registry, &services, &len)) { dbus_message_unref (reply); @@ -412,6 +481,7 @@ bus_driver_handle_list_services (DBusConnection *connection, return FALSE; } + if(!bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl { /* Include the bus driver in the list */ const char *v_STRING = DBUS_SERVICE_DBUS; @@ -583,13 +653,25 @@ bus_driver_handle_acquire_service (DBusConnection *connection, retval = FALSE; reply = NULL; - _dbus_string_init_const (&service_name, name); + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + if (!bus_registry_acquire_kdbus_service (registry, connection, + message, + &service_reply, transaction, + error)) + goto out; + } + else + { + _dbus_string_init_const (&service_name, name); - if (!bus_registry_acquire_service (registry, connection, - &service_name, flags, - &service_reply, transaction, - error)) - goto out; + if (!bus_registry_acquire_service (registry, connection, + &service_name, flags, + &service_reply, transaction, + error)) + goto out; + + } reply = dbus_message_new_method_return (message); if (reply == NULL) @@ -604,6 +686,8 @@ bus_driver_handle_acquire_service (DBusConnection *connection, goto out; } + _dbus_verbose ("Reply sender: %s, destination: %s\n", dbus_message_get_sender(reply), dbus_message_get_destination(reply)); //todo kdbus incl + if (!bus_transaction_send_from_driver (transaction, connection, reply)) { BUS_SET_OOM (error); @@ -647,6 +731,14 @@ bus_driver_handle_release_service (DBusConnection *connection, _dbus_string_init_const (&service_name, name); + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) + { + registry = (BusRegistry*) dbus_message_get_sender(message); + /* todo looks like hack? Yes. + * But how to pass sender of message to bus_registry_release_service in other way? + */ + } + if (!bus_registry_release_service (registry, connection, &service_name, &service_reply, transaction, error)) @@ -710,9 +802,27 @@ bus_driver_handle_service_exists (DBusConnection *connection, } else { - _dbus_string_init_const (&service_name, name); - service = bus_registry_lookup (registry, &service_name); - service_exists = service != NULL; + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + int inter_ret; + struct nameInfo info; + + inter_ret = kdbus_NameQuery(name, dbus_connection_get_transport(connection), &info); + if((inter_ret == 0) || (inter_ret == -ENOENT)) + service_exists = (inter_ret == 0) ? TRUE : FALSE; + else + { + _dbus_verbose("kdbus error checking if name exists: err %d (%m)\n", errno); + dbus_set_error (error, DBUS_ERROR_FAILED, "Could not determine whether name '%s' exists", name); + service_exists = FALSE; + } + } + else + { + _dbus_string_init_const (&service_name, name); + service = bus_registry_lookup (registry, &service_name); + service_exists = service != NULL; + } } reply = dbus_message_new_method_return (message); @@ -827,7 +937,6 @@ bus_driver_handle_update_activation_environment (DBusConnection *connection, DBusMessageIter iter; DBusMessageIter dict_iter; DBusMessageIter dict_entry_iter; - int msg_type; int array_type; int key_type; DBusList *keys, *key_link; @@ -842,9 +951,7 @@ bus_driver_handle_update_activation_environment (DBusConnection *connection, /* The message signature has already been checked for us, * so let's just assert it's right. */ - msg_type = dbus_message_iter_get_arg_type (&iter); - - _dbus_assert (msg_type == DBUS_TYPE_ARRAY); + _dbus_assert (dbus_message_iter_get_arg_type (&iter) == DBUS_TYPE_ARRAY); dbus_message_iter_recurse (&iter, &dict_iter); @@ -985,20 +1092,33 @@ bus_driver_handle_add_match (DBusConnection *connection, if (rule == NULL) goto failed; - matchmaker = bus_connection_get_matchmaker (connection); + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { - if (!bus_matchmaker_add_rule (matchmaker, rule)) - { - BUS_SET_OOM (error); - goto failed; - } + if (!kdbus_add_match_rule (connection, message, text, error)) + goto failed; - if (!send_ack_reply (connection, transaction, - message, error)) - { - bus_matchmaker_remove_rule (matchmaker, rule); - goto failed; - } + if (!send_ack_reply (connection, transaction, + message, error)) + goto failed; + } + else + { + matchmaker = bus_connection_get_matchmaker (connection); + + if (!bus_matchmaker_add_rule (matchmaker, rule)) + { + BUS_SET_OOM (error); + goto failed; + } + + if (!send_ack_reply (connection, transaction, + message, error)) + { + bus_matchmaker_remove_rule (matchmaker, rule); + goto failed; + } + } bus_match_rule_unref (rule); @@ -1041,6 +1161,12 @@ bus_driver_handle_remove_match (DBusConnection *connection, if (rule == NULL) goto failed; + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + if(!kdbus_remove_match(connection, message, error)) + goto failed; + } + /* Send the ack before we remove the rule, since the ack is undone * on transaction cancel, but rule removal isn't. */ @@ -1048,10 +1174,13 @@ bus_driver_handle_remove_match (DBusConnection *connection, message, error)) goto failed; - matchmaker = bus_connection_get_matchmaker (connection); + if(!bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + matchmaker = bus_connection_get_matchmaker (connection); - if (!bus_matchmaker_remove_rule_by_value (matchmaker, rule, error)) - goto failed; + if (!bus_matchmaker_remove_rule_by_value (matchmaker, rule, error)) + goto failed; + } bus_match_rule_unref (rule); @@ -1076,6 +1205,7 @@ bus_driver_handle_get_service_owner (DBusConnection *connection, BusRegistry *registry; BusService *service; DBusMessage *reply; + char unique_name[(unsigned int)(snprintf((char*)base_name, 0, "%llu", ULLONG_MAX) + sizeof(":1."))]; _DBUS_ASSERT_ERROR_IS_CLEAR (error); @@ -1089,35 +1219,63 @@ bus_driver_handle_get_service_owner (DBusConnection *connection, DBUS_TYPE_INVALID)) goto failed; - _dbus_string_init_const (&str, text); - service = bus_registry_lookup (registry, &str); - if (service == NULL && - _dbus_string_equal_c_str (&str, DBUS_SERVICE_DBUS)) - { - /* ORG_FREEDESKTOP_DBUS owns itself */ - base_name = DBUS_SERVICE_DBUS; - } - else if (service == NULL) - { - dbus_set_error (error, - DBUS_ERROR_NAME_HAS_NO_OWNER, - "Could not get owner of name '%s': no such name", text); - goto failed; - } + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + int ret; + struct nameInfo info; + + ret = kdbus_NameQuery(text, dbus_connection_get_transport(connection), &info); + if(ret == 0) //unique id of the name + { + sprintf(unique_name, ":1.%llu", (unsigned long long int)info.uniqueId); + _dbus_verbose("Unique name discovered:%s\n", unique_name); + base_name = unique_name; + } + else if(ret == -ENOENT) //name has no owner + { + dbus_set_error (error, DBUS_ERROR_NAME_HAS_NO_OWNER, + "Could not get owner of name '%s': no such name", text); + goto failed; + } + else + { + _dbus_verbose("kdbus error sending name query: err %d (%m)\n", errno); + dbus_set_error (error, DBUS_ERROR_FAILED, + "Could not determine unique name for '%s'", text); + goto failed; + } + } else - { - base_name = bus_connection_get_name (bus_service_get_primary_owners_connection (service)); - if (base_name == NULL) - { - /* FIXME - how is this error possible? */ - dbus_set_error (error, - DBUS_ERROR_FAILED, - "Could not determine unique name for '%s'", text); - goto failed; - } - _dbus_assert (*base_name == ':'); - } - + { + _dbus_string_init_const (&str, text); + service = bus_registry_lookup (registry, &str); + if (service == NULL && + _dbus_string_equal_c_str (&str, DBUS_SERVICE_DBUS)) + { + /* ORG_FREEDESKTOP_DBUS owns itself */ + base_name = DBUS_SERVICE_DBUS; + } + else if (service == NULL) + { + dbus_set_error (error, + DBUS_ERROR_NAME_HAS_NO_OWNER, + "Could not get owner of name '%s': no such name", text); + goto failed; + } + else + { + base_name = bus_connection_get_name (bus_service_get_primary_owners_connection (service)); + if (base_name == NULL) + { + /* FIXME - how is this error possible? */ + dbus_set_error (error, + DBUS_ERROR_FAILED, + "Could not determine unique name for '%s'", text); + goto failed; + } + _dbus_assert (*base_name == ':'); + } + } _dbus_assert (base_name != NULL); reply = dbus_message_new_method_return (message); @@ -1259,52 +1417,39 @@ bus_driver_handle_get_connection_unix_user (DBusConnection *connection, DBusMessage *message, DBusError *error) { - const char *service; - DBusString str; - BusRegistry *registry; - BusService *serv; DBusConnection *conn; DBusMessage *reply; unsigned long uid; dbus_uint32_t uid32; + const char *service; _DBUS_ASSERT_ERROR_IS_CLEAR (error); - registry = bus_connection_get_registry (connection); - - service = NULL; - reply = NULL; - - if (! dbus_message_get_args (message, error, - DBUS_TYPE_STRING, &service, - DBUS_TYPE_INVALID)) - goto failed; - - _dbus_verbose ("asked for UID of connection %s\n", service); - - _dbus_string_init_const (&str, service); - serv = bus_registry_lookup (registry, &str); - if (serv == NULL) - { - dbus_set_error (error, - DBUS_ERROR_NAME_HAS_NO_OWNER, - "Could not get UID of name '%s': no such name", service); - goto failed; - } - - conn = bus_service_get_primary_owners_connection (serv); - reply = dbus_message_new_method_return (message); if (reply == NULL) goto oom; - if (!dbus_connection_get_unix_user (conn, &uid)) - { - dbus_set_error (error, - DBUS_ERROR_FAILED, - "Could not determine UID for '%s'", service); - goto failed; - } + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + if(!kdbus_get_connection_unix_user(connection, message, &uid, error)) + goto failed; + } + else + { + conn = bus_driver_get_conn_helper (connection, message, "UID", &service, + error); + + if (conn == NULL) + goto failed; + + if (!dbus_connection_get_unix_user (conn, &uid)) + { + dbus_set_error (error, + DBUS_ERROR_FAILED, + "Could not determine UID for '%s'", service); + goto failed; + } + } uid32 = uid; if (! dbus_message_append_args (reply, @@ -1335,52 +1480,41 @@ bus_driver_handle_get_connection_unix_process_id (DBusConnection *connection, DBusMessage *message, DBusError *error) { - const char *service; - DBusString str; - BusRegistry *registry; - BusService *serv; DBusConnection *conn; DBusMessage *reply; unsigned long pid; dbus_uint32_t pid32; + const char *service; _DBUS_ASSERT_ERROR_IS_CLEAR (error); - registry = bus_connection_get_registry (connection); - - service = NULL; - reply = NULL; - - if (! dbus_message_get_args (message, error, - DBUS_TYPE_STRING, &service, - DBUS_TYPE_INVALID)) - goto failed; + reply = dbus_message_new_method_return (message); + if (reply == NULL) + goto oom; - _dbus_verbose ("asked for PID of connection %s\n", service); + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + if(!kdbus_get_connection_unix_process_id(connection, message, &pid, error)) + goto failed; + } + else + { + conn = bus_driver_get_conn_helper (connection, message, "PID", &service, + error); - _dbus_string_init_const (&str, service); - serv = bus_registry_lookup (registry, &str); - if (serv == NULL) - { - dbus_set_error (error, - DBUS_ERROR_NAME_HAS_NO_OWNER, - "Could not get PID of name '%s': no such name", service); - goto failed; - } + if (conn == NULL) + goto failed; - conn = bus_service_get_primary_owners_connection (serv); - reply = dbus_message_new_method_return (message); - if (reply == NULL) - goto oom; - if (!dbus_connection_get_unix_process_id (conn, &pid)) - { - dbus_set_error (error, - DBUS_ERROR_UNIX_PROCESS_ID_UNKNOWN, - "Could not determine PID for '%s'", service); - goto failed; - } + if (!dbus_connection_get_unix_process_id (conn, &pid)) + { + dbus_set_error (error, + DBUS_ERROR_UNIX_PROCESS_ID_UNKNOWN, + "Could not determine PID for '%s'", service); + goto failed; + } + } pid32 = pid; if (! dbus_message_append_args (reply, @@ -1411,40 +1545,21 @@ bus_driver_handle_get_adt_audit_session_data (DBusConnection *connection, DBusMessage *message, DBusError *error) { - const char *service; - DBusString str; - BusRegistry *registry; - BusService *serv; DBusConnection *conn; DBusMessage *reply; void *data = NULL; dbus_uint32_t data_size; + const char *service; _DBUS_ASSERT_ERROR_IS_CLEAR (error); - registry = bus_connection_get_registry (connection); - - service = NULL; reply = NULL; - if (! dbus_message_get_args (message, error, - DBUS_TYPE_STRING, &service, - DBUS_TYPE_INVALID)) - goto failed; - - _dbus_verbose ("asked for audit session data for connection %s\n", service); - - _dbus_string_init_const (&str, service); - serv = bus_registry_lookup (registry, &str); - if (serv == NULL) - { - dbus_set_error (error, - DBUS_ERROR_NAME_HAS_NO_OWNER, - "Could not get audit session data for name '%s': no such name", service); - goto failed; - } + conn = bus_driver_get_conn_helper (connection, message, + "audit session data", &service, error); - conn = bus_service_get_primary_owners_connection (serv); + if (conn == NULL) + goto failed; reply = dbus_message_new_method_return (message); if (reply == NULL) @@ -1486,60 +1601,135 @@ bus_driver_handle_get_connection_selinux_security_context (DBusConnection *conne DBusMessage *message, DBusError *error) { - const char *service; - DBusString str; - BusRegistry *registry; - BusService *serv; DBusConnection *conn; DBusMessage *reply; BusSELinuxID *context; + const char *service; _DBUS_ASSERT_ERROR_IS_CLEAR (error); - registry = bus_connection_get_registry (connection); + reply = dbus_message_new_method_return (message); + if (reply == NULL) + goto oom; - service = NULL; - reply = NULL; + if(bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + if(!kdbus_get_connection_unix_selinux_security_context(connection, message, reply, error)) + goto failed; + } + else + { + conn = bus_driver_get_conn_helper (connection, message, "security context", + &service, error); + + if (conn == NULL) + goto failed; + + context = bus_connection_get_selinux_id (conn); + if (!context) + { + dbus_set_error (error, + DBUS_ERROR_SELINUX_SECURITY_CONTEXT_UNKNOWN, + "Could not determine security context for '%s'", service); + goto failed; + } + + if (! bus_selinux_append_context (reply, context, error)) + goto failed; + } - if (! dbus_message_get_args (message, error, - DBUS_TYPE_STRING, &service, - DBUS_TYPE_INVALID)) - goto failed; + if (! bus_transaction_send_from_driver (transaction, connection, reply)) + goto oom; - _dbus_verbose ("asked for security context of connection %s\n", service); + dbus_message_unref (reply); - _dbus_string_init_const (&str, service); - serv = bus_registry_lookup (registry, &str); - if (serv == NULL) - { - dbus_set_error (error, - DBUS_ERROR_NAME_HAS_NO_OWNER, - "Could not get security context of name '%s': no such name", service); - goto failed; - } + return TRUE; - conn = bus_service_get_primary_owners_connection (serv); + oom: + BUS_SET_OOM (error); - reply = dbus_message_new_method_return (message); + failed: + _DBUS_ASSERT_ERROR_IS_SET (error); + if (reply) + dbus_message_unref (reply); + return FALSE; +} + +static dbus_bool_t +bus_driver_handle_get_connection_credentials (DBusConnection *connection, + BusTransaction *transaction, + DBusMessage *message, + DBusError *error) +{ + DBusConnection *conn; + DBusMessage *reply; + DBusMessageIter reply_iter; + DBusMessageIter array_iter; + unsigned long ulong_val; + const char *service; + + _DBUS_ASSERT_ERROR_IS_CLEAR (error); + + reply = _dbus_asv_new_method_return (message, &reply_iter, &array_iter); if (reply == NULL) goto oom; - context = bus_connection_get_selinux_id (conn); - if (!context) - { - dbus_set_error (error, - DBUS_ERROR_SELINUX_SECURITY_CONTEXT_UNKNOWN, - "Could not determine security context for '%s'", service); - goto failed; - } - - if (! bus_selinux_append_context (reply, context, error)) - goto failed; + if(!bus_context_is_kdbus(bus_transaction_get_context (transaction))) //todo kdbus incl + { + conn = bus_driver_get_conn_helper (connection, message, "credentials", + &service, error); + + if (conn == NULL) + goto failed; + + /* we can't represent > 32-bit pids; if your system needs them, please + * add ProcessID64 to the spec or something */ + if (dbus_connection_get_unix_process_id (conn, &ulong_val) && + ulong_val <= _DBUS_UINT32_MAX) + { + if (!_dbus_asv_add_uint32 (&array_iter, "ProcessID", ulong_val)) + goto oom; + } + + /* we can't represent > 32-bit uids; if your system needs them, please + * add UnixUserID64 to the spec or something */ + if (dbus_connection_get_unix_user (conn, &ulong_val) && + ulong_val <= _DBUS_UINT32_MAX) + { + if (!_dbus_asv_add_uint32 (&array_iter, "UnixUserID", ulong_val)) + goto oom; + } + } + else + { + if(kdbus_get_connection_unix_process_id(connection, message, &ulong_val, error)) + { + if (!_dbus_asv_add_uint32 (&array_iter, "ProcessID", ulong_val)) + goto oom; + } + else + goto failed; + + if(kdbus_get_connection_unix_user(connection, message, &ulong_val, error)) + { + if (!_dbus_asv_add_uint32 (&array_iter, "UnixUserID", ulong_val)) + goto oom; + } + else + goto failed; + } - if (! bus_transaction_send_from_driver (transaction, connection, reply)) + if (!_dbus_asv_close (&reply_iter, &array_iter)) goto oom; - dbus_message_unref (reply); + if (! bus_transaction_send_from_driver (transaction, connection, reply)) + { + /* this time we don't want to close the iterator again, so just + * get rid of the message */ + dbus_message_unref (reply); + reply = NULL; + goto oom; + } return TRUE; @@ -1548,8 +1738,13 @@ bus_driver_handle_get_connection_selinux_security_context (DBusConnection *conne failed: _DBUS_ASSERT_ERROR_IS_SET (error); + if (reply) - dbus_message_unref (reply); + { + _dbus_asv_abandon (&reply_iter, &array_iter); + dbus_message_unref (reply); + } + return FALSE; } @@ -1733,6 +1928,8 @@ static const MessageHandler dbus_message_handlers[] = { "", DBUS_TYPE_STRING_AS_STRING, bus_driver_handle_get_id }, + { "GetConnectionCredentials", "s", "a{sv}", + bus_driver_handle_get_connection_credentials }, { NULL, NULL, NULL, NULL } }; @@ -1930,7 +2127,7 @@ bus_driver_handle_message (DBusConnection *connection, DBusMessage *message, DBusError *error) { - const char *name, *sender, *interface; + const char *name, *interface; const InterfaceHandler *ih; const MessageHandler *mh; dbus_bool_t found_interface = FALSE; @@ -1957,13 +2154,12 @@ bus_driver_handle_message (DBusConnection *connection, _dbus_assert (dbus_message_get_member (message) != NULL); name = dbus_message_get_member (message); - sender = dbus_message_get_sender (message); - _dbus_verbose ("Driver got a method call: %s\n", - dbus_message_get_member (message)); + _dbus_verbose ("Driver got a method call: %s\n", name); /* security checks should have kept this from getting here */ - _dbus_assert (sender != NULL || strcmp (name, "Hello") == 0); + _dbus_assert (dbus_message_get_sender (message) != NULL || + strcmp (name, "Hello") == 0); for (ih = interface_handlers; ih->name != NULL; ih++) { @@ -2009,7 +2205,6 @@ bus_driver_handle_message (DBusConnection *connection, } } - unknown: _dbus_verbose ("No driver handler for message \"%s\"\n", name);