Class TransferThread
java.lang.Object
fr.gouv.vitam.storage.engine.server.distribution.impl.TransferThread
- All Implemented Interfaces:
Callable<ThreadResponseData>
Thread Future used to send stream to one offer
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionTransferThread
(int tenantId, String requestId, Driver driver, OfferReference offerReference, StoragePutRequest request, Digest globalDigest, long size) Default constructorTransferThread
(int tenantId, String requestId, Driver driver, OfferReference offerReference, StoragePutRequest request, Digest globalDigest, long size, StorageOfferProvider offerProvider) -
Method Summary
Modifier and TypeMethodDescriptioncall()
static void
setJunitMode
(boolean mode) Allow to check timeout in Junit
-
Field Details
-
TIMEOUT_TEST
- See Also:
-
-
Constructor Details
-
TransferThread
public TransferThread(int tenantId, String requestId, Driver driver, OfferReference offerReference, StoragePutRequest request, Digest globalDigest, long size) Default constructor- Parameters:
tenantId
-requestId
-driver
- thre diverofferReference
- the offer reference to put objectrequest
- the request to put objectglobalDigest
- the globalDigest associated with the stream
-
TransferThread
public TransferThread(int tenantId, String requestId, Driver driver, OfferReference offerReference, StoragePutRequest request, Digest globalDigest, long size, StorageOfferProvider offerProvider)
-
-
Method Details
-
setJunitMode
public static void setJunitMode(boolean mode) Allow to check timeout in Junit- Parameters:
mode
- if true allow to implement timeout using GUID to "timeoutTest"
-
call
public ThreadResponseData call() throws StorageException, StorageDriverException, InterruptedException- Specified by:
call
in interfaceCallable<ThreadResponseData>
- Throws:
StorageException
StorageDriverException
InterruptedException
-