Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-1936 HLog group commit, fixed 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@830786 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jean-Daniel Cryans 2009-10-28 22:44:46 +00:00
parent e525abf672
commit 66728e6f67
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java
View File

@ -759,8 +759,9 @@ public class HLog implements HConstants, Syncable {
LOG.error("Error while syncing, requesting close of hlog ", e);
requestLogRoll();
} catch (InterruptedException e) {
LOG.debug(getName() + "interrupted while waiting for sync requests",e );
LOG.debug(getName() + "interrupted while waiting for sync requests");
} finally {
syncDone.signalAll();
lock.unlock();
LOG.info(getName() + " exiting");
}
@ -792,7 +793,7 @@ public class HLog implements HConstants, Syncable {
}
}
public void sync() throws IOException {
public void sync(){
sync(false);
}
@ -800,11 +801,11 @@ public class HLog implements HConstants, Syncable {
* This method calls the LogSyncer in order to group commit the sync
* with other threads.
* @param force For catalog regions, force the sync to happen
* @throws IOException
*/
public void sync(boolean force) throws IOException {
// Set force sync if force is true and forceSync is false
forceSync.compareAndSet(!forceSync.get() && force, true);
public void sync(boolean force) {
// Set to force only if it was false and force == true
// It is reset to false after sync
forceSync.compareAndSet(!forceSync.get() && !force, true);
logSyncerThread.addToSyncQueue();
}