From 7ebf1588c59339a8690835c7a67888ed0c7e1c2f Mon Sep 17 00:00:00 2001
From: Vitaliy Filippov <vitalif@yourcmc.ru>
Date: Wed, 24 Mar 2021 00:09:59 +0300
Subject: [PATCH] Check for immediate_commit==small in the OSD code

---
 src/osd_primary_write.cpp | 18 ++++++++++++++++--
 1 file changed, 16 insertions(+), 2 deletions(-)

diff --git a/src/osd_primary_write.cpp b/src/osd_primary_write.cpp
index 540e4da3..47a7a317 100644
--- a/src/osd_primary_write.cpp
+++ b/src/osd_primary_write.cpp
@@ -183,7 +183,6 @@ resume_6:
 resume_7:
     if (!remember_unstable_write(cur_op, pg, pg.cur_loc_set, 6))
     {
-        // FIXME: Check for immediate_commit == IMMEDIATE_SMALL
         free_object_state(pg, &op_data->object_state);
         return;
     }
@@ -283,9 +282,9 @@ bool osd_t::remember_unstable_write(osd_op_t *cur_op, pg_t & pg, pg_osd_set_t &
     {
         goto resume_7;
     }
-    // FIXME: Check for immediate_commit == IMMEDIATE_SMALL
     if (immediate_commit == IMMEDIATE_ALL)
     {
+immediate:
         if (op_data->scheme != POOL_SCHEME_REPLICATED)
         {
             // Send STABILIZE ops immediately
@@ -327,8 +326,23 @@ resume_7:
             }
         }
     }
+    else if (immediate_commit == IMMEDIATE_SMALL)
+    {
+        int stripe_count = (op_data->scheme == POOL_SCHEME_REPLICATED ? 1 : op_data->pg_size);
+        for (int role = 0; role < stripe_count; role++)
+        {
+            if (op_data->stripes[role].write_start == 0 &&
+                op_data->stripes[role].write_end == bs_block_size)
+            {
+                // Big write. Treat write as unsynced
+                goto lazy;
+            }
+        }
+        goto immediate;
+    }
     else
     {
+lazy:
         if (op_data->scheme != POOL_SCHEME_REPLICATED)
         {
             // Remember version as unstable for EC/XOR