Update a maximum of row_cnt rows when updating an rra

diff --git a/src/rrd_update.c b/src/rrd_update.c
index 1529772a6800f1830653da58c54a6795aa2b2bf3..2ab9ccecba7333346c47280fe18b9d79c1cdd034 100644 (file)
--- a/src/rrd_update.c
+++ b/src/rrd_update.c
@@ -1476,8 +1476,9 @@ static int update_all_cdp_prep(
             proc_pdp_cnt % rrd->rra_def[rra_idx].pdp_cnt;
         skip_update[rra_idx] = 0;
         if (start_pdp_offset <= elapsed_pdp_st) {
-            rra_step_cnt[rra_idx] = (elapsed_pdp_st - start_pdp_offset) /
-                rrd->rra_def[rra_idx].pdp_cnt + 1;
+            rra_step_cnt[rra_idx] = min((elapsed_pdp_st - start_pdp_offset) /
+                rrd->rra_def[rra_idx].pdp_cnt + 1,
+                rrd->rra_def[rra_idx].row_cnt);
         } else {
             rra_step_cnt[rra_idx] = 0;
         }