Package one.microstream.storage.types

Class StorageChannelTask.Abstract<R>

java.lang.Object

one.microstream.storage.types.StorageTask.Abstract

one.microstream.storage.types.StorageChannelTask.Abstract<R>

All Implemented Interfaces:

StorageChannelTask, StorageTask

Direct Known Subclasses:

StorageChannelSynchronizingTask.AbstractCompletingTask, StorageRequestTaskLoad.Abstract

Enclosing interface:

StorageChannelTask

public abstract static class StorageChannelTask.Abstract<R>
extends StorageTask.Abstract
implements StorageChannelTask

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannelTask

StorageChannelTask.Abstract<R>

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageTask

StorageTask.Abstract, StorageTask.DummyTask

Constructor Summary

Constructors

Constructor	Description
Abstract(long timestamp, int channelCount)

Method Summary

Modifier and Type	Method	Description
void	addProblem(int hashIndex, Throwable problem)
boolean	hasProblems()
void	incrementCompletionProgress()
void	incrementProcessingProgress()
boolean	isComplete()
boolean	isProcessed()
Throwable	problemForChannel(StorageChannel channel)
Throwable[]	problems()
void	processBy(StorageChannel storageChannel)
void	waitOnCompletion()
void	waitOnProcessing()

Methods inherited from class one.microstream.storage.types.StorageTask.Abstract

awaitNext, next, setNext, timestamp

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.microstream.storage.types.StorageTask

awaitNext, next, setNext, timestamp

Constructor Details

Abstract

public Abstract(long timestamp, int channelCount)

Method Details

incrementCompletionProgress

public final void incrementCompletionProgress()

Specified by:

incrementCompletionProgress in interface StorageChannelTask

isComplete

public final boolean isComplete()

Specified by:

isComplete in interface StorageTask

waitOnCompletion

public final void waitOnCompletion() throws InterruptedException

Specified by:

waitOnCompletion in interface StorageTask

Throws:

InterruptedException

hasProblems

public final boolean hasProblems()

Specified by:

hasProblems in interface StorageTask

problems

public final Throwable[] problems()

Specified by:

problems in interface StorageTask

problemForChannel

public final Throwable problemForChannel(StorageChannel channel)

Specified by:

problemForChannel in interface StorageTask

addProblem

public final void addProblem(int hashIndex, Throwable problem)

Specified by:

addProblem in interface StorageChannelTask

isProcessed

public final boolean isProcessed()

waitOnProcessing

public final void waitOnProcessing() throws InterruptedException

Throws:

InterruptedException

incrementProcessingProgress

public final void incrementProcessingProgress()

processBy

public final void processBy(StorageChannel storageChannel) throws InterruptedException

Specified by:

processBy in interface StorageTask

Throws:

InterruptedException