a ‘º”h®ã@sJUddlZddlZddlmZmZddlZddlmZgd¢Ze e e d<e edœdd„Z e ejd ƒse ejd ƒrxJ‚e ejd ƒrˆJ‚e ejd ƒr˜J‚e ejd ƒr¨J‚e ejdƒr¸J‚e d ƒejjd <e d ƒejjd <e d ƒejjd <e d ƒejjd <e d ƒejjd <e dƒejjd<eddœdd„Zeddœdd„ZGdd„dƒZdS)éN)ÚCallableÚOptional)ÚStorage)Úgds_register_bufferÚgds_deregister_bufferÚGdsFileÚ__all__)ÚnameÚreturncs‡fdd„}|S)Ncstdˆ›dƒ‚dS)Nz torch._C.z" is not supported on this platform)Ú RuntimeError)ÚargsÚkwargs©r ©ú.fnr)r rrrrÚ _dummy_fns rÚ_gds_register_bufferÚ_gds_deregister_bufferÚ_gds_register_handleÚ_gds_deregister_handleÚ_gds_load_storageÚ_gds_save_storage)Úsr cCstj |¡dS)a:Registers a storage on a CUDA device as a cufile buffer. Example:: >>> # xdoctest: +SKIP("gds filesystem requirements") >>> src = torch.randn(1024, device="cuda") >>> s = src.untyped_storage() >>> gds_register_buffer(s) Args: s (Storage): Buffer to register. N)ÚtorchÚ_Cr©rrrrr&s rcCstj |¡dS)awDeregisters a previously registered storage on a CUDA device as a cufile buffer. Example:: >>> # xdoctest: +SKIP("gds filesystem requirements") >>> src = torch.randn(1024, device="cuda") >>> s = src.untyped_storage() >>> gds_register_buffer(s) >>> gds_deregister_buffer(s) Args: s (Storage): Buffer to register. N)rrrrrrrr6src@sreZdZdZeedœdd„Zddœdd„Zddœd d „Zddœd d „Z de eddœdd„Z de eddœdd„Z dS)ra“Wrapper around cuFile. cuFile is a file-like interface to the GPUDirect Storage (GDS) API. See the `cufile docs `_ for more details. Args: filename (str): Name of the file to open. flags (int): Flags to pass to ``os.open`` when opening the file. ``os.O_DIRECT`` will be added automatically. Example:: >>> # xdoctest: +SKIP("gds filesystem requirements") >>> src1 = torch.randn(1024, device="cuda") >>> src2 = torch.randn(2, 1024, device="cuda") >>> file = torch.cuda.gds.GdsFile(f, os.O_CREAT | os.O_RDWR) >>> file.save_storage(src1.untyped_storage(), offset=0) >>> file.save_storage(src2.untyped_storage(), offset=src1.nbytes) >>> dest1 = torch.empty(1024, device="cuda") >>> dest2 = torch.empty(2, 1024, device="cuda") >>> file.load_storage(dest1.untyped_storage(), offset=0) >>> file.load_storage(dest2.untyped_storage(), offset=src1.nbytes) >>> torch.equal(src1, dest1) True >>> torch.equal(src2, dest2) True )ÚfilenameÚflagscCsDtjdkrtdƒ‚||_||_t ||tjB¡|_d|_ |  ¡dS)NÚwin32z*GdsFile is not supported on this platform.) ÚsysÚplatformr rrÚosÚopenÚO_DIRECTÚfdÚhandleÚregister_handle)ÚselfrrrrrÚ__init__gs zGdsFile.__init__N)r cCs"|jdur| ¡t |j¡dS)N)r&Úderegister_handler"Úcloser%©r(rrrÚ__del__ps zGdsFile.__del__cCs&|jdusJdƒ‚tj |j¡|_dS)zpRegisters file descriptor to cuFile Driver. This is a wrapper around ``cuFileHandleRegister``. Nz4Cannot register a handle that is already registered.)r&rrrr%r,rrrr'us ÿþzGdsFile.register_handlecCs*|jdusJdƒ‚tj |j¡d|_dS)zvDeregisters file descriptor from cuFile Driver. This is a wrapper around ``cuFileHandleDeregister``. Nz2Cannot deregister a handle that is not registered.)r&rrrr,rrrr*s ÿþzGdsFile.deregister_handler)ÚstorageÚoffsetr cCs(|jdusJdƒ‚tj |j||¡dS)amLoads data from the file into the storage. This is a wrapper around ``cuFileRead``. ``storage.nbytes()`` of data will be loaded from the file at ``offset`` into the storage. Args: storage (Storage): Storage to load data into. offset (int, optional): Offset into the file to start loading from. (Default: 0) Nz4Cannot load data from a file that is not registered.)r&rrr©r(r.r/rrrÚ load_storageŠs ÿþzGdsFile.load_storagecCs(|jdusJdƒ‚tj |j||¡dS)aUSaves data from the storage into the file. This is a wrapper around ``cuFileWrite``. All bytes of the storage will be written to the file at ``offset``. Args: storage (Storage): Storage to save data from. offset (int, optional): Offset into the file to start saving to. (Default: 0) Nz2Cannot save data to a file that is not registered.)r&rrrr0rrrÚ save_storage™s ÿþzGdsFile.save_storage)r)r) Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚstrÚintr)r-r'r*rr1r2rrrrrGs   r)r"r ÚtypingrrrZ torch.typesrrÚlistr7Ú__annotations__rÚhasattrrÚ__dict__rrrrrrrÚs*