Class DfsInserter
- All Implemented Interfaces:
AutoCloseable
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate classprivate final classprivate classprivate classNested classes/interfaces inherited from class org.eclipse.jgit.lib.ObjectInserter
ObjectInserter.Filter, ObjectInserter.Formatter -
Field Summary
FieldsModifier and TypeFieldDescription(package private) DfsBlockCacheprivate boolean(package private) int(package private) final DfsObjDatabaseprivate static final intAlways produce version 2 indexes, to get CRC data.(package private) List<PackedObjectInfo>(package private) ObjectIdOwnerMap<PackedObjectInfo>(package private) DfsPackDescription(package private) DfsStreamKey(package private) DfsInserter.PackStreamprivate boolean -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedInitialize a new inserter. -
Method Summary
Modifier and TypeMethodDescriptionprivate longbeginObject(int type, long len) private voidvoidcheckExisting(boolean check) Check existenceprivate voidclear()voidclose()private ObjectIdvoidflush()Make all inserted objects visible.private static voidindex(OutputStream out, byte[] packHash, List<PackedObjectInfo> list) insert(int type, byte[] data, int off, int len) Insert a single object into the store, returning its unique name.insert(int type, long len, InputStream in) Insert a single object into the store, returning its unique name.private byte[]insertBuffer(long len) private TemporaryBuffer.HeapInitialize a parser to read from a pack formatted stream.Open a reader for objects that may have been written by this inserter.(package private) voidsetCompressionLevel(int compression) private void(package private) PackIndexwritePackIndex(DfsPackDescription pack, byte[] packHash, List<PackedObjectInfo> list)
-
Field Details
-
INDEX_VERSION
private static final int INDEX_VERSIONAlways produce version 2 indexes, to get CRC data.- See Also:
-
db
-
compression
int compression -
objectList
List<PackedObjectInfo> objectList -
objectMap
ObjectIdOwnerMap<PackedObjectInfo> objectMap -
cache
DfsBlockCache cache -
packKey
DfsStreamKey packKey -
packDsc
DfsPackDescription packDsc -
packOut
DfsInserter.PackStream packOut -
rollback
private boolean rollback -
checkExisting
private boolean checkExisting
-
-
Constructor Details
-
DfsInserter
Initialize a new inserter.- Parameters:
db- database the inserter writes to.
-
-
Method Details
-
checkExisting
public void checkExisting(boolean check) Check existence- Parameters:
check- iffalse, will write out possibly-duplicate objects without first checking whether they exist in the repo; default is true.
-
setCompressionLevel
void setCompressionLevel(int compression) -
newPackParser
Initialize a parser to read from a pack formatted stream.- Specified by:
newPackParserin classObjectInserter- Parameters:
in- the input stream. The stream is not closed by the parser, and must instead be closed by the caller once parsing is complete.- Returns:
- the pack parser.
- Throws:
IOException- the parser instance, which can be configured and then used to parse objects into the ObjectDatabase.
-
newReader
Open a reader for objects that may have been written by this inserter.The returned reader allows the calling thread to read back recently inserted objects without first calling
flush()to make them visible to the repository. The returned reader should only be used from the same thread as the inserter. Objects written by this inserter may not be visible tothis.newReader().newReader().The returned reader should return this inserter instance from
ObjectReader.getCreatedFromInserter().Behavior is undefined if an insert method is called on the inserter in the middle of reading from an
ObjectStreamopened from this reader. For example, reading the remainder of the object may fail, or newly written data may even be corrupted. Interleaving whole object reads (including streaming reads) with inserts is fine, just not interleaving streaming partial object reads with inserts.- Specified by:
newReaderin classObjectInserter- Returns:
- reader for any object, including an object recently inserted by this inserter since the last flush.
-
insert
Insert a single object into the store, returning its unique name.- Overrides:
insertin classObjectInserter- Parameters:
type- type code of the object to store.data- complete content of the object.off- first position withindata.len- number of bytes to copy fromdata.- Returns:
- the name of the object.
- Throws:
IOException- the object could not be stored.
-
insert
Insert a single object into the store, returning its unique name.- Specified by:
insertin classObjectInserter- Parameters:
type- type code of the object to store.len- number of bytes to copy fromin.in- stream providing the object content. The caller is responsible for closing the stream.- Returns:
- the name of the object.
- Throws:
IOException- the object could not be stored, or the source stream could not be read.
-
insertBuffer
private byte[] insertBuffer(long len) -
flush
Make all inserted objects visible.The flush may take some period of time to make the objects available to other threads.
- Specified by:
flushin classObjectInserter- Throws:
IOException- the flush could not be completed; objects inserted thus far are in an indeterminate state.
-
close
public void close()Release any resources used by this inserter.
An inserter that has been released can be used again, but may need to be released after the subsequent usage.
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein classObjectInserter
-
clear
private void clear() -
beginObject
- Throws:
IOException
-
endObject
-
beginPack
- Throws:
IOException
-
sortObjectsById
private void sortObjectsById() -
maybeGetTemporaryBuffer
-
writePackIndex
PackIndex writePackIndex(DfsPackDescription pack, byte[] packHash, List<PackedObjectInfo> list) throws IOException - Throws:
IOException
-
index
private static void index(OutputStream out, byte[] packHash, List<PackedObjectInfo> list) throws IOException - Throws:
IOException
-