┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н 3 y╛Ьbёлу@s╓ddlZddlZddlZddlZddlZddlZddlmZddlZddl m Z ddlmZddlm Z ddlmZddlmZmZdd lmZmZmZmZmZdd lmZmZmZmZmZmZmZddl m!Z!dd l m"Z"e#ГZ$GddДde!ГZ%GddДde%ГZ&GddДde%ГZ'GddДde%ГZ(GddДde%ГZ)GddДde%ГZ*GddДde%ГZ+GddДde%ГZ,GddДde%ГZ-Gd d!Дd!e%ГZ.Gd"d#Дd#e%ГZ/Gd$d%Дd%e&ГZ0Gd&d'Дd'e%ГZ1Gd(d)Дd)e.ГZ2Gd*d+Дd+e!ГZ3dS),щN)┌patchщ)┌NSIndex)┌Location)┌IntegrityError)┌msgpack)┌Lock┌ LockFailed)┌RemoteRepository┌InvalidRPCMethod┌PathNotAllowed┌ConnectionClosedWithHint┌handle_remote_line)┌ Repository┌LoggedIO┌MAGIC┌ MAX_DATA_SIZE┌ TAG_DELETE┌TAG_PUT┌ TAG_COMMITщ)┌BaseTestCase)┌Hc@sPeZdZdZdZdefddДZddДZdd ДZefd dДZ dd ДZ dddДZdS)┌RepositoryTestCaseBaseщ TFcCs(|tkr|j}ttjj|jdГ||dНS)N┌ repository)┌ exclusive┌create)┌UNSPECIFIEDrr┌os┌path┌join┌tmppath)┌selfrrйr$·"/usr/lib64/python3.6/repository.py┌openszRepositoryTestCaseBase.opencCs&tjГ|_|jddН|_|jjГdS)NT)r)┌tempfileZmkdtempr"r&r┌ __enter__)r#r$r$r%┌setUp"s zRepositoryTestCaseBase.setUpcCs|jjГtj|jГdS)N)r┌close┌shutilZrmtreer")r#r$r$r%┌tearDown's zRepositoryTestCaseBase.tearDowncCs"|jr|jjГ|j|dН|_dS)N)r)rr*r&)r#rr$r$r%┌reopen+s zRepositoryTestCaseBase.reopencCsx|jjtdГdГ|jjtdГdГ|jjtdГdГ|jjГ|jjtdГdГ|jjtdГdГ|jjtdГГdS) Nrsfoorsbarщsbar2rsboo)r┌putr┌commit┌delete)r#r$r$r%┌add_keys0s zRepositoryTestCaseBase.add_keysNc Csв|dk r|dnd}ddДtdГDГ}d|d<tdtdtd i}xX|jjjГD]H\}}x>|jjj|ГD],\}}}} td |||||||| fГqdWqLWtГdS)Nz: ┌cSsi|]}|t|ГУqSr$)r)┌.0┌ir$r$r%· ;sz4RepositoryTestCaseBase.repo_dump..щ rr/┌delZcommz%s%s H(%d) -> %s[%d..+%d]щ ) ┌rangerrrr┌io┌segment_iterator┌iter_objects┌print) r#ZlabelZH_transZ tag_trans┌segment┌fn┌tag┌key┌offset┌sizer$r$r%┌ repo_dump9s(z RepositoryTestCaseBase.repo_dump)N)┌__name__┌ __module__┌__qualname__Zkey_sizerrr&r)r,r-r2rEr$r$r$r%rs rc@sTeZdZddДZddДZddДZddДZd d ДZddДZd dДZ ddДZ ddДZdS)┌RepositoryTestCasecs┌x"tdГD]}Иjjt|ГdГq WtdГЙИjИjjИГdГИjjИГИjtj ЗЗfddДГИjj ГИjjГИjГПPЙИjtj ЗЗfddДГx0tdГD]$}|dkr▓qдИjИjt|ГГdГqдWWdQRXdS)NщdsSOMEDATAщ2csИjjИГS)N)r┌getr$)┌key50r#r$r%┌Lsz*RepositoryTestCase.test1..cs ИjИГS)N)rLr$)rM┌repository2r$r%rNPs) r:rr/r┌assert_equalrLr1┌ assert_raisesr┌ObjectNotFoundr0r*r&)r#┌xr$)rMrOr#r%┌test1Fs zRepositoryTestCase.test1cCsv|jjtdГdГ|jjtdГdГ|jjГ|jjtdГГ|jjtdГdГ|jjГ|j|jjtdГГdГdS)z.Test multiple sequential transactions rsfoorsbarN)rr/rr0r1rPrL)r#r$r$r%┌test2Vs zRepositoryTestCase.test2csиИjjtdГdГИjИjjtdГГdГИjjtdГdГИjИjjtdГГdГИjjtdГdГИjИjjtdГГdГИjjtdГГИjtjЗfddДГdS)zTest cache consistency rsfoosfoo2sbarcsИjjtdГГS)Nr)rrLrr$)r#r$r%rNksz5RepositoryTestCase.test_consistency..N) rr/rrPrLr1rQrrR)r#r$)r#r%┌test_consistencyasz#RepositoryTestCase.test_consistencycCsД|jjtdГdГ|j|jjtdГГdГ|jjГ|jjtdГdГ|j|jjtdГГdГ|jjГ|j|jjtdГГdГdS)z Test cache consistency2 rsfoosfoo2N)rr/rrPrLr0┌rollback)r#r$r$r%┌test_consistency2ms z$RepositoryTestCase.test_consistency2cCsJ|jjtdГdГ|jjtdГdГ|jjГ|j|jjtdГГdГdS)z Test cache consistency2 rsfoosfoo2N)rr/rr0rPrL)r#r$r$r%┌"test_overwrite_in_same_transactionxs z5RepositoryTestCase.test_overwrite_in_same_transactioncCsШ|jjtdГdГ|jjГ|jjГ|jГ|_|jП"|jjtdГdГ|jjГWdQRX|jГ|_|jП |jjtdГГ|jjГWdQRXdS)Nrsfoosbar)rr/rr0r*r&r1)r#r$r$r%┌test_single_kind_transactionsАs z0RepositoryTestCase.test_single_kind_transactionscCs╬x"tdГD]}|jjt|ГdГq W|jjГ|jjГ}|jt|ГdГ|jjddН}|jt|ГdГ|j||ddЕГ|jj|ddН}|jt|ГdГ|j||ddЕГ|jt|jjddНГdГdS)NrJsSOMEDATArK)┌limitr)┌markerr9)r:rr/rr0┌listrP┌len)r#rS┌all┌ first_half┌second_halfr$r$r%┌ test_listРs zRepositoryTestCase.test_listcCsЇx"tdГD]}|jjt|ГdГq W|jjГ|jjГ}t|ГdksHtВ|jjddН}t|ГdksftВ||ddЕksztВ|jj|ddН}t|ГdksЬtВ||ddЕks░tВt|jjddНГdks╩tВx$tdГD]}||t|Гks╘tВq╘WdS)NrJsSOMEDATArK)r[r)r\r9)r:rr/rr0┌scanr^┌AssertionError)r#rSr_r`rar$r$r%┌ test_scanЮs zRepositoryTestCase.test_scancsLdtЙИjjtdГИГИjИjjtdГГИГИjtЗЗfddДГdS)NєxrcsИjjtdГИdГS)Nrrf)rr/rr$)┌max_datar#r$r%rN┤sz7RepositoryTestCase.test_max_data_size..)rrr/rrPrLrQr)r#r$)rgr#r%┌test_max_data_sizeпs z%RepositoryTestCase.test_max_data_sizeN)rFrGrHrTrUrVrXrYrZrbrerhr$r$r$r%rIDsrIc@s4eZdZddДZddДZddДZddДZd d ДZdS)┌LocalRepositoryTestCasecCsL|jjddkstВ|jjddks(tВ|jjdГ|jjddksHtВdS)Nrщ)щ rrKrK)r┌compactrd┌_rebuild_sparse)r#r$r$r%┌_assert_sparse║sz&LocalRepositoryTestCase._assert_sparsecCsL|jjtdГdГ|jjtdГdГ|jjГ|jjtdГdГ|jГdS)Nrsfoors 123456789sbar)rr/rr0rn)r#r$r$r%┌test_sparse1┬s z$LocalRepositoryTestCase.test_sparse1cCsJ|jjtdГdГ|jjtdГdГ|jjГ|jjtdГГ|jГdS)Nrsfoors 123456789)rr/rr0r1rn)r#r$r$r%┌test_sparse2╔s z$LocalRepositoryTestCase.test_sparse2cCsШ|jjtdГdГ|jjtdГГ|jjjjГ|jjddksDtВ|jj dГ|jjdd t tГksltВ|jjГdddД|jjj ГDГksФtВdS)Nrs1245rjщcSsg|]\}}|СqSr$r$)r4r?┌_r$r$r%· ▄sz>LocalRepositoryTestCase.test_sparse_delete..щRщVrtru)rr/rr1r;Z _write_fd┌syncrlrdrmr^rr0r<)r#r$r$r%┌test_sparse_delete╨s z*LocalRepositoryTestCase.test_sparse_deletecCsа|jjtdГdГ|jjГ|jjjГ}t|jjj|dГdГП}|jt dГWdQRX|jj Г|jГ|_|jП"|jjtdГdГ|jjГWdQRXdS)Nrsfoor┌wbscrapcrapcrapsbar)rr/rr0r;┌get_latest_segmentr&Zsegment_filename┌writerr*)r#┌last_segment┌fr$r$r%┌test_uncommitted_garbage▐s z0LocalRepositoryTestCase.test_uncommitted_garbageN)rFrGrHrnrorprwr}r$r$r$r%ri╖s ric@s\eZdZddДZddДZddДZddДZd d ДZddДZd dДZ ddДZ ddДZddДZdS)┌RepositoryCommitTestCasec CsД|jГx8tj|jjГD]&}|jdГrtjtjj|jj|ГГqW|jГ|jП*|j t |jГdГ|j |jjГdГWdQRXdS)Nzindex.r.T)r2r┌listdirrr ┌ startswith┌unlinkr!r-rPr^┌check)r#┌namer$r$r%┌test_replay_of_missing_indexЄs z5RepositoryCommitTestCase.test_replay_of_missing_indexcCsv|jГd|j_y|jjГWntk r2YnX|jГ|jП*|jt|jГdГ|j|jjГdГWdQRXdS)Nr.T) r2r┌compact_segmentsr0┌ TypeErrorr-rPr^rВ)r#r$r$r%┌"test_crash_before_compact_segments№sz;RepositoryCommitTestCase.test_crash_before_compact_segmentscCsv|jГd|j_y|jjГWntk r2YnX|jГ|jП*|jt|jГdГ|j|jjГdГWdQRXdS)Nr.T) r2rZwrite_indexr0rЖr-rPr^rВ)r#r$r$r%┌test_crash_before_write_indexsz6RepositoryCommitTestCase.test_crash_before_write_indexcsЬИjГx8tjИjjГD]&}|jdГrtjtjjИjj|ГГqWtj t dtdНП@}ИjddНИjП"Иj tЗfddДГ|jГWdQRXWdQRXdS)Nzindex.┌upgrade)┌side_effect)rcs tИjГS)N)r^rr$)r#r$r%rNszGRepositoryCommitTestCase.test_replay_lock_upgrade_old..)r2rrrr rАrБr!r┌objectrr r-rQ┌assert_called_once_with)r#rГrЙr$)r#r%┌test_replay_lock_upgrade_olds z5RepositoryCommitTestCase.test_replay_lock_upgrade_oldcsЬИjГx8tjИjjГD]&}|jdГrtjtjjИjj|ГГqWtj t dtdНП@}ИjddНИjП"Иj tЗfddДГ|jГWdQRXWdQRXdS)Nzindex.rЙ)rКF)rcs tИjГS)N)r^rr$)r#r$r%rN+szCRepositoryCommitTestCase.test_replay_lock_upgrade..)r2rrrr rАrБr!rrЛrr r-rQrМ)r#rГrЙr$)r#r%┌test_replay_lock_upgrade!s z1RepositoryCommitTestCase.test_replay_lock_upgradecCsК|jГd|jj_y|jjГWntk r4YnX|jГ|jП<|jt|jГdГ|j|jj ГdГ|jt|jГdГWdQRXdS)Nr.T) r2rr;┌delete_segmentr0rЖr-rPr^rВ)r#r$r$r%┌-test_crash_before_deleting_compacted_segments.s zFRepositoryCommitTestCase.test_crash_before_deleting_compacted_segmentsc CsN|jjtdГtjГ|jГ|jП"|jj}|j|jГГs@t ВWdQRXdS)Nr) rr/rrZCOMMITr-r;Zis_committed_segmentryrd)r#r;r$r$r%┌test_ignores_commit_tag_in_data;s z8RepositoryCommitTestCase.test_ignores_commit_tag_in_datac CsТ|jjtdГdГ|jjtdГdГ|jjГ|jdГ|jjtdГГ|jjГ|jdГ|jjjГd}d}x>|jjj|ГD],\}}}}|t krА|tdГksдt В|d7}qАW|dks╝t В||jjks╠t В|jjtdГd Г|jjГ|jd Г||jjkРst В|jjj|ГРst Вx\|jjj ГD]L\}}x@|jjj|ГD].\}}}}|t kРsZt В|tdГkРs@t ВРq@WРq(WtdГ|jjkРsОt ВdS)Nrє1rє2zp1 p2 cczd1 ccrr.є3zp3 cc)rr/rr0rEr1r;ryr=rrdrl┌segment_existsr<┌shadow_index) r#r{Znum_deletesrArBrCrDr?rrr$r$r%┌test_moved_deletes_are_trackedBs2 z7RepositoryCommitTestCase.test_moved_deletes_are_trackedcCs°|jjj}|jjtdГdГ|Г}|jjГ|jjtdГГ|jjtdГdГ|Г}|jj|=|jj|=|jjГ|jjtdГГ|jjГ|jjj|ГsЮt В|jjj|Гs▓t ВtdГ|jks─t Вt jt jj |jjd|ГГГtdГ|jksЇt ВdS)NrrТrzindex.%d)rr;ryr/rr0r1rlrХrdrrБr r!)r#ryZput_segmentrПr$r$r%┌#test_shadowed_entries_are_preserved_s" ztВИjjtdГdГИjjГ|ГdkshtВdИj_|Гdks~tВИjjtdГdГИjjГ|Гd ksиtВdS) NcsttИjjjГГГS)N)r^r]rr;r<r$)r#r$r%┌segments_in_repositoryаszMRepositoryAppendOnlyTestCase.test_append_only..segments_in_repositoryrsfooFrrqTщ)rr/rr0rЬrd)r#rЯr$)r#r%┌test_append_onlyЯs z-RepositoryAppendOnlyTestCase.test_append_onlyN)F)rFrGrHr&rЮrбr$r$r$r%rЫХs rЫc@seZdZddДZddДZdS)┌RepositoryFreeSpaceTestCasecCsМ|jГ|jjjdddГ|jjdГ|jГ|jП:|jjtdГdГtj t jГП|jjГWdQRXWdQRXt jj|jjГsИtВdS)Nr┌additional_free_spaceZ1000Tsshortcut to save_configrsfoobar)r2r┌config┌setZsave_keyr-r/r┌pytest┌raisesr┌InsufficientFreeSpaceErrorr0rr ┌existsrd)r#r$r$r%┌test_additional_free_space╡sz6RepositoryFreeSpaceTestCase.test_additional_free_spacec CsBd|j_tjtjГП|jГWdQRXtjj |jjГs>t ВdS)Ng@М╡xпD)rrгrжrзrrиr2rr rйrd)r#r$r$r%┌test_create_free_space┴sz2RepositoryFreeSpaceTestCase.test_create_free_spaceN)rFrGrHrкrлr$r$r$r%rв┤srвc@seZdZddДZddДZdS)┌ QuotaTestCasecCs|jjdkstВ|jjtdГtdГГ|jjd ks6tВ|jjtdГtdГГ|jjdks\tВ|jjtdГГ|jjdks|tВ|jjГ|jjdksЦtВ|jГ|jПV|jjtdГdГ|jjtdГГ|jjdkРs┌tВ|jjГ|jjdkРsЎtВWdQRXdS)Nrri╥rjri.r.єi√irtiRirtiRiWrtiАiW) r┌storage_quota_userdr/r┌bytesr1r0r-)r#r$r$r%┌ test_tracking╔s zQuotaTestCase.test_trackingcCs|jjdkstВd|j_|jjtdГdГ|jjdks:tВ|jjГtjt j ГП|jjtdГdГWdQRX|jjdks~tВtjt j ГП|jjГWdQRX|jjdks░tВ|jГ|jПLd|j_|jjtdГdГ|jjdksъtВ|jjГ|jjdkРstВWdQRXdS) NrrKrrнrjrrtrJ)rrоrd┌ storage_quotar/rr0rжrзrZStorageQuotaExceededr-)r#r$r$r%┌test_exceed_quota▄s$ zQuotaTestCase.test_exceed_quotaN)rFrGrHr░r▓r$r$r$r%rм╚srмc@s,eZdZddДZddДZddДZddДZd S) ┌NonceReservationcCsB|jddНtjtГП"|jП|jjГWdQRXWdQRXdS)NF)r)r-rжrзrdr┌get_free_nonce)r#r$r$r%┌test_get_free_nonce_assertsєsz,NonceReservation.test_get_free_nonce_assertscCsи|jПШ|jjГdkstВttjj|jjdГdГП}|jdГWdQRX|jjГdksZtВttjj|jjdГdГП}|jdГWdQRX|jjГdksЪtВWdQRXdS)N┌nonce┌wZ0000000000000000rZ5000000000000000l)rr┤rdr&rr r!rz)r#┌fdr$r$r%┌test_get_free_nonce∙sz$NonceReservation.test_get_free_noncecCsF|jddНtjtГП&|jП|jjddГWdQRXWdQRXdS)NF)riщ)r-rжrзrdr┌commit_nonce_reservation)r#r$r$r%┌%test_commit_nonce_reservation_assertssz6NonceReservation.test_commit_nonce_reservation_assertsc%Csт|jП╥tjtГП|jjddГWdQRX|jjddГttjj|jjdГdГП}|j Гdksdt ВWdQRXtjtГП|jjddГWdQRX|jjddГttjj|jjdГdГП}|j Гdks╩t ВWdQRXWdQRXdS)Niщr╢rЩZ0000000000000200iZ0000000000000400)rrжrз┌ Exceptionr╗r&rr r!┌readrd)r#r╕r$r$r%┌test_commit_nonce_reservationsz.NonceReservation.test_commit_nonce_reservationN)rFrGrHr╡r╣r╝r└r$r$r$r%r│Єsr│csФeZdZЗfddДZddДZddДZddДZd d ДZddДZd dДZ ddДZ ddДZddДZddДZ ddДZddДZddДZddДZdd ДZЗZS)!┌%RepositoryAuxiliaryCorruptionTestCasecs4tГjГ|jjtdГdГ|jjГ|jjГdS)Nrsfoo)┌superr)rr/rr0r*)r#)┌ __class__r$r%r)s z+RepositoryAuxiliaryCorruptionTestCase.setUpc Cs2|jП"|jjtdГdГ|jjГWdQRXdS)Nrsfox)rr/rr0)r#r$r$r%┌ do_commit#sz/RepositoryAuxiliaryCorruptionTestCase.do_commitc Cs:ttjj|jjdГdГП}|jdГWdQRX|jГdS)Nzhints.1Zabs 123456789)r&rr r!rrzr─)r#r╕r$r$r%┌test_corrupted_hints(sz:RepositoryAuxiliaryCorruptionTestCase.test_corrupted_hintscCs$tjtjj|jjdГГ|jГdS)Nzhints.1)rrБr r!rr─)r#r$r$r%┌test_deleted_hints-sz8RepositoryAuxiliaryCorruptionTestCase.test_deleted_hintscCs$tjtjj|jjdГГ|jГdS)Nzindex.1)rrБr r!rr─)r#r$r$r%┌test_deleted_index1sz8RepositoryAuxiliaryCorruptionTestCase.test_deleted_indexc CsHtjj|jjdГ}tj|Гtj|Г|jtГП|jГWdQRXdS)Nzhints.1) rr r!rrБ┌mkdirrQ┌OSErrorr─)r#┌hintsr$r$r%┌test_unreadable_hints5s z;RepositoryAuxiliaryCorruptionTestCase.test_unreadable_hintsc Cs:ttjj|jjdГdГП}|jdГWdQRX|jГdS)Nzindex.1rxs 123456789)r&rr r!rrzr─)r#r╕r$r$r%┌ test_index<sz0RepositoryAuxiliaryCorruptionTestCase.test_indexcCsVttjj|jjdГdГП}|jdГWdQRX|jПt|jГdksHtВWdQRXdS)Nzindex.1rxs 123456789r)r&rr r!rrzr^rd)r#r╕r$r$r%┌test_index_outside_transactionAszDRepositoryAuxiliaryCorruptionTestCase.test_index_outside_transactionc CsФtjj|jjdГ}t|dГПn}|jГ}tjtdГdГdAj ddГ}|j tdГ|Г}||ks^tВt|Гt|ГksrtВ|j dГ|j|ГWdQRXdS)Nzindex.1zr+br┌littlerr)rr r!rr&r┐┌int┌ from_bytesr┌to_bytes┌replacerdr^┌seekrz)r#Z index_pathr╕Z index_dataZ corrupted_keyZcorrupted_index_datar$r$r%┌_corrupt_indexGs z4RepositoryAuxiliaryCorruptionTestCase._corrupt_indexc CsH|jГ|jП0t|jГdks"tВ|jjtdГГdks:tВWdQRXdS)Nrrsfoo)r╘rr^rdrLr)r#r$r$r%┌test_index_corruptedUsz:RepositoryAuxiliaryCorruptionTestCase.test_index_corruptedcCst|jГtjj|jjdГ}tj|Г|jП@t|jГdks>tВtj t jГП|jjt dГГWdQRXWdQRXdS)Nzintegrity.1rr)r╘rr r!rrБr^rdrжrзrrRrLr)r#┌integrity_pathr$r$r%┌&test_index_corrupted_without_integrity_s zLRepositoryAuxiliaryCorruptionTestCase.test_index_corrupted_without_integrityc CsHtjj|jjdГ}tj|Гtj|Г|jtГП|jГWdQRXdS)Nzindex.1) rr r!rrБr╚rQr╔r─)r#┌indexr$r$r%┌test_unreadable_indexks z;RepositoryAuxiliaryCorruptionTestCase.test_unreadable_indexcCsАtjj|jjdГ}t|dГП}tjddi|Г|jГWdQRX|jП0t|jГdksZt В|jj tdГГdksrt ВWdQRXdS)Nzintegrity.1zr+bsversiong═╠╠╠╠╠@rrsfoo)rr r!rr&r┌pack┌truncater^rdrLr)r#r╓r╕r$r$r%┌test_unknown_integrity_versionrszDRepositoryAuxiliaryCorruptionTestCase.test_unknown_integrity_versioncCs|jПВd|j_t|jГdks"tВ|jjtdГГdks:tВ|jjtdГdГ|jjtdГdГ|jjГ|jjtdГdГ|jjГWdQRXtj j |jj d Г}t|d ГПN}tj |Г}|jdГ|dddks╘tВd|dd<tj||Г|jГWdQRXdS)NTrrsfoosbarrsbazsbazzzhints.5zr+bssegments)rrЬr^rdrLrr/r0rr r!r&r┌unpackr╙r┌r█)r#Z hints_pathr╕r╩r$r$r%┌_subtly_corrupted_hints_setupАs" zCRepositoryAuxiliaryCorruptionTestCase._subtly_corrupted_hints_setupc CsЬ|jГ|jПДd|j_|jjtdГdГ|jjГt|jГdksFtВ|jjtdГГdks^tВ|jjtdГГdksvtВ|jjtd ГГd ksОtВWdQRXdS)NFr.s1234rqrsfoorsbarrsbazz) r▐rrЬr/rr0r^rdrL)r#r$r$r%┌test_subtly_corrupted_hintsХs zARepositoryAuxiliaryCorruptionTestCase.test_subtly_corrupted_hintscCsЖ|jГtjj|jjdГ}tj|Г|jПRd|j_|jjtdГdГt j tГП}|jjГWdQRXdt |jГksxtВWdQRXdS)Nzintegrity.5Fr.s1234z!Corrupted segment reference count)r▐rr r!rrБrЬr/rrжrзrdr0┌str┌value)r#r╓┌exc_infor$r$r%┌-test_subtly_corrupted_hints_without_integrityвs zSRepositoryAuxiliaryCorruptionTestCase.test_subtly_corrupted_hints_without_integrity)rFrGrHr)r─r┼r╞r╟r╦r╠r═r╘r╒r╫r┘r▄r▐r▀rу┌ __classcell__r$r$)r├r%r┴s r┴c@sжeZdZddДZd*ddДZddДZd d ДZddДZd dДZddДZ ddДZ ddДZddДZddДZ ddДZddДZddДZdd ДZd!d"ДZd#d$ДZd%d&ДZd'd(ДZd)S)+┌RepositoryCheckTestCasecCs ddДtjtjj|jdГГDГS)NcSsg|]}|jdГr|СqS)zindex.)rА)r4rГr$r$r%rs▓sz8RepositoryCheckTestCase.list_indices..r)rrr r!r")r#r$r$r%┌list_indices▒sz$RepositoryCheckTestCase.list_indicesFTcCsD|j|jj|dН|Г|jddДtjtjj|jdГГDГgdГdS)N)┌repaircSsg|]}d|kr|СqS)Ztmpr$)r4rГr$r$r%rs╖sz1RepositoryCheckTestCase.check..rzFound tmp files)rPrrВrrr r!r")r#rч┌statusr$r$r%rВ┤szRepositoryCheckTestCase.checkcGs"x|D]}|jjt|ГГqWdS)N)rrLr)r#┌ids┌id_r$r$r%┌get_objects╣s z#RepositoryCheckTestCase.get_objectscCs<x6|D].}x|D]}|jjt|ГdГqW|jjГqWdS)Nsdata)rr/rr0)r#┌segmentsrщrъr$r$r%┌add_objects╜s z#RepositoryCheckTestCase.add_objectscCs,tddДtjtjj|jdddГГDГГdS)Ncss|]}|jГrt|ГVqdS)N)┌isdigitr╧)r4┌nr$r$r%· ─sz3RepositoryCheckTestCase.get_head..r┌data┌0rr9)┌sortedrrr r!r")r#r$r$r%┌get_head├sz RepositoryCheckTestCase.get_headcCs"tjtjj|jddj|jГГГГS)Nrzindex.{})rr┐rr r!r"┌formatrЇ)r#r$r$r%┌ open_index╞sz"RepositoryCheckTestCase.open_indexc Cs\|jГ}|t|Г\}}ttjj|jdddt|ГГdГП}|j|Г|j dГWdQRXdS)NrrёrЄzr+bsBOOM) rЎrr&rr r!r"rрr╙rz)r#rъ┌idxr?rCr╕r$r$r%┌corrupt_object╔s " z&RepositoryCheckTestCase.corrupt_objectcCs$tjtjj|jdddt|ГГГdS)NrrёrЄ)rrБr r!r"rр)r#r?r$r$r%rП╨sz&RepositoryCheckTestCase.delete_segmentcCs&tjtjj|jddj|jГГГГdS)Nrzindex.{})rrБr r!r"rїrЇ)r#r$r$r%┌delete_index╙sz$RepositoryCheckTestCase.delete_indexcCs6tjtjj|jddj|jГГГtjj|jd|ГГdS)Nrzindex.{})r┌renamer r!r"rїrЇ)r#┌new_namer$r$r%┌rename_index╓sz$RepositoryCheckTestCase.rename_indexcCstddД|jjГDГГS)Ncss|]}t|ГVqdS)N)r╧)r4rBr$r$r%rЁ█sz7RepositoryCheckTestCase.list_objects..)rеrr])r#r$r$r%┌list_objects┌sz$RepositoryCheckTestCase.list_objectscs╬ИjdddgddgdggГИjtddddddgГИjГГИjddНИjdГИjtЗfd d ДГИjj ГИjddНИjddНИjdddНИj dГИjddНИjtdddddgГИjГГdS) Nrrr.rqщrаT)rшcs ИjdГS)Nr■)rыr$)r#r$r%rNтszGRepositoryCheckTestCase.test_repair_corrupted_segment..F)rчrш)rэrPrеr¤rВr°rQrrrWrы)r#r$)r#r%┌test_repair_corrupted_segment▌s z5RepositoryCheckTestCase.test_repair_corrupted_segmentcCsЖ|jdddgdddggГ|jtddddddgГ|jГГ|jddН|jdГ|jjГ|jddd Н|jtdddgГ|jГГdS) Nrrr.rqr■rаT)rш)rчrш)rэrPrеr¤rВrПrrW)r#r$r$r%┌test_repair_missing_segmentэs z3RepositoryCheckTestCase.test_repair_missing_segmentcsXИjdddgdddggГИjdГИjtjЗfddДГИjtdddgГИjГГdS) Nrrr.rqr■rаcs ИjdГS)Nrq)rыr$)r#r$r%rN∙szLRepositoryCheckTestCase.test_repair_missing_commit_segment..)rэrПrQrrRrPrеr¤)r#r$)r#r%┌"test_repair_missing_commit_segmentЎs z:RepositoryCheckTestCase.test_repair_missing_commit_segmentcsдИjdddgdddggГttjjИjddd d ГdГП}|jdtjГ|jdГWdQRXИj t jЗfd dДГИjddНИj dГИjtdddgГИjГГdS)Nrrr.rqr■rаrrёrЄ┌3zr+bєXcs ИjdГS)Nrq)rыr$)r#r$r%rNszNRepositoryCheckTestCase.test_repair_corrupted_commit_segment..T)rшr9)rэr&rr r!r"r╙┌SEEK_ENDrzrQrrRrВrыrPrеr¤)r#r╕r$)r#r%┌$test_repair_corrupted_commit_segment№s z.F)rшzindex.1T)rчrшzindex.3r9)rэr&rr r!r"r╙rrzrQr┌CheckNeededrВrPrцrыrеr¤)r#r╕r$)r#r%┌test_repair_no_commitss z.RepositoryCheckTestCase.test_repair_no_commitscCs\|jdddgdddggГ|jГ|jddН|jdГ|jtddddddgГ|jГГdS) Nrrr.rqr■rаT)rш)rэr∙rВrыrPrеr¤)r#r$r$r%┌test_repair_missing_indexs z1RepositoryCheckTestCase.test_repair_missing_indexcCsВ|jdddgdddggГ|j|jГdgГ|jdГ|jd d Н|j|jГdgГ|jdГ|jtddddddgГ|jГГdS)Nrrr.rqr■rаzindex.3z index.100T)rш)rэrPrцr№rВrыrеr¤)r#r$r$r%┌test_repair_index_too_news z1RepositoryCheckTestCase.test_repair_index_too_newcCsР|jjtdГdГ|jjtdГdГtjtdГП}|jjГ|jГWdQRX|jГ|jП*|j ddН|j |jjtdГГdГWdQRXdS)Nrsdatasdata2rЕT)rч)rr/rrrЛrr0rМr-rВrPrL)r#rlr$r$r%┌test_crash_before_compact%s z1RepositoryCheckTestCase.test_crash_before_compactN)FT)rFrGrHrцrВrыrэrЇrЎr°rПr∙r№r¤r rrrrr r rr$r$r$r%rхпs& rхc@seZdZddДZdS)┌RepositoryHintsTestCasecCsд|jjtdГdГ|j|jjiГt|jjГdks6tВ|jjtdГГ|jj Г|jjtdГdГ|jj Г|j tdГ|jjГ|j d|jjГ|j d|jjГdS)Nrsdatar)rr/rrPrЦr^rlrdr1r0Z assert_not_inrь)r#r$r$r%┌test_hints_behaviour4s z,RepositoryHintsTestCase.test_hints_behaviourN)rFrGrHr r$r$r$r%r2src@sBeZdZdZdddДZddДZddДZd d ДZddДZd dДZ dS)┌RemoteRepositoryTestCaseNFcCs"ttdtjj|jdГГd|dНS)Nz__testsuite__:rT)rr)r rrr r!r")r#rr$r$r%r&HszRemoteRepositoryTestCase.opencCsGddДdГ}|ГS)Nc@s$eZdZdZdZgZdZddДZdS)z9RemoteRepositoryTestCase._get_mock_args..MockArgs┌borgщ?NcSs t||ГS)N)┌hasattr)r#┌itemr$r$r%┌__contains__SszFRemoteRepositoryTestCase._get_mock_args..MockArgs.__contains__)rFrGrH┌remote_path┌umask┌debug_topics┌rshrr$r$r$r%┌MockArgsMs rr$)r#rr$r$r%┌_get_mock_argsLs z'RemoteRepositoryTestCase._get_mock_argscsИjtЗfddДГdS)NcsИjjdiГS)N┌__init__)r┌callr$)r#r$r%rNZsz;RemoteRepositoryTestCase.test_invalid_rpc..)rQr)r#r$)r#r%┌test_invalid_rpcYsz)RemoteRepositoryTestCase.test_invalid_rpccrCsld}y|jjdddiГWnNtjk rh}z0t|jГdks@tВ|jd|jjjksXtВWYdd}~XnXy|jjdddiГWnNtj k r╬}z0t|jГdksжtВ|jd|jjjks╛tВWYdd}~XnXy|jjdddiГWnTtj k Рr:}z4t|jГdkРstВ|jd|jjjkРs*tВWYdd}~XnXy|jjddd iГWnLtk РrЮ}z.t|jГdkРsztВ|jd|kРsОtВWYdd}~XnXy|jjddd iГWnLtk Рr}z.t|jГdkРs▐tВ|jddkРsЄtВWYdd}~XnXy|jjdddiГWnhtj k РrВ}zHt|jГd kРsDtВ|jd|kРsXtВ|jd|jjjkРsrtВWYdd}~XnXy|jjdddiГWnLtk Рrц}z.t|jГdkРs┬tВ|jd|kРs╓tВWYdd}~XnXy|jjdddiГWnhtjk Рrf}zH|jРs tВ|jГdkРs2tВ|jdkРsBtВt|jГdkРsVtВWYdd}~XnXdS)Nztest stringZinject_exceptionZkind┌DoesNotExistrr┌ AlreadyExistsrrr┌foorRrrZdividez6ZeroDivisionError: integer division or modulo by zero ┌ZeroDivisionError)rrrrr^┌argsrd┌locationZ processedrrrrrRrr ZRPCErrorZunpackedZget_messageZexception_classZexception_full)r#┌s1┌er$r$r%┌test_rpc_exception_transport\sX**,&&,&z5RemoteRepositoryTestCase.test_rpc_exception_transportcCs░|jГ}||j_|jjtdГГddgks,tВ|jjtdГГddgksHtВ|jjtdГГddgksdtВ|jjtdГГddd dgksДtВd tjd<|jjtdГГdddgksмtВdS) Nzexample.com:foo┌sshzexample.comzssh://example.com/foozssh://user@example.com/foozuser@example.comzssh://user@example.com:1234/fooz-pZ1234z ssh --fooZBORG_RSHz--foo)rr┌_args┌ssh_cmdrrdr┌environ)r#r!r$r$r%┌test_ssh_cmdТs z%RemoteRepositoryTestCase.test_ssh_cmdcCs8|jjdddНtjdddgks"tВ|jГ}tjГjtj Г|jj|ddНdddd gksZtВd |_ |jj|ddНd ddd gksАtВddg|_|jj|ddНd ddd d gksмtВ|jГ}d|_|jj|ddНdddd gks┌tВd|_|jj|ddНdddd dgkРstВd|_ ||j_|jjtdГГddddgkРs4tВdS)NT)Ztestingz-mz borg.archiverZserveFrz--umask=077z--infozborg-0.28.2Zsomething_client_sideZrepository_compactionz.--debug-topic=borg.debug.repository_compactionriб░╣z--storage-quota=314159265z ssh -i foozexample.com:foor&z-irzexample.com)rZborg_cmd┌sys┌ executablerdr┌logging┌ getLogger┌setLevel┌INFOrrr▒rr'r(r)r#r!r$r$r%┌ test_borg_cmdЬs$" z&RemoteRepositoryTestCase.test_borg_cmd)F) rFrGrHrr&rrr%r*r1r$r$r$r%rEs 6 rc@seZdZdddДZddДZdS)┌RemoteLegacyFreeFc Cs<tjtddГП$ttdtjj|jdГГd|dНSQRXdS)NZ dictFormatTz__testsuite__:r)rr)rrЛr rrr r!r")r#rr$r$r%r&╢szRemoteLegacyFree.opencCsШ|jjtdГdГ|jjГ|jjГ|jГ|_|jП"|jjtdГdГ|jjГWdQRX|jГ|_|jП |jjtdГГ|jjГWdQRXdS)Nrsfoosbar)rr/rr0r*r&r1)r#r$r$r%┌test_legacy_free╗s z!RemoteLegacyFree.test_legacy_freeN)F)rFrGrHr&r3r$r$r$r%r2│s r2c@seZdZdddДZddДZdS)┌RemoteRepositoryCheckTestCaseFcCs"ttdtjj|jdГГd|dНS)Nz__testsuite__:rT)rr)r rrr r!r")r#rr$r$r%r&╬sz"RemoteRepositoryCheckTestCase.opencCsdS)Nr$)r#r$r$r%r╥sz7RemoteRepositoryCheckTestCase.test_crash_before_compactN)F)rFrGrHr&rr$r$r$r%r4╠s r4c@sLeZdZddДZddДZddДZddДZd d ДZddДZd dДZ ddДZ dS)┌RemoteLoggerTestCasecCs|tjГ|_tj|jГ|_|jgtjГjddЕ<gtjdГjddЕ<gtjdГjddЕ<tj j Гtj |_tjГ|_ t_ dS)Nzborg.repositoryzborg.repository.foo)r;┌StringIO┌streamr-┌ StreamHandler┌handlerr.┌handlersr+┌stderr┌flush┌ old_stderr)r#r$r$r%r)╪s zRemoteLoggerTestCase.setUpcCs|jt_dS)N)r=r+r;)r#r$r$r%r,уszRemoteLoggerTestCase.tearDowncCs0tdГ|j|jjГdГ|j|jjГdГdS)Nzunstructured stderr message r3z$Remote: unstructured stderr message )rrPr7┌getvaluer;)r#r$r$r%┌test_stderr_messagesцsz)RemoteLoggerTestCase.test_stderr_messagescCs0tdГ|j|jjГdГ|j|jjГdГdS)Nz%unstructured stderr progress message r3z-Remote: unstructured stderr progress message )rrPr7r>r;)r#r$r$r%┌test_stderr_progress_messagesьsz2RemoteLoggerTestCase.test_stderr_progress_messagescCsN|jjtjГtjГjtjГtdГ|j|jjГdГ|j|j jГdГdS)Nz,$LOG INFO Remote: borg < 1.1 format message z"Remote: borg < 1.1 format message r3) r9r/r-┌DEBUGr.rrPr7r>r;)r#r$r$r%┌test_pre11_format_messagesЄs z/RemoteLoggerTestCase.test_pre11_format_messagescCsN|jjtjГtjГjtjГtdГ|j|jjГdГ|j|j jГdГdS)Nz=$LOG INFO borg.repository Remote: borg >= 1.1 format message z#Remote: borg >= 1.1 format message r3) r9r/r-rAr.rrPr7r>r;)r#r$r$r%┌test_post11_format_messages·s z0RemoteLoggerTestCase.test_post11_format_messagescCsN|jjtjГtjГjtjГtdГ|j|jjГdГ|j|j jГdГdS)Nz:$LOG INFO borg.repository Remote: new format info message r3) r9r/r-┌WARNINGr.rrPr7r>r;)r#r$r$r%┌test_remote_messages_screeneds z2RemoteLoggerTestCase.test_remote_messages_screenedcCs·tjdГjtjГtjdГjtjГ|jjtjГtjГjtjГtjГ}tj|Г}|jtjГ|gtjdГj ddЕ<tjГ}tj|Г}|jtjГ|gtjdГj ddЕ<t dГ|j|jГdГ|j|jГdГ|j|j jГdГ|j|jjГdГdS)Nzborg.repositoryzborg.repository.fooz;$LOG INFO borg.repository Remote: new format child message r3z!Remote: new format child message )r-r.r/r0r9rDr;r6r8r:rrPr>r7r;)r#Zchild_streamZ child_handlerZ foo_streamZfoo_handlerr$r$r%┌ test_info_to_correct_local_childs" z5RemoteLoggerTestCase.test_info_to_correct_local_childN)rFrGrHr)r,r?r@rBrCrErFr$r$r$r%r5╫s r5)4r;r-rr+r+r'Z unittest.mockrrжZ hashindexrZhelpersrrrZlockingrr Zremoter rrr rrrrrrrrrr3rrrЛrrrIrir~rЫrвrмr│r┴rхrrr2r4r5r$r$r$r%┌sF$+s9&**n