Skip to content

Check status prior submitting parts. #17124

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
May 26, 2025
Merged

Check status prior submitting parts. #17124

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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: 3 additions & 1 deletion backblaze/src/main/java/ch/cyberduck/core/b2/B2LargeUploadService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import ch.cyberduck.core.ProgressListener;
import ch.cyberduck.core.concurrency.Interruptibles;
import ch.cyberduck.core.exception.BackgroundException;
import ch.cyberduck.core.exception.ConnectionCanceledException;
import ch.cyberduck.core.features.Upload;
import ch.cyberduck.core.features.Write;
import ch.cyberduck.core.http.HttpUploadFeature;
Expand Down Expand Up @@ -215,7 +216,8 @@ private Future<B2UploadPartResponse> submit(final ThreadPool pool, final Path fi
final BandwidthThrottle throttle, final StreamListener listener,
final TransferStatus overall,
final String fileId, final int partNumber,
final Long offset, final Long length, final ConnectionCallback callback) {
final Long offset, final Long length, final ConnectionCallback callback) throws ConnectionCanceledException {
overall.validate();
log.info("Submit part {} of {} to queue with offset {} and length {}", partNumber, file, offset, length);
final BytecountStreamListener counter = new BytecountStreamListener(listener);
return pool.execute(new SegmentRetryCallable<>(session.getHost(), new BackgroundExceptionCallable<B2UploadPartResponse>() {
Expand Down
4 changes: 3 additions & 1 deletion brick/src/main/java/ch/cyberduck/core/brick/BrickUploadFeature.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@
import ch.cyberduck.core.brick.io.swagger.client.model.FilesPathBody;
import ch.cyberduck.core.concurrency.Interruptibles;
import ch.cyberduck.core.exception.BackgroundException;
import ch.cyberduck.core.exception.ConnectionCanceledException;
import ch.cyberduck.core.exception.NotfoundException;
import ch.cyberduck.core.features.Write;
import ch.cyberduck.core.http.HttpUploadFeature;
Expand Down Expand Up @@ -154,7 +155,8 @@ protected FileEntity completeUpload(final Path file, final String ref, final Tra
private Future<TransferStatus> submit(final ThreadPool pool, final Path file, final Local local,
final BandwidthThrottle throttle, final StreamListener listener,
final TransferStatus overall, final String url, final Integer partNumber,
final long offset, final long length, final ConnectionCallback callback) {
final long offset, final long length, final ConnectionCallback callback) throws ConnectionCanceledException {
overall.validate();
log.info("Submit part {} of {} to queue with offset {} and length {}", partNumber, file, offset, length);
final BytecountStreamListener counter = new BytecountStreamListener(listener);
return pool.execute(new SegmentRetryCallable<>(session.getHost(), new BackgroundExceptionCallable<TransferStatus>() {
Expand Down
4 changes: 3 additions & 1 deletion dracoon/src/main/java/ch/cyberduck/core/sds/SDSDirectS3UploadFeature.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import ch.cyberduck.core.UUIDRandomStringService;
import ch.cyberduck.core.concurrency.Interruptibles;
import ch.cyberduck.core.exception.BackgroundException;
import ch.cyberduck.core.exception.ConnectionCanceledException;
import ch.cyberduck.core.features.Write;
import ch.cyberduck.core.http.HttpUploadFeature;
import ch.cyberduck.core.io.BandwidthThrottle;
Expand Down Expand Up @@ -237,7 +238,8 @@ private List<PresignedUrl> retrievePresignedUrls(final CreateFileUploadResponse
private Future<TransferStatus> submit(final ThreadPool pool, final Path file, final Local local,
final Buffer buffer, final BandwidthThrottle throttle, final StreamListener listener,
final TransferStatus overall, final String url, final Integer partNumber,
final long offset, final long length, final ConnectionCallback callback) {
final long offset, final long length, final ConnectionCallback callback) throws ConnectionCanceledException {
overall.validate();
log.info("Submit part {} of {} to queue with offset {} and length {}", partNumber, file, offset, length);
final BytecountStreamListener counter = new BytecountStreamListener(listener);
return pool.execute(new SegmentRetryCallable<>(session.getHost(), new BackgroundExceptionCallable<TransferStatus>() {
Expand Down
4 changes: 3 additions & 1 deletion eue/src/main/java/ch/cyberduck/core/eue/EueLargeUploadService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@
import ch.cyberduck.core.eue.io.swagger.client.model.UploadType;
import ch.cyberduck.core.exception.BackgroundException;
import ch.cyberduck.core.exception.ChecksumException;
import ch.cyberduck.core.exception.ConnectionCanceledException;
import ch.cyberduck.core.features.Upload;
import ch.cyberduck.core.features.Write;
import ch.cyberduck.core.http.HttpUploadFeature;
Expand Down Expand Up @@ -152,7 +153,8 @@ public EueWriteFeature.Chunk upload(final Path file, final Local local, final Ba
private Future<EueWriteFeature.Chunk> submit(final ThreadPool pool, final Path file, final Local local,
final BandwidthThrottle throttle, final StreamListener listener,
final TransferStatus overall, final String url, final String resourceId,
final int partNumber, final long offset, final long length, final ConnectionCallback callback) {
final int partNumber, final long offset, final long length, final ConnectionCallback callback) throws ConnectionCanceledException {
overall.validate();
log.info("Submit {} to queue with offset {} and length {}", file, offset, length);
final BytecountStreamListener counter = new BytecountStreamListener(listener);
return pool.execute(new SegmentRetryCallable<>(session.getHost(), new BackgroundExceptionCallable<EueWriteFeature.Chunk>() {
Expand Down
5 changes: 4 additions & 1 deletion openstack/src/main/java/ch/cyberduck/core/openstack/SwiftLargeObjectUploadFeature.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@
import ch.cyberduck.core.ProgressListener;
import ch.cyberduck.core.concurrency.Interruptibles;
import ch.cyberduck.core.exception.BackgroundException;
import ch.cyberduck.core.exception.ConnectionCanceledException;
import ch.cyberduck.core.exception.NotfoundException;
import ch.cyberduck.core.features.Delete;
import ch.cyberduck.core.features.Upload;
Expand Down Expand Up @@ -196,7 +197,9 @@ public StorageObject upload(final Path file, final Local local,

private Future<StorageObject> submit(final ThreadPool pool, final Path segment, final Local local,
final BandwidthThrottle throttle, final StreamListener listener,
final TransferStatus overall, final Long offset, final Long length, final ConnectionCallback callback) {
final TransferStatus overall, final Long offset, final Long length, final ConnectionCallback callback) throws ConnectionCanceledException {
overall.validate();
log.info("Submit part {} to queue with offset {} and length {}", segment, offset, length);
final BytecountStreamListener counter = new BytecountStreamListener(listener);
return pool.execute(new SegmentRetryCallable<>(session.getHost(), new BackgroundExceptionCallable<StorageObject>() {
@Override
Expand Down
4 changes: 3 additions & 1 deletion s3/src/main/java/ch/cyberduck/core/s3/S3MultipartUploadService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@
import ch.cyberduck.core.exception.AccessDeniedException;
import ch.cyberduck.core.exception.BackgroundException;
import ch.cyberduck.core.exception.ChecksumException;
import ch.cyberduck.core.exception.ConnectionCanceledException;
import ch.cyberduck.core.exception.InteroperabilityException;
import ch.cyberduck.core.features.Upload;
import ch.cyberduck.core.features.Write;
Expand Down Expand Up @@ -212,7 +213,8 @@ public StorageObject upload(final Path file, final Local local, final BandwidthT
private Future<MultipartPart> submit(final ThreadPool pool, final Path file, final Local local,
final BandwidthThrottle throttle, final StreamListener listener,
final TransferStatus overall, final MultipartUpload multipart,
final int partNumber, final long offset, final long length, final ConnectionCallback callback) {
final int partNumber, final long offset, final long length, final ConnectionCallback callback) throws ConnectionCanceledException {
overall.validate();
log.info("Submit part {} of {} to queue with offset {} and length {}", partNumber, file, offset, length);
final BytecountStreamListener counter = new BytecountStreamListener(listener);
return pool.execute(new SegmentRetryCallable<>(session.getHost(), new BackgroundExceptionCallable<MultipartPart>() {
Expand Down
1 change: 1 addition & 0 deletions tus/src/main/java/ch/cyberduck/core/tus/TusUploadFeature.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -167,6 +167,7 @@ private Future<Void> submit(final Path file, final Local local,
final BandwidthThrottle throttle, final StreamListener listener,
final TransferStatus overall, final String uploadUrl,
final long offset, final long length, final ConnectionCallback callback) throws BackgroundException {
overall.validate();
log.info("Send part of {} with offset {} and length {}", file, offset, length);
return ConcurrentUtils.constantFuture(new DefaultRetryCallable<>(host, new BackgroundExceptionCallable<Void>() {
@Override
Expand Down