mutex_unlock(&hwq->sq_mutex);
        return ret;
 }
+
+/**
+ * ufshcd_mcq_abort - Abort the command in MCQ.
+ * @cmd - The command to be aborted.
+ *
+ * Returns SUCCESS or FAILED error codes
+ */
+int ufshcd_mcq_abort(struct scsi_cmnd *cmd)
+{
+       struct Scsi_Host *host = cmd->device->host;
+       struct ufs_hba *hba = shost_priv(host);
+       int tag = scsi_cmd_to_rq(cmd)->tag;
+       struct ufshcd_lrb *lrbp = &hba->lrb[tag];
+       struct ufs_hw_queue *hwq;
+       int err = FAILED;
+
+       if (!ufshcd_cmd_inflight(lrbp->cmd)) {
+               dev_err(hba->dev,
+                       "%s: skip abort. cmd at tag %d already completed.\n",
+                       __func__, tag);
+               goto out;
+       }
+
+       /* Skip task abort in case previous aborts failed and report failure */
+       if (lrbp->req_abort_skip) {
+               dev_err(hba->dev, "%s: skip abort. tag %d failed earlier\n",
+                       __func__, tag);
+               goto out;
+       }
+
+       hwq = ufshcd_mcq_req_to_hwq(hba, scsi_cmd_to_rq(cmd));
+
+       if (ufshcd_mcq_sqe_search(hba, hwq, tag)) {
+               /*
+                * Failure. The command should not be "stuck" in SQ for
+                * a long time which resulted in command being aborted.
+                */
+               dev_err(hba->dev, "%s: cmd found in sq. hwq=%d, tag=%d\n",
+                       __func__, hwq->id, tag);
+               goto out;
+       }
+
+       /*
+        * The command is not in the submission queue, and it is not
+        * in the completion queue either. Query the device to see if
+        * the command is being processed in the device.
+        */
+       if (ufshcd_try_to_abort_task(hba, tag)) {
+               dev_err(hba->dev, "%s: device abort failed %d\n", __func__, err);
+               lrbp->req_abort_skip = true;
+               goto out;
+       }
+
+       err = SUCCESS;
+       if (ufshcd_cmd_inflight(lrbp->cmd))
+               ufshcd_release_scsi_cmd(hba, lrbp);
+
+out:
+       return err;
+}
 
 
 bool ufshcd_cmd_inflight(struct scsi_cmnd *cmd);
 int ufshcd_mcq_sq_cleanup(struct ufs_hba *hba, int task_tag);
+int ufshcd_mcq_abort(struct scsi_cmnd *cmd);
+int ufshcd_try_to_abort_task(struct ufs_hba *hba, int tag);
+void ufshcd_release_scsi_cmd(struct ufs_hba *hba,
+                            struct ufshcd_lrb *lrbp);
 
 #define UFSHCD_MCQ_IO_QUEUE_OFFSET     1
 #define SD_ASCII_STD true
 
 static int ufshcd_setup_vreg(struct ufs_hba *hba, bool on);
 static inline int ufshcd_config_vreg_hpm(struct ufs_hba *hba,
                                         struct ufs_vreg *vreg);
-static int ufshcd_try_to_abort_task(struct ufs_hba *hba, int tag);
 static void ufshcd_wb_toggle_buf_flush_during_h8(struct ufs_hba *hba,
                                                 bool enable);
 static void ufshcd_hba_vreg_set_lpm(struct ufs_hba *hba);
 }
 
 /* Release the resources allocated for processing a SCSI command. */
-static void ufshcd_release_scsi_cmd(struct ufs_hba *hba,
-                                   struct ufshcd_lrb *lrbp)
+void ufshcd_release_scsi_cmd(struct ufs_hba *hba,
+                            struct ufshcd_lrb *lrbp)
 {
        struct scsi_cmnd *cmd = lrbp->cmd;
 
  *
  * Returns zero on success, non-zero on failure
  */
-static int ufshcd_try_to_abort_task(struct ufs_hba *hba, int tag)
+int ufshcd_try_to_abort_task(struct ufs_hba *hba, int tag)
 {
        struct ufshcd_lrb *lrbp = &hba->lrb[tag];
        int err = 0;
                goto release;
        }
 
-       if (is_mcq_enabled(hba))
+       if (is_mcq_enabled(hba)) {
+               /* MCQ mode. Branch off to handle abort for mcq mode */
+               err = ufshcd_mcq_abort(cmd);
                goto release;
+       }
 
        /* Skip task abort in case previous aborts failed and report failure */
        if (lrbp->req_abort_skip) {