public class DfsInserter extends ObjectInserter
ObjectInserter.Filter, ObjectInserter.Formatter| Modifier | Constructor and Description |
|---|---|
protected |
DfsInserter(DfsObjDatabase db)
Initialize a new inserter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
checkExisting(boolean check)
Check existence
|
void |
close() |
void |
flush()
Make all inserted objects visible.
|
ObjectId |
insert(int type,
byte[] data,
int off,
int len)
Insert a single object into the store, returning its unique name.
|
ObjectId |
insert(int type,
long len,
InputStream in)
Insert a single object into the store, returning its unique name.
|
DfsPackParser |
newPackParser(InputStream in)
Initialize a parser to read from a pack formatted stream.
|
ObjectReader |
newReader()
Open a reader for objects that may have been written by this inserter.
|
protected DfsInserter(DfsObjDatabase db)
db - database the inserter writes to.public void checkExisting(boolean check)
check - if false, will write out possibly-duplicate objects
without first checking whether they exist in the repo; default
is true.public DfsPackParser newPackParser(InputStream in) throws IOException
newPackParser in class ObjectInserterin - the input stream. The stream is not closed by the parser, and
must instead be closed by the caller once parsing is complete.IOException - the parser instance, which can be configured and then used to
parse objects into the ObjectDatabase.public ObjectReader newReader()
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 to this.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 ObjectStream opened 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.
newReader in class ObjectInserterpublic ObjectId insert(int type, byte[] data, int off, int len) throws IOException
insert in class ObjectInsertertype - type code of the object to store.data - complete content of the object.off - first position within data.len - number of bytes to copy from data.IOException - the object could not be stored.public ObjectId insert(int type, long len, InputStream in) throws IOException
insert in class ObjectInsertertype - type code of the object to store.len - number of bytes to copy from in.in - stream providing the object content. The caller is responsible
for closing the stream.IOException - the object could not be stored, or the source stream could
not be read.public void flush()
throws IOException
The flush may take some period of time to make the objects available to other threads.
flush in class ObjectInserterIOException - the flush could not be completed; objects inserted thus far
are in an indeterminate state.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.
close in interface AutoCloseableclose in class ObjectInserterCopyright © 2019 Eclipse JGit Project. All rights reserved.