public class ReprioritizationTracker extends Object implements IReprioritizationTracker
Modifier and Type | Class and Description |
---|---|
protected static class |
ReprioritizationTracker.PreloadedValues
A set of preloaded values
|
protected static class |
ReprioritizationTracker.PreloadRequest
A preload request
|
Modifier and Type | Field and Description |
---|---|
static String |
_rcsid |
protected IBinManager |
binManager |
protected ILockManager |
lockManager
Lock manager
|
protected Map<String,ReprioritizationTracker.PreloadedValues> |
preloadedValues
Preload values
|
protected Map<String,ReprioritizationTracker.PreloadRequest> |
preloadRequests
Preload requests
|
protected static String |
trackerMinimumDepthResource |
protected static String |
trackerProcessIDResource |
protected static String |
trackerReproIDResource |
protected static String |
trackerWriteLock |
Constructor and Description |
---|
ReprioritizationTracker(IThreadContext threadContext)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
addPreloadRequest(String binName,
double weightedMinimumDepth)
Note preload amounts.
|
void |
assessMinimumDepth(Double[] binNamesSet)
Assess the current minimum depth.
|
void |
clearPreloadedValues()
Clear remaining preloaded values.
|
void |
clearPreloadRequests()
Clear any preload requests.
|
void |
doneReprioritization(String reproID)
Complete a reprioritization activity.
|
double |
getIncrementBinValue(String binName,
double weightedMinimumDepth)
Get a bin value.
|
double |
getMinimumDepth()
Retrieve current minimum depth.
|
String |
isSpecifiedProcessReprioritizing(String processID)
Check if the specified processID is the one performing reprioritization.
|
void |
preloadBinValues()
Preload bin values.
|
protected double |
readMinimumDepth()
Read minimum depth.
|
protected String |
readProcessID()
Read process ID.
|
protected String |
readReproID()
Read repriotization ID.
|
void |
startReprioritization(String processID,
String reproID)
Start a reprioritization activity.
|
protected void |
writeMinimumDepth(double depth)
Write minimum depth.
|
protected void |
writeProcessID(String processID)
Write process ID.
|
protected void |
writeReproID(String reproID)
Write repro ID.
|
public static final String _rcsid
protected static final String trackerWriteLock
protected static final String trackerProcessIDResource
protected static final String trackerReproIDResource
protected static final String trackerMinimumDepthResource
protected final ILockManager lockManager
protected final IBinManager binManager
protected final Map<String,ReprioritizationTracker.PreloadRequest> preloadRequests
protected final Map<String,ReprioritizationTracker.PreloadedValues> preloadedValues
public ReprioritizationTracker(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public void startReprioritization(String processID, String reproID) throws ManifoldCFException
startReprioritization
in interface IReprioritizationTracker
prioritizationTime
- is the timestamp of the prioritization.processID
- is the process ID of the process performing/waiting for the prioritization
to complete.reproID
- is the reprocessing thread IDManifoldCFException
public void doneReprioritization(String reproID) throws ManifoldCFException
doneReprioritization
in interface IReprioritizationTracker
processID
- is the process ID of the process completing the prioritization.ManifoldCFException
public String isSpecifiedProcessReprioritizing(String processID) throws ManifoldCFException
isSpecifiedProcessReprioritizing
in interface IReprioritizationTracker
processID
- is the process ID to check.ManifoldCFException
public void assessMinimumDepth(Double[] binNamesSet) throws ManifoldCFException
assessMinimumDepth
in interface IReprioritizationTracker
binNamesSet
- is the current set of priorities we see on the queuing operation.ManifoldCFException
public double getMinimumDepth() throws ManifoldCFException
getMinimumDepth
in interface IReprioritizationTracker
ManifoldCFException
public void addPreloadRequest(String binName, double weightedMinimumDepth)
addPreloadRequest
in interface IReprioritizationTracker
public void preloadBinValues() throws ManifoldCFException
preloadBinValues
in interface IReprioritizationTracker
ManifoldCFException
public void clearPreloadRequests()
clearPreloadRequests
in interface IReprioritizationTracker
public void clearPreloadedValues()
clearPreloadedValues
in interface IReprioritizationTracker
public double getIncrementBinValue(String binName, double weightedMinimumDepth) throws ManifoldCFException
getIncrementBinValue
in interface IReprioritizationTracker
binName
- is the bin name.weightedMinimumDepth
- is the minimum depth to use.ManifoldCFException
protected String readProcessID() throws ManifoldCFException
ManifoldCFException
protected void writeProcessID(String processID) throws ManifoldCFException
processID
- is the process ID to write.ManifoldCFException
protected String readReproID() throws ManifoldCFException
ManifoldCFException
protected void writeReproID(String reproID) throws ManifoldCFException
reproID
- is the repro ID to write.ManifoldCFException
protected double readMinimumDepth() throws ManifoldCFException
ManifoldCFException
protected void writeMinimumDepth(double depth) throws ManifoldCFException
the
- minimum depth.ManifoldCFException