§
|<ˆje ã óž — d Z ddlmZmZmZmZmZ ddlmZm Z m
Z
mZmZm
Z
ddlmZ ddlZddlmZ ddlZddlZddlmZ G d„ d e¦ « ZdS )
zTest for object dbé )ÚTestBaseÚDummyStreamÚ
make_bytesÚmake_objectÚfixture_path)ÚDecompressMemMapReaderÚFDCompressedSha1WriterÚ
LooseObjectDBÚ
Sha1WriterÚMemoryDBÚIStream)Ú
hex_to_binN)Ú
str_blob_type)ÚBytesIOc ó: — e Zd ZdZdZd„ fd„Zd„ Zd„ Zd„ Zd„ Z d S )
Ú
TestStreamzTest stream classes)é i' i ¢ c ó — d S )N© )Úss úh/builddir/build/BUILD/cloudlinux-venv-1.0.12/venv/lib/python3.11/site-packages/gitdb/test/test_stream.pyúzTestStream.) s € È4€ ó c ó — d}t |¦ « |dz
k sJ d|t |¦ « fz ¦ « ‚t |¦ « |z }t |¦ « D ]2}| |¦ « }|||z |dz |z … }||k sJ ‚Œ3| ¦ « } | r| |t | ¦ « d… k sJ ‚t |t ¦ « r9t | ¦ « ¦ « | ¦ « k sJ ‚ ||¦ « | ¦ « }
|
|k sJ ‚t |t ¦ « r9t | ¦ « ¦ « | ¦ « k sJ ‚dS dS )a Make stream tests - the orig_stream is seekable, allowing it to be
rewound and reused
:param cdata: the data we expect to read from stream, the contents
:param rewind_stream: function called to rewind the stream to make it ready
for reuseé
é z#Data must be larger than %i, was %iN)ÚlenÚrangeÚreadÚ
isinstancer ÚdataÚcompressed_bytes_read)ÚselfÚstreamÚcdataÚ
rewind_streamÚnsÚssÚir! ÚchunkÚrestÚrdatas r Ú_assert_stream_readerz TestStream._assert_stream_reader) sœ € ð ˆÝ�5‰zŒz˜B ™FÒ"Ð"Ð"Ð$IÈRÕQTÐUZÑQ[ÔQ[ÐL\Ñ$\Ñ"Ô"Ð"õ �‰ZŒZ˜2Ñ
ˆÝ�r‘”ð !ð !ˆAØ—;’;˜r‘?”?ˆDؘ!˜b™& ! a¡%¨2¡Ð-Ô.ˆEؘ5’=�=�=�=�=à�{Š{‰}Œ}ˆØð .ؘ5¥# d¡)¤) Ô-Ò-Ð-Ð-Ð-õ �fÕ4Ñ5Ô5ð HÝ�v—{’{‘}”}Ñ%Ô%¨×)EÒ)EÑ)GÔ)GÒGÐGÐGÐGð ˆ
�fÑÔÐð —’‘
”
ˆØ˜Š~ˆ~ˆ~ˆ~å�fÕ4Ñ5Ô5ð HÝ�v—{’{‘}”}Ñ%Ô%¨×)EÒ)EÑ)GÔ)GÒGÐGÐGÐGð Hð HØGÐGr c
óÐ — t d¦ « D �]T}t d¦ « D �]@}| j D �]4}t |d¬¦ « }|rŽt j t t |¦ « ¦ « }t j ||¦ « \ }}}|t |¦ « k sJ ‚|t k sJ ‚t |d¬¦ « } | j
t |¦ « k sJ ‚nLt j |¦ « }t ||t |¦ « ¦ « }|j
t |¦ « k sJ ‚| ||d„ ¦ « t ¦ « }
|
|_
|
j rJ ‚~|
j |k sJ ‚�Œ6�ŒB�ŒVd S )Né F©Ú randomize)Úclose_on_deletionc ó, — | d¦ « S )Nr )Úseek)Úrs r r z3TestStream.test_decompress_reader..g s € ÈÏÊÈqÉ Ì € r )r Ú
data_sizesr ÚzlibÚcompressr r r Únewr Ú_sr- r Ú_mÚclosed)r# r2 Ú with_sizeÚdsr% ÚzdataÚtypÚsizeÚreaderÚtest_readerÚdummys r Útest_decompress_readerz!TestStream.test_decompress_readerL s™ € Ý!& q¡¤ð " =ñ " =ÐÝ" 1™XœXð !
=ñ !
=� Øœ/ð =ñ =�BÝ& r°UÐ;Ñ;Ô;�Eð !ð 7å $¤
k½-ÈÑ.OÔ.OÑ PÔ P˜Ý,BÔ,FÀuÐN_Ñ,`Ô,`Ñ)˜˜T 6Ø#¥s¨5¡z¤zÒ1Ð1Ð1Ð1Ø"¥mÒ3Ð3Ð3Ð3õ '=¸UÐV[Ð&\Ñ&\Ô&\˜Ø*œ~µ°U±´Ò;Ð;Ð;Ð;Ð;õ !%¤
¨eÑ 4Ô 4˜Ý!7¸Ð?PÕRUÐV[ÑR\ÔR\Ñ!]Ô!]˜Ø%œyC°©J¬JÒ6Ð6Ð6Ð6ð ×.Ò.¨v°uÐ>QÐ>QÑRÔRÐRõ (™MœM�EØ %�F”Ià$œ|Ð+Ð+Ð+ØØ œ<Ð+<Ò<Ð<Ð<Ð<Ñ<ñA =ñ!
=ð" =ð " =r c ó‚ — t ¦ « }d| d¦ « k sJ ‚t | d¬¦ « ¦ « dk sJ ‚t | d¬¦ « ¦ « dk sJ ‚| ¦ « }| d¦ « | ¦ « |k sJ ‚d S ) Nr/ s hir )Úas_hexé( r é s hi again)r Úwriter Úsha)r# ÚwriterÚprev_shas r Útest_sha_writerzTestStream.test_sha_writert s¶ € Ý‘”ˆØ�F—L’L Ñ'Ô'Ò'Ð'Ð'Ð'Ý�6—:’: Q�:Ñ'Ô'Ñ(Ô(¨BÒ.Ð.Ð.Ð.Ý�6—:’: Q�:Ñ'Ô'Ñ(Ô(¨BÒ.Ð.Ð.Ð.ð —:’:‘<”<ˆØ�Š�[Ñ!Ô!Ð!Ø�zŠz‰|Œ|˜xÒ'Ð'Ð'Ð'Ð'Ð'r c
ó — | j D �]x}t j ¦ « \ }}t |¦ « }t |d¬¦ « }t |¦ « | |¦ « k sJ ‚| ¦ « | t t j |¦ « t j |t j t t dd¦ « z ¦ « }t j |t j |¦ « ¦ « }t |¦ « t j |¦ « k sJ ‚t j |¦ « |t# j |d¦ « k sJ ‚t j |¦ « �Œzd S )NFr0 ÚO_BINARYr r )r6 ÚtempfileÚmkstempr r r rJ ÚcloseÚassertRaisesÚOSErrorÚosÚopenÚO_RDONLYÚgetattrr ÚpathÚgetsizer7 r8 Úremove)r# r> ÚfdrZ Úostreamr! Úwritten_datas r Útest_compressed_writerz!TestStream.test_compressed_writer sA € Ø”/ð ñ ˆBÝÔ'Ñ)Ô)‰HˆB�Ý,¨RÑ0Ô0ˆGݘb¨EÐ2Ñ2Ô2ˆDõ �t‘9”9 §
¢
¨dÑ 3Ô 3Ò3Ð3Ð3Ð3Ø�MŠM‰OŒOˆOð
×Ò�g¥r¤x°Ñ4Ô4Ð4õ ”˜�rœ{WµR¸ÀQÑ-GÔ-GÑGÑHÔHˆBÝœ7 2¥r¤w§¢°tÑ'<Ô'<Ñ=Ô=ˆLÝ�|Ñ$Ô$¬¯ª¸Ñ(=Ô(=Ò=Ð=Ð=Ð=ÝŒH�R‰LŒLˆLØ¥4¤=°°qÑ#9Ô#9Ò9Ð9Ð9Ð9åŒI�d‰OŒOˆO‰Oð' ð r c
ó” — t t d¦ « ¦ « }t ¦ « }dD ]š}| t |¦ « ¦ « }| ¦ « }t
|¦ « |j k sJ ‚| t |j
|j t |¦ « ¦ « ¦ « }|j |k sJ ‚Œ›d S )NÚobjects)s( 888401851f15db0eed60eb1bc29dec5ddcace911s( 7bb839852ed5e3a069966281bb08d50012fb309b)
r
r r r$ r r r rA Ústorer
Útyper Úhexsha)r# ÚodbÚmdbrK r^ r! Údumps r Ú#test_decompress_reader_special_casez.TestStream.test_decompress_reader_special_case– sº € Ý�L¨Ñ3Ô3Ñ4Ô4ˆÝ‰jŒjˆðBð
&ð