Package org.infinispan.configuration.parsing

Class SFSToSIFSStore<K,V>

java.lang.Object

org.infinispan.persistence.support.DelegatingNonBlockingStore<K,V>

org.infinispan.configuration.parsing.SFSToSIFSStore<K,V>

Type Parameters:

K - key type

V - value type

All Implemented Interfaces:

NonBlockingStore<K,V>

public class SFSToSIFSStore<K,V>
extends DelegatingNonBlockingStore<K,V>

Store that is used to migrate data from ISPN 12.0 SingleFileStore to an ISPN 13.0 SoftIndexFileStore. This store works identically to a SoftIndexFileStore except that it will first attempt to copy all the entries from a SingleFileStore with the same location as the configured SoftIndexFileStoreConfiguration.dataLocation(). Note that both a segmented and non segmented SingleFileStore is attempted since it could have been either and SoftIndexFileStore only supports segmentation now.

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.persistence.spi.NonBlockingStore

NonBlockingStore.Characteristic, NonBlockingStore.SegmentedPublisher<Type>

Field Summary

Fields inherited from interface org.infinispan.persistence.spi.NonBlockingStore

SIZE_UNAVAILABLE_FUTURE

Constructor Summary

Constructors

Constructor	Description
SFSToSIFSStore()

Method Summary

Modifier and Type	Method	Description
NonBlockingStore<K,V>	delegate()
CompletionStage<Void>	start(InitializationContext ctx)	The first method to invoke so that the store can be configured and additional steps, such as connecting through a socket or opening file descriptors, are performed.

Methods inherited from class org.infinispan.persistence.support.DelegatingNonBlockingStore

addSegments, approximateSize, batch, characteristics, clear, commit, containsKey, delete, ignoreCommandWithFlags, isAvailable, load, prepareWithModifications, publishEntries, publishKeys, purgeExpired, removeSegments, rollback, size, stop, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.persistence.spi.NonBlockingStore

destroy

Constructor Details

SFSToSIFSStore

public SFSToSIFSStore()

Method Details

delegate

public NonBlockingStore<K,V> delegate()

Specified by:

delegate in class DelegatingNonBlockingStore<K,V>

start

public CompletionStage<Void> start(InitializationContext ctx)

Description copied from interface: NonBlockingStore

The first method to invoke so that the store can be configured and additional steps, such as connecting through a socket or opening file descriptors, are performed.

The provided InitializationContext contains many helpful objects, including the configuration of the cache and store, concurrency utilities such as BlockingManager or an executor reserved for non-blocking operations only InitializationContext.getNonBlockingExecutor().

This method is guaranteed not to be invoked concurrently with other operations. This means other methods are not invoked on this store until after the returned Stage completes.

It is expected that an implementation should be able to "restart" by invoking start a second time if NonBlockingStore.stop() has been invoked and allowed for its stage to complete.

Specified by:

start in interface NonBlockingStore<K,V>

Overrides:

start in class DelegatingNonBlockingStore<K,V>

Parameters:

ctx - initialization context used to initialize this store.

Returns:

a stage that, when complete, indicates that this store has started successfully.