U ʹjG @sUddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZ ddlZddlZddlmZmZmZmZmZmZmZmZmZmZddlmZddlZddl Z ddl!Z!ddl"m#Z#ddl$m%Z%m&Z&dZ'dXee(e)ee*ddd d Z+dYe)e)e*dd d dZ,dZe)e*e)dddZ-e)e)ee.dddZ/d[e)ee)e.dddZ0d\e)e*e)dddZ1e)ee)dddZ2d]e)e)ee)ee)e*dd d!d"Z3d^e)e.ee)d$d%d&Z4d_e)e)e.ee)d'd(d)Z5d`e*ee(ee(fd*d+d,Z6dae)e)ee)ee)d-d.d/Z7e)e)ee)dd0d1d2Z8ej9ej:d3Z;ee)e*feee)ee)e)ee)gdffeZAee)eee)ee)ffe0z_urlretrieve..r,)r)urllibrequesturlopenRequest USER_AGENTriterr)r!r"r#rr)r _urlretrieve.sr3)fpathr#rc CsXtjdkrtjdd}nt}t|d }||}rF||q,W5QRX|S)N) F)Zusedforsecurityrb)sys version_infohashlibmd5rr(r hexdigest)r5r#r<frrrr calculate_md53s  r?)r5r<kwargsrcKs|t|f|kSr')r?)r5r<r@rrr check_md5AsrA)r5r<rcCs&tj|sdS|dkrdSt||S)NFT)ospathisfilerA)r5r<rrrcheck_integrityEs  rEr6)r!max_hopsrc Cs|}dtd}t|dD]V}tjtjj||d4}|j|ksL|jdkr`|W5QRS|j}W5QRXqtd|d|d|ddS) NHEAD)ZMethodr$r%z Request to z exceeded z( redirects. The last redirect points to .)r1ranger-r.r/r0r!RecursionError)r!rFZ initial_urlr&_r*rrr_get_redirect_urlMs rM)r!rcCsBt|}td|jdkrdStd|j}|dkr8dS|dS)Nz(drive|docs)[.]google[.]comz/file/d/(?P[^/]*)id)r rematchnetlocrCgroup)r!partsrPrrr_get_google_drive_file_id]srT)r!rootr"r<max_redirect_hopsrc Cs8tj|}|stj|}tj||}tj|ddt||rRtd|dStrdt ||nt ||d}t |}|dk rt ||||Sz"td|d|t ||Wnntjjtfk r}zF|ddd kr |d d }td |d|t ||n|W5d}~XYnXt||s4td dS)aDownload a file from a url and place it in root. Args: url (str): URL to download file from root (str): Directory to place downloaded file in filename (str, optional): Name to save the file under. If None, use the basename of the URL md5 (str, optional): MD5 checksum of the download. If None, do not check max_redirect_hops (int, optional): Maximum number of redirect hops allowed Texist_okz$Using downloaded and verified file: N)rFz Downloading  to httpszhttps:zhttp:z;Failed download. Trying https -> http instead. Downloading zFile not found or corrupted.)rBrC expanduserbasenamejoinmakedirsrEprintrrrMrTdownload_file_from_google_driver3r-errorURLErrorOSErrorreplace RuntimeError)r!rUr"r<rVr5file_iderrr download_urljs2         riF)rUprefixrcsBtjfddtD}|dkr>fdd|D}|S)a List all directories at a given root Args: root (str): Path to directory whose folders need to be listed prefix (bool, optional): If true, prepends the path to each result, otherwise only returns the name of the directories found cs&g|]}tjtj|r|qSr)rBrCisdirr^.0prUrr szlist_dir..Tcsg|]}tj|qSrrBrCr^rmdrorrrpsrBrCr\listdir)rUrj directoriesrrorlist_dirs  rw)rUsuffixrjrcsDtjfddtD}|dkr@fdd|D}|S)aList all files ending with a suffix at a given root Args: root (str): Path to directory whose folders need to be listed suffix (str or tuple): Suffix of the files to match, e.g. '.png' or ('.jpg', '.png'). It uses the Python "str.endswith" method and is passed directly prefix (bool, optional): If true, prepends the path to each result, otherwise only returns the name of the files found cs0g|](}tjtj|r|r|qSr)rBrCrDr^endswithrlrUrxrrrps zlist_files..Tcsg|]}tj|qSrrqrrrorrrpsrt)rUrxrjfilesrrzr list_filess r|)r#rcCst||}d}|st|}qt|g|}z(td|}|dk rL|dnd}Wntk rjd}YnX||fS)Nz3Google Drive - (?P<api_response>.+?) api_response) iter_contentnext itertoolschainrOsearchdecodeUnicodeDecodeError)r*r#rZ first_chunkrPr}rrr_extract_gdrive_api_responses   r)rgrUr"r<c Cstj|}|s|}tj||}tj|ddt||rZtd|rFdndd|dSd}t|d d }t }|j ||dd }|j D]\} } | d r| } qqt|\} } | d krdnd} | dk r|j |t|| ddd }t|\} } | dkr td|dt| |W5QRXt|jdkrtt@t|,}|}td|rntd|W5QRXW5QRX|rt||std|ddS)afDownload a Google Drive file from and place it in root. Args: file_id (str): id of file to be downloaded root (str): Directory to place downloaded file in filename (str, optional): Name to save the file under. If None, use the id of the file. md5 (str, optional): MD5 checksum of the download. If None, do not check TrWzUsing downloaded z and verified zfile: Nzhttps://drive.google.com/ucdownload)rNZexport)paramsstreamZdownload_warningzVirus scan warningt)ZconfirmzQuota exceededzThe daily quota of the file z} is exceeded and it can't be downloaded. This is a limitation of Google Drive and can only be overcome by trying again later.i(z5]*\s*>|(&(?:[\w\d]+|#\d+|#x[a-f\d]+);)zWe detected some HTML elements in the downloaded file. This most likely means that the download triggered an unhandled API response by GDrive. Please report this to torchvision at https://github.com/pytorch/vision/issues including the response: z&The MD5 checksum of the download file z does not match the one on record.Please delete the file and try again. If the issue persists, please report this to torchvision at https://github.com/pytorch/vision/issues.)rBrCr\r^r_rEr`dictrequestsSessiongetcookiesitems startswithrrfrstatst_size contextlibsuppressrrr(rOrwarningswarnrA)rgrUr"r<r5r!rsessionr*keyvaluetokenr}rrtextrrrrasJ          ra) from_pathto_path compressionrc Cs<t||rd|ddnd}||W5QRXdS)Nzr:rHr)tarfiler extractall)rrrtarrrr _extract_tars$r).bz2.xz_ZIP_COMPRESSION_MAPc Cs8tj|d|rt|ntjd}||W5QRXdS)Nr)r)zipfileZipFiler ZIP_STOREDr)rrrziprrr _extract_zipsr).tarz.zip_ARCHIVE_EXTRACTORS)r.gzr._COMPRESSED_FILE_OPENERS)rr)rr)z.tbzz.tbz2z.tgz_FILE_TYPE_ALIASES)filercCst|j}|s td|d|d}|tkr>|ft|S|tkrP||dfS|tkrt|dkr|d}|tkr||||fS|d|fStt tt tBt tB}td|d|d dS) aDetect the archive type and/or compression of a file. Args: file (str): the filename Returns: (tuple): tuple of suffix, archive type, and compression Raises: RuntimeError: if file has no suffix or suffix is not supported zFile 'zP' has no suffixes that could be used to detect the archive type and compression.NrHz&Unknown compression or archive type: 'z'. Known suffixes are: 'z'.) pathlibPathsuffixesrfrrrrsortedset)rrrxZsuffix2Zvalid_suffixesrrr_detect_file_type5s$     r)rrremove_finishedrc Cst|\}}}|s"td|d|dkrB|||dk r<|nd}t|}||d*}t|d}||W5QRXW5QRX|rt||S)aDecompress a file. The compression is automatically detected from the file name. Args: from_path (str): Path to the file to be decompressed. to_path (str): Path to the decompressed file. If omitted, ``from_path`` without compression extension is used. remove_finished (bool): If ``True``, remove the file after the extraction. Returns: (str): Path to the decompressed file. z*Couldn't detect a compression from suffix rINrr8r) rrfrerrrr(rBremove) rrrrx archive_typerZcompressed_file_openerZrfhZwfhrrr _decompress`s " rc Cst|dkrtj|}t|\}}}|sNt|tj|tj||d|dSt|}|||||rpt ||S)aDExtract an archive. The archive type and a possible compression is automatically detected from the file name. If the file is compressed but not an archive the call is dispatched to :func:`decompress`. Args: from_path (str): Path to the file to be extracted. to_path (str): Path to the directory the file will be extracted to. If omitted, the directory of the file is used. remove_finished (bool): If ``True``, remove the file after the extraction. Returns: (str): Path to the directory the file was extracted to. Nr)r) rBrCdirnamerrr^r]rerr)rrrrxrrZ extractorrrrextract_archives   r)r! download_root extract_rootr"r<rrcCshtj|}|dkr|}|s(tj|}t||||tj||}td|d|t|||dS)Nz Extracting rY)rBrCr\r]rir^r`r)r!rrr"r<rarchiverrrdownload_and_extract_archives  r)iterablercCsdddd|DdS)N'z', 'cSsg|] }t|qSr)str)rmitemrrrrpsz#iterable_to_str..)r^)rrrriterable_to_strsrT)rarg valid_values custom_msgrcCs|t|ts6|dkrd}nd}|jt||d}t||dkrB|S||krx|dk rX|}nd}|j||t|d}t||S)Nz'Expected type str, but got type {type}.z:Expected type str for argument {arg}, but got type {type}.)typerzPUnknown value '{value}' for argument {arg}. Valid values are {{{valid_values}}}.)rrr) isinstancerformatr ValueErrorr)rrrrmsgrrrverify_str_args r) file_nameslice_channelsrc Cst|d}|}|dkr(tdtd|}|sDtddd|D\}}t|}|dkr~d }| }nd }t j ||d d } W5QRX|d krdnd} | |||  ddd} t j | dd} | d|ddddf} | t jS)aDRead file in .pfm format. Might contain either 1 or 3 channels of data. Args: file_name (str): Path to the file. slice_channels (int): Number of channels to slice out of the file. Useful for reading different data formats stored in .pfm files: Optical Flows, Stereo Disparity Maps, etc. r8)PFsPfzInvalid PFM files^(\d+)\s(\d+)\s$zMalformed PFM header.css|]}t|VqdSr')int)rmdimrrr sz_read_pfm..r<>r>)dtyperr6rHr)ZaxisN)rreadlinerstriprrOrP ExceptiongroupsfloatnpfromfileZreshapeZ transposeflipZastypeZfloat32) rrr>headerZ dim_matchwhscaleZendiandataZ pfm_channelsrrr _read_pfms&  r)rrcCsD|tjj|j|fdj|jddd|jS)Nr)r) contiguousviewtorchZuint8shapeZ element_sizerr)rrrr_flip_byte_ordersBr)N)r )r4)N)r6)NNr6)F)F)r )NN)NF)NF)NNNF)NNN)r)Mbz2rgzipr;rlzmarBos.pathrrOr9rr- urllib.errorurllib.requestrrtypingrrrrrrrr r r urllib.parser numpyrrrZtorch.utils.model_zoor Z_internally_replaced_utilsrrr1bytesrrrr3r?boolrArErMrTrirwr|rrar ZIP_BZIP2ZIP_LZMAr__annotations__rrrrrrrrrrrrZndarrayrZTensorrrrrrs0    4E(&"+ '    $