U 楡c@sddlmZmZmZddlmZmZddlmZm Z m Z m Z ddl m Z mZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZddlmZm Z m!Z!m"Z"ddl#m$Z$ddl%Z%ddl&Z&ddl'Z'd Z(Gd d d eeeZ)dS) ) FileDBBase ObjectDBR ObjectDBW) BadObjectAmbiguousObjectName)DecompressMemMapReaderFDCompressedSha1WriterFDStream Sha1Writer)OStreamOInfo)file_contents_ro_filepathENOENT hex_to_bin bin_to_hexexistschmodisdirisfileremovemkdirrenamedirnamebasenamejoin) chunk_sizeloose_object_header_info write_object stream_copy) force_bytesN) LooseObjectDBcseZdZdZeZeddZej dkr.eddZfddZ dd Z d d Z d d Z ddZfddZddZddZddZddZddZddZZS)r z/A database which operates on loose object filesZ444ntZ644cs&t|t|_ttdd|_dS)N O_NOATIMEr)super__init__dict_hexsha_to_filegetattros_fd_open_flags)self root_path __class__2/tmp/pip-unpacked-wheel-jjg5dubb/gitdb/db/loose.pyr%Ms zLooseObjectDB.__init__cCst|dd|ddS)z{ :return: path at which the object with the given hexsha would be stored, relative to the database rootN)r)r+hexshar/r/r0 object_pathVszLooseObjectDB.object_pathcCsTz |j|WStk r YnX|||}t|rH||j|<|St|dS)z :return: readable object path to the object identified by hexsha :raise BadObject: If the object file does not existN)r'KeyErrordb_pathr3rr)r+r2pathr/r/r0readable_db_object_path\s  z%LooseObjectDB.readable_db_object_pathcCsLd}|D]*}t|t|r |dk r2t||}q |dkrHt||S)z:return: 20 byte binary sha1 string which matches the given name uniquely :param name: hexadecimal partial name (bytes or ascii string) :raise AmbiguousObjectName: :raise BadObject: N)sha_iterr startswithrrr)r+Zpartial_hexsha candidatebinshar/r/r0partial_to_complete_sha_hexns z)LooseObjectDB.partial_to_complete_sha_hexc Cs||t|}zt||jdWStk r}z`|jtkrzt|WWYDStk r~}zt||W5d}~XYnXd|_n t||W5d}~XYnXdS)z~ :return: memory map of that file to allow random read access :raise BadObject: if object could not be located)flagsNr) r5r3rr r*OSErrorerrnorr)r+shar5eZnew_er/r/r0_map_loose_objects zLooseObjectDB._map_loose_objectcs,|dk r t|ts tdtjt|S)zI:raise TypeError: if the stream does not support the Sha1Writer interfaceNz,Output stream musst support the %s interface) isinstancer TypeError__name__r$ set_ostream)r+streamr-r/r0rFszLooseObjectDB.set_ostreamc Cs@||}zt|\}}t|||WSt|dr:|XdS)Nclose)rBhasattrrHrr )r+r@mtypsizer/r/r0infos    zLooseObjectDB.infocCs,||}tj|dd\}}}t||||S)NT)Zclose_on_deletion)rBrnewr )r+r@rJtyperLrGr/r/r0rGs zLooseObjectDB.streamcCs0z|t|WdStk r*YdSXdS)NTF)r7rr)r+r@r/r/r0 has_objects zLooseObjectDB.has_objectcCs>d}|}|dkrDtjd|jd\}}|jdkrs@