Package org.tmatesoft.svn.core.internal.io.fs

Class FSOutputStream

java.lang.Object

java.io.OutputStream

org.tmatesoft.svn.core.internal.io.fs.FSOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, ISVNDeltaConsumer

public class FSOutputStream
extends OutputStream
implements ISVNDeltaConsumer

Version:

1.3

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	isHeaderWritten
private SVNDeltaGenerator	myDeltaGenerator
private long	myDeltaStart
private boolean	myIsClosed
private boolean	myIsCompress
private MessageDigest	myMD5Digest
private long	myRepOffset
private long	myRepSize
private FSRevisionNode	myRevNode
private MessageDigest	mySHA1Digest
private long	mySourceOffset
private InputStream	mySourceStream
private File	myTargetFile
private CountingOutputStream	myTargetFileOS
private ByteArrayOutputStream	myTextBuffer
private FSWriteLock	myTxnLock
private FSTransactionRoot	myTxnRoot
static final int	SVN_DELTA_WINDOW_SIZE
static final int	WRITE_BUFFER_SIZE

Constructor Summary

Constructors

Modifier	Constructor	Description
private	FSOutputStream(FSRevisionNode revNode, CountingOutputStream targetFileOS, File targetFile, InputStream source, long deltaStart, long repSize, long repOffset, FSTransactionRoot txnRoot, boolean compress, FSWriteLock txnLock)

Method Summary

Modifier and Type	Method	Description
void	applyTextDelta(String path, String baseChecksum)	Starts applying text delta(s) to an opened file.
private void	checkRepresentation(FSFS fsfs, FSRepresentation representation, Object hint)
void	close()
void	closeStreams()
static OutputStream	createStream(FSRevisionNode revNode, FSTransactionRoot txnRoot, OutputStream dstStream, boolean compress)
FSRevisionNode	getRevisionNode()
private FSRepresentation	getSharedRepresentation(FSFS fsfs, FSRepresentation representation, Map<String,FSRepresentation> representationsMap)
private FSP2LEntry	lookupEntry(List<FSP2LEntry> entries, long offset, Object hint)
private FSP2LEntry	lookupP2LEntry(FSFile revFile, long revision, long offset)
private static File	pathTxnSha1(FSFS fsfs, FSRepresentation representation, String txnId)
private void	reset(FSRevisionNode revNode, CountingOutputStream targetFileOS, File targetFile, InputStream source, long deltaStart, long repSize, long repOffset, FSTransactionRoot txnRoot, FSWriteLock txnLock)
private static void	storeSha1RepMapping(FSFS fsfs, FSRepresentation representation)
OutputStream	textDeltaChunk(String path, SVNDiffWindow diffWindow)	Collects a next delta chunk.
void	textDeltaEnd(String path)	Finalizes collecting text delta(s).
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.io.OutputStream

flush, nullOutputStream

Methods inherited from class java.lang.Object

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

Field Details

SVN_DELTA_WINDOW_SIZE

public static final int SVN_DELTA_WINDOW_SIZE

See Also:

• Constant Field Values

WRITE_BUFFER_SIZE

public static final int WRITE_BUFFER_SIZE

See Also:

• Constant Field Values

isHeaderWritten

private boolean isHeaderWritten

myTargetFileOS

private CountingOutputStream myTargetFileOS

myTargetFile

private File myTargetFile

myDeltaStart

private long myDeltaStart

myRepSize

private long myRepSize

myRepOffset

private long myRepOffset

mySourceStream

private InputStream mySourceStream

myDeltaGenerator

private SVNDeltaGenerator myDeltaGenerator

myRevNode

private FSRevisionNode myRevNode

myMD5Digest

private MessageDigest myMD5Digest

mySHA1Digest

private MessageDigest mySHA1Digest

myTxnRoot

private FSTransactionRoot myTxnRoot

mySourceOffset

private long mySourceOffset

myTextBuffer

private ByteArrayOutputStream myTextBuffer

myIsClosed

private boolean myIsClosed

myIsCompress

private boolean myIsCompress

myTxnLock

private FSWriteLock myTxnLock

Constructor Details

FSOutputStream

private FSOutputStream(FSRevisionNode revNode,
 CountingOutputStream targetFileOS,
 File targetFile,
 InputStream source,
 long deltaStart,
 long repSize,
 long repOffset,
 FSTransactionRoot txnRoot,
 boolean compress,
 FSWriteLock txnLock)
                throws SVNException

Throws:

SVNException

Method Details

reset

private void reset(FSRevisionNode revNode,
 CountingOutputStream targetFileOS,
 File targetFile,
 InputStream source,
 long deltaStart,
 long repSize,
 long repOffset,
 FSTransactionRoot txnRoot,
 FSWriteLock txnLock)

createStream

public static OutputStream createStream(FSRevisionNode revNode,
 FSTransactionRoot txnRoot,
 OutputStream dstStream,
 boolean compress)
                                 throws SVNException

Throws:

SVNException

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b,
 int off,
 int len)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException

closeStreams

public void closeStreams()
                  throws IOException

Throws:

IOException

getRevisionNode

public FSRevisionNode getRevisionNode()

textDeltaChunk

public OutputStream textDeltaChunk(String path,
 SVNDiffWindow diffWindow)
                            throws SVNException

Description copied from interface: ISVNDeltaConsumer

Collects a next delta chunk. The return type is nomore relevant and is left only for backward compatibility. So, the return value may be just null. Otherwise if it's not null, the stream will be immediately closed.

If there are more than one windows for the file, this method is called several times.

Specified by:

textDeltaChunk in interface ISVNDeltaConsumer

Parameters:

path - a file path relative to the edit root directory

diffWindow - a next diff window

Returns:

an output stream

Throws:

SVNException

textDeltaEnd

public void textDeltaEnd(String path)
                  throws SVNException

Description copied from interface: ISVNDeltaConsumer

Finalizes collecting text delta(s).

Specified by:

textDeltaEnd in interface ISVNDeltaConsumer

Parameters:

path - a file path relative to the edit root directory

Throws:

SVNException

applyTextDelta

public void applyTextDelta(String path,
 String baseChecksum)
                    throws SVNException

Description copied from interface: ISVNDeltaConsumer

Starts applying text delta(s) to an opened file.

Specified by:

applyTextDelta in interface ISVNDeltaConsumer

Parameters:

path - a file path relative to the edit root directory

baseChecksum - an MD5 checksum for the base file contents (before the file is changed)

Throws:

SVNException - if the calculated base file checksum didn't match the expected baseChecksum

getSharedRepresentation

private FSRepresentation getSharedRepresentation(FSFS fsfs,
 FSRepresentation representation,
 Map<String,FSRepresentation> representationsMap)
                                          throws SVNException

Throws:

SVNException

checkRepresentation

private void checkRepresentation(FSFS fsfs,
 FSRepresentation representation,
 Object hint)
                          throws SVNException

Throws:

SVNException

lookupP2LEntry

private FSP2LEntry lookupP2LEntry(FSFile revFile,
 long revision,
 long offset)
                           throws SVNException

Throws:

SVNException

lookupEntry

private FSP2LEntry lookupEntry(List<FSP2LEntry> entries,
 long offset,
 Object hint)

storeSha1RepMapping

private static void storeSha1RepMapping(FSFS fsfs,
 FSRepresentation representation)
                                 throws SVNException

Throws:

SVNException

pathTxnSha1

private static File pathTxnSha1(FSFS fsfs,
 FSRepresentation representation,
 String txnId)