Commit ad3c36a5 authored by Rafael J. Wysocki's avatar Rafael J. Wysocki

PM / Runtime: Don't run callbacks under lock for power.irq_safe set

The rpm_suspend() and rpm_resume() routines execute subsystem or PM
domain callbacks under power.lock if power.irq_safe is set for the
given device.  This is inconsistent with that rpm_idle() does after
commit 02b26774 (PM / Runtime: Allow _put_sync() from
interrupts-disabled context) and is problematic for subsystems and PM
domains wanting to use power.lock for synchronization in their
runtime PM callbacks.

This change requires the code checking if the device's runtime PM
status is RPM_SUSPENDING or RPM_RESUMING to be modified too, to take
the power.irq_safe set case into account (that code wasn't reachable
before with power.irq_safe set, because it's executed with the
device's power.lock held).
Signed-off-by: default avatarRafael J. Wysocki <rjw@sisk.pl>
Reviewed-by: default avatarMing Lei <tom.leiming@gmail.com>
Reviewed-by: default avatarKevin Hilman <khilman@ti.com>
parent 30b1a7a3
...@@ -154,6 +154,31 @@ static int rpm_check_suspend_allowed(struct device *dev) ...@@ -154,6 +154,31 @@ static int rpm_check_suspend_allowed(struct device *dev)
return retval; return retval;
} }
/**
* __rpm_callback - Run a given runtime PM callback for a given device.
* @cb: Runtime PM callback to run.
* @dev: Device to run the callback for.
*/
static int __rpm_callback(int (*cb)(struct device *), struct device *dev)
__releases(&dev->power.lock) __acquires(&dev->power.lock)
{
int retval;
if (dev->power.irq_safe)
spin_unlock(&dev->power.lock);
else
spin_unlock_irq(&dev->power.lock);
retval = cb(dev);
if (dev->power.irq_safe)
spin_lock(&dev->power.lock);
else
spin_lock_irq(&dev->power.lock);
return retval;
}
/** /**
* rpm_idle - Notify device bus type if the device can be suspended. * rpm_idle - Notify device bus type if the device can be suspended.
* @dev: Device to notify the bus type about. * @dev: Device to notify the bus type about.
...@@ -225,19 +250,8 @@ static int rpm_idle(struct device *dev, int rpmflags) ...@@ -225,19 +250,8 @@ static int rpm_idle(struct device *dev, int rpmflags)
else else
callback = NULL; callback = NULL;
if (callback) { if (callback)
if (dev->power.irq_safe) __rpm_callback(callback, dev);
spin_unlock(&dev->power.lock);
else
spin_unlock_irq(&dev->power.lock);
callback(dev);
if (dev->power.irq_safe)
spin_lock(&dev->power.lock);
else
spin_lock_irq(&dev->power.lock);
}
dev->power.idle_notification = false; dev->power.idle_notification = false;
wake_up_all(&dev->power.wait_queue); wake_up_all(&dev->power.wait_queue);
...@@ -252,22 +266,14 @@ static int rpm_idle(struct device *dev, int rpmflags) ...@@ -252,22 +266,14 @@ static int rpm_idle(struct device *dev, int rpmflags)
* @dev: Device to run the callback for. * @dev: Device to run the callback for.
*/ */
static int rpm_callback(int (*cb)(struct device *), struct device *dev) static int rpm_callback(int (*cb)(struct device *), struct device *dev)
__releases(&dev->power.lock) __acquires(&dev->power.lock)
{ {
int retval; int retval;
if (!cb) if (!cb)
return -ENOSYS; return -ENOSYS;
if (dev->power.irq_safe) { retval = __rpm_callback(cb, dev);
retval = cb(dev);
} else {
spin_unlock_irq(&dev->power.lock);
retval = cb(dev);
spin_lock_irq(&dev->power.lock);
}
dev->power.runtime_error = retval; dev->power.runtime_error = retval;
return retval != -EACCES ? retval : -EIO; return retval != -EACCES ? retval : -EIO;
} }
...@@ -347,6 +353,15 @@ static int rpm_suspend(struct device *dev, int rpmflags) ...@@ -347,6 +353,15 @@ static int rpm_suspend(struct device *dev, int rpmflags)
goto out; goto out;
} }
if (dev->power.irq_safe) {
spin_unlock(&dev->power.lock);
cpu_relax();
spin_lock(&dev->power.lock);
goto repeat;
}
/* Wait for the other suspend running in parallel with us. */ /* Wait for the other suspend running in parallel with us. */
for (;;) { for (;;) {
prepare_to_wait(&dev->power.wait_queue, &wait, prepare_to_wait(&dev->power.wait_queue, &wait,
...@@ -496,6 +511,15 @@ static int rpm_resume(struct device *dev, int rpmflags) ...@@ -496,6 +511,15 @@ static int rpm_resume(struct device *dev, int rpmflags)
goto out; goto out;
} }
if (dev->power.irq_safe) {
spin_unlock(&dev->power.lock);
cpu_relax();
spin_lock(&dev->power.lock);
goto repeat;
}
/* Wait for the operation carried out in parallel with us. */ /* Wait for the operation carried out in parallel with us. */
for (;;) { for (;;) {
prepare_to_wait(&dev->power.wait_queue, &wait, prepare_to_wait(&dev->power.wait_queue, &wait,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment