geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dschnei...@apache.org
Subject geode git commit: oplog closed while writing to oplog with gemfire.syncWrites=true Moved the channel force call inside the sync block
Date Thu, 09 Mar 2017 20:31:13 GMT
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 <shankar@ampool.io>
Authored: Fri Dec 16 16:31:54 2016 +0530
Committer: Darrel Schneider <dschneider@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) {


Mime
View raw message