com.facebook.buck.artifact_cache

Class ThriftArtifactCache

java.lang.Object

com.facebook.buck.artifact_cache.AbstractAsynchronousCache

com.facebook.buck.artifact_cache.AbstractNetworkCache

com.facebook.buck.artifact_cache.ThriftArtifactCache

All Implemented Interfaces:

ArtifactCache, AutoCloseable

public class ThriftArtifactCache
extends AbstractNetworkCache

This is the Thrift protocol for the cache. The underlying channel is still HTTP but the payload is Thrift. To learn a bit more about the protocol please look at ThriftArtifactCacheProtocol.

Nested Class Summary

Nested classes/interfaces inherited from class com.facebook.buck.artifact_cache.AbstractAsynchronousCache

AbstractAsynchronousCache.CacheEventListener, AbstractAsynchronousCache.FetchRequest, AbstractAsynchronousCache.StoreEvents

Field Summary

Fields

Modifier and Type	Field and Description
static okhttp3.MediaType	HYBRID_THRIFT_STREAM_CONTENT_TYPE
static ThriftProtocol	PROTOCOL
static String	PROTOCOL_HEADER

Fields inherited from class com.facebook.buck.artifact_cache.AbstractNetworkCache

fetchClient, scheduleType, storeClient

Constructor Summary

Constructors

Constructor and Description
ThriftArtifactCache(com.facebook.buck.artifact_cache.NetworkCacheArgs args, String hybridThriftEndpoint, BuildId buildId, int multiFetchLimit, int concurrencyLevel, boolean multiCheckEnabled, String producerId, String producerHostname)

Method Summary

Modifier and Type	Method and Description
protected CacheDeleteResult	deleteImpl(List<RuleKey> ruleKeys)
protected com.facebook.buck.artifact_cache.AbstractAsynchronousCache.FetchResult	fetchImpl(BuildTarget target, RuleKey ruleKey, LazyPath output)
protected int	getMultiFetchBatchSize(int pendingRequestsSize) Used to compute the number of keys to include in every multiFetchRequest.
protected boolean	isMultiCheckEnabled()
protected com.facebook.buck.artifact_cache.AbstractAsynchronousCache.MultiContainsResult	multiContainsImpl(com.google.common.collect.ImmutableSet<RuleKey> uniqueRuleKeys)
protected com.facebook.buck.artifact_cache.AbstractAsynchronousCache.MultiFetchResult	multiFetchImpl(Iterable<AbstractAsynchronousCache.FetchRequest> requests) The MultiFetchResult should contain results in the same order as the requests.
protected com.facebook.buck.artifact_cache.AbstractAsynchronousCache.StoreResult	storeImpl(ArtifactInfo info, Path file)

Methods inherited from class com.facebook.buck.artifact_cache.AbstractNetworkCache

close, getRepository

Methods inherited from class com.facebook.buck.artifact_cache.AbstractAsynchronousCache

deleteAsync, fetchAsync, getCacheReadMode, getMode, getName, getProjectFilesystem, multiContainsAsync, skipPendingAndFutureAsyncFetches, store, store

Methods inherited from class java.lang.Object

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

Field Detail

HYBRID_THRIFT_STREAM_CONTENT_TYPE

public static final okhttp3.MediaType HYBRID_THRIFT_STREAM_CONTENT_TYPE

PROTOCOL_HEADER

public static final String PROTOCOL_HEADER

See Also:

Constant Field Values

PROTOCOL

public static final ThriftProtocol PROTOCOL

Constructor Detail

ThriftArtifactCache

public ThriftArtifactCache(com.facebook.buck.artifact_cache.NetworkCacheArgs args,
                           String hybridThriftEndpoint,
                           BuildId buildId,
                           int multiFetchLimit,
                           int concurrencyLevel,
                           boolean multiCheckEnabled,
                           String producerId,
                           String producerHostname)

Method Detail

fetchImpl

protected com.facebook.buck.artifact_cache.AbstractAsynchronousCache.FetchResult fetchImpl(@Nullable
                                                                                           BuildTarget target,
                                                                                           RuleKey ruleKey,
                                                                                           LazyPath output)
                                                                                    throws IOException

Specified by:

fetchImpl in class AbstractAsynchronousCache

Throws:

IOException

multiContainsImpl

protected com.facebook.buck.artifact_cache.AbstractAsynchronousCache.MultiContainsResult multiContainsImpl(com.google.common.collect.ImmutableSet<RuleKey> uniqueRuleKeys)
                                                                                                    throws IOException

Specified by:

multiContainsImpl in class AbstractAsynchronousCache

Throws:

IOException

getMultiFetchBatchSize

protected int getMultiFetchBatchSize(int pendingRequestsSize)

Description copied from class: AbstractAsynchronousCache

Used to compute the number of keys to include in every multiFetchRequest. If < 1, fetch will be used instead of multifetch.

Overrides:

getMultiFetchBatchSize in class AbstractAsynchronousCache

isMultiCheckEnabled

protected boolean isMultiCheckEnabled()

Overrides:

isMultiCheckEnabled in class AbstractAsynchronousCache

multiFetchImpl

protected com.facebook.buck.artifact_cache.AbstractAsynchronousCache.MultiFetchResult multiFetchImpl(Iterable<AbstractAsynchronousCache.FetchRequest> requests)
                                                                                              throws IOException

Description copied from class: AbstractAsynchronousCache

The MultiFetchResult should contain results in the same order as the requests.

Specified by:

multiFetchImpl in class AbstractAsynchronousCache

Throws:

IOException

storeImpl

protected com.facebook.buck.artifact_cache.AbstractAsynchronousCache.StoreResult storeImpl(ArtifactInfo info,
                                                                                           Path file)
                                                                                    throws IOException

Specified by:

storeImpl in class AbstractAsynchronousCache

Throws:

IOException

deleteImpl

protected CacheDeleteResult deleteImpl(List<RuleKey> ruleKeys)
                                throws IOException

Specified by:

deleteImpl in class AbstractAsynchronousCache

Throws:

IOException