org.eclipse.jgit.internal.storage.file

Class PackInserter.PackStream

java.lang.Object

java.io.OutputStream

org.eclipse.jgit.internal.storage.file.PackInserter.PackStream

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

Enclosing class:

PackInserter

private class PackInserter.PackStream
extends java.io.OutputStream

Stream that writes to a pack file.

Backed by two views of the same open file descriptor: a random-access file, and an output stream. Seeking in the file causes subsequent writes to the output stream to occur wherever the file pointer is pointing, so we need to take care to always seek to the end of the file before writing a new object.

Callers should always use seek(long) to seek, rather than reaching into the file member. As long as this contract is followed, calls to write(byte[], int, int) are guaranteed to write at the end of the file, even if there have been intermediate seeks.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	atEnd
(package private) java.util.zip.DeflaterOutputStream	compress
(package private) java.util.zip.CRC32	crc32
private java.util.zip.Deflater	deflater
private java.io.RandomAccessFile	file
(package private) byte[]	hdrBuf
private CountingOutputStream	out

Constructor Summary

Constructors

Constructor and Description
PackStream(java.io.File pack)

Method Summary

Modifier and Type	Method and Description
(package private) void	beginObject(int objectType, long length)
void	close()
private int	encodeTypeSize(int type, long rawLength)
(package private) byte[]	finishPack()
(package private) long	getOffset()
(package private) byte[]	inflate(long filePos, int len)
(package private) void	seek(long offset)
private int	setInput(long filePos, java.util.zip.Inflater inf, byte[] buf)
void	write(byte[] data, int off, int len)
void	write(int b)

Methods inherited from class java.io.OutputStream

flush, write

Methods inherited from class java.lang.Object

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

Field Detail

hdrBuf

final byte[] hdrBuf

crc32

final java.util.zip.CRC32 crc32

compress

final java.util.zip.DeflaterOutputStream compress

file

private final java.io.RandomAccessFile file

out

private final CountingOutputStream out

deflater

private final java.util.zip.Deflater deflater

atEnd

private boolean atEnd

Constructor Detail

PackStream

PackStream(java.io.File pack)
    throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getOffset

long getOffset()

seek

void seek(long offset)
   throws java.io.IOException

Throws:

java.io.IOException

beginObject

void beginObject(int objectType,
                 long length)
          throws java.io.IOException

Throws:

java.io.IOException

encodeTypeSize

private int encodeTypeSize(int type,
                           long rawLength)

write

public void write(int b)
           throws java.io.IOException

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

write

public void write(byte[] data,
                  int off,
                  int len)
           throws java.io.IOException

Overrides:

write in class java.io.OutputStream

Throws:

java.io.IOException

finishPack

byte[] finishPack()
           throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.OutputStream

Throws:

java.io.IOException

inflate

byte[] inflate(long filePos,
               int len)
        throws java.io.IOException,
               java.util.zip.DataFormatException

Throws:

java.io.IOException

java.util.zip.DataFormatException

setInput

private int setInput(long filePos,
                     java.util.zip.Inflater inf,
                     byte[] buf)
              throws java.io.IOException

Throws:

java.io.IOException