Package aQute.libg.cafs

Class CAFS

java.lang.Object

aQute.libg.cafs.CAFS

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<SHA1>

public class CAFS
extends Object
implements Closeable, Iterable<SHA1>

CAFS implements a SHA-1 based file store. The basic idea is that every file in the universe has a unique SHA-1. Hard to believe but people smarter than me have come to that conclusion. This class maintains a compressed store of SHA-1 identified files. So if you have the SHA-1, you can get the contents. This makes it easy to store a SHA-1 instead of the whole file or maintain a naming scheme. An added advantage is that it is always easy to verify you get the right stuff. The SHA-1 Content Addressable File Store is the core underlying idea in Git.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final String	ALGORITHM
(package private) static final byte[]	CAFE
(package private) static final byte[]	CAFS
(package private) FileChannel	channel
(package private) static final int	HEADERLENGTH
(package private) final File	home
(package private) Index	index
(package private) static final String	INDEXFILE
(package private) static final int	KEYLENGTH
(package private) RandomAccessFile	store
(package private) static final String	STOREFILE

Constructor Summary

Constructors

Constructor	Description
CAFS(File home, boolean create)	Constructor for a Content Addressable File Store

Method Summary

Modifier and Type	Method	Description
(package private) short	checksum(int flags, int compressedLength, int totalLength, byte[] sha1)
void	close()
boolean	exists(byte[] sha1)
private InputStream	getSha1Stream(SHA1 sha1, byte[] buffer, int total)
boolean	isEmpty()
Iterator<SHA1>	iterator()
InputStream	read(SHA1 sha1)	Read the contents of a sha 1 key.
void	reindex()
private void	update(byte[] sha1, byte[] compressed, int totalLength)	Update a record in the store, assuming the store is at the right position.
private SHA1	verifyEntry(RandomAccessFile in)
private boolean	verifySignature(DataInput din, byte[] org)
SHA1	write(InputStream in)	Store an input stream in the CAFS while calculating and returning the SHA-1 code.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

CAFS

static final byte[] CAFS

CAFE

static final byte[] CAFE

INDEXFILE

static final String INDEXFILE

See Also:

• Constant Field Values

STOREFILE

static final String STOREFILE

See Also:

• Constant Field Values

ALGORITHM

static final String ALGORITHM

See Also:

• Constant Field Values

KEYLENGTH

static final int KEYLENGTH

See Also:

• Constant Field Values

HEADERLENGTH

static final int HEADERLENGTH

See Also:

• Constant Field Values

home

final File home

index

Index index

store

RandomAccessFile store

channel

FileChannel channel

Constructor Details

CAFS

public CAFS(File home,
 boolean create)
     throws Exception

Constructor for a Content Addressable File Store

Parameters:

home -

create -

Throws:

Exception

Method Details

write

public SHA1 write(InputStream in)
           throws Exception

Store an input stream in the CAFS while calculating and returning the SHA-1 code.

Parameters:

in - The input stream to store.

Returns:

The SHA-1 code.

Throws:

Exception - if anything goes wrong

read

public InputStream read(SHA1 sha1)
                 throws Exception

Read the contents of a sha 1 key.

Parameters:

sha1 - The key

Returns:

An Input Stream on the content or null of key not found

Throws:

Exception

exists

public boolean exists(byte[] sha1)
               throws Exception

Throws:

Exception

reindex

public void reindex()
             throws Exception

Throws:

Exception

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

verifyEntry

private SHA1 verifyEntry(RandomAccessFile in)
                  throws IOException,
NoSuchAlgorithmException

Throws:

IOException

NoSuchAlgorithmException

verifySignature

private boolean verifySignature(DataInput din,
 byte[] org)
                         throws IOException

Throws:

IOException

getSha1Stream

private InputStream getSha1Stream(SHA1 sha1,
 byte[] buffer,
 int total)
                           throws NoSuchAlgorithmException

Throws:

NoSuchAlgorithmException

update

private void update(byte[] sha1,
 byte[] compressed,
 int totalLength)
             throws IOException

Update a record in the store, assuming the store is at the right position.

Parameters:

sha1 - The checksum

compressed - The compressed length

totalLength - The uncompressed length

Throws:

IOException - The exception

checksum

short checksum(int flags,
 int compressedLength,
 int totalLength,
 byte[] sha1)

iterator

public Iterator<SHA1> iterator()

Specified by:

iterator in interface Iterable<SHA1>

isEmpty

public boolean isEmpty()
                throws IOException

Throws:

IOException