o U˟i@s`ddlmZddlmZddlmZGdddejZGdddej Z e dkr.e dSdS) )lockN)test__semaphorec@seZdZddZddZdS)TestRLockMultiThreadcCstSN)rRLock)selfr_/var/www/apps/myagent/mysuperagent/venv/lib/python3.10/site-packages/gevent/tests/test__lock.py_makeOne s zTestRLockMultiThread._makeOnecCs||jjdSr) assertIsNone_blockhub)rsemrrr assertOneHasNoHubsz&TestRLockMultiThread.assertOneHasNoHubN)__name__ __module__ __qualname__r rrrrr rs rc@seZdZddZdS)TestLockReinitAfterForkcCsjddl}ddl}ddl}ddl}t|ds|d|d}|j|jd|g|j d d}| |dS)NrforkzRequires os.forka from gevent import monkey monkey.patch_all() from gevent import spawn import os from logging import Handler from threading import Event handler = Handler() handler.acquire() event = Event() def forker(): event.set() handler.acquire() handler.release() os.fork() g = spawn(forker) event.wait() handler.release() g.join() z-c)stderrzutf-8) sys subprocesstextwraposhasattrskipTestdedent check_output executableSTDOUTdecode assertFalse)rrrrrscriptoutputrrr test_its    zTestLockReinitAfterFork.test_itN)rrrr$rrrr rs r__main__) geventrgevent.testingtesting greentest gevent.testsrTestSemaphoreMultiThreadrTestCaserrmainrrrr s  2