Commit 0d30dae3 authored by Zhang Lixu's avatar Zhang Lixu Committed by Jiri Kosina
Browse files

HID: intel-ish-hid: Use dedicated unbound workqueues to prevent resume blocking



During suspend/resume tests with S2IDLE, some ISH functional failures were
observed because of delay in executing ISH resume handler. Here
schedule_work() is used from resume handler to do actual work.
schedule_work() uses system_wq, which is a per CPU work queue. Although
the queuing is not bound to a CPU, but it prefers local CPU of the caller,
unless prohibited.

Users of this work queue are not supposed to queue long running work.
But in practice, there are scenarios where long running work items are
queued on other unbound workqueues, occupying the CPU. As a result, the
ISH resume handler may not get a chance to execute in a timely manner.

In one scenario, one of the ish_resume_handler() executions was delayed
nearly 1 second because another work item on an unbound workqueue occupied
the same CPU. This delay causes ISH functionality failures.

A similar issue was previously observed where the ISH HID driver timed out
while getting the HID descriptor during S4 resume in the recovery kernel,
likely caused by the same workqueue contention problem.

Create dedicated unbound workqueues for all ISH operations to allow work
items to execute on any available CPU, eliminating CPU-specific bottlenecks
and improving resume reliability under varying system loads. Also ISH has
three different components, a bus driver which implements ISH protocols, a
PCI interface layer and HID interface. Use one dedicated work queue for all
of them.

Signed-off-by: default avatarZhang Lixu <lixu.zhang@intel.com>
Signed-off-by: default avatarJiri Kosina <jkosina@suse.com>
parent 54ba6d9b
Loading
Loading
Loading
Loading
+20 −1
Original line number Diff line number Diff line
@@ -628,7 +628,7 @@ static void recv_ipc(struct ishtp_device *dev, uint32_t doorbell_val)
		if (!ishtp_dev) {
			ishtp_dev = dev;
		}
		schedule_work(&fw_reset_work);
		queue_work(dev->unbound_wq, &fw_reset_work);
		break;

	case MNG_RESET_NOTIFY_ACK:
@@ -933,6 +933,21 @@ static const struct ishtp_hw_ops ish_hw_ops = {
	.dma_no_cache_snooping = _dma_no_cache_snooping
};

static struct workqueue_struct *devm_ishtp_alloc_workqueue(struct device *dev)
{
	struct workqueue_struct *wq;

	wq = alloc_workqueue("ishtp_unbound_%d", WQ_UNBOUND, 0, dev->id);
	if (!wq)
		return NULL;

	if (devm_add_action_or_reset(dev, (void (*)(void *))destroy_workqueue,
				     wq))
		return NULL;

	return wq;
}

/**
 * ish_dev_init() -Initialize ISH devoce
 * @pdev: PCI device
@@ -953,6 +968,10 @@ struct ishtp_device *ish_dev_init(struct pci_dev *pdev)
	if (!dev)
		return NULL;

	dev->unbound_wq = devm_ishtp_alloc_workqueue(&pdev->dev);
	if (!dev->unbound_wq)
		return NULL;

	dev->devc = &pdev->dev;
	ishtp_device_init(dev);

+1 −1
Original line number Diff line number Diff line
@@ -384,7 +384,7 @@ static int __maybe_unused ish_resume(struct device *device)
	ish_resume_device = device;
	dev->resume_flag = 1;

	schedule_work(&resume_work);
	queue_work(dev->unbound_wq, &resume_work);

	return 0;
}
+2 −2
Original line number Diff line number Diff line
@@ -860,7 +860,7 @@ static int hid_ishtp_cl_reset(struct ishtp_cl_device *cl_device)
	hid_ishtp_trace(client_data, "%s hid_ishtp_cl %p\n", __func__,
			hid_ishtp_cl);

	schedule_work(&client_data->work);
	queue_work(ishtp_get_workqueue(cl_device), &client_data->work);

	return 0;
}
@@ -902,7 +902,7 @@ static int hid_ishtp_cl_resume(struct device *device)

	hid_ishtp_trace(client_data, "%s hid_ishtp_cl %p\n", __func__,
			hid_ishtp_cl);
	schedule_work(&client_data->resume_work);
	queue_work(ishtp_get_workqueue(cl_device), &client_data->resume_work);
	return 0;
}

+17 −1
Original line number Diff line number Diff line
@@ -541,7 +541,7 @@ void ishtp_cl_bus_rx_event(struct ishtp_cl_device *device)
		return;

	if (device->event_cb)
		schedule_work(&device->event_work);
		queue_work(device->ishtp_dev->unbound_wq, &device->event_work);
}

/**
@@ -876,6 +876,22 @@ struct device *ishtp_get_pci_device(struct ishtp_cl_device *device)
}
EXPORT_SYMBOL(ishtp_get_pci_device);

/**
 * ishtp_get_workqueue - Retrieve the workqueue associated with an ISHTP device
 * @cl_device: Pointer to the ISHTP client device structure
 *
 * Returns the workqueue_struct pointer (unbound_wq) associated with the given
 * ISHTP client device. This workqueue is typically used for scheduling work
 * related to the device.
 *
 * Return: Pointer to struct workqueue_struct.
 */
struct workqueue_struct *ishtp_get_workqueue(struct ishtp_cl_device *cl_device)
{
	return cl_device->ishtp_dev->unbound_wq;
}
EXPORT_SYMBOL(ishtp_get_workqueue);

/**
 * ishtp_trace_callback() - Return trace callback
 * @cl_device: ISH-TP client device instance
+2 −2
Original line number Diff line number Diff line
@@ -573,7 +573,7 @@ void ishtp_hbm_dispatch(struct ishtp_device *dev,

		/* Start firmware loading process if it has loader capability */
		if (version_res->host_version_supported & ISHTP_SUPPORT_CAP_LOADER)
			schedule_work(&dev->work_fw_loader);
			queue_work(dev->unbound_wq, &dev->work_fw_loader);

		dev->version.major_version = HBM_MAJOR_VERSION;
		dev->version.minor_version = HBM_MINOR_VERSION;
@@ -864,7 +864,7 @@ void recv_hbm(struct ishtp_device *dev, struct ishtp_msg_hdr *ishtp_hdr)
	dev->rd_msg_fifo_tail = (dev->rd_msg_fifo_tail + IPC_PAYLOAD_SIZE) %
		(RD_INT_FIFO_SIZE * IPC_PAYLOAD_SIZE);
	spin_unlock_irqrestore(&dev->rd_msg_spinlock, flags);
	schedule_work(&dev->bh_hbm_work);
	queue_work(dev->unbound_wq, &dev->bh_hbm_work);
eoi:
	return;
}
Loading