Commit 1d613312 authored by Marco Chiappero's avatar Marco Chiappero Committed by Herbert Xu

crypto: qat - handle retries due to collisions in adf_iov_putmsg()

Rework __adf_iov_putmsg() to handle retries due to collisions
internally, removing the need for an external retry loop.
The functions __adf_iov_putmsg() and adf_iov_putmsg() have been merged
together maintaining the adf_iov_putmsg() name.

This will allow to use this function only for GEN2 devices, since
collision are peculiar of this generation and therefore should be
confined to the actual implementation of the transport/medium access.

Note that now adf_iov_putmsg() will retry to send a message only in case
of collisions and will now fail if an ACK is not received from the
remote function.
Signed-off-by: default avatarMarco Chiappero <marco.chiappero@intel.com>
Co-developed-by: default avatarGiovanni Cabiddu <giovanni.cabiddu@intel.com>
Signed-off-by: default avatarGiovanni Cabiddu <giovanni.cabiddu@intel.com>
Signed-off-by: default avatarHerbert Xu <herbert@gondor.apana.org.au>
parent bd59b769
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
ADF_PFVF_MSG_ACK_MAX_RETRY + \ ADF_PFVF_MSG_ACK_MAX_RETRY + \
ADF_PFVF_MSG_COLLISION_DETECT_DELAY) ADF_PFVF_MSG_COLLISION_DETECT_DELAY)
static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr) static int adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr)
{ {
struct adf_accel_pci *pci_info = &accel_dev->accel_pci_dev; struct adf_accel_pci *pci_info = &accel_dev->accel_pci_dev;
struct adf_hw_device_data *hw_data = accel_dev->hw_device; struct adf_hw_device_data *hw_data = accel_dev->hw_device;
...@@ -24,8 +24,9 @@ static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr) ...@@ -24,8 +24,9 @@ static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr)
u32 local_in_use_mask, local_in_use_pattern; u32 local_in_use_mask, local_in_use_pattern;
u32 remote_in_use_mask, remote_in_use_pattern; u32 remote_in_use_mask, remote_in_use_pattern;
struct mutex *lock; /* lock preventing concurrent acces of CSR */ struct mutex *lock; /* lock preventing concurrent acces of CSR */
unsigned int retries = ADF_PFVF_MSG_MAX_RETRIES;
u32 int_bit; u32 int_bit;
int ret = 0; int ret;
if (accel_dev->is_vf) { if (accel_dev->is_vf) {
pf2vf_offset = hw_data->get_pf2vf_offset(0); pf2vf_offset = hw_data->get_pf2vf_offset(0);
...@@ -45,20 +46,22 @@ static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr) ...@@ -45,20 +46,22 @@ static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr)
int_bit = ADF_PF2VF_INT; int_bit = ADF_PF2VF_INT;
} }
msg &= ~local_in_use_mask;
msg |= local_in_use_pattern;
mutex_lock(lock); mutex_lock(lock);
start:
ret = 0;
/* Check if the PFVF CSR is in use by remote function */ /* Check if the PFVF CSR is in use by remote function */
val = ADF_CSR_RD(pmisc_bar_addr, pf2vf_offset); val = ADF_CSR_RD(pmisc_bar_addr, pf2vf_offset);
if ((val & remote_in_use_mask) == remote_in_use_pattern) { if ((val & remote_in_use_mask) == remote_in_use_pattern) {
dev_dbg(&GET_DEV(accel_dev), dev_dbg(&GET_DEV(accel_dev),
"PFVF CSR in use by remote function\n"); "PFVF CSR in use by remote function\n");
ret = -EBUSY; goto retry;
goto out;
} }
msg &= ~local_in_use_mask;
msg |= local_in_use_pattern;
/* Attempt to get ownership of the PFVF CSR */ /* Attempt to get ownership of the PFVF CSR */
ADF_CSR_WR(pmisc_bar_addr, pf2vf_offset, msg | int_bit); ADF_CSR_WR(pmisc_bar_addr, pf2vf_offset, msg | int_bit);
...@@ -77,8 +80,7 @@ static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr) ...@@ -77,8 +80,7 @@ static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr)
if (val != msg) { if (val != msg) {
dev_dbg(&GET_DEV(accel_dev), dev_dbg(&GET_DEV(accel_dev),
"Collision - PFVF CSR overwritten by remote function\n"); "Collision - PFVF CSR overwritten by remote function\n");
ret = -EIO; goto retry;
goto out;
} }
/* Finished with the PFVF CSR; relinquish it and leave msg in CSR */ /* Finished with the PFVF CSR; relinquish it and leave msg in CSR */
...@@ -86,31 +88,15 @@ static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr) ...@@ -86,31 +88,15 @@ static int __adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr)
out: out:
mutex_unlock(lock); mutex_unlock(lock);
return ret; return ret;
}
/** retry:
* adf_iov_putmsg() - send PFVF message if (--retries) {
* @accel_dev: Pointer to acceleration device. msleep(ADF_PFVF_MSG_RETRY_DELAY);
* @msg: Message to send goto start;
* @vf_nr: VF number to which the message will be sent if on PF, ignored } else {
* otherwise ret = -EBUSY;
* goto out;
* Function sends a message through the PFVF channel }
*
* Return: 0 on success, error code otherwise.
*/
static int adf_iov_putmsg(struct adf_accel_dev *accel_dev, u32 msg, u8 vf_nr)
{
u32 count = 0;
int ret;
do {
ret = __adf_iov_putmsg(accel_dev, msg, vf_nr);
if (ret)
msleep(ADF_PFVF_MSG_RETRY_DELAY);
} while (ret && (count++ < ADF_PFVF_MSG_MAX_RETRIES));
return ret;
} }
/** /**
......
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