com.aspc.DBObj.Internal

Class DirtyRows

java.lang.Object

java.lang.Thread

com.aspc.DBObj.Internal.DirtyRows

All Implemented Interfaces:

ServerProcess, java.lang.Runnable

public final class DirtyRows
extends java.lang.Thread
implements ServerProcess

Background thread to load records from the database. The background loader is a server process that can be canceled, killed or paused via the PROCESS command. The background loader process will restart if canceled or killed The background loader process will spawn a new process if the current one becomes blocked. If a blockage is detected, an alert email will be sent via logger THREAD MODE: MULTI-THREADED

Since:

April 23, 2005

Author:

Nigel Leck

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DISABLE_RESTART disabled the auto restart of dirty rows loader.
static java.util.concurrent.atomic.AtomicBoolean	DISABLE_STALE_READ disabled the dirty read detection.
static java.lang.ThreadLocal<java.lang.Boolean>	DISABLE_TRANSACTION_VALIDATE disabled the validate of parameters.
static java.util.concurrent.atomic.AtomicLong	MAX_PROCESS_TIME The MAXIMUM PROCESSING TIME of one call.
static java.util.concurrent.atomic.AtomicLong	MIN_WARNING_PROCESS_TIME The MINIMUM WARNING PROCESSING TIME of one call.
static java.lang.String	PROPERTY_DIRTY_READ_DELAY The property to disable the dirty read delay
static java.lang.String	PROPERTY_DIRTY_ROWS_MAX_PROCESS_TIME The property to set the default maximum processing time.
static java.lang.String	PROPERTY_DIRTY_ROWS_WARNING_PROCESS_TIME The property to set the default maximum processing time.
static java.lang.String	PROPERTY_DISABLE_DIRTY_ROWS_CHECK The property to disable the dirty rows check.
static java.lang.String	PROPERTY_DISABLE_DIRTY_ROWS_RESTART The property to disable the dirty rows auto restart.
static java.lang.String	PROPERTY_DISABLE_STALE_READ The property to disable the dirty read.
static java.lang.String	PROPERTY_RETRY_READ_DELAY The property to disable the retry read delay
static long	RETRY_READ_DELAY disabled the retry read delay
static long	STALE_READ_DELAY disabled the dirty read delay
static java.lang.String	THREAD_NAME The thread name
static long	WARNING_PROCESS_TIME The WARNING PROCESSING TIME of one call.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method and Description
static void	checkUp() Check if the background loader is running.
static PossibleRowsHolder	dirtyRows(VirtualDB layer, GlobalKeyId baseClassId) get the known dirty rows for this base class.
static long	getMaxProccessTime() Get the max processing time
static int	getPendingCount() get the pending count
static long	getStaleReadCount() get the stale read count
static long	getWarningProccessTime() Get the warning processing time
boolean	isCurrent() Is this the current process ?
boolean	isPaused() Is this process paused ?
boolean	isTerminated() Is this process terminated ?
static void	lastError() Check if there has been an issue.
java.lang.String	makeThreadName() get the progress message
static Marker	mark() create a marker which will be notified when the back ground loading has finished.
void	paused() This process has been paused.
static boolean	recordThreadPublishedRows(boolean turnOn) start recording of published rows
void	resumed() This process has been resumed.
void	run() load the dirty rows as fast as possible.
static void	schedule(VirtualDB layer, long transNr, java.lang.String rootId, java.lang.String rowList) schedule the processing of the rows to be loaded.
static void	setMaxProccessTime(long maxProcessTime) Set the max processing time
static void	setWarningProccessTime(long warningProcessTime) Set the warning processing time
static boolean	simulateBlock(boolean flag) simulate block
void	terminated() This process has been terminated.
static HashLongMap	threadPublishedRows() the published dirty rows for this thread.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

PROPERTY_DISABLE_DIRTY_ROWS_CHECK

public static final java.lang.String PROPERTY_DISABLE_DIRTY_ROWS_CHECK

The property to disable the dirty rows check.

See Also:

Constant Field Values

THREAD_NAME

public static final java.lang.String THREAD_NAME

The thread name

See Also:

Constant Field Values

PROPERTY_DISABLE_DIRTY_ROWS_RESTART

public static final java.lang.String PROPERTY_DISABLE_DIRTY_ROWS_RESTART

The property to disable the dirty rows auto restart.

See Also:

Constant Field Values

DISABLE_RESTART

public static final boolean DISABLE_RESTART

disabled the auto restart of dirty rows loader.

PROPERTY_DISABLE_STALE_READ

public static final java.lang.String PROPERTY_DISABLE_STALE_READ

The property to disable the dirty read.

See Also:

Constant Field Values

DISABLE_STALE_READ

public static final java.util.concurrent.atomic.AtomicBoolean DISABLE_STALE_READ

disabled the dirty read detection.

DISABLE_TRANSACTION_VALIDATE

public static final java.lang.ThreadLocal<java.lang.Boolean> DISABLE_TRANSACTION_VALIDATE

disabled the validate of parameters.

PROPERTY_DIRTY_READ_DELAY

public static final java.lang.String PROPERTY_DIRTY_READ_DELAY

The property to disable the dirty read delay

See Also:

Constant Field Values

STALE_READ_DELAY

public static final long STALE_READ_DELAY

disabled the dirty read delay

PROPERTY_RETRY_READ_DELAY

public static final java.lang.String PROPERTY_RETRY_READ_DELAY

The property to disable the retry read delay

See Also:

Constant Field Values

RETRY_READ_DELAY

public static final long RETRY_READ_DELAY

disabled the retry read delay

PROPERTY_DIRTY_ROWS_MAX_PROCESS_TIME

public static final java.lang.String PROPERTY_DIRTY_ROWS_MAX_PROCESS_TIME

The property to set the default maximum processing time.

See Also:

Constant Field Values

MAX_PROCESS_TIME

public static final java.util.concurrent.atomic.AtomicLong MAX_PROCESS_TIME

The MAXIMUM PROCESSING TIME of one call.

PROPERTY_DIRTY_ROWS_WARNING_PROCESS_TIME

public static final java.lang.String PROPERTY_DIRTY_ROWS_WARNING_PROCESS_TIME

The property to set the default maximum processing time.

See Also:

Constant Field Values

WARNING_PROCESS_TIME

public static final long WARNING_PROCESS_TIME

The WARNING PROCESSING TIME of one call.

MIN_WARNING_PROCESS_TIME

public static final java.util.concurrent.atomic.AtomicLong MIN_WARNING_PROCESS_TIME

The MINIMUM WARNING PROCESSING TIME of one call.

Method Detail

getStaleReadCount

@CheckReturnValue
public static long getStaleReadCount()

get the stale read count

Returns:

the count.

simulateBlock

public static boolean simulateBlock(boolean flag)

simulate block

Parameters:

flag - true to turn on.

Returns:

was blocking

isPaused

@CheckReturnValue
public boolean isPaused()

Is this process paused ?

Returns:

true if this dirty rows loader is paused

isCurrent

@CheckReturnValue
public boolean isCurrent()

Is this the current process ?

Returns:

true if this is the current loader

isTerminated

@CheckReturnValue
public boolean isTerminated()

Is this process terminated ?

Returns:

true if this loader is terminated

getMaxProccessTime

@CheckReturnValue
public static long getMaxProccessTime()

Get the max processing time

Returns:

the maximum processing time in milliseconds.

setMaxProccessTime

public static void setMaxProccessTime(long maxProcessTime)

Set the max processing time

Parameters:

maxProcessTime - set the current max processing time.

getWarningProccessTime

@CheckReturnValue
public static long getWarningProccessTime()

Get the warning processing time

Returns:

the warning processing time in milliseconds.

setWarningProccessTime

public static void setWarningProccessTime(long warningProcessTime)

Set the warning processing time

Parameters:

warningProcessTime - set the current warning processing time.

checkUp

public static void checkUp()

Check if the background loader is running.

run

public void run()

load the dirty rows as fast as possible.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

lastError

public static void lastError()
                      throws java.lang.Exception

Check if there has been an issue.

Throws:

java.lang.Exception - if there has been an error since the last time this method was called.

getPendingCount

@CheckReturnValue
public static int getPendingCount()

get the pending count

Returns:

the count

recordThreadPublishedRows

public static boolean recordThreadPublishedRows(boolean turnOn)

start recording of published rows

Parameters:

turnOn - true to turn on

Returns:

true if currently recording.

threadPublishedRows

@CheckReturnValue
 @Nullable
public static HashLongMap threadPublishedRows()

the published dirty rows for this thread.

Returns:

the published rows.

dirtyRows

@CheckReturnValue
 @Nonnull
public static PossibleRowsHolder dirtyRows(@Nonnull
                                                                       VirtualDB layer,
                                                                       @Nonnull
                                                                       GlobalKeyId baseClassId)

get the known dirty rows for this base class.

Parameters:

layer - The layer

baseClassId - the base class

Returns:

known dirty rows.

mark

@CheckReturnValue
 @Nonnull
public static Marker mark()

create a marker which will be notified when the back ground loading has finished.

Returns:

the marker.

schedule

public static void schedule(@Nonnull
                            VirtualDB layer,
                            @Nonnegative
                            long transNr,
                            @Nonnull
                            java.lang.String rootId,
                            @Nonnull
                            java.lang.String rowList)
                     throws java.lang.Exception

schedule the processing of the rows to be loaded.

Parameters:

layer - The layer

transNr - the transaction (ZERO means just load the latest)

rootId - the class of the rows

rowList - The row list

Throws:

java.lang.Exception - A serious problem

paused

public void paused()

This process has been paused. MODE: Multi Threaded

Specified by:

paused in interface ServerProcess

resumed

public void resumed()

This process has been resumed. MODE: Multi Threaded

Specified by:

resumed in interface ServerProcess

terminated

public void terminated()

This process has been terminated. MODE: Multi Threaded

Specified by:

terminated in interface ServerProcess

makeThreadName

@CheckReturnValue
public java.lang.String makeThreadName()

get the progress message

Specified by:

makeThreadName in interface ServerProcess

Returns:

the string message