Class TransportBundleStream
- java.lang.Object
-
- org.eclipse.jgit.transport.Transport
-
- org.eclipse.jgit.transport.TransportBundleStream
-
- All Implemented Interfaces:
AutoCloseable
,PackTransport
,TransportBundle
public class TransportBundleStream extends Transport implements TransportBundle
Single shot fetch from a streamed Git bundle.The bundle is read from an unbuffered input stream, which limits the transport to opening at most one FetchConnection before needing to recreate the transport instance.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.eclipse.jgit.transport.Transport
Transport.Operation
-
-
Field Summary
-
Fields inherited from class org.eclipse.jgit.transport.Transport
DEFAULT_FETCH_THIN, DEFAULT_PUSH_THIN, local, REFSPEC_PUSH_ALL, REFSPEC_TAGS, uri
-
Fields inherited from interface org.eclipse.jgit.transport.TransportBundle
V2_BUNDLE_SIGNATURE
-
-
Constructor Summary
Constructors Constructor Description TransportBundleStream(Repository db, URIish uri, InputStream in)
Create a new transport to fetch objects from a streamed bundle.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
FetchConnection
openFetch()
Begins a new connection for fetching from the remote repository.PushConnection
openPush()
Begins a new connection for pushing into the remote repository.-
Methods inherited from class org.eclipse.jgit.transport.Transport
applyConfig, fetch, fetch, findRemoteRefUpdatesFor, findRemoteRefUpdatesFor, findRemoteRefUpdatesFor, findRemoteRefUpdatesFor, getCredentialsProvider, getDeepenNots, getDeepenSince, getDepth, getFilterBlobLimit, getFilterSpec, getObjectChecker, getOptionReceivePack, getOptionUploadPack, getPackConfig, getPushOptions, getTagOpt, getTimeout, getTransportProtocols, getURI, isCheckFetchedObjects, isDryRun, isFetchThin, isPushAtomic, isPushThin, isRemoveDeletedRefs, open, open, open, open, open, open, open, openAll, openAll, openAll, openAll, openFetch, push, push, register, setCheckFetchedObjects, setCredentialsProvider, setDeepenNots, setDeepenSince, setDepth, setDepth, setDryRun, setFetchThin, setFilterBlobLimit, setFilterSpec, setObjectChecker, setOptionReceivePack, setOptionUploadPack, setPackConfig, setPushAtomic, setPushOptions, setPushThin, setRemoveDeletedRefs, setTagOpt, setTimeout, unregister
-
-
-
-
Constructor Detail
-
TransportBundleStream
public TransportBundleStream(Repository db, URIish uri, InputStream in)
Create a new transport to fetch objects from a streamed bundle.The stream can be unbuffered (buffering is automatically provided internally to smooth out short reads) and unpositionable (the stream is read from only once, sequentially).
When the FetchConnection or the this instance is closed the supplied input stream is also automatically closed. This frees callers from needing to keep track of the supplied stream.
- Parameters:
db
- repository the fetched objects will be loaded into.uri
- symbolic name of the source of the stream. The URI can reference a non-existent resource. It is used only for exception reporting.in
- the stream to read the bundle from.
-
-
Method Detail
-
openFetch
public FetchConnection openFetch() throws TransportException
Begins a new connection for fetching from the remote repository.If the transport has no local repository, the fetch connection can only be used for reading remote refs.
- Specified by:
openFetch
in classTransport
- Returns:
- a fresh connection to fetch from the remote repository.
- Throws:
TransportException
- the remote connection could not be established.
-
openPush
public PushConnection openPush() throws NotSupportedException
Begins a new connection for pushing into the remote repository.- Specified by:
openPush
in classTransport
- Returns:
- a fresh connection to push into the remote repository.
- Throws:
NotSupportedException
- the implementation does not support pushing.
-
close
public void close()
Close any resources used by this transport.
If the remote repository is contacted by a network socket this method must close that network socket, disconnecting the two peers. If the remote repository is actually local (same system) this method must close any open file handles used to read the "remote" repository.
AutoClosable.close()
declares that it throwsException
. Implementers shouldn't throw checked exceptions. This override narrows the signature to prevent them from doing so.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in classTransport
-
-