diff options
Diffstat (limited to 'src/dbusHAL.cpp')
| -rw-r--r-- | src/dbusHAL.cpp | 671 |
1 files changed, 2 insertions, 669 deletions
diff --git a/src/dbusHAL.cpp b/src/dbusHAL.cpp index 4bac9c8..48686a3 100644 --- a/src/dbusHAL.cpp +++ b/src/dbusHAL.cpp @@ -42,9 +42,7 @@ dbusHAL::dbusHAL(){ kdDebugFuncIn(trace); dbus_is_connected = false; - hal_is_connected = false; aquiredPolicyPower = false; - hal_ctx = NULL; // add pointer to this for filter_function() myInstance=this; @@ -53,8 +51,6 @@ dbusHAL::dbusHAL(){ kdError() << "Can't connect to D-Bus" << endl; m_dBusQtConnection = NULL; } - if(!initHAL()) - kdError() << "Can't connect to HAL" << endl; kdDebugFuncOut(trace); } @@ -80,16 +76,6 @@ bool dbusHAL::isConnectedToDBUS() { } /*! - * This function return information about connection status to the HAL daemon. - * \return boolean with the state of the connection to HAL - * \retval true if connected - * \retval false if disconnected - */ -bool dbusHAL::isConnectedToHAL() { - return hal_is_connected; -} - -/*! * This function return information if the org.freedesktop.Policy.Power * interface was claimed. * \return boolean with the status of claim the interface @@ -107,12 +93,10 @@ bool dbusHAL::aquiredPolicyPowerInterface() { * \retval false if unsuccessful */ bool dbusHAL::reconnect() { - // free HAL context - freeHAL(); // close D-Bus connection close(); // init D-Bus conntection and HAL context - return (initDBUS() && initHAL()); + return (initDBUS()); } /*! @@ -176,20 +160,6 @@ bool dbusHAL::initDBUS(){ "interface='org.freedesktop.DBus'," "member='NameOwnerChanged'", NULL); - /* add a match rule to catch all signals going through the bus with HAL interface */ - dbus_bus_add_match( dbus_connection, "type='signal'," - "interface='org.freedesktop.Hal.Manager'," - "member='DeviceAdded'", NULL); - dbus_bus_add_match( dbus_connection, "type='signal'," - "interface='org.freedesktop.Hal.Manager'," - "member='DeviceRemoved'", NULL); - dbus_bus_add_match( dbus_connection, "type='signal'," - "interface='org.freedesktop.Hal.Device'," - "member='PropertyModified'", NULL); - dbus_bus_add_match( dbus_connection, "type='signal'," - "interface='org.freedesktop.Hal.Device'," - "member='Condition'", NULL); - /* add a match rule to catch all signals going through the bus with ConsoleKit Interface */ dbus_bus_add_match( dbus_connection, "type='signal'," "interface='org.freedesktop.ConsoleKit.Session'," @@ -318,418 +288,7 @@ bool dbusHAL::isPolicyPowerIfaceOwned(){ } /* ----> DBUS section :: END <---- */ -/* ----> HAL section :: START <---- */ - -/*! - * This function initialise the connection to HAL over the D-Bus daemon. - * \return boolean with the result of the operation - * \retval true if successful initialised HAL connection and context - * \retval false if unsuccessful - */ -bool dbusHAL::initHAL(){ - kdDebugFuncIn(trace); - - if ( !dbus_is_connected ) { - freeHAL(); - return false; - } else if ( hal_is_connected && (hal_ctx != NULL)) { - return true; - } - - // could not connect to HAL, reset all and try again - freeHAL(); - - DBusError error; - dbus_error_init(&error); - - dbus_connection = dbus_bus_get(DBUS_BUS_SYSTEM, &error); - if (dbus_connection == NULL || dbus_error_is_set(&error)) { - kdError() << "could not open connection to system bus: " << error.message << endl; - dbus_error_free(&error); - return false; - } - - bool hal_is_ready = dbus_bus_name_has_owner(dbus_connection, "org.freedesktop.Hal", &error); - - if (!hal_is_ready) { - kdWarning() << "HAL is not ready. We will try later... " << endl; - - if ( dbus_error_is_set( &error ) ) { - kdError() << "Error checking if hal service exists: " << error.message << endl; - dbus_error_free( &error ); - } - - freeHAL(); - return false; - } - - if((hal_ctx = libhal_ctx_new()) == NULL) { - kdError() << "Could not init HAL context" << endl; - return false; - } - - /* setup dbus connection for hal */ - if (!libhal_ctx_set_dbus_connection(hal_ctx, dbus_connection)) { - kdError() << "Could not set up connection to dbus for hal" << endl; - freeHAL(); - return false; - } - - /* init the hal library */ - if (!libhal_ctx_init(hal_ctx, &error)) { - kdError() << "Could not init hal library: " << error.message << endl; - freeHAL(); - return false; - } - - hal_is_connected = true; - - kdDebugFuncOut(trace); - return hal_is_connected; -} - -/*! - * This function free the hal connection/context. - */ -void dbusHAL::freeHAL(){ - - if ( hal_ctx != NULL ) { - libhal_ctx_free( hal_ctx ); - hal_ctx = NULL; - } - hal_is_connected = false; -} - -/*! - * This function try a reconnect to the HAL daemon only. - * \return boolean with the result of the operation - * \retval true if successful reconnected to HAL - * \retval false if unsuccessful - */ -bool dbusHAL::reconnectHAL() { - // free HAL context - freeHAL(); - // init HAL context - return (initHAL()); -} - -/*! - * This function query a integer property from HAL for a given device - * \param udi TQString with the UDI of the device - * \param property TQString with the property - * \param returnval pointer to the return value - * \return If the query was successful or not - */ -bool dbusHAL::halGetPropertyInt(TQString udi, TQString property, int *returnval){ - kdDebugFuncIn(trace); - - bool ret = false; - - if (!initHAL() || udi.isEmpty() || property.isEmpty()) - goto out; - - DBusError error; - dbus_error_init(&error); - - if (!libhal_device_property_exists(hal_ctx, udi.ascii(), property.ascii(), &error)) { - kdWarning() << "Property: " << property << " for: " << udi << " doesn't exist." << endl; - goto out; - } - - *returnval = libhal_device_get_property_int(hal_ctx, udi.ascii(), property.ascii(), &error); - - if (dbus_error_is_set(&error)) { - kdError() << "Fetching property: " << property << " for: " << udi - << " failed with: " << error.message << endl; - dbus_error_free(&error); - goto out; - } else { - ret = true; - } - -out: - kdDebugFuncOut(trace); - return true; -} - -/*! - * This function query a boolean property from HAL for a given device - * \param udi TQString with the UDI of the device - * \param property TQString with the property - * \param returnval pointer to the return value - * \return If the query was successful or not - */ -bool dbusHAL::halGetPropertyBool(TQString udi, TQString property, bool *returnval){ - kdDebugFuncIn(trace); - - bool ret = false; - - if (!initHAL() || udi.isEmpty() || property.isEmpty()) - goto out; - - DBusError error; - dbus_error_init(&error); - - if (!libhal_device_property_exists(hal_ctx, udi.ascii(), property.ascii(), &error)) { - kdWarning() << "Property: " << property << " for: " << udi << " doesn't exist." << endl; - goto out; - } - - *returnval = libhal_device_get_property_bool(hal_ctx, udi.ascii(), property.ascii(), &error); - - if (dbus_error_is_set(&error)) { - kdError() << "Fetching property: " << property << " for: " << udi - << " failed with: " << error.message << endl; - dbus_error_free(&error); - goto out; - } else { - ret = true; - } - -out: - kdDebugFuncOut(trace); - return ret; -} - - -/*! - * This function query a Sting property from HAL for a given device - * \param udi TQString with the UDI of the device - * \param property TQString with the property - * \param returnval pointer to the return value - * \return If the query was successful or not - */ -bool dbusHAL::halGetPropertyString(TQString udi, TQString property, TQString *returnval){ - kdDebugFuncIn(trace); - - bool ret = false; - - if (!initHAL() || udi.isEmpty() || property.isEmpty()) - goto out; - - DBusError error; - dbus_error_init(&error); - - if (!libhal_device_property_exists(hal_ctx, udi.ascii(), property.ascii(), &error)) { - kdWarning() << "Property: " << property << " for: " << udi << " doesn't exist." << endl; - goto out; - } - - *returnval = libhal_device_get_property_string(hal_ctx, udi.ascii(), property.ascii(), &error); - - if (dbus_error_is_set(&error)) { - kdError() << "Fetching property: " << property << " for: " << udi - << " failed with: " << error.message << endl; - dbus_error_free(&error); - goto out; - } else { - ret = true; - } - -out: - kdDebugFuncOut(trace); - return ret; -} - -/*! - * This function query a String List property from HAL for a given device - * \param udi TQString with the udi of the device - * \param property TQString with the property to query - * \param devices TQStringList to return the values - * \return If the query was successful or not - */ -bool dbusHAL::halGetPropertyStringList (TQString udi, TQString property, TQStringList *devices) { - kdDebugFuncIn(trace); - - bool ret = false; - - if (!initHAL() || udi.isEmpty() || property.isEmpty()) - goto out; - - DBusError error; - char ** found; - - dbus_error_init(&error); - - if (!libhal_device_property_exists(hal_ctx, udi.ascii(), property.ascii(), &error)) { - kdWarning() << "Property: " << property << " for: " << udi << " doesn't exist." << endl; - goto out; - } - - found = libhal_device_get_property_strlist (hal_ctx, udi.ascii(), property.ascii(), &error); - - if (dbus_error_is_set(&error)) { - kdWarning() << "Error while query existing strlist Property: " << property - << " for: " << udi << " error: " << error.message << endl; - dbus_error_free(&error); - libhal_free_string_array(found); - goto out; - } else { - for (int i = 0; found[i] != NULL ; ++i) { - TQString _to_add = found[i]; - if (!_to_add.isEmpty()) *devices += _to_add; - } - libhal_free_string_array(found); - ret = true; - } - -out: - kdDebugFuncOut(trace); - return ret; -} - - -/*! - * This function query a capability from HAL for a given device - * \param udi TQString with the UDI of the device - * \param capability TQString with the capability to query - * \param returnval pointer to the return value as boolean - * \return If the query was successful or not - */ -bool dbusHAL::halQueryCapability(TQString udi, TQString capability, bool *returnval) { - kdDebugFuncIn(trace); - - bool ret = false; - - if (!initHAL() || udi.isEmpty() || capability.isEmpty()) - goto out; - - DBusError error; - dbus_error_init(&error); - - *returnval = libhal_device_query_capability(hal_ctx, udi.ascii(), capability.ascii(), &error); - if (dbus_error_is_set(&error)) { - kdError() << "Fetching capability: " << capability << " for: " << udi - << " failed with: " << error.message << endl; - dbus_error_free(&error); - goto out; - } else { - ret = true; - } - -out: - kdDebugFuncOut(trace); - return ret; -} - -/*! - * Use this function to check if a device has a specia property/key. - * \param udi TQString with the UDI of the device - * \param property TQString with the property - * \return If the query was successful or not - */ -bool dbusHAL::halDevicePropertyExist(TQString udi, TQString property ) { - kdDebugFuncIn(trace); - - bool ret = false; - - if (!initHAL() || udi.isEmpty() || property.isEmpty()) - goto out; - - DBusError error; - dbus_error_init(&error); - - if (! libhal_device_property_exists (hal_ctx, udi.ascii(), property.ascii(), &error)) { - if (dbus_error_is_set(&error)) { - kdError() << "Fetching existing property: " << property << " for: " << udi - << " failed with: " << error.message << endl; - dbus_error_free(&error); - } - goto out; - } else { - ret = true; - } - -out: - kdDebugFuncOut(trace); - return ret; -} - -/*! - * Use this function to search find devices with a give capability - * \param capability TQString with the capability to query - * \param devices TQStringList to return the found devices - * \return If the query was successful or not - */ -bool dbusHAL::halFindDeviceByCapability (TQString capability, TQStringList *devices) { - kdDebugFuncIn(trace); - - DBusError error; - char ** found; - int num = 0; - bool ret = false; - - if (!initHAL() || capability.isEmpty()) - goto out; - - dbus_error_init(&error); - - found = libhal_find_device_by_capability (hal_ctx, capability.ascii(), &num, &error); - - if (dbus_error_is_set(&error)) { - kdError() << "Could not get list of devices with capability: " << capability - << " error: " << error.message << endl; - dbus_error_free(&error); - libhal_free_string_array(found); - goto out; - } else { - for (int i = 0; i < num; ++i) { - TQString _to_add = found[i]; - if (!_to_add.isEmpty()) *devices += _to_add; - } - libhal_free_string_array(found); - ret = true; - } - -out: - kdDebugFuncOut(trace); - return ret; -} - -/*! - * Use this function to search find devices with a special string property - * \param property TQString with the name of the property - * \param keyval TQString with value of the string property - * \param devices TQStringList to return the found devices - * \return If the query was successful or not - */ -bool dbusHAL::halFindDeviceByString (TQString property, TQString keyval, TQStringList *devices) { - kdDebugFuncIn(trace); - - DBusError error; - char ** found; - int num = 0; - bool ret = false; - - if (!initHAL() || property.isEmpty() || keyval.isEmpty()) - goto out; - - dbus_error_init(&error); - - found = libhal_manager_find_device_string_match (hal_ctx, property.ascii(), keyval.ascii(), &num, &error); - - if (dbus_error_is_set(&error)) { - kdError() << "Could not get list of devices with key: " << property - << "and string value: " << keyval << " error: " << error.message << endl; - dbus_error_free(&error); - libhal_free_string_array(found); - goto out; - } else { - for (int i = 0; i < num; ++i) { - TQString _to_add = found[i]; - if (!_to_add.isEmpty()) *devices += _to_add; - } - libhal_free_string_array(found); - ret = true; - } - -out: - kdDebugFuncOut(trace); - return ret; -} - -/* ----> HAL section :: END <---- */ /* ----> D-Bus methode calls functions :: START <---- */ /*! * This function call a D-Bus method @@ -868,102 +427,6 @@ out: return ret; } -/*! - * Function to call a suspend and call if resumed \ref callBackSuspend() - * to emit a resume signal. - * \param suspend a char pointer with the name of the suspend interface - * \return If the query was successful or not - */ -bool dbusHAL::dbusMethodCallSuspend ( const char *suspend ) { - kdDebugFuncIn(trace); - - DBusMessage *message; - DBusError error; - DBusPendingCall* pcall = NULL; - bool ret = false; - - dbus_error_init(&error); - dbus_connection = dbus_bus_get(DBUS_BUS_SYSTEM, &error); - - if (dbus_error_is_set(&error)) { - kdError() << "Could not get dbus connection: " << error.message << endl; - dbus_error_free(&error); - goto out; - } - - message = dbus_message_new_method_call( HAL_SERVICE, HAL_COMPUTER_UDI, HAL_PM_IFACE, suspend); - if (strcmp( suspend, "Suspend") == 0) { - int wake_up = 0; - dbus_message_append_args (message, DBUS_TYPE_INT32, &wake_up, DBUS_TYPE_INVALID); - } - - if (message) { - // need to set INT_MAX as default and not -1 - dbus_connection_send_with_reply (dbus_connection, message, &pcall, INT_MAX); - if (pcall) { - dbus_pending_call_ref (pcall); // really needed? - dbus_pending_call_set_notify (pcall, dbusHAL::callBackSuspend, NULL, NULL); - } - dbus_message_unref (message); - ret = true; - } - -out: - kdDebugFuncOut(trace); - return ret; -} - -/*! - * Slot called by D-Bus as set in \ref dbusMethodCallSuspend() - * Here we emit the resume signal. - */ -void dbusHAL::callBackSuspend (DBusPendingCall* pcall, void* /*data*/) { - kdDebugFuncIn(trace); - - DBusMessage* reply = NULL; - DBusError error; - int result; - bool failed = false; - - if (!pcall) { - kdError() << "dbusHAL::callBackSuspend - DBusPendingCall not set, return" << endl; - kdDebugFuncOut(trace); - return; - } - - reply = dbus_pending_call_steal_reply (pcall); - if (reply == NULL) { - kdError() << "dbusHAL::callBackSuspend - Got no reply, return" << endl; - goto out; - } - - dbus_error_init(&error); - - if (!dbus_message_get_args (reply, &error, DBUS_TYPE_INT32, &result, DBUS_TYPE_INVALID)) { - if (dbus_error_is_set(&error)) { - kdError() << "Could not get argument from reply: " << error.message << endl; - dbus_error_free(&error); - } - - kdWarning() << "dbusHAL::callBackSuspend dbus_message_get_args failed, maybe timouted" << endl; - failed = true; - } - - dbus_message_unref (reply); - -out: - dbus_pending_call_unref (pcall); - - if (failed) - emit ((dbusHAL*) myInstance)->backFromSuspend( -1 ); - else - emit ((dbusHAL*) myInstance)->backFromSuspend( result ); - - kdDebugFuncOut(trace); - return; -} - - /* ----> D-Bus methode calls functions :: END <---- */ /* ---> PolicyKit method call section :: START <--- */ @@ -998,38 +461,6 @@ int dbusHAL::isUserPrivileged(TQString privilege, TQString udi, TQString ressour _unique_name = dbus_bus_get_unique_name(dbus_connection); _privilege = privilege.latin1(); -#ifdef USE_LIBHAL_POLICYCHECK - DBusError error; - char *result; - - if (udi.isEmpty()) { - kdError() << "No UDI given ... could not lookup privileges" << endl; - goto out; - } - if (!hal_is_connected) { - kdError() << "HAL not running, could not call libhal for lookup privileges" << endl; - goto out; - } - - dbus_error_init(&error); - result = libhal_device_is_caller_privileged ( hal_ctx, udi.latin1(), _privilege, _unique_name, &error); - - if ( dbus_error_is_set( &error ) ) { - kdWarning() << "Error while lookup privileges: " << error.message << endl; - dbus_error_free( &error ); - retval = -1; - } else { - if (!strcmp(result, "yes")) { - retval = 1; - } else if (!strcmp(result, "no")) { - retval = 0; - } else { - retval = -1; - } - } - - libhal_free_string(result); -#else // not sure if we need this, but to avoid problems dbus_bool_t _retval; const char *_ressource; @@ -1049,7 +480,6 @@ int dbusHAL::isUserPrivileged(TQString privilege, TQString udi, TQString ressour } else { retval = (int) _retval; } -#endif out: kdDebugFuncOut(trace); @@ -1157,22 +587,7 @@ filterFunction (DBusConnection *connection, DBusMessage *message, void */*data*/ if (dbus_message_get_args (message, NULL, DBUS_TYPE_STRING, &service, DBUS_TYPE_STRING, &old_owner, DBUS_TYPE_STRING, &new_owner, DBUS_TYPE_INVALID)) { - if (!strcmp(service, "org.freedesktop.Hal")) { - if (!strcmp(new_owner, "") && strcmp(old_owner, "")) { - // Hal service stopped. - kdDebug() << "=== org.freedesktop.Hal terminated ===" << endl; - ((dbusHAL*) myInstance)->emitMsgReceived( DBUS_EVENT, - "hal.terminate", - NULL ); - } - else if (!strcmp(old_owner, "") && strcmp(new_owner, "")) { - // Hal service started. - kdDebug() << "=== org.freedesktop.Hal started ===" << endl; - ((dbusHAL*) myInstance)->emitMsgReceived( DBUS_EVENT, - "hal.started", - NULL ); - } - } else if (!strcmp(service, "org.freedesktop.Policy.Power")) { + if (!strcmp(service, "org.freedesktop.Policy.Power")) { const char *own_name; own_name = dbus_bus_get_unique_name(((dbusHAL*) myInstance)->get_DBUS_connection()); @@ -1195,88 +610,6 @@ filterFunction (DBusConnection *connection, DBusMessage *message, void */*data*/ } kdDebugFuncOut(trace); return DBUS_HANDLER_RESULT_HANDLED; - } else if (ifaceType.startsWith("org.freedesktop.Hal.Manager")) { - kdDebug() << "Received from org.freedesktop.Hal.Manager" << endl; - char *udi; - - const char *signal = dbus_message_get_member( message ); - /* get the first argument. This must be a string at the moment */ - dbus_message_get_args( message, &error, DBUS_TYPE_STRING, &value, DBUS_TYPE_INVALID ); - - if ( dbus_error_is_set( &error ) ) { - kdWarning() << "Received signal, but no string argument: " << error.message << endl; - dbus_error_free( &error ); - kdDebugFuncOut(trace); - return DBUS_HANDLER_RESULT_HANDLED; - } - - if (dbus_message_get_args( message, &error, DBUS_TYPE_STRING, &udi, DBUS_TYPE_INVALID )) { - if (! strcmp(signal, "DeviceRemoved") || ! strcmp(signal, "DeviceAdded")) { - ((dbusHAL*) myInstance)->emitMsgReceived( HAL_DEVICE, signal, udi ); - kdDebug() << "org.freedesktop.Hal.Manager: uid: " << udi - << " signal: " << signal << endl; - } else { - kdWarning() << "Received unknown signal from org.freedesktop.Hal.Manager: " - << signal << endl; - } - } - kdDebugFuncOut(trace); - return DBUS_HANDLER_RESULT_HANDLED; - - } else if (ifaceType.startsWith("org.freedesktop.Hal.Device")) { - const char *udi = dbus_message_get_path (message); - const char *signal = dbus_message_get_member( message ); - - /* Code taken from libhal */ - if (! strcmp(signal, "PropertyModified")) { - if (trace) kdDebug() << "-------- PropertyModified ------" << endl; - int i, num_modifications; - DBusMessageIter iter; - DBusMessageIter iter_array; - - dbus_message_iter_init (message, &iter); - dbus_message_iter_get_basic (&iter, &num_modifications); - dbus_message_iter_next (&iter); - - dbus_message_iter_recurse (&iter, &iter_array); - - for (i = 0; i < num_modifications; i++) { - dbus_bool_t removed, added; - char *key; - DBusMessageIter iter_struct; - - dbus_message_iter_recurse (&iter_array, &iter_struct); - - dbus_message_iter_get_basic (&iter_struct, &key); - dbus_message_iter_next (&iter_struct); - dbus_message_iter_get_basic (&iter_struct, &removed); - dbus_message_iter_next (&iter_struct); - dbus_message_iter_get_basic (&iter_struct, &added); - - /* don't check if we really need this device, check this in an other class */ - ((dbusHAL*) myInstance)->emitMsgReceived( HAL_PROPERTY_CHANGED, udi, key); - kdDebug() << "PropertyModified: uid: " << udi << " key: " << key << endl; - - dbus_message_iter_next (&iter_array); - } - } else if (! strcmp(signal, "Condition")) { - if (trace) kdDebug() << "-------- Condition ------" << endl; - char *name, *detail; - - dbus_message_get_args( message, &error, DBUS_TYPE_STRING, &value, DBUS_TYPE_INVALID ); - - if (dbus_message_get_args (message, &error, DBUS_TYPE_STRING, &name, - DBUS_TYPE_STRING, &detail, DBUS_TYPE_INVALID)) { - ((dbusHAL*) myInstance)->emitMsgReceived( HAL_CONDITION, name, detail ); - } else { - if (dbus_error_is_set( &error )) dbus_error_free( &error ); - } - } else { - kdDebug() << "Received unknown signal from org.freedesktop.Hal.Device: " - << signal << endl; - } - kdDebugFuncOut(trace); - return DBUS_HANDLER_RESULT_HANDLED; } else if (ifaceType.startsWith("org.freedesktop.ConsoleKit.Session")) { kdDebug() << "Received from org.freedesktop.ConsoleKit.Session" << endl; |