U .Wjÿ ã@sÆdZddlmZGdd„dƒZdd„Zde_dd „Zd d „Zd d „Zdd„Z ddd„Z e ƒZ dd„Z dd„Zdd„Zdadadadaz ddlZWnek r¨dZYnXeZe dƒddddgZdS)zT A module to provide some very basic threading primitives, such as synchronization. é©Úwrapsc@seZdZdZdd„ZdS)Ú DummyLockzF Hack to allow locks to be unpickled on an unthreaded system. cCstdfS©N©©Ú unpickle_lock©Úselfrrúdc:\users\psant\downloads\hotstarbackend\school\venv38\Lib\site-packages\twisted/python/threadable.pyÚ __reduce__szDummyLock.__reduce__N)Ú__name__Ú __module__Ú __qualname__Ú__doc__r rrrr rsrcCstdk rtƒStƒSdS©N)ÚthreadingmoduleÚXLockrrrrr rsrTcCs>d|jkr0t ¡d|jkr(tƒ|jd<t ¡|j ¡dS)NÚ_threadable_lock)Ú__dict__Ú_synchLockCreatorÚacquirerÚreleaserr rrr Ú _synchPre!s    rcCs|j ¡dSr)rrr rrr Ú _synchPost*srcstˆƒ‡fdd„ƒ}|S)Ncs,t|ƒzˆ|f|ž|ŽW¢St|ƒXdSr)rr)r ÚargsÚkwargs©Úfunctionrr Úsync/sz_sync..syncr)Úklassrrrrr Ú_sync.sr!cGs>tdk r:|D],}|jD] }t||j|ƒ}t|||ƒqq dS)a& Make all methods listed in each class' synchronized attribute synchronized. The synchronized attribute should be a list of strings, consisting of the names of methods that must be synchronized. If we are running in threaded mode these methods will be wrapped with a lock. N)rZ synchronizedr!rÚsetattr)Zklassesr Ú methodNamerrrr Ú synchronize:s  r$écCsJ|r8tsFtdk r.daGdd„dtjƒatƒaqFtdƒ‚ntrFtdƒ‚ndS)zbInitialize threading. Don't bother calling this. If it needs to happen, it will happen. NTc@seZdZdd„ZdS)rcSstdfSrrr rrr r VszXLock.__reduce__N)r rrr rrrr rUsrz:Cannot initialize threading, platform lacks thread supportzCannot uninitialize threads)ÚthreadedrÚ_RLockrrÚ RuntimeError)Z with_threadsrrr ÚinitIsÿ r)cCstdkr tSt ¡jSr)rÚ_dummyIDÚcurrent_threadÚidentrrrr Ú getThreadIDhsr-cCs ttƒkS)zCAre we in the thread responsible for I/O requests (the event loop)?)ÚioThreadr-rrrr Ú isInIOThreadnsr/cCs tƒadS)z8Mark the current thread as responsible for I/O requests.N)r-r.rrrr ÚregisterAsIOThreadssr0NFr)r%)rÚ functoolsrrrZ__safe_for_unpickling__rrr!r$r)Úobjectr*r-r/r0r.r&rrÚ threadingZ_threadingmoduleÚ ImportErrorrÚ__all__rrrr Ús0