Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
7ab5361
SDK-571: enhance LargeFileUploader to support resumable MPU.
xiaoxin-ren Nov 18, 2021
eb57a1d
Add resumeSafeguard to avoid MPU resume from stale parts.
xiaoxin-ren Feb 25, 2022
88fe0c7
* Updated LFU to support new extensible multi-part source (with File …
Mar 8, 2022
d034ecf
updated build plugin versions (git-publish -> 3.0.1, release -> 15.3.…
Mar 8, 2022
b0acfed
ObjectConfig.connectTimeout should now be effective for the apache (d…
Mar 8, 2022
c4593b7
Merge pull request #75 from EMCECS/feature-SDK-571-updates-from-stu
xiaoxin-ren Mar 9, 2022
ad1e747
Merge branch 'master' into feature-SDK-571-resumable-mpu-new-branch
Mar 9, 2022
010b822
Add test for MPU resume from LargeFileMultipartSource.
xiaoxin-ren Mar 11, 2022
96fb8ac
LFU: detect if an external ExecutorService is specified and do not sh…
Mar 9, 2022
94cfe3c
LFU: isolated S3 client calls to support extension
Mar 18, 2022
6d0f0d0
Merge pull request #78 from EMCECS/feature-SDK-571-updates-from-stu
xiaoxin-ren Mar 18, 2022
248e79d
add x-emc-copy-mode into headers
dunedodo Mar 9, 2022
fd6e63a
Refine test case testResumeMpuFromMultiPartSource().
xiaoxin-ren Apr 4, 2022
045f467
* updates to LFU logic: removed uploadId locator logic (determined to…
Apr 4, 2022
a7aea1a
LFU: fixed bug in resume logic
Apr 5, 2022
b6a0965
Added new general option to abort MPU on any failure (default true)
xiaoxin-ren Apr 6, 2022
a2738d3
Added more test cases for MPU Resume.
xiaoxin-ren Apr 7, 2022
88997ee
LFU: added support for calling asynchronously, with ability to pause …
Apr 7, 2022
38b8ea4
LFU: changes from PR
Apr 8, 2022
8c31eaa
Merge pull request #81 from EMCECS/feature-SDK-571-resumable-mpu-work…
twincitiesguy Apr 8, 2022
ff5bdc0
Merge pull request #82 from EMCECS/feature-lfu-async
twincitiesguy Apr 8, 2022
0ce3d84
LFU:
Apr 8, 2022
46dbef5
added version-id to CompleteMultipartUploadResult
Apr 11, 2022
bc8afd1
LFU:
Apr 11, 2022
21340d1
LFU: added tests for pause and abort
Apr 11, 2022
59c3c55
updated LFU class comment to accurately describe result of a failure
Apr 13, 2022
e19c64c
* changed S3JerseyClientTest.testTimeouts() to set timeouts directly …
Apr 13, 2022
467f393
Merge branch 'master' into feature-SDK-571-resumable-mpu-new-branch
twincitiesguy Apr 13, 2022
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ plugins {
id 'signing'
id 'maven'
id 'org.ajoberstar.git-publish' version '3.0.1'
id 'nebula.release' version '15.2.0'
id 'nebula.release' version '15.3.1'
}

group 'com.emc.ecs'
Expand Down Expand Up @@ -271,4 +271,4 @@ gradle.taskGraph.whenReady { taskGraph ->
System.setProperty('org.ajoberstar.grgit.auth.username', rootProject.ext.gitUsername)
System.setProperty('org.ajoberstar.grgit.auth.password', rootProject.ext.gitPassword)
}
}
}
15 changes: 12 additions & 3 deletions src/main/java/com/emc/object/ObjectConfig.java
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@
import com.emc.rest.smart.SmartConfig;
import com.emc.rest.smart.ecs.Vdc;
import com.sun.jersey.api.client.config.ClientConfig;
import org.apache.http.params.CoreConnectionPNames;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down Expand Up @@ -211,6 +212,8 @@ public SmartConfig toSmartConfig() {

// CONNECT_TIMEOUT
smartConfig.setProperty(ClientConfig.PROPERTY_CONNECT_TIMEOUT, connectTimeout);
// apache client uses a different property
smartConfig.setProperty(CoreConnectionPNames.CONNECTION_TIMEOUT, connectTimeout);

// READ_TIMEOUT
smartConfig.setProperty(ClientConfig.PROPERTY_READ_TIMEOUT, readTimeout);
Expand Down Expand Up @@ -430,21 +433,27 @@ public int getConnectTimeout() {
return connectTimeout;
}

public void setConnectTimeout(int connectTimeout) {this.connectTimeout = connectTimeout; }
public void setConnectTimeout(int connectTimeout) {
this.connectTimeout = connectTimeout;
}

@ConfigUriProperty
public int getReadTimeout() {
return readTimeout;
}

public void setReadTimeout(int readTimeout) {this.readTimeout = readTimeout; }
public void setReadTimeout(int readTimeout) {
this.readTimeout = readTimeout;
}

@ConfigUriProperty
public String getSessionToken() {
return sessionToken;
}

public void setSessionToken(String sessionToken) {this.sessionToken = sessionToken; }
public void setSessionToken(String sessionToken) {
this.sessionToken = sessionToken;
}

@ConfigUriProperty(converter = ConfigUri.StringPropertyConverter.class)
public Map<String, Object> getProperties() {
Expand Down
Loading