fix

apache · Jul 21, 2021 · 680d7ea · 680d7ea
1 parent bf46657
commit 680d7ea
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/server/pegasus_server_write.cpp b/src/server/pegasus_server_write.cpp
@@ -111,10 +111,12 @@ int pegasus_server_write::on_batched_writes(dsn::message_ex **requests, int coun
             }
         }
 
-        if (err == 0) {
-            err = _write_svc->batch_commit(_decree);
-        } else {
-            _write_svc->batch_abort(_decree, err);
+        if (dsn_likely(_put_rpc_batch.size() + _remove_rpc_batch.size() != 0)) {
+            if (err == 0) {
+                err = _write_svc->batch_commit(_decree);
+            } else {
+                _write_svc->batch_abort(_decree, err);
+            }
         }
     }