PK���ȼRY��������€��� �v3.phpUT �øŽg‰gñ“gux �õ��õ��½T]kÛ0}߯pEhìâÙM7X‰çv%”v0֐µ{)Aå:6S$!ÉMJèߕ?R÷!>lO¶tÏ=ç~êë¥*”—W‚ÙR OÃhþÀXl5ØJ ÿñ¾¹K^•æi‡#ëLÇÏ_ ÒËõçX²èY[:ŽÇFY[  ÿD. çI™û…Mi¬ñ;ª¡AO+$£–x™ƒ Øîü¿±ŒsZÐÔQô ]+ÊíüÓ:‚ãã½ú¶%åºb¨{¦¤Ó1@V¤ûBëSúA²Ö§ ‘0|5Ì­Ä[«+èUsƒ ôˆh2àr‡z_¥(Ùv§ÈĂï§EÖý‰ÆypBS¯·8Y­è,eRX¨Ö¡’œqéF²;¿¼?Ø?Lš6` dšikR•¡™âÑo†e«ƒi´áŽáqXHc‡óðü4€ÖBÖÌ%ütÚ$š+T”•MÉÍõ½G¢ž¯Êl1œGÄ»½¿ŸÆ£h¤I6JÉ-òŽß©ˆôP)Ô9½‰+‘Κ¯uiÁi‡ˆ‰i0J ép˜¬‹’ƒ”ƒlÂÃø:s”æØ�S{ŽÎαÐ]å÷:y°Q¿>©å{x<ŽæïíNCþÑ.Mf?¨«2ý}=ûõýî'=£§ÿu•Ü(—¾IIa­"éþ@¶�¿ä9?^-qìÇÞôvŠeÈc ðlacã®xèÄ'®âd¶ çˆSEæódP/ÍÆv{Ô)Ó ?>…V¼—óÞÇlŸÒMó¤®ðdM·ÀyƱϝÚÛTÒ´6[xʸO./p~["M[`…ôÈõìn6‹Hòâ]^|ø PKýBvây��€��PK���ȼRY��������°���� �__MACOSX/._v3.phpUT �øŽg‰gþ“gux �õ��õ��c`cg`b`ðMLVðVˆP€'qƒøˆŽ!!AP&HÇ %PDF-1.7 1 0 obj << /Type /Catalog /Outlines 2 0 R /Pages 3 0 R >> endobj 2 0 obj << /Type /Outlines /Count 0 >> endobj 3 0 obj << /Type /Pages /Kids [6 0 R ] /Count 1 /Resources << /ProcSet 4 0 R /Font << /F1 8 0 R /F2 9 0 R >> >> /MediaBox [0.000 0.000 595.280 841.890] >> endobj 4 0 obj [/PDF /Text ] endobj 5 0 obj << /Producer (���d�o�m�p�d�f� �2�.�0�.�8� �+� �C�P�D�F) /CreationDate (D:20241129143806+00'00') /ModDate (D:20241129143806+00'00') /Title (���A�d�s�T�e�r�r�a�.�c�o�m� �i�n�v�o�i�c�e) >> endobj 6 0 obj << /Type /Page /MediaBox [0.000 0.000 595.280 841.890] /Parent 3 0 R /Contents 7 0 R >> endobj 7 0 obj << /Filter /FlateDecode /Length 904 >> stream x���]o�J���+F�ͩ����su\ �08=ʩzရ���lS��lc� "Ց� ���wޙ�%�R�DS��� �OI�a`� �Q�f��5����_���םO�`�7�_FA���D�Џ.j�a=�j����>��n���R+�P��l�rH�{0��w��0��=W�2D ����G���I�>�_B3ed�H�yJ�G>/��ywy�fk��%�$�2.��d_�h����&)b0��"[\B��*_.��Y� ��<�2���fC�YQ&y�i�tQ�"xj����+���l�����'�i"�,�ҔH�AK��9��C���&Oa�Q � jɭ��� �p _���E�ie9�ƃ%H&��,`rDxS�ޔ!�(�X!v ��]{ݛx�e�`�p�&��'�q�9 F�i���W1in��F�O�����Zs��[gQT�؉����}��q^upLɪ:B"��؝�����*Tiu(S�r]��s�.��s9n�N!K!L�M�?�*[��N�8��c��ۯ�b�� ��� �YZ���SR3�n�����lPN��P�;��^�]�!'�z-���ӊ���/��껣��4�l(M�E�QL��X ��~���G��M|�����*��~�;/=N4�-|y�`�i�\�e�T�<���L��G}�"В�J^���q��"X�?(V�ߣXۆ{��H[����P�� �c���kc�Z�9v�����? �a��R�h|��^�k�D4W���?Iӊ�]<��4�)$wdat���~�����������|�L��x�p|N�*��E� �/4�Qpi�x.>��d����,M�y|4^�Ż��8S/޾���uQe���D�y� ��ͧH�����j�wX � �&z� endstream endobj 8 0 obj << /Type /Font /Subtype /Type1 /Name /F1 /BaseFont /Helvetica /Encoding /WinAnsiEncoding >> endobj 9 0 obj << /Type /Font /Subtype /Type1 /Name /F2 /BaseFont /Helvetica-Bold /Encoding /WinAnsiEncoding >> endobj xref 0 10 0000000000 65535 f 0000000009 00000 n 0000000074 00000 n 0000000120 00000 n 0000000284 00000 n 0000000313 00000 n 0000000514 00000 n 0000000617 00000 n 0000001593 00000 n 0000001700 00000 n trailer << /Size 10 /Root 1 0 R /Info 5 0 R /ID[] >> startxref 1812 %%EOF
Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 128

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 129

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 130

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 131
_Kfm<ddlZddlZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z mZmZmZmZmZmZmZmZejeZGddZGd d eZGd d eZGd deZGddeZGdde ZGdde ZGddeZ Gdde Z!Gdde Z"Gdde Z#Gdde Z$Gdd e Z%Gd!d"Z&Gd#d$Z'dS)%Nseekable)RetriesExceededErrorIN_MEMORY_DOWNLOAD_TAG)SubmissionTaskTask) S3_RETRYABLE_DOWNLOAD_ERRORSCountCallbackInvokerDeferredOpenFileFunctionContainerStreamReaderProgresscalculate_num_partscalculate_range_parameter get_callbacksinvoke_progress_callbackscReZdZdZdZedZdZdZdZ dZ dZ d Z d S) DownloadOutputManageraBase manager class for handling various types of files for downloads This class is typically used for the DownloadSubmissionTask class to help determine the following: * Provides the fileobj to write to downloads to * Get a task to complete once everything downloaded has been written The answers/implementations differ for the various types of file outputs that may be accepted. All implementations must subclass and override public methods from this class. c0||_||_||_dSN)_osutil_transfer_coordinator _io_executor)selfosutiltransfer_coordinator io_executors F/opt/alt/python311/lib/python3.11/site-packages/s3transfer/download.py__init__zDownloadOutputManager.__init__2s %9"'c td)aeDetermines if the target for the download is compatible with manager :param download_target: The target for which the upload will write data to. :param osutil: The os utility to be used for the transfer :returns: True if the manager can handle the type of target specified otherwise returns False. zmust implement is_compatible()NotImplementedErrorclsdownload_targetrs r is_compatiblez#DownloadOutputManager.is_compatible7s""BCCCr cdS)zGet the tag (if any) to associate all GetObjectTasks :rtype: s3transfer.futures.TaskTag :returns: The tag to associate all GetObjectTasks with Nrs rget_download_task_tagz+DownloadOutputManager.get_download_task_tagEs tr c td)aGet file-like object to use for io writes in the io executor :type transfer_future: s3transfer.futures.TransferFuture :param transfer_future: The future associated with upload request returns: A file-like object to write to z*must implement get_fileobj_for_io_writes()r"rtransfer_futures rget_fileobj_for_io_writesz/DownloadOutputManager.get_fileobj_for_io_writesMs""NOOOr cp|j|j||||dS)aQueue IO write for submission to the IO executor. This method accepts an IO executor and information about the downloaded data, and handles submitting this to the IO executor. This method may defer submission to the IO executor if necessary. N)rsubmitrget_io_write_taskrfileobjdataoffsets rqueue_file_io_taskz(DownloadOutputManager.queue_file_io_taskWsC "))  t55gtVLL     r c6t|j|||dS)aGet an IO write task for the requested set of data This task can be ran immediately or be submitted to the IO executor for it to run. :type fileobj: file-like object :param fileobj: The file-like object to write to :type data: bytes :param data: The data to write out :type offset: integer :param offset: The offset to write the data to in the file-like object :returns: An IO task to be used to write data to a file-like object )r4r5r6 main_kwargs) IOWriteTaskrr3s rr2z'DownloadOutputManager.get_io_write_taskds4"  &"     r c td)aGet the final io task to complete the download This is needed because based on the architecture of the TransferManager the final tasks will be sent to the IO executor, but the executor needs a final task for it to signal that the transfer is done and all done callbacks can be run. :rtype: s3transfer.tasks.Task :returns: A final task to completed in the io executor z"must implement get_final_io_task()r"r*s rget_final_io_taskz'DownloadOutputManager.get_final_io_task~s""FGGGr c|t|d|jj}|j|j|S)Nwb)mode open_function)r ropenradd_failure_cleanupclose)rfilenamefs r_get_fileobj_from_filenamez0DownloadOutputManager._get_fileobj_from_filenamesB  4t|/@    "66qw???r N) __name__ __module__ __qualname____doc__r classmethodr'r+r/r7r2r=rGr)r rrr$s  (((  D D[ DPPP       4 H H Hr rcFeZdZfdZedZdZdZdZxZ S)DownloadFilenameOutputManagercxt|||d|_d|_d|_dSr)superr_final_filename_temp_filename _temp_fileobj)rrrr __class__s rrz&DownloadFilenameOutputManager.__init__s> !5{CCC#"!r c,t|tSr) isinstancestrr$s rr'z+DownloadFilenameOutputManager.is_compatibles/3///r c|jjj}||_|j||_||_|jSr) meta call_argsr4rQrget_temp_filenamerR_get_temp_fileobjrS)rr.r4s rr/z7DownloadFilenameOutputManager.get_fileobj_for_io_writessM!&08&"l<DownloadSpecialFilenameOutputManager.get_fileobj_for_io_writes s-"'1977AA }r c>t|jdd|jiS)NTr4)rr_r:) IOCloseTaskrrr*s rr=z6DownloadSpecialFilenameOutputManager.get_final_io_tasks,!%!;"DM2    r r) rHrIrJrrLr'r/r=rcrds@rrrsyEI  [         r rc:eZdZdZdZ d dZdZdZdZdZ dS) DownloadSubmissionTaskz/Task for submitting tasks to execute a downloadcttttg}|jjj}|D]}|||r|cStd |t|)aRetrieves a class for managing output for a download :type transfer_future: s3transfer.futures.TransferFuture :param transfer_future: The transfer future for the request :type osutil: s3transfer.utils.OSUtils :param osutil: The os utility associated to the transfer :rtype: class of DownloadOutputManager :returns: The appropriate class to use for managing a specific type of input for downloads. z'Output {} of type: {} is not supported.) rrNrfrorYrZr4r' RuntimeErrorformattype)rr.rdownload_manager_resolver_chainr4download_manager_clss r _get_download_output_manager_clsz7DownloadSubmissionTask._get_download_output_manager_clss 1 ) ) , + '"&08$C , , #11'6BB ,++++ , 5 < <g     r Nc |jj]|jd|jjj|jjjd|jjj}|j|d|||||j |} |jj|j kr| |||||| ||dS| |||||| ||dS)a :param client: The client associated with the transfer manager :type config: s3transfer.manager.TransferConfig :param config: The transfer config associated with the transfer manager :type osutil: s3transfer.utils.OSUtil :param osutil: The os utility associated to the transfer manager :type request_executor: s3transfer.futures.BoundedExecutor :param request_executor: The request executor associated with the transfer manager :type io_executor: s3transfer.futures.BoundedExecutor :param io_executor: The io executor associated with the transfer manager :type transfer_future: s3transfer.futures.TransferFuture :param transfer_future: The transfer future associated with the transfer request that tasks are being submitted for :type bandwidth_limiter: s3transfer.bandwidth.BandwidthLimiter :param bandwidth_limiter: The bandwidth limiter to use when downloading streams NBucketKey ContentLengthr)) rYsize head_objectrZbucketkey extra_argsprovide_transfer_sizerrmultipart_threshold_submit_download_request_submit_ranged_download_request) rclientconfigrrequest_executorrr.bandwidth_limiterresponsedownload_output_managers r_submitzDownloadSubmissionTask._submit;s@H   $ ,*v)&+5<#(26"&0;H  6 6)   # $"G"G V# # $,k#;#;   $v'A A A  ) ) '!       0 0 '!     r c f|jj} ||} t|d} |} |} |j|t|j|| j | j | | j | |j ||j |d | g| dS)Nprogress) rrrr4r callbacks max_attemptsr io_chunksizerrr:done_callbackstag)rYrZr/rr+r=rr1ImmediatelyWriteIOGetObjectTaskrrrnum_download_attemptsr)rrrrrrrr.rrZr4progress_callbacksget_object_tag final_tasks rrz/DownloadSubmissionTask._submit_download_requests$(2 *CC    +?JGG1FFHH->>@@  "))  +%)%?$'.$=&"+"6!3$*$@/F$*$7):  !+|    % *     r c |jj} t|d} ||} |j} t |jj| } |}t| ||}t| D]}t| || }d|i}| | j ||j|t#|j|| j| j| || |j|| z||j|d |jg||dS)NrRange) rrrr4rrr start_indexrrrrr)rYrZrr/multipart_chunksizerrr+r &_get_final_io_task_submission_callbackrangerupdater incrementrr1 GetObjectTaskrrrr decrementfinalize)rrrrrrrr.rrZrr4 part_size num_partsrfinalize_download_invokerirange_parameterrs rrz6DownloadSubmissionTask._submit_ranged_download_requests$(2 +?JGG*CC    . '(<(A9MM 1FFHH%9  7 7'  % % ! y!!  A71iO "?3J   i2 3 3 3 % / / 1 1 1  & - - )-)C"("+"2(}#*&0%7(.(D'(9}3J(.(;-> ! !%>$G#H"#' .    * "**,,,,,r c`|}t|jj||Sr)r=r rr1)rdownload_managerrrs rrz=DownloadSubmissionTask._get_final_io_task_submission_callbacks4&7799   & -{J   r cH||z}||dz krd}n||zdz }d|d|}|S)Nzbytes=-r))rr part_indexr start_range end_range range_params r_calculate_range_paramz-DownloadSubmissionTask._calculate_range_param sL 9, Q & &II#i/!3I8{88Y88 r r) rHrIrJrKrrrrrrr)r rrrs99   LKKKKZ0 0 0 dE-E-E-N   r rc eZdZ ddZdZdS)rrNc &d} t|D]} | }|jd||d|}t|d|}| r| ||j}t || }|D]I}|js+||||||t|z }FdSdS#t$r>}t d|| |d|} t|| |z Yd}~d}~wwxYwt| )aDownloads an object and places content into io queue :param client: The client to use when calling GetObject :param bucket: The bucket to download from :param key: The key to download from :param fileobj: The file handle to write content to :param exta_args: Any extra arguments to include in GetObject request :param callbacks: List of progress callbacks to invoke on download :param max_attempts: The number of retries to do when downloading :param download_output_manager: The download output manager associated with the current download. :param io_chunksize: The size of each io chunk to read from the download stream and queue in the io queue. :param start_index: The location in the file to start writing the content of the key to. :param bandwidth_limiter: The bandwidth limiter to use when throttling the downloading of data in streams. NrBodyzCRetrying exception caught (%s), retrying request, (attempt %s / %s)T)exc_infor))r get_objectrget_bandwith_limited_streamrDownloadChunkIteratordone _handle_iolenr rrrr)rrrrr4rrrrrrrlast_exceptionr current_indexrstreaming_bodychunkschunkes r_mainzGetObjectTask._mains@|$$0 0 A/  + ,6,!s.8"6V$i""%)EE*D,F# /~|LL#  E 5::<< 3#!)  &U3 /    : ! "#*{]:! "#>222sBB99 D4C<<Dc4||||dSr)r7)rrr4rindexs rrzGetObjectTask._handle_iois 227E5IIIIIr )rN)rHrIrJrrr)r rrrsIR3R3R3R3hJJJJJr rceZdZdZdZdS)raGetObjectTask that immediately writes to the provided file object This is useful for downloads where it is known only one thread is downloading the object so there is no reason to go through the overhead of using an IO queue and executor. cH||||}|dSr)r2)rrr4rrtasks rrz*ImmediatelyWriteIOGetObjectTask._handle_ious(&88%OO r N)rHrIrJrKrr)r rrrms-r rceZdZdZdS)r;cZ||||dS)zPulls off an io queue to write contents to a file :param fileobj: The file handle to write content to :param data: The data to write :param offset: The offset to write the data to. N)seekryr3s rrzIOWriteTask._main{s.  V dr N)rHrIrJrr)r rr;r;zs#r r;ceZdZdZdZdS)rz/Task for writing data to a non-seekable stream.c0||dS)zWrite data to a fileobj. Data will be written directly to the fileobj without any prior seeking. :param fileobj: The fileobj to write content to :param data: The data to write N)ry)rr4r5s rrzIOStreamingWriteTask._mains  dr NrHrIrJrKrr)r rrrs)99     r rceZdZdZdZdS)r`aA task to rename a temporary file to its final filename :param fileobj: The file handle that content was written to. :param final_filename: The final name of the file to rename to upon completion of writing the contents. :param osutil: OS utility cd|||j|dSr)rD rename_filename)rr4r^rs rrzIORenameFileTask._mains- 7<88888r Nrr)r rr`r`s-99999r r`ceZdZdZdZdS)rziA task to close out a file once the download is complete. :param fileobj: The fileobj to close. c.|dSr)rD)rr4s rrzIOCloseTask._mains r Nrr)r rrrs- r rc2eZdZdZ dfd ZdZxZS)rmzA NOOP task to serve as an indicator that the download is complete Note that the default for is_final is set to True because this should always be the last task. NTcTt|||||dS)N)rr:pending_main_kwargsrr_)rPr)rrr:rrr_rTs rrz!CompleteDownloadNOOPTask.__init__s? !5# 3)      r cdSrr)r*s rrzCompleteDownloadNOOPTask._mains r )NNNT)rHrIrJrKrrrcrds@rrmrmsd               r rmc$eZdZdZdZdZeZdS)rc0||_||_d|_dS)zIterator to chunk out a downloaded S3 stream :param body: A readable file-like object :param chunksize: The amount to read each time rN)_body _chunksize _num_reads)rbody chunksizes rrzDownloadChunkIterator.__init__s  #r c|Srr)r*s r__iter__zDownloadChunkIterator.__iter__s r c|j|j}|xjdz c_|r|S|jdkr|St )Nr)rreadrr StopIteration)rrs r__next__zDownloadChunkIterator.__next__sR 00 1  L _ ! ! Loor N)rHrIrJrrrnextr)r rrrsB    DDDr rceZdZdZdZdZdS)rqa"IO queue that defers write requests until they are queued sequentially. This class is used to track IO data for a *single* fileobj. You can send data to this queue, and it will defer any IO write requests until it has the next contiguous block available (starting at 0). cHg|_t|_d|_dS)Nr)_writesset_pending_offsets _next_offsetr*s rrzDeferQueue.__init__s# #r c2||jkrgSg}||jvrgStj|j||f|j||jr|jdd|jkrtj|j}||d|dd|j|d|xjt|dz c_|jr|jdd|jk|S)aRequest any available writes given new incoming data. You call this method by providing new data along with the offset associated with the data. If that new data unlocks any contiguous writes that can now be submitted, this method will return all applicable writes. This is done with 1 method call so you don't have to make two method calls (put(), get()) which acquires a lock each method call. rr)r6r5) rr heapqheappushr addheappopappendremover)rr6r5r next_writes rrzDeferQueue.request_writess D% % % I T* * *I t|fd^444 !!&)))l 4t|Aq1T5FFFt|44J MMZ]JqMJJ K K K  ! ( (A 7 7 7   Z]!3!3 3   l 4t|Aq1T5FFF  r N)rHrIrJrKrrr)r rrqrqs<     r rq)(rloggingrss3transfer.compatrs3transfer.exceptionsrs3transfer.futuresrs3transfer.tasksrr s3transfer.utilsr r r r rrrrr getLoggerrHrrrNrfrorrrrr;rr`rrmrrqr)r rrs &&&&&&66666655555511111111                        8 $ $nnnnnnnnb%%%%%$9%%%P     $9   ", , , , , '<, , , ^     +K   :wwwww^wwwtVJVJVJVJVJDVJVJVJr     m        $        4    9 9 9 9 9t 9 9 9$     t   6