o <Æ&iÔã@s^ddlZddlZddlZddlmZGdd„dƒZGdd„dejjƒZGdd„dejj ƒZ dS) éN)ÚForkingPicklerc@s0eZdZdZdd„Zdd„Zdd„Zdd „Zd S) ÚConnectionWrapperz_Proxy class for _multiprocessing.Connection which uses ForkingPickler for object serialization.cCs ||_dS©N)Úconn)Úselfr©rúFC:\wamp64\www\opt\env\Lib\site-packages\torch/multiprocessing/queue.pyÚ__init__ s zConnectionWrapper.__init__cCs,t ¡}t|tjƒ |¡| | ¡¡dSr)ÚioÚBytesIOrÚpickleÚHIGHEST_PROTOCOLÚdumpZ send_bytesÚgetvalue)rÚobjÚbufrrrÚsend szConnectionWrapper.sendcCs| ¡}t |¡Sr)Z recv_bytesr Úloads)rrrrrÚrecvs zConnectionWrapper.recvcCs,d|jvr t|j|ƒStdt|ƒj›dƒ‚)Nrú'z ' object has no attribute 'conn')Ú__dict__ÚgetattrrÚAttributeErrorÚtypeÚ__name__)rÚnamerrrÚ __getattr__s  zConnectionWrapper.__getattr__N)rÚ __module__Ú __qualname__Ú__doc__r rrrrrrrrs  rcóeZdZ‡fdd„Z‡ZS)ÚQueuecsBtƒj|i|¤Žt|jƒ|_t|jƒ|_|jj|_|jj|_dSr) Úsuperr rÚ_readerÚ_writerrZ_sendrZ_recv)rÚargsÚkwargs©Ú __class__rrr s    zQueue.__init__)rrrr Ú __classcell__rrr'rr!ór!cr )Ú SimpleQueuecs2t|jtƒst|jƒ|_t|jƒ|_tƒ ¡dSr)Ú isinstancer#rr$r"Ú _make_methods)rr'rrr-&s   zSimpleQueue._make_methods)rrrr-r)rrr'rr+%r*r+) r Zmultiprocessing.queuesÚmultiprocessingr Zmultiprocessing.reductionrrÚqueuesr!r+rrrrÚs