o "@sdZddlmZddlmZddlmZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z dd l mZddlZdd lmZGd d d e jZGd dde jZdS)zlA persistent cache implementation using files. See the persistent_cache module for a detailed description. )absolute_import)division)unicode_literalsN) exceptions)metadata_table)persistent_cache_base)files)rangecsjeZdZdZ  dfdd ZddZd d Zd d Zd dZddZ ddZ dddZ dddZ Z S)_TableaCA persistent cache table. Attributes: name: The table name. deleted: Table was deleted if True. restricted: Table is restricted if True. modified: Table modify timestamp. timeout: Tables older than timeout are invalid. _cache: The parent cache object. _rows: The list of rows in the table. rFc sd|_tt|j|||||||d|r|jj|d|_zt t j |jj ||}Wntjy>d}d|_Yn tjyFw|rUddt|D|_ng|_|jjrd||jj|<dSdS)N)columnskeystimeoutmodified restrictedFTcSsg|]}t|qS)tuple).0rrrA/tmp/google-cloud-sdk/lib/googlecloudsdk/core/cache/file_cache.py Gsz#_Table.__init__..)_rowssuperr __init___cache _restrictedadddeletedrReadFileContentsospathjoinname EncodeNameMissingFileErrorchangedErrorjsonloads _metadata_tables) selfcacher"r r rrrcontents __class__rrr4s0 z_Table.__init__cCs.|||jj|jfgd|_dS)zDeletes the table.TN) Invalidate DeleteRowsrr)r"rr+rrrDeleteNs z _Table.Deletec Cs|jrsd|_tj|jj||j}|jrLd|_|jj |jfg|jj |j=zt |WdSt yK}z|j t jkr@WYd}~dSd}~ww|jjtjj|j|j|j|j|j|j|jjdgt|t|jdSdS)z5Commits changed/deleted table data to the table file.FN)r"r r rrrversion)r%rr r!rr"r#rr)r1r*removeOSErrorerrnoENOENTAddRowsrMetadataRowr r rrrr4rWriteFileContentsr'dumpsr)r+r errr_CommitVs8   z_Table._CommitcCs|d|j|d|jkS)z/Returns True if rows a and b have the same key.Nr )r+abrrr _RowEqualrsz_Table._RowEqualcCsx|r:tt|D]1}||dur9t||tjr.t||tjr.t||||s-dSq||||kr9dSqdS)z)Returns True if row_template matches row.NFT)r len isinstancesix string_typesfnmatch)r+ row_templaterowirrr _RowMatchvs z_Table._RowMatchcCs |D] }|||r dSqdS)z:Returns True if any template in row_templates matches row.TF)rL)r+ row_templatesrJrIrrr _AnyRowMatchs  z_Table._AnyRowMatchcs|d_tjt|fddd}g_d}|t|krb|t|dkrN||||drN|d7}|t|dkrN||||ds6j|||d7}|t|ks"dSdS)z#Adds each row in rows to the table.Tcs|djSNr@)xr2rrsz _Table.AddRows..)keyrr N) _CheckRowsr%sortedrlistrDrCappend)r+rowsrKrr2rr9s  ((z_Table.AddRowsNcCsNd|_|r"||g}|jD] }|||s||q||_dSg|_dS)z@Deletes each row in the table matching any of the row_templates.TN)r%_CheckRowTemplatesrrNrV)r+rMkeeprJrrrr1s      z_Table.DeleteRowscCsj|dur ||g|s|js|jstd|jj|jg}|jD]}|r2| ||r2| |q#|S)z?Returns the list of rows that match row_template, None for all.Nz"[{}] cache table [{}] has expired.) rXrrrCacheTableExpiredformatrr"rrLrV)r+rIignore_expirationmatchedrJrrrSelects    z _Table.Select)r r rrFrO)NF)__name__ __module__ __qualname____doc__rr3r?rCrLrNr9r1r^ __classcell__rrr.rr 's    r cs<eZdZdZd fdd ZddZdd Zd d d ZZS)CacheaA persistent cache object. Attributes: name: The db path name. Created/removed by this object. May be a file or directory. In this implementation its a file. timeout: The default table timeout. version: A caller defined version string that must match the version string stored when the persistent object was created. _lock: The cache lock object. None if no files have been committed yet. _lock_path: The cache lock meta file. _metadata: The metadata restricted _Table. _persistent: True if the persistent object has been committed at least once. _restricted: The set of restricted table names. _start: The cache instance start time. _tables: The map of open table objects. TNcstt|jt||||dd}t|g|_i|_d|_t |_ t j |j||_d|_d|_t j |jsB|sAtd|jn!t j |jsRtd|jd|_tj|jdd|_|jz|WdStjyy|jdd w) N)createrr4__lock__Fz Persistent cache [{}] not found.z[{}] is not a persistent cache.T timeout_secscommit)rrdrr setrr*r)rNow_startrr r!r" _lock_path_lock _persistentexistsr CacheNotFoundr[ CacheInvalidrFileLockLockInitializeMetadatar&Close)r+r"rerr4 lock_namer.rrrs<        zCache.__init__cCs,|jdd|jrt|jd|_dSdS)z)Permanently deletes the persistent cache.FrjN)rxrqrRmTreer"r2rrrr3s   z Cache.DeletecCsv|jst|jdd|_tj|jdd|_|jt dd|j DD]}| q'|j jr9|j dSdS)z(Commits all operations up to this point.iTrgrhcSsg|]}|jr|qSr)r%)rrPrrrrsz Cache.Commit..N)rprmkdirr"rqrrurorvrUr*valuesr?r)r%)r+tablerrrCommits  z Cache.CommitcCs2|r||jr|jd|_d|_d|_dS)z~Closes the cache, optionally committing any changes. Args: commit: Commits any changes before closing if True. N)r~rpUnlockr)r*)r+rkrrrrxs  z Cache.Close)TNN)T) r_r`rarbrr3r~rxrcrrr.rrds  rd)rb __future__rrrr7rHr'rgooglecloudsdk.core.cacherrrgooglecloudsdk.core.utilrrF six.movesr Tabler CacheUsingMetadataTablerdrrrrs"