We do not increase inflight number when we chain pios, so we should
decrease inflight only after all chained pios are also completed,
e.g. pio->remaining is zero, and file is flushed if needed

https://virtuozzo.atlassian.net/browse/VSTOR-108540
Signed-off-by: Andrey Zhadchenko <andrey.zhadche...@virtuozzo.com>
---
 drivers/md/dm-ploop-map.c | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/drivers/md/dm-ploop-map.c b/drivers/md/dm-ploop-map.c
index 7604b3c8d644..9f2e55df2904 100644
--- a/drivers/md/dm-ploop-map.c
+++ b/drivers/md/dm-ploop-map.c
@@ -214,6 +214,8 @@ static void ploop_prq_endio(struct pio *pio, void *prq_ptr,
        dm_complete_request(rq, bi_status);
 }
 
+static void ploop_dec_nr_inflight(struct ploop *ploop, struct pio *pio);
+
 static void ploop_wrkr_pio_endio(struct pio *pio)
 {
        ploop_endio_t endio_cb = pio->endio_cb;
@@ -223,6 +225,8 @@ static void ploop_wrkr_pio_endio(struct pio *pio)
 
        file = ploop_top_delta(pio->ploop)->file;
        vfs_fsync(file, 1);
+
+       ploop_dec_nr_inflight(pio->ploop, pio);
        endio_cb(pio, endio_cb_data, pio->bi_status);
        if (free_on_endio) {
                ploop_free_pio(pio->ploop, pio);
@@ -245,6 +249,7 @@ static void ploop_do_pio_endio(struct pio *pio)
                return;
        }
 
+       ploop_dec_nr_inflight(pio->ploop, pio);
        endio_cb(pio, endio_cb_data, pio->bi_status);
 
        if (free_on_endio)
@@ -2695,7 +2700,6 @@ static void ploop_handle_cleanup(struct ploop *ploop, 
struct pio *pio)
                ploop_discard_index_pio_end(ploop, pio);
 
        ploop_unlink_completed_pio(ploop, pio);
-       ploop_dec_nr_inflight(ploop, pio);
 }
 
 /*
-- 
2.43.5

_______________________________________________
Devel mailing list
Devel@openvz.org
https://lists.openvz.org/mailman/listinfo/devel

Reply via email to