com.facebook.buck.artifact_cache

Class RetryingCacheDecorator

java.lang.Object

com.facebook.buck.artifact_cache.RetryingCacheDecorator

All Implemented Interfaces:

ArtifactCache, CacheDecorator, AutoCloseable

public class RetryingCacheDecorator
extends Object
implements ArtifactCache, CacheDecorator

Constructor Summary

Constructors

Constructor and Description
RetryingCacheDecorator(ArtifactCacheMode cacheMode, ArtifactCache delegate, int maxFetchRetries, BuckEventBus buckEventBus)

Method Summary

Modifier and Type	Method and Description
void	close()
com.google.common.util.concurrent.ListenableFuture<CacheDeleteResult>	deleteAsync(List<RuleKey> ruleKeys)
com.google.common.util.concurrent.ListenableFuture<CacheResult>	fetchAsync(BuildTarget target, RuleKey ruleKey, LazyPath output) Fetch a cached artifact, keyed by ruleKey, save the artifact to path specified by output, and return true on success.
CacheReadMode	getCacheReadMode() This method must return the same value over the lifetime of this object.
ArtifactCache	getDelegate()
com.google.common.util.concurrent.ListenableFuture<com.google.common.collect.ImmutableMap<RuleKey,CacheResult>>	multiContainsAsync(com.google.common.collect.ImmutableSet<RuleKey> ruleKeys) Check if the cache contains the given artifacts, keyed by ruleKeys, without fetching them, and return a map of results wrapped in a ListenableFuture.
void	skipPendingAndFutureAsyncFetches() All pending (and future) async fetches will be immediately marked as skipped.
com.google.common.util.concurrent.ListenableFuture<Unit>	store(ArtifactInfo info, BorrowablePath output) Store the artifact at path specified by output to cache, such that it can later be fetched using ruleKey as the lookup key.
com.google.common.util.concurrent.ListenableFuture<Unit>	store(com.google.common.collect.ImmutableList<Pair<ArtifactInfo,BorrowablePath>> artifacts) Store the list of artifacts at path specified by output to cache in passed order, such that it can later be fetched using ruleKey as the lookup key.

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryingCacheDecorator

public RetryingCacheDecorator(ArtifactCacheMode cacheMode,
                              ArtifactCache delegate,
                              int maxFetchRetries,
                              BuckEventBus buckEventBus)

Method Detail

fetchAsync

public com.google.common.util.concurrent.ListenableFuture<CacheResult> fetchAsync(@Nullable
                                                                                  BuildTarget target,
                                                                                  RuleKey ruleKey,
                                                                                  LazyPath output)

Description copied from interface: ArtifactCache

Fetch a cached artifact, keyed by ruleKey, save the artifact to path specified by output, and return true on success.

Specified by:

fetchAsync in interface ArtifactCache

Parameters:

target - rule for which this is an artifact

ruleKey - cache fetch key

output - Path to store artifact to. Path should not be accessed unless store operation is guaranteed by the cache, to avoid potential extra disk I/O.

Returns:

whether it was a CacheResultType.MISS (indicating a failure) or some type of hit.

skipPendingAndFutureAsyncFetches

public void skipPendingAndFutureAsyncFetches()

Description copied from interface: ArtifactCache

All pending (and future) async fetches will be immediately marked as skipped.

Specified by:

skipPendingAndFutureAsyncFetches in interface ArtifactCache

getDelegate

public ArtifactCache getDelegate()

Specified by:

getDelegate in interface CacheDecorator

Returns:

Cache that is wrapped by a decorator.

store

public com.google.common.util.concurrent.ListenableFuture<Unit> store(ArtifactInfo info,
                                                                      BorrowablePath output)

Description copied from interface: ArtifactCache

Store the artifact at path specified by output to cache, such that it can later be fetched using ruleKey as the lookup key. If any internal errors occur, fail silently and continue execution. Store may be performed synchronously or asynchronously.

This is a noop if ArtifactCache.getCacheReadMode()} returns READONLY.

Specified by:

store in interface ArtifactCache

Parameters:

info - information to store with the artifact

output - path to read artifact from. If its borrowable, you may freely move the file into cache without obtaining a copy of the file.

Returns:

ListenableFuture that completes once the store has finished.

store

public com.google.common.util.concurrent.ListenableFuture<Unit> store(com.google.common.collect.ImmutableList<Pair<ArtifactInfo,BorrowablePath>> artifacts)

Description copied from interface: ArtifactCache

Store the list of artifacts at path specified by output to cache in passed order, such that it can later be fetched using ruleKey as the lookup key. If any internal errors occur, fail silently and continue execution. Store may be performed synchronously or asynchronously.

This is a noop if ArtifactCache.getCacheReadMode()} returns READONLY.

Specified by:

store in interface ArtifactCache

Parameters:

artifacts - list of artifact info and path to be uploaded to the cache in given order.

Returns:

ListenableFuture that completes once the store has finished.

multiContainsAsync

public com.google.common.util.concurrent.ListenableFuture<com.google.common.collect.ImmutableMap<RuleKey,CacheResult>> multiContainsAsync(com.google.common.collect.ImmutableSet<RuleKey> ruleKeys)

Description copied from interface: ArtifactCache

Check if the cache contains the given artifacts, keyed by ruleKeys, without fetching them, and return a map of results wrapped in a ListenableFuture. This is supposed to be fast, but best-effort, meaning that there will be false-positives.

Specified by:

multiContainsAsync in interface ArtifactCache

Parameters:

ruleKeys - Set of cache fetch keys.

Returns:

map of keys to CacheResult which can be a CacheResultType.MISS / CacheResultType.ERROR (indicating a failure) or CacheResultType.CONTAINS.

deleteAsync

public com.google.common.util.concurrent.ListenableFuture<CacheDeleteResult> deleteAsync(List<RuleKey> ruleKeys)

Specified by:

deleteAsync in interface ArtifactCache

getCacheReadMode

public CacheReadMode getCacheReadMode()

Description copied from interface: ArtifactCache

This method must return the same value over the lifetime of this object.

Specified by:

getCacheReadMode in interface ArtifactCache

Returns:

whether thisArtifactCache supports storing artifacts.

close

public void close()

Specified by:

close in interface ArtifactCache

Specified by:

close in interface AutoCloseable