IGNITE-10779 Call writtenPagesCntr incrementor - Fixes #5721.

Signed-off-by: Dmitriy Pavlov <dpav...@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7ff04043
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7ff04043
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7ff04043

Branch: refs/heads/ignite-601
Commit: 7ff040438319b55fd81c467bacb644efa3afaf92
Parents: 5354373
Author: zzzadruga <zzzadr...@gmail.com>
Authored: Wed Dec 26 18:44:59 2018 +0300
Committer: Dmitriy Pavlov <dpav...@apache.org>
Committed: Wed Dec 26 18:44:59 2018 +0300

----------------------------------------------------------------------
 .../cache/persistence/GridCacheDatabaseSharedManager.java          | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/7ff04043/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
index 62e5186..c85099f 100755
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
@@ -4133,6 +4133,8 @@ public class GridCacheDatabaseSharedManager extends 
IgniteCacheDatabaseSharedMan
                             tracker.onDataPageWritten();
                     }
 
+                    writtenPagesCntr.incrementAndGet();
+
                     PageStore store = storeMgr.writeInternal(grpId, 
fullId.pageId(), tmpWriteBuf, tag, true);
 
                     updStores.computeIfAbsent(store, k -> new 
LongAdder()).increment();

Reply via email to