org.jclouds.aws.s3.blobstore.strategy.internal

Class ParallelMultipartUploadStrategy

java.lang.Object

org.jclouds.aws.s3.blobstore.strategy.internal.ParallelMultipartUploadStrategy

All Implemented Interfaces:

AsyncMultipartUploadStrategy, MultipartUpload

public class ParallelMultipartUploadStrategy
extends Object
implements AsyncMultipartUploadStrategy

Field Summary

Fields

Modifier and Type	Field and Description
protected AWSS3AsyncBlobStore	ablobstore
protected Logger	logger
protected Long	maxTime maximum duration of an blob Request
protected PayloadSlicer	slicer

Fields inherited from interface org.jclouds.aws.s3.blobstore.strategy.MultipartUpload

MAX_LIST_MPU_RETURNED, MAX_LIST_PARTS_RETURNED, MAX_NUMBER_OF_PARTS, MAX_PART_SIZE, MIN_PART_SIZE

Constructor Summary

Constructors

Constructor and Description
ParallelMultipartUploadStrategy(AWSS3AsyncBlobStore ablobstore, PayloadSlicer slicer, com.google.common.util.concurrent.ListeningExecutorService ioExecutor)

Method Summary

Methods

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<String>	execute(String container, Blob blob, PutOptions options)
protected void	prepareUploadPart(String container, String key, String uploadId, Integer part, Payload payload, long offset, long size, SortedMap<Integer,String> etags, BlockingQueue<Integer> activeParts, Map<Integer,com.google.common.util.concurrent.ListenableFuture<String>> futureParts, AtomicInteger errors, int maxRetries, Map<Integer,Exception> errorMap, Queue<org.jclouds.aws.s3.blobstore.strategy.internal.ParallelMultipartUploadStrategy.Part> toRetry, CountDownLatch latch)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

@Named(value="jclouds.blobstore")
protected Logger logger

maxTime

@Inject(optional=true)
@Named(value="jclouds.request-timeout")
protected Long maxTime

maximum duration of an blob Request

ablobstore

protected final AWSS3AsyncBlobStore ablobstore

slicer

protected final PayloadSlicer slicer

Constructor Detail

ParallelMultipartUploadStrategy

@Inject
public ParallelMultipartUploadStrategy(AWSS3AsyncBlobStore ablobstore,
                                      PayloadSlicer slicer,
                                      @Named(value="jclouds.io-worker-threads")
                                      com.google.common.util.concurrent.ListeningExecutorService ioExecutor)

Method Detail

prepareUploadPart

protected void prepareUploadPart(String container,
                     String key,
                     String uploadId,
                     Integer part,
                     Payload payload,
                     long offset,
                     long size,
                     SortedMap<Integer,String> etags,
                     BlockingQueue<Integer> activeParts,
                     Map<Integer,com.google.common.util.concurrent.ListenableFuture<String>> futureParts,
                     AtomicInteger errors,
                     int maxRetries,
                     Map<Integer,Exception> errorMap,
                     Queue<org.jclouds.aws.s3.blobstore.strategy.internal.ParallelMultipartUploadStrategy.Part> toRetry,
                     CountDownLatch latch)

execute

public com.google.common.util.concurrent.ListenableFuture<String> execute(String container,
                                                                 Blob blob,
                                                                 PutOptions options)

Specified by:

execute in interface AsyncMultipartUploadStrategy