1 files changed, 15 insertions, 3 deletions

diff --git a/drivers/lightnvm/pblk-recovery.c b/drivers/lightnvm/pblk-recovery.c
index 7b0ace2f4957..b9f2b40bd5a7 100644
--- a/drivers/lightnvm/pblk-recovery.c
+++ b/drivers/lightnvm/pblk-recovery.c
@@ -257,7 +257,6 @@ next_read_rq:
 
         rqd->bio = bio;
         rqd->opcode = NVM_OP_PREAD;
-        rqd->flags = pblk_set_read_mode(pblk);
         rqd->meta_list = meta_list;
         rqd->nr_ppas = rq_ppas;
         rqd->ppa_list = ppa_list;
@@ -266,6 +265,11 @@ next_read_rq:
         rqd->end_io = pblk_end_io_sync;
         rqd->private = &wait;
 
+        if (pblk_io_aligned(pblk, rq_ppas))
+                rqd->flags = pblk_set_read_mode(pblk, PBLK_READ_SEQUENTIAL);
+        else
+                rqd->flags = pblk_set_read_mode(pblk, PBLK_READ_RANDOM);
+
         for (i = 0; i < rqd->nr_ppas; ) {
                 struct ppa_addr ppa;
                 int pos;
@@ -473,7 +477,6 @@ next_rq:
 
         rqd->bio = bio;
         rqd->opcode = NVM_OP_PREAD;
-        rqd->flags = pblk_set_read_mode(pblk);
         rqd->meta_list = meta_list;
         rqd->nr_ppas = rq_ppas;
         rqd->ppa_list = ppa_list;
@@ -482,6 +485,11 @@ next_rq:
         rqd->end_io = pblk_end_io_sync;
         rqd->private = &wait;
 
+        if (pblk_io_aligned(pblk, rq_ppas))
+                rqd->flags = pblk_set_read_mode(pblk, PBLK_READ_SEQUENTIAL);
+        else
+                rqd->flags = pblk_set_read_mode(pblk, PBLK_READ_RANDOM);
+
         for (i = 0; i < rqd->nr_ppas; ) {
                 struct ppa_addr ppa;
                 int pos;
@@ -607,7 +615,6 @@ next_rq:
 
         rqd->bio = bio;
         rqd->opcode = NVM_OP_PREAD;
-        rqd->flags = pblk_set_read_mode(pblk);
         rqd->meta_list = meta_list;
         rqd->nr_ppas = rq_ppas;
         rqd->ppa_list = ppa_list;
@@ -616,6 +623,11 @@ next_rq:
         rqd->end_io = pblk_end_io_sync;
         rqd->private = &wait;
 
+        if (pblk_io_aligned(pblk, rq_ppas))
+                rqd->flags = pblk_set_read_mode(pblk, PBLK_READ_SEQUENTIAL);
+        else
+                rqd->flags = pblk_set_read_mode(pblk, PBLK_READ_RANDOM);
+
         for (i = 0; i < rqd->nr_ppas; ) {
                 struct ppa_addr ppa;
                 int pos;