HBASE-1401 close HLog (and open new one) if there hasnt been edits in N minutes/hours; back out changes

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@775824 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Andrew Kyle Purtell 2009-05-18 06:10:06 +00:00
parent b33dfbeaea
commit d25c8da619
3 changed files with 9 additions and 27 deletions

View File

@ -256,8 +256,6 @@ Release 0.20.0 - Unreleased
HLog#append?)
HBASE-1429 Allow passing of a configuration object to HTablePool
HBASE-1432 LuceneDocumentWrapper is not public
HBASE-1401 close HLog (and open new one) if there hasnt been edits in N
minutes/hours
OPTIMIZATIONS
HBASE-1412 Change values for delete column and column family in KeyValue

View File

@ -132,6 +132,7 @@ public class HLog implements HConstants, Syncable {
private final AtomicLong logSeqNum = new AtomicLong(0);
private volatile long filenum = -1;
private volatile long old_filenum = -1;
private final AtomicInteger numEntries = new AtomicInteger(0);
@ -273,10 +274,6 @@ public class HLog implements HConstants, Syncable {
* @throws IOException
*/
public byte [] rollWriter() throws FailedLogCloseException, IOException {
// Return if nothing to flush.
if (this.writer != null && this.numEntries.get() <= 0) {
return null;
}
byte [] regionToFlush = null;
this.cacheFlushLock.lock();
try {
@ -286,6 +283,9 @@ public class HLog implements HConstants, Syncable {
synchronized (updateLock) {
// Clean up current writer.
Path oldFile = cleanupCurrentWriter(this.filenum);
if (this.filenum >= 0) {
this.old_filenum = this.filenum;
}
this.filenum = System.currentTimeMillis();
Path newPath = computeFilename(this.filenum);
this.writer = SequenceFile.createWriter(this.fs, this.conf, newPath,

View File

@ -40,32 +40,17 @@ class LogRoller extends Thread implements LogRollListener {
private final ReentrantLock rollLock = new ReentrantLock();
private final AtomicBoolean rollLog = new AtomicBoolean(false);
private final HRegionServer server;
private volatile long lastrolltime = System.currentTimeMillis();
// Period to roll log.
private final long rollperiod;
/** @param server */
public LogRoller(final HRegionServer server) {
super();
this.server = server;
this.rollperiod =
this.server.conf.getLong("hbase.regionserver.logroll.period", 3600000);
}
@Override
public void run() {
while (!server.isStopRequested()) {
long now = System.currentTimeMillis();
boolean periodic = false;
if (!rollLog.get()) {
periodic = (now - this.lastrolltime) < this.rollperiod;
if (periodic) {
// Time for periodic roll
if (LOG.isDebugEnabled()) {
LOG.debug("Hlog roll period " + this.rollperiod + "ms elapsed");
}
break;
}
synchronized (rollLog) {
try {
rollLog.wait(server.threadWakeFrequency);
@ -77,7 +62,6 @@ class LogRoller extends Thread implements LogRollListener {
}
rollLock.lock(); // Don't interrupt us. We're working
try {
this.lastrolltime = now;
byte [] regionToFlush = server.getLog().rollWriter();
if (regionToFlush != null) {
scheduleFlush(regionToFlush);