Field Detail

• logger

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

• PART_SEPARATOR

  public static final String PART_SEPARATOR

  See Also:

  Constant Field Values

• maxTime

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

  maximum duration of an blob Request

• blobstore

  protected final SwiftBlobStore blobstore

• slicer

  protected final PayloadSlicer slicer

Constructor Detail

• ParallelMultipartUploadStrategy

  @Inject
  public ParallelMultipartUploadStrategy(SwiftBlobStore blobstore,
                                        PayloadSlicer slicer,
                                        @Named(value="jclouds.user-threads")
                                        com.google.common.util.concurrent.ListeningExecutorService executor)

Method Detail

• prepareUploadPart

  protected void prepareUploadPart(String container,
                       Blob blob,
                       String key,
                       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.openstack.swift.blobstore.strategy.internal.ParallelMultipartUploadStrategy.Part> toRetry,
                       CountDownLatch latch,
                       BlobToObject blob2Object)

• execute

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

  Specified by:

  execute in interface AsyncMultipartUploadStrategy