com.bigdata.journal

Class StressTestConcurrentUnisolatedIndices.WriteTask

java.lang.Object

com.bigdata.journal.AbstractTask<Void>

com.bigdata.journal.StressTestConcurrentUnisolatedIndices.WriteTask

All Implemented Interfaces:

ITask<Void>, Callable<Void>

Enclosing class:

StressTestConcurrentUnisolatedIndices

public static class StressTestConcurrentUnisolatedIndices.WriteTask
extends AbstractTask<Void>

A task that writes on named unisolated index(s).

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.journal.AbstractTask

AbstractTask.DelegateTask<T>, AbstractTask.InnerReadWriteTxServiceCallable<T>, AbstractTask.InnerWriteServiceCallable<T>, AbstractTask.ResubmitException

Field Summary

Fields inherited from class com.bigdata.journal.AbstractTask

checkpointNanoTime, concurrencyManager, isReadWriteTx, log, nanoTime_assignedWorker, nanoTime_beginWork, nanoTime_finishedWork, nanoTime_submitTask, readOnly, resourceManager, taskCounters, timestamp, transactionManager, tx

Constructor Summary

Constructors

Constructor and Description
StressTestConcurrentUnisolatedIndices.WriteTask(IConcurrencyManager concurrencyManager, String[] resource, int trial, int keyLen, int nops, double failureRate, ConcurrentHashMap<String,Thread> btrees)

Method Summary

Methods

Modifier and Type	Method and Description
Void	doTask() Executes random operation on a named unisolated index.
protected String	getTaskName() Returns the name of the class by default.

Methods inherited from class com.bigdata.journal.AbstractTask

assertResource, assertRunning, assertUnisolated, call, clearLoggingContext, dropIndex, getCommitTime, getIndex, getJournal, getOnlyResource, getResource, getResourceManager, getTaskCounters, getTimestamp, isResource, registerIndex, setupLoggingContext, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

StressTestConcurrentUnisolatedIndices.WriteTask

public StressTestConcurrentUnisolatedIndices.WriteTask(IConcurrencyManager concurrencyManager,
                                               String[] resource,
                                               int trial,
                                               int keyLen,
                                               int nops,
                                               double failureRate,
                                               ConcurrentHashMap<String,Thread> btrees)

Method Detail

getTaskName

protected String getTaskName()

Description copied from class: AbstractTask

Returns the name of the class by default.

Overrides:

getTaskName in class AbstractTask<Void>

doTask

public Void doTask()
            throws Exception

Executes random operation on a named unisolated index.

Specified by:

doTask in class AbstractTask<Void>

Returns:

null

Throws:

Exception - The exception that will be thrown by AbstractTask.call() iff the operation fails.

InterruptedException - This exception SHOULD be thrown if Thread.interrupted() becomes true during execution.