┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н 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_listcCsnx"tdГD]}|jjt|ГdГq W|jjГ|jjГ}|jjddН}|jj|ddН}xtdГD]}qbWdS)NrJsSOMEDATArK)r[r)r\r9)r:rr/rr0┌scan)r#rSr_r`rar$r$r%┌ test_scanЮs zRepositoryTestCase.test_scancsLdtЙИjjtdГИГИjИjjtdГГИГИjtЗЗfddДГdS)NєxrcsИjjtdГИdГS)Nrre)rr/rr$)┌max_datar#r$r%rN┤sz7RepositoryTestCase.test_max_data_size..)rrr/rrPrLrQr)r#r$)rfr#r%┌test_max_data_sizeпs z%RepositoryTestCase.test_max_data_sizeN)rFrGrHrTrUrVrXrYrZrbrdrgr$r$r$r%rIDsrIc@s4eZdZddДZddДZddДZddДZd d ДZdS)┌LocalRepositoryTestCasecCs|jjdГdS)Nr)r┌_rebuild_sparse)r#r$r$r%┌_assert_sparse║sz&LocalRepositoryTestCase._assert_sparsecCsL|jjtdГdГ|jjtdГdГ|jjГ|jjtdГdГ|jГdS)Nrsfoors 123456789sbar)rr/rr0rj)r#r$r$r%┌test_sparse1┬s z$LocalRepositoryTestCase.test_sparse1cCsJ|jjtdГdГ|jjtdГdГ|jjГ|jjtdГГ|jГdS)Nrsfoors 123456789)rr/rr0r1rj)r#r$r$r%┌test_sparse2╔s z$LocalRepositoryTestCase.test_sparse2cCsJ|jjtdГdГ|jjtdГГ|jjjjГ|jjdГ|jjГdS)Nrs1245) rr/rr1r;Z _write_fd┌syncrir0)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)rFrGrHrjrkrlrnrtr$r$r$r%rh╖s rhc@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^ry)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^ry)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..)r2rrvrr rwrxr!r┌objectrr r-rQ┌assert_called_once_with)r#rzrА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..)r2rrvrr rwrxr!rrВrr r-rQrГ)r#rzrА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^ry)r#r$r$r%┌-test_crash_before_deleting_compacted_segments.s zFRepositoryCommitTestCase.test_crash_before_deleting_compacted_segmentsc Cs:|jjtdГtjГ|jГ|jП|jj}WdQRXdS)Nr)rr/rrZCOMMITr-r;)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А|d7}qАW|jjtdГd Г|jjГ|jd Гx8|jjj ГD](\}}x|jjj|ГD]\}}}}qьWq╘WdS)Nrє1rє2zp1 p2 cczd1 ccrr.є3zp3 cc)rr/rr0rEr1r;rpr=rr<) r#rrZnum_deletesrArBrCrDr?┌_r$r$r%┌test_moved_deletes_are_trackedBs& z7RepositoryCommitTestCase.test_moved_deletes_are_trackedcCsо|jjj}|jjtdГdГ|Г}|jjГ|jjtdГГ|jjtdГdГ|Г}|jj|=|jj|=|jjГ|jjtdГГ|jjГtj tj j|jj d|ГГГdS)NrrЙrzindex.%d)rr;rpr/rr0r1┌compactrrxr r!)r#rpZput_segmentrЖr$r$r%┌#test_shadowed_entries_are_preserved_s z.segments_in_repositoryrsfooFT)rr/rr0rУ)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)┌RepositoryFreeSpaceTestCasecCsx|jГ|jjjdddГ|jjdГ|jГ|jП:|jjtdГdГtj t jГП|jjГWdQRXWdQRXdS)Nr┌additional_free_spaceZ1000Tsshortcut to save_configrsfoobar) r2r┌config┌setZsave_keyr-r/r┌pytest┌raisesr┌InsufficientFreeSpaceErrorr0)r#r$r$r%┌test_additional_free_space╡sz6RepositoryFreeSpaceTestCase.test_additional_free_spacec Cs,d|j_tjtjГП|jГWdQRXdS)Ng@М╡xпD)rrЩrЬrЭrrЮr2)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)┌ QuotaTestCasec CsР|jjtdГtdГГ|jjtdГtdГГ|jjtdГГ|jjГ|jГ|jП2|jjtdГdГ|jjtdГГ|jjГWdQRXdS)Nri╥ri.r.є)rr/r┌bytesr1r0r-)r#r$r$r%┌ test_tracking╔s zQuotaTestCase.test_trackingcCs▓d|j_|jjtdГdГ|jjГtjtjГП|jjtdГdГWdQRXtjtjГП|jjГWdQRX|j Г|jП*d|j_|jjtdГdГ|jjГWdQRXdS)NrKrrвrrJ) r┌ 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Э┌AssertionErrorrZget_free_nonce)r#r$r$r%┌test_get_free_nonce_assertsєsz,NonceReservation.test_get_free_nonce_assertscCsr|jПbttjj|jjdГdГП}|jdГWdQRXttjj|jjdГdГП}|jdГWdQRXWdQRXdS)N┌nonce┌wZ0000000000000000Z5000000000000000)rr&rr r!rq)r#┌fdr$r$r%┌test_get_free_nonce∙sz$NonceReservation.test_get_free_noncecCsF|jddНtjtГП&|jП|jjddГWdQRXWdQRXdS)NF)riщ)r-rЬrЭrиr┌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ГП}WdQRXtjtГП|jjddГWdQRX|jjddГttjj|jjdГdГП}WdQRXWdQRXdS)NiщrкrРi) rrЬrЭ┌ Exceptionrпr&rr r!)r#rмr$r$r%┌test_commit_nonce_reservations z.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!rrqr╖)r#rмr$r$r%┌test_corrupted_hints(sz:RepositoryAuxiliaryCorruptionTestCase.test_corrupted_hintscCs$tjtjj|jjdГГ|jГdS)Nzhints.1)rrxr r!rr╖)r#r$r$r%┌test_deleted_hints-sz8RepositoryAuxiliaryCorruptionTestCase.test_deleted_hintscCs$tjtjj|jjdГГ|jГdS)Nzindex.1)rrxr r!rr╖)r#r$r$r%┌test_deleted_index1sz8RepositoryAuxiliaryCorruptionTestCase.test_deleted_indexc CsHtjj|jjdГ}tj|Гtj|Г|jtГП|jГWdQRXdS)Nzhints.1) rr r!rrx┌mkdirrQ┌OSErrorr╖)r#┌hintsr$r$r%┌test_unreadable_hints5s z;RepositoryAuxiliaryCorruptionTestCase.test_unreadable_hintsc Cs:ttjj|jjdГdГП}|jdГWdQRX|jГdS)Nzindex.1ros 123456789)r&rr r!rrqr╖)r#rмr$r$r%┌ test_index<sz0RepositoryAuxiliaryCorruptionTestCase.test_indexcCsDttjj|jjdГdГП}|jdГWdQRX|jПWdQRXdS)Nzindex.1ros 123456789)r&rr r!rrq)r#rмr$r$r%┌test_index_outside_transactionAszDRepositoryAuxiliaryCorruptionTestCase.test_index_outside_transactionc Csttjj|jjdГ}t|dГПN}|jГ}tjtdГdГdAj ddГ}|j tdГ|Г}|jdГ|j|ГWdQRXdS)Nzindex.1zr+br┌littlerr) rr r!rr&┌read┌int┌ from_bytesr┌to_bytes┌replace┌seekrq)r#Z index_pathrмZ index_dataZ corrupted_keyZcorrupted_index_datar$r$r%┌_corrupt_indexGs z4RepositoryAuxiliaryCorruptionTestCase._corrupt_indexc Cs|jГ|jПWdQRXdS)N)r╚r)r#r$r$r%┌test_index_corruptedUsz:RepositoryAuxiliaryCorruptionTestCase.test_index_corruptedcCsb|jГtjj|jjdГ}tj|Г|jП.tjtj ГП|jj tdГГWdQRXWdQRXdS)Nzintegrity.1r)r╚rr r!rrxrЬ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!rrxr╗rQr╝r╖)r#┌indexr$r$r%┌test_unreadable_indexks z;RepositoryAuxiliaryCorruptionTestCase.test_unreadable_indexcCsVtjj|jjdГ}t|dГП}tjddi|Г|jГWdQRX|jПWdQRXdS)Nzintegrity.1zr+bsversiong═╠╠╠╠╠@)rr r!rr&r┌pack┌truncate)r#r╩rмr$r$r%┌test_unknown_integrity_versionrszDRepositoryAuxiliaryCorruptionTestCase.test_unknown_integrity_versioncCs─|jПXd|j_|jjtdГdГ|jjtdГdГ|jjГ|jjtdГdГ|jjГWdQRXtjj|jjdГ}t|dГП:}t j |Г}|jd Гd |d d<t j||Г|j ГWdQRXdS)NTrsbarrsbazsbazzzhints.5zr+brssegments)rrУr/rr0rr r!r&r┌unpackr╟r╬r╧)r#Z hints_pathrмr╜r$r$r%┌_subtly_corrupted_hints_setupАs zCRepositoryAuxiliaryCorruptionTestCase._subtly_corrupted_hints_setupc CsB|jГ|jП*d|j_|jjtdГdГ|jjГWdQRXdS)NFr.s1234)r╥rrУr/rr0)r#r$r$r%┌test_subtly_corrupted_hintsХs zARepositoryAuxiliaryCorruptionTestCase.test_subtly_corrupted_hintscCst|jГtjj|jjdГ}tj|Г|jП@d|j_|jjtdГdГt j tГП}|jjГWdQRXWdQRXdS)Nzintegrity.5Fr.s1234) r╥rr r!rrxrУr/rrЬrЭrиr0)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.)rw)r4rzr$r$r%· ▓sz8RepositoryCheckTestCase.list_indices..r)rrvr 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$)r4rzr$r$r%r╪╖sz1RepositoryCheckTestCase.check..rzFound tmp files)rPrryrrvr r!r")r#r┌┌statusr$r$r%ry┤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)┌sortedrrvr 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"┌strr╟rq)r#r▌┌idxr?rCrмr$r$r%┌corrupt_object╔s " z&RepositoryCheckTestCase.corrupt_objectcCs$tjtjj|jdddt|ГГГdS)Nrrфrх)rrxr r!r"rъ)r#r?r$r$r%rЖ╨sz&RepositoryCheckTestCase.delete_segmentcCs&tjtjj|jddj|jГГГГdS)Nrzindex.{})rrxr 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.щщщT)r█cs ИjdГS)Nrє)r▐r$)r#r$r%rNтszGRepositoryCheckTestCase.test_repair_corrupted_segment..F)r┌r█)rрrPrЫrёryrь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.rЄrєrЇT)r█)r┌r█)rрrPrЫrёryrЖrrW)r#r$r$r%┌test_repair_missing_segmentэs z3RepositoryCheckTestCase.test_repair_missing_segmentcsXИjdddgdddggГИjdГИjtjЗfddДГИjtdddgГИjГГdS) Nrrr.rЄrєrЇcs ИjdГS)NrЄ)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.rЄrєrЇrrфrх┌3zr+bєXcs ИjdГS)NrЄ)r▐r$)r#r$r%rNszNRepositoryCheckTestCase.test_repair_corrupted_commit_segment..T)r█r9)rрr&rr r!r"r╟┌SEEK_ENDrqrQrrRryr▐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╟r·rqrQr┌CheckNeededryrPr┘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.rЄrєrЇT)r█)rрrэryr▐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.rЄrєrЇzindex.3z index.100T)r█)rрrPr┘rЁryr▐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-ryrPrL)r#rОr$r$r%┌test_crash_before_compact%s z1RepositoryCheckTestCase.test_crash_before_compactN)FT)rFrGrHr┘ryr▐rрrчrщrьrЖrэrЁrёrїrЎrўr√r■r rrr$r$r$r%r╫пs& r╫c@seZdZddДZdS)┌RepositoryHintsTestCasecCsР|jjtdГdГ|j|jjiГ|jjtdГГ|jjГ|jjtdГdГ|jjГ|jtdГ|jjГ|jd|jjГ|jd|jj ГdS)Nrsdatar) rr/rrPZshadow_indexr1r0Z assert_not_inrОr▀)r#r$r$r%┌test_hints_behaviour4s z,RepositoryHintsTestCase.test_hints_behaviourN)rFrGrHrr$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..MockArgsZborgщ?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 r r$)r#r r$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_rpccrCsъd}y|jjdddiГWn$tjk r>}zWYdd}~XnXy|jjdddiГWn$tjk rz}zWYdd}~XnXy|jjdddiГWn$tjk r╢}zWYdd}~XnXy|jjdddiГWn"tk rЁ}zWYdd}~XnXy|jjdddiГWn$tk Рr,}zWYdd}~XnXy|jjddd iГWn&tjk Рrj}zWYdd}~XnXy|jjddd iГWn$t k Рrж}zWYdd}~XnXy|jjdddiГWn&t jk Рrф}zWYdd}~XnXdS)Nztest stringZinject_exceptionZkind┌DoesNotExist┌ AlreadyExistsr¤rrrRrZdivide)rrrrrr¤rrrRrr ZRPCError)r#┌s1┌er$r$r%┌test_rpc_exception_transport\sBz5RemoteRepositoryTestCase.test_rpc_exception_transportcCs|jГ}||j_dtjd<dS)Nz ssh --fooZBORG_RSH)rr┌_argsr┌environ)r#┌argsr$r$r%┌test_ssh_cmdТs z%RemoteRepositoryTestCase.test_ssh_cmdcCsN|jГ}tjГjtjГd|_ddg|_|jГ}d|_d|_d|_||j _ dS)Nzborg-0.28.2Zsomething_client_sideZrepository_compactionriб░╣z ssh -i foo)r┌logging┌ getLogger┌setLevel┌INFOr rrеrrr)r#rr$r$r%┌ test_borg_cmdЬs z&RemoteRepositoryTestCase.test_borg_cmd)F) rFrGrHrr&rrrrrr$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&r!r$r$r$r%r │s r c@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%r"╠s r"c@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┌handlers┌sys┌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 )rrPr%┌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 )rrPr%r-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) r'rr┌DEBUGrrrPr%r-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) r'rrr0rrrPr%r-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) r'rr┌WARNINGrrrPr%r-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 )rrrrr'r3r;r$r&r(rrPr-r%r*)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/r1r2r4r5r$r$r$r%r#╫s r#)4r;rrr+r)r'Z unittest.mockrrЬZ hashindexrZhelpersrrrZlockingrr Zremoter rrr rrrrrrrrrr3rrrВrrrIrhrurТrШrбrзr┤r╫rrr r"r#r$r$r$r%┌sF$+s9&**n