Ë
    oj
  ã                   óÌ   — d Z ddlZddlZddlmZ 	 ddlZdZddlm	Z	 ddl
mZmZ  G d„ d	«      Z e	j                  e«        G d
„ de«      Z G d„ de«      Zy# e$ r dZY ŒJw xY w)z)
Tests for L{twisted.python.threadable}.
é    N)ÚskipIfFT)Ú
threadable)ÚFailTestÚSynchronousTestCasec                   ó    — e Zd ZdgZdZdZd„ Zy)Ú
TestObjectÚaMethodéÿÿÿÿé   c                 óî   — t        d«      D ]g  }| j                  | j                  c| _        | _        | j                  | j                  z   | _        | j                  dk(  rŒTJ d| j                  fz  «       ‚ y )Né
   r   zz == %d, not 0 as expected)ÚrangeÚyÚxÚz)ÚselfÚis     ú>/usr/lib/python3/dist-packages/twisted/test/test_threadable.pyr	   zTestObject.aMethod   sb   € Ü�r“ò 	IˆAØ!ŸV™V T§V¡VˆNˆDŒF�D”FØ—V‘V˜dŸf™f‘_ˆDŒFØ—6‘6˜Q“;ÐHÐ <ÀÇÁ¸yÑ HÓH�;ñ	Ió    N)Ú__name__Ú
__module__Ú__qualname__Úsynchronizedr   r   r	   © r   r   r   r      s   „ Ø�;€Là
€AØ	€AóIr   r   c                   óZ   — e Zd Zd„ Zd„ Z eed«      d„ «       Z eed«      d„ «       Zd„ Z	y)ÚSynchronizationTestsc                 ó’   — | j                  t        j                  t        j                  «       «       t        j                  d«       y)zì
        Reduce the CPython check interval so that thread switches happen much
        more often, hopefully exercising more possible race conditions.  Also,
        delay actual test startup until the reactor has been started.
        gH¯¼šò×z>N)Ú
addCleanupÚsysÚsetswitchintervalÚgetswitchinterval©r   s    r   ÚsetUpzSynchronizationTests.setUp)   s/   € ð 	�‰œ×-Ñ-¬s×/DÑ/DÓ/FÔGÜ×Ñ˜iÕ(r   c                 óX   — | j                  dt        j                  j                  «       y)zk
        The name of a synchronized method is inaffected by the synchronization
        decorator.
        r	   N)ÚassertEqualr   r	   r   r"   s    r   Útest_synchronizedNamez*SynchronizationTests.test_synchronizedName2   s    € ð
 	×Ñ˜¤J×$6Ñ$6×$?Ñ$?Õ@r   ú!Platform does not support threadsc                 ó  ‡— t        j                  «        g Št        j                  ˆfd„¬«      }|j	                  «        |j                  «        | j                  ‰d   d«       | j                  t        j                  «       d«       y)z˜
        L{threadable.isInIOThread} returns C{True} if and only if it is called
        in the same thread as L{threadable.registerAsIOThread}.
        c                  óJ   •— ‰ j                  t        j                  «       «      S ©N)Úappendr   ÚisInIOThread)ÚforeignResults   €r   ú<lambda>z8SynchronizationTests.test_isInIOThread.<locals>.<lambda>B   s   ø€ ˜=×/Ñ/´
×0GÑ0GÓ0IÓJ€ r   ©Útargetr   z#Non-IO thread reported as IO threadz#IO thread reported as not IO threadN)	r   ÚregisterAsIOThreadÚ	threadingÚThreadÚstartÚjoinÚassertFalseÚ
assertTruer,   )r   Útr-   s     @r   Útest_isInIOThreadz&SynchronizationTests.test_isInIOThread9   sn   ø€ ô 	×%Ñ%Ô'ØˆÜ×ÑÛJô
ˆð 	
�‰Œ	Ø	�‰ŒØ×Ñ˜ qÑ)Ð+PÔQØ�‰Ü×#Ñ#Ó%Ð'Lõ	
r   c                 ó  ‡‡— t        «       Šg Šˆˆfd„}g }t        d«      D ]9  }t        j                  |¬«      }|j	                  |«       |j                  «        Œ; |D ]  }|j                  «        Œ ‰rt        ‰«      ‚y )Nc                  ó¨   •— 	 t        d«      D ]  } ‰j                  «        Œ y # t        $ r$}‰j                  t	        |«      «       Y d }~y d }~ww xY w©Niè  )r   r	   ÚAssertionErrorr+   Ústr)r   ÚeÚerrorsÚos     €€r   ÚcallMethodLotszHSynchronizationTests.testThreadedSynchronization.<locals>.callMethodLotsQ   sG   ø€ ð&Ü˜t›ò  �AØ—I‘I•Kñ øä!ò &Ø—‘œc !›f×%Ñ%ûð&ús   ƒ $ ¤	A­AÁAé   r/   )r   r   r2   r3   r+   r4   r5   r   )r   rB   Úthreadsr   r8   r@   rA   s        @@r   ÚtestThreadedSynchronizationz0SynchronizationTests.testThreadedSynchronizationK   s‚   ù€ ä‹Lˆàˆõ	&ð ˆÜ�q“ò 	ˆAÜ× Ñ ¨Ô7ˆAØ�N‰N˜1ÔØ�G‰G�Ið	ð
 ò 	ˆAØ�F‰F�Hð	ñ Ü˜6Ó"Ð"ð r   c                 óX   — t        «       }t        d«      D ]  }|j                  «        Œ y r<   )r   r   r	   )r   rA   r   s      r   ÚtestUnthreadedSynchronizationz2SynchronizationTests.testUnthreadedSynchronizationd   s%   € Ü‹LˆÜ�t“ò 	ˆAØ�I‰I�Kñ	r   N)
r   r   r   r#   r&   r   ÚthreadingSkipr9   rE   rG   r   r   r   r   r   (   sL   „ ò)òAñ ˆMÐ>Ó?ñ
ó @ð
ñ" ˆMÐ>Ó?ñ#ó @ð#ó0r   r   c                   ó0   — e Zd Z eed«      d„ «       Zd„ Zy)ÚSerializationTestsr'   c                 óº   — t        j                  «       }t        |«      }t        j                  |«      }t        j
                  |«      }| j                  ||«       y r*   )r   ÚXLockÚtypeÚpickleÚdumpsÚloadsÚassertIsInstance)r   ÚlockÚlockTypeÚ
lockPickleÚnewLocks        r   ÚtestPicklingzSerializationTests.testPicklingk   sE   € ä×ÑÓ!ˆÜ˜“:ˆÜ—\‘\ $Ó'ˆ
Ü—,‘,˜zÓ*ˆØ×Ñ˜g xÕ0r   c                 óˆ   — d}t        j                  |«      }t        j                  |d«      }t        j                  |«       y )Ns6   ctwisted.python.threadable
unpickle_lock
p0
(tp1
Rp2
.é   )rN   rP   rO   )r   rT   rR   Ú	newPickles       r   ÚtestUnpicklingz!SerializationTests.testUnpicklings   s1   € ØSˆ
Ü�|‰|˜JÓ'ˆÜ—L‘L  qÓ)ˆ	Ü�‰�YÕr   N)r   r   r   r   rH   rV   rZ   r   r   r   rJ   rJ   j   s"   „ ÙˆMÐ>Ó?ñ1ó @ð1ó r   rJ   )Ú__doc__rN   r   Úunittestr   r2   rH   ÚImportErrorÚtwisted.pythonr   Útwisted.trial.unittestr   r   r   Úsynchronizer   rJ   r   r   r   ú<module>ra      sz   ðñó
 Û 
Ý ðÛð €Må %ß @÷
Iñ 
Ið €
× Ñ �zÔ "ô?Ð.ô ?ôD Ð,õ  øðw ò Ø‚Mðús   ’A ÁA#Á"A#