hazza/DSpace
1
0
Fork 0
mirror of https://github.com/DSpace/DSpace.git synced 2025-10-17 15:03:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

94474: Transfer manger should be class wide

Browse Source
This commit is contained in:
Jens Vannerum
2022-09-20 15:19:19 +02:00
parent 5ae5398b99
commit 74b56d6fe1
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
dspace-api/src/main/java/org/dspace/storage/bitstore/S3BitStoreService.java
View File

@@ -75,6 +75,12 @@ public class S3BitStoreService implements BitStoreService {
*/ */
private AmazonS3 s3Service = null; private AmazonS3 s3Service = null;
/**
* S3 transfer manager
* this is reused between put calls to use less resources for multiple uploads
*/
private TransferManager tm = null;
private static final ConfigurationService configurationService private static final ConfigurationService configurationService
= DSpaceServicesFactory.getInstance().getConfigurationService(); = DSpaceServicesFactory.getInstance().getConfigurationService();
public S3BitStoreService() { public S3BitStoreService() {
@@ -128,6 +134,11 @@ public class S3BitStoreService implements BitStoreService {
} }
log.info("AWS S3 Assetstore ready to go! bucket:" + bucketName); log.info("AWS S3 Assetstore ready to go! bucket:" + bucketName);
tm = TransferManagerBuilder.standard()
.withAlwaysCalculateMultipartMd5(true)
.withS3Client(s3Service)
.build();
} }
@@ -184,12 +195,6 @@ public class S3BitStoreService implements BitStoreService {
// Therefore, we precalculate before uploading // Therefore, we precalculate before uploading
String localChecksum = org.dspace.curate.Utils.checksum(scratchFile, CSA); String localChecksum = org.dspace.curate.Utils.checksum(scratchFile, CSA);
TransferManager tm = TransferManagerBuilder.standard()
.withAlwaysCalculateMultipartMd5(true)
.withS3Client(s3Service)
.build();
Upload upload = tm.upload(bucketName, key, scratchFile); Upload upload = tm.upload(bucketName, key, scratchFile);
upload.waitForUploadResult(); upload.waitForUploadResult();