๓ าbc@@sถddlmZddlZddlmZmZmZmZddlm Z ddl m Z ddl m Z mZmZmZddlmZmZd Zd efd „ƒYZdS( i(tabsolute_importN(tdebugtinfotwarningterrori(tParameterError(tS3UriS3(tgetTextFromXmltgetTreeFromXmlts3_quotet parseNodes(t formatSizetcalculateChecksumitMultiPartUploadcB@sƒeZdZdZd ZdZddd„Zd„Zd„Z d„Z dd„Z ddd „Z dd „Z d „Zd „ZRS(s<Supports MultiPartUpload and MultiPartUpload(Copy) operationiicC@sภ||_d|_d|_||_||_i|_|p?i|_t|t ƒrˆ||_|srt dƒ‚n|jj j t }n||_|jj jt }||_|jƒ|_dS(Ns8Source size is missing for MultipartUploadCopy operation(ts3tNonet file_streamtsrc_uritsrc_sizetdst_uritpartstheaders_baselinet isinstanceRRtconfigtmultipart_copy_chunk_size_mbtSIZE_1MBtmultipart_chunk_size_mbt chunk_sizetinitiate_multipart_uploadt upload_id(tselfRtsrcRRRtc_size((sL/oak/stanford/groups/akundaje/marinovg/programs/s3cmd-master/S3/MultiPart.pyt__init__s          cC@su|jj||ƒ}tƒ}xP|D]H}y.i|dd6|dd6|t|dƒRZRtetagR/N(RRRR)R RRRt send_chunktstripRRRtstrRBt send_fileRO( RRWRZRRVR\RJR#tremote_checksumR=tquery_string_paramsRDRE((sL/oak/stanford/groups/akundaje/marinovg/programs/s3cmd-master/S3/MultiPart.pyRNฬs8      &c C@s๙td||j|fƒitd|jjƒ|jjƒfdtdtƒd6}d|||df|du remote copyuactionR@R"R/(RRR RtbucketR3tFalseRMRRBRtsend_request_with_progressRR( RRWRZRRVRJR=RgRDRE((sL/oak/stanford/groups/akundaje/marinovg/programs/s3cmd-master/S3/MultiPart.pyRP๕s$       c C@sอtd|jƒg}d}x4|jjƒD]#\}}|j|||fƒq-Wddj|ƒ}itt|ƒƒd6}|jj dd|j d|d |d i|jd 6ƒ}|jj |ƒ}|S( sŠ Finish a multipart upload http://docs.amazonwebservices.com/AmazonS3/latest/API/index.html?mpUploadComplete.html s MultiPart: Completing upload: %ss7%i%ss5%sR/scontent-lengthR<R+R=tbodyR>R_( RRRtitemstappendtjoinRdRRRRBRRC( Rt parts_xmltpart_xmlRWRaRmR=RDRE((sL/oak/stanford/groups/akundaje/marinovg/programs/s3cmd-master/S3/MultiPart.pytcomplete_multipart_upload#s cC@std|jƒd}|S(s„ Abort multipart upload http://docs.amazonwebservices.com/AmazonS3/latest/API/index.html?mpUploadAbort.html sMultiPart: Aborting upload: %sN(RRR(RRE((sL/oak/stanford/groups/akundaje/marinovg/programs/s3cmd-master/S3/MultiPart.pyt abort_upload9siiiPN(t__name__t __module__t__doc__tMIN_CHUNK_SIZE_MBtMAX_CHUNK_SIZE_MBt MAX_FILE_SIZERR!R.R;RR]RNRPRsRt(((sL/oak/stanford/groups/akundaje/marinovg/programs/s3cmd-master/S3/MultiPart.pyR s     ` ( . i(t __future__RR5tloggingRRRRt ExceptionsRtS3UriRt BaseUtilsRRR R tUtilsR R RR3R (((sL/oak/stanford/groups/akundaje/marinovg/programs/s3cmd-master/S3/MultiPart.pyts ""