Package com.atlassian.plugin.cache.filecache.impl

Class TwoStreamsCache

java.lang.Object

com.atlassian.plugin.cache.filecache.impl.StreamsCache

com.atlassian.plugin.cache.filecache.impl.TwoStreamsCache

public class TwoStreamsCache
extends StreamsCache

Caches the contents of two streams, and deletes the cache when asked to do so. This class encapsulates the lifecycle of two cached files, from as-yet-uncached, to cached, to needs-deletion, to deleted.

Calls to stream() always succeed, even if the cache was deleted. The initial call to stream() will block other callers to stream() and deleteWhenPossible().

Subsequent calls to stream() don't block other calls.

Subsequent calls to deleteWhenPossible() don't block.

A call to deleteWhenPossible() always results in the file being (eventually) deleted.

Both stream() and deleteWhenPossible() can be called multiple times, in any order, with any level of concurrency.

Since:

v3.3

Field Summary

Fields

Modifier and Type	Field	Description
protected final File	tmpFile1
protected final File	tmpFile2

Constructor Summary

Constructors

Constructor	Description
TwoStreamsCache(File tmpFile1, File tmpFile2)

Method Summary

Modifier and Type	Method	Description
void	deleteWhenPossible()
void	stream(OutputStream out, Cache.StreamProvider provider)
void	streamTwo(OutputStream out1, OutputStream out2, Cache.TwoStreamProvider provider)

Methods inherited from class com.atlassian.plugin.cache.filecache.impl.StreamsCache

createWriteStream, deleteWhenPossible, doEnter, doExit, setLogger, streamFromFile

Methods inherited from class java.lang.Object

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

Field Details

tmpFile1

protected final File tmpFile1

tmpFile2

protected final File tmpFile2

Constructor Details

TwoStreamsCache

public TwoStreamsCache(File tmpFile1,
 File tmpFile2)

Method Details

streamTwo

public void streamTwo(OutputStream out1,
 OutputStream out2,
 Cache.TwoStreamProvider provider)

Specified by:

streamTwo in class StreamsCache

stream

public void stream(OutputStream out,
 Cache.StreamProvider provider)

Specified by:

stream in class StreamsCache

deleteWhenPossible

public void deleteWhenPossible()

Specified by:

deleteWhenPossible in class StreamsCache