You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2017/03/09 20:31:13 UTC
geode git commit: oplog closed while writing to oplog with
gemfire.syncWrites=true Moved the channel force call inside the sync block
Repository: geode
Updated Branches:
refs/heads/feature/GEODE-1969 [created] 4d1ded8df
oplog closed while writing to oplog with gemfire.syncWrites=true
Moved the channel force call inside the sync block
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/4d1ded8d
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/4d1ded8d
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/4d1ded8d
Branch: refs/heads/feature/GEODE-1969
Commit: 4d1ded8dfe00affeadd014611a8d9e786d866aa8
Parents: bd72c95
Author: shankar <sh...@ampool.io>
Authored: Fri Dec 16 16:31:54 2016 +0530
Committer: Darrel Schneider <ds...@pivotal.io>
Committed: Thu Mar 9 12:30:31 2017 -0800
----------------------------------------------------------------------
.../main/java/org/apache/geode/internal/cache/Oplog.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/4d1ded8d/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java b/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java
index 32d6e30..2936559 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java
@@ -5186,11 +5186,11 @@ public final class Oplog implements CompactableOplog, Flushable {
olf.bytesFlushed += flushed;
bb.clear();
}
- }
- if (doSync) {
- if (SYNC_WRITES) {
- // Synch Meta Data as well as content
- olf.channel.force(true);
+ if (doSync) {
+ if (SYNC_WRITES) {
+ // Synch Meta Data as well as content
+ olf.channel.force(true);
+ }
}
}
} catch (ClosedChannelException ignore) {