U <ºc'ã@sVdZddlZddlZddlZddlmZddlmZddlm Z dd„Z dd d „ZdS)zÍ"Contains definitions of the methods used by the _BaseDataLoaderIter to put fetched tensors into pinned memory. These **needs** to be in global scope since Py2 doesn't support serializing static methods. éN)Ústring_classesé)ÚMP_STATUS_CHECK_INTERVAL)ÚExceptionWrappercs>t d¡tj ˆ¡‡‡‡‡‡fdd„}ˆ ¡s:|ƒq*dS)NrcsÀzˆjtd}Wntjk r(YdSX|\}}ˆ ¡s€t|tƒs€zt|ˆƒ}Wn$tk rvtd ˆ¡d}YnX||f}ˆ ¡s¼zˆj |tdWq¼Wq€tjk r¸Yq€Yq€Xq€dS)N)Útimeoutz"in pin memory thread for device {})Úwhere)ÚgetrÚqueueÚEmptyÚis_setÚ isinstancerÚ pin_memoryÚ ExceptionÚformatÚputÚFull)ÚrÚidxÚdata©ÚdeviceÚ device_idÚ done_eventÚin_queueÚ out_queue©úF/tmp/pip-unpacked-wheel-gikjz4vx/torch/utils/data/_utils/pin_memory.pyÚdo_one_steps&ÿz%_pin_memory_loop..do_one_step)ÚtorchZset_num_threadsZcudaZ set_devicer)rrrrrrrrrÚ_pin_memory_loops rcs>t|tjƒr| ˆ¡St|tƒr$|St|tjjƒr€z t|ƒ‡fdd„| ¡DƒƒWSt k r|‡fdd„| ¡DƒYSXnºt|tƒr®t|dƒr®t|ƒ‡fdd„|DƒŽSt|tƒrÊ‡fdd„|DƒSt|tjj ƒr"zt|ƒ‡fd d„|DƒƒWSt k r‡fd d„|DƒYSXnt|dƒr6| ¡S|SdS)Ncsi|]\}}|t|ˆƒ“qSr©r ©Ú.0ÚkÚsample©rrrÚ :szpin_memory..csi|]\}}|t|ˆƒ“qSrr r!r%rrr&=sÚ_fieldsc3s|]}t|ˆƒVqdS)Nr ©r"r$r%rrÚ ?szpin_memory..csg|]}t|ˆƒ‘qSrr r(r%rrÚ Aszpin_memory..csg|]}t|ˆƒ‘qSrr r(r%rrr*Dscsg|]}t|ˆƒ‘qSrr r(r%rrr*Gsr )rrZTensorr rÚcollectionsÚabcÚMappingÚtypeÚitemsÚ TypeErrorÚtupleÚhasattrÚSequence)rrrr%rr 3s* r )N)Ú__doc__r+r rZ torch._sixrÚrZtorch._utilsrrr rrrrÚs"