Merge a488a49 into 7b3eb46

apache · Aug 15, 2019 · c39d670 · c39d670
2 parents 7b3eb46 + a488a49
commit c39d670
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/...rvicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java b/...rvicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java
@@ -89,12 +89,12 @@ public ElasticsearchTransactionRepository(
 
   @Override
   public void send(GlobalTransaction transaction) throws Exception {
-    long begin = System.currentTimeMillis();
-    queries.add(convert(transaction));
-    batchSizeCounter++;
-    metricsService.metrics().doRepositoryReceived();
-    if (batchSize == 0 || batchSizeCounter == batchSize) {
-      synchronized (lock) {
+    synchronized (lock) {
+      long begin = System.currentTimeMillis();
+      queries.add(convert(transaction));
+      batchSizeCounter++;
+      metricsService.metrics().doRepositoryReceived();
+      if (batchSize == 0 || batchSizeCounter == batchSize) {
         save(begin);
         batchSizeCounter = 0;
       }