org.n52.sos.cache.ctrl

Class ContentCacheControllerImpl

java.lang.Object

org.n52.sos.cache.ctrl.AbstractSchedulingContentCacheController

org.n52.sos.cache.ctrl.ContentCacheControllerImpl

All Implemented Interfaces:

ContentCacheController, Cleanupable

public class ContentCacheControllerImpl
extends AbstractSchedulingContentCacheController

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ContentCacheControllerImpl.CompleteUpdate
private class	ContentCacheControllerImpl.PartialUpdate
private static class	ContentCacheControllerImpl.State
private class	ContentCacheControllerImpl.Update

Field Summary

Fields

Modifier and Type	Field and Description
private WritableContentCache	cache
private static AtomicInteger	COMPLETE_UPDATE_COUNT
private ContentCacheControllerImpl.CompleteUpdate	current
private ReentrantLock	lock
private static org.slf4j.Logger	LOGGER
private ContentCacheControllerImpl.CompleteUpdate	next
private static AtomicInteger	PARTIAL_UPDATE_COUNT
private ContentCachePersistenceStrategy	persistenceStrategy

Constructor Summary

Constructors

Constructor and Description
ContentCacheControllerImpl()
ContentCacheControllerImpl(ContentCachePersistenceStrategy persistenceStrategy)

Method Summary

Modifier and Type	Method and Description
void	cleanup()
private void	executeComplete(ContentCacheControllerImpl.CompleteUpdate update)
private void	executePartial(ContentCacheControllerImpl.PartialUpdate update)
WritableContentCache	getCache()
ContentCachePersistenceStrategy	getContentCachePersistenceStrategy()
boolean	isUpdateInProgress()
private void	loadOrCreateCache()
private void	lock()
private void	runCurrent()
protected void	setCache(WritableContentCache wcc)
private void	unlock()
void	update() Renew the content cache completly.
void	update(ContentCacheUpdate update) Update the content cache with the specified update.

Methods inherited from class org.n52.sos.cache.ctrl.AbstractSchedulingContentCacheController

finalize, isInitialized, setInitialized, setUpdateInterval

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

COMPLETE_UPDATE_COUNT

private static final AtomicInteger COMPLETE_UPDATE_COUNT

PARTIAL_UPDATE_COUNT

private static final AtomicInteger PARTIAL_UPDATE_COUNT

current

private ContentCacheControllerImpl.CompleteUpdate current

next

private ContentCacheControllerImpl.CompleteUpdate next

cache

private volatile WritableContentCache cache

lock

private final ReentrantLock lock

persistenceStrategy

private final ContentCachePersistenceStrategy persistenceStrategy

Constructor Detail

ContentCacheControllerImpl

public ContentCacheControllerImpl(ContentCachePersistenceStrategy persistenceStrategy)

ContentCacheControllerImpl

public ContentCacheControllerImpl()

Method Detail

loadOrCreateCache

private void loadOrCreateCache()

getCache

public WritableContentCache getCache()

Returns:

the content cache

cleanup

public void cleanup()

Specified by:

cleanup in interface Cleanupable

Overrides:

cleanup in class AbstractSchedulingContentCacheController

setCache

protected void setCache(WritableContentCache wcc)

update

public void update(ContentCacheUpdate update)
            throws OwsExceptionReport

Description copied from interface: ContentCacheController

Update the content cache with the specified update.

Parameters:

update - the update

Throws:

OwsExceptionReport - if an error occurs while updating the cache

runCurrent

private void runCurrent()
                 throws OwsExceptionReport

Throws:

OwsExceptionReport

executePartial

private void executePartial(ContentCacheControllerImpl.PartialUpdate update)
                     throws OwsExceptionReport

Throws:

OwsExceptionReport

executeComplete

private void executeComplete(ContentCacheControllerImpl.CompleteUpdate update)
                      throws OwsExceptionReport

Throws:

OwsExceptionReport

lock

private void lock()

unlock

private void unlock()

isUpdateInProgress

public boolean isUpdateInProgress()

Returns:

Is a cache update currently in progress?

update

public void update()
            throws OwsExceptionReport

Description copied from interface: ContentCacheController

Renew the content cache completly.

Throws:

OwsExceptionReport - if an error occurs while updating the cache

getContentCachePersistenceStrategy

public ContentCachePersistenceStrategy getContentCachePersistenceStrategy()

Returns:

the ContentCachePersistenceStrategy