public class INCompressor extends DaemonThread
envImpl, logger, name, nWakeupRequests, stifleExceptionChatter
Constructor and Description |
---|
INCompressor(EnvironmentImpl env,
long waitTime,
java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
void |
addBinRefToQueue(BINReference binRef,
boolean doWakeup)
Adds the BINReference to the queue if the BIN is not already in the
queue, or adds the deleted keys to an existing entry if one exists.
|
void |
addBinToQueue(BIN bin,
boolean doWakeup)
Adds the BIN to the queue if the BIN is not already in the queue.
|
void |
addMultipleBinRefsToQueue(java.util.Collection<BINReference> binRefs,
boolean doWakeup)
Adds an entire collection of BINReferences to the queue at once.
|
void |
clearEnv() |
void |
doCompress()
The real work to doing a compress.
|
boolean |
exists(long nodeId) |
int |
getBinRefQueueSize() |
void |
lazyCompress(IN in)
Lazily compress prior to logging a full version of a BIN; the caller
is responsible for ensuring that a full version is likely to be logged
next.
|
StatGroup |
loadStats(StatsConfig config)
Return stats
|
protected long |
nDeadlockRetries()
Return the number of retries when a deadlock exception occurs.
|
void |
onWakeup()
onWakeup is synchronized to ensure that multiple invocations of the
DaemonThread aren't made.
|
BIN |
searchForBIN(DatabaseImpl db,
BINReference binRef)
Search the tree for the BIN that corresponds to this BINReference.
|
void |
setBeforeFlushTrackerHook(TestHook hook) |
void |
verifyCursors() |
checkErrorListener, createLogger, getExceptionListener, getNWakeupRequests, getThread, isPaused, isRunning, isShutdownRequested, requestShutdown, run, runOrPause, setExceptionListener, shutdown, toString, wakeup
public INCompressor(EnvironmentImpl env, long waitTime, java.lang.String name)
public void clearEnv()
public void setBeforeFlushTrackerHook(TestHook hook)
public void verifyCursors() throws DatabaseException
DatabaseException
public int getBinRefQueueSize()
public void addBinToQueue(BIN bin, boolean doWakeup)
public void addBinRefToQueue(BINReference binRef, boolean doWakeup)
public void addMultipleBinRefsToQueue(java.util.Collection<BINReference> binRefs, boolean doWakeup)
public boolean exists(long nodeId)
public StatGroup loadStats(StatsConfig config)
protected long nDeadlockRetries()
nDeadlockRetries
in class DaemonThread
public void onWakeup() throws DatabaseException
DaemonThread
onWakeup
in class DaemonThread
DatabaseException
public void doCompress() throws DatabaseException
DatabaseException
public BIN searchForBIN(DatabaseImpl db, BINReference binRef)
binRef
- the BINReference that indicates the bin we want.public void lazyCompress(IN in)
Copyright (c) 2004-2012 Oracle. All rights reserved.