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
package s3manager import ( "fmt" "sync" "github.com/aws/aws-sdk-go/aws" ) type byteSlicePool interface { Get(aws.Context) (*[]byte, error) Put(*[]byte) ModifyCapacity(int) SliceSize() int64 Close() } type maxSlicePool struct { // allocator is defined as a function pointer to allow // for test cases to instrument custom tracers when allocations // occur. allocator sliceAllocator slices chan *[]byte allocations chan struct{} capacityChange chan struct{} max int sliceSize int64 mtx sync.RWMutex } func newMaxSlicePool(sliceSize int64) *maxSlicePool { p := &maxSlicePool{sliceSize: sliceSize} p.allocator = p.newSlice return p } var errZeroCapacity = fmt.Errorf("get called on zero capacity pool") func (p *maxSlicePool) Get(ctx aws.Context) (*[]byte, error) { // check if context is canceled before attempting to get a slice // this ensures priority is given to the cancel case first select { case <-ctx.Done(): return nil, ctx.Err() default: } p.mtx.RLock() for { select { case bs, ok := <-p.slices: p.mtx.RUnlock() if !ok { // attempt to get on a zero capacity pool return nil, errZeroCapacity } return bs, nil case <-ctx.Done(): p.mtx.RUnlock() return nil, ctx.Err() default: // pass } select { case _, ok := <-p.allocations: p.mtx.RUnlock() if !ok { // attempt to get on a zero capacity pool return nil, errZeroCapacity } return p.allocator(), nil case <-ctx.Done(): p.mtx.RUnlock() return nil, ctx.Err() default: // In the event that there are no slices or allocations available // This prevents some deadlock situations that can occur around sync.RWMutex // When a lock request occurs on ModifyCapacity, no new readers are allowed to acquire a read lock. // By releasing the read lock here and waiting for a notification, we prevent a deadlock situation where // Get could hold the read lock indefinitely waiting for capacity, ModifyCapacity is waiting for a write lock, // and a Put is blocked trying to get a read-lock which is blocked by ModifyCapacity. // Short-circuit if the pool capacity is zero. if p.max == 0 { p.mtx.RUnlock() return nil, errZeroCapacity } // Since we will be releasing the read-lock we need to take the reference to the channel. // Since channels are references we will still get notified if slices are added, or if // the channel is closed due to a capacity modification. This specifically avoids a data race condition // where ModifyCapacity both closes a channel and initializes a new one while we don't have a read-lock. c := p.capacityChange p.mtx.RUnlock() select { case _ = <-c: p.mtx.RLock() case <-ctx.Done(): return nil, ctx.Err() } } } } func (p *maxSlicePool) Put(bs *[]byte) { p.mtx.RLock() defer p.mtx.RUnlock() if p.max == 0 { return } select { case p.slices <- bs: p.notifyCapacity() default: // If the new channel when attempting to add the slice then we drop the slice. // The logic here is to prevent a deadlock situation if channel is already at max capacity. // Allows us to reap allocations that are returned and are no longer needed. } } func (p *maxSlicePool) ModifyCapacity(delta int) { if delta == 0 { return } p.mtx.Lock() defer p.mtx.Unlock() p.max += delta if p.max == 0 { p.empty() return } if p.capacityChange != nil { close(p.capacityChange) } p.capacityChange = make(chan struct{}, p.max) origAllocations := p.allocations p.allocations = make(chan struct{}, p.max) newAllocs := len(origAllocations) + delta for i := 0; i < newAllocs; i++ { p.allocations <- struct{}{} } if origAllocations != nil { close(origAllocations) } origSlices := p.slices p.slices = make(chan *[]byte, p.max) if origSlices == nil { return } close(origSlices) for bs := range origSlices { select { case p.slices <- bs: default: // If the new channel blocks while adding slices from the old channel // then we drop the slice. The logic here is to prevent a deadlock situation // if the new channel has a smaller capacity then the old. } } } func (p *maxSlicePool) notifyCapacity() { select { case p.capacityChange <- struct{}{}: default: // This *shouldn't* happen as the channel is both buffered to the max pool capacity size and is resized // on capacity modifications. This is just a safety to ensure that a blocking situation can't occur. } } func (p *maxSlicePool) SliceSize() int64 { return p.sliceSize } func (p *maxSlicePool) Close() { p.mtx.Lock() defer p.mtx.Unlock() p.empty() } func (p *maxSlicePool) empty() { p.max = 0 if p.capacityChange != nil { close(p.capacityChange) p.capacityChange = nil } if p.allocations != nil { close(p.allocations) for range p.allocations { // drain channel } p.allocations = nil } if p.slices != nil { close(p.slices) for range p.slices { // drain channel } p.slices = nil } } func (p *maxSlicePool) newSlice() *[]byte { bs := make([]byte, p.sliceSize) return &bs } type returnCapacityPoolCloser struct { byteSlicePool returnCapacity int } func (n *returnCapacityPoolCloser) ModifyCapacity(delta int) { if delta > 0 { n.returnCapacity = -1 * delta } n.byteSlicePool.ModifyCapacity(delta) } func (n *returnCapacityPoolCloser) Close() { if n.returnCapacity < 0 { n.byteSlicePool.ModifyCapacity(n.returnCapacity) } } type sliceAllocator func() *[]byte var newByteSlicePool = func(sliceSize int64) byteSlicePool { return newMaxSlicePool(sliceSize) }