com.facebook.buck.remoteexecution.util

Class LocalContentAddressedStorage

java.lang.Object

com.facebook.buck.remoteexecution.util.LocalContentAddressedStorage

All Implemented Interfaces:

ContentAddressedStorageClient

public class LocalContentAddressedStorage
extends Object
implements ContentAddressedStorageClient

A simple, on-disk content addressed storage.

Nested Class Summary

Nested classes/interfaces inherited from interface com.facebook.buck.remoteexecution.ContentAddressedStorageClient

ContentAddressedStorageClient.FileMaterializer

Constructor Summary

Constructors

Constructor and Description
LocalContentAddressedStorage(Path cacheDir, Protocol protocol, BuckEventBus buckEventBus)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Unit>	addMissing(Collection<UploadDataSupplier> data)
com.google.common.collect.ImmutableList<CasBlobUploader.UploadResult>	batchUpdateBlobs(com.google.common.collect.ImmutableList<UploadDataSupplier> blobData) Upload blobs.
boolean	containsDigest(Protocol.Digest digest)
com.google.common.util.concurrent.ListenableFuture<ByteBuffer>	fetch(Protocol.Digest digest)
java.util.stream.Stream<Protocol.Digest>	findMissing(Iterable<Protocol.Digest> digests)
InputStream	getData(Protocol.Digest digest) Looks up some data.
FileInputStream	getFileInputStream(Protocol.Digest digest) Get a file input stream to a Digest
com.google.common.collect.ImmutableList<Protocol.Directory>	getTree(Protocol.Digest rootDigest) Returns a list of all sub directories.
Protocol.Action	materializeAction(Protocol.Digest actionDigest)
Optional<Protocol.Command>	materializeInputs(Path buildDir, Protocol.Digest rootDigest, Optional<Protocol.Digest> commandDigest)
com.google.common.util.concurrent.ListenableFuture<Unit>	materializeOutputs(List<Protocol.OutputDirectory> outputDirectories, List<Protocol.OutputFile> outputFiles, ContentAddressedStorageClient.FileMaterializer materializer) Materializes the outputs into the build root.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalContentAddressedStorage

public LocalContentAddressedStorage(Path cacheDir,
                                    Protocol protocol,
                                    BuckEventBus buckEventBus)

Method Detail

batchUpdateBlobs

public com.google.common.collect.ImmutableList<CasBlobUploader.UploadResult> batchUpdateBlobs(com.google.common.collect.ImmutableList<UploadDataSupplier> blobData)

Upload blobs.

addMissing

public com.google.common.util.concurrent.ListenableFuture<Unit> addMissing(Collection<UploadDataSupplier> data)
                                                                    throws IOException

Specified by:

addMissing in interface ContentAddressedStorageClient

Throws:

IOException

containsDigest

public boolean containsDigest(Protocol.Digest digest)

Specified by:

containsDigest in interface ContentAddressedStorageClient

fetch

public com.google.common.util.concurrent.ListenableFuture<ByteBuffer> fetch(Protocol.Digest digest)

Specified by:

fetch in interface ContentAddressedStorageClient

materializeOutputs

public com.google.common.util.concurrent.ListenableFuture<Unit> materializeOutputs(List<Protocol.OutputDirectory> outputDirectories,
                                                                                   List<Protocol.OutputFile> outputFiles,
                                                                                   ContentAddressedStorageClient.FileMaterializer materializer)
                                                                            throws IOException

Materializes the outputs into the build root. All required data must be present (or inlined).

Specified by:

materializeOutputs in interface ContentAddressedStorageClient

Throws:

IOException

materializeAction

public Protocol.Action materializeAction(Protocol.Digest actionDigest)
                                  throws IOException

Throws:

IOException

materializeInputs

public Optional<Protocol.Command> materializeInputs(Path buildDir,
                                                    Protocol.Digest rootDigest,
                                                    Optional<Protocol.Digest> commandDigest)
                                             throws IOException

Throws:

IOException

getTree

public com.google.common.collect.ImmutableList<Protocol.Directory> getTree(Protocol.Digest rootDigest)
                                                                    throws IOException

Returns a list of all sub directories.

Throws:

IOException

getData

public InputStream getData(Protocol.Digest digest)
                    throws IOException

Looks up some data. Used internally and in tests.

Throws:

IOException

getFileInputStream

public FileInputStream getFileInputStream(Protocol.Digest digest)
                                   throws IOException

Get a file input stream to a Digest

Throws:

IOException

findMissing

public java.util.stream.Stream<Protocol.Digest> findMissing(Iterable<Protocol.Digest> digests)