"dZddlmZddlmZddlmZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z dd l mZddlZdd lmZGd d e j$ZGd de j(Zy)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)rangec\eZdZdZ d fd ZdZdZdZdZdZ dZ d d Z d d Z xZ 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. c d|_tt|||||||||r%|jj j |d|_ tjtjj|jj|j|}|r2t%j&|D cgc] } t)| c} |_ng|_|jj*r||jj,|<yy#tj$r d}d|_Ytj"$rwxYwcc} w)N)columnskeystimeoutmodified restrictedFT)_rowssuperr __init___cache _restrictedadddeletedr ReadFileContentsospathjoinname EncodeNameMissingFileErrorchangedErrorjsonloadstuple _metadata_tables) selfcacherrrrrrcontentsr __class__s +lib/googlecloudsdk/core/cache/file_cache.pyrz_Table.__init__4sDJ &$ gD)08,6!8 kk!!$'DL '' '',,t{{'')> ?Ah&*jj&:;&:E!H&:;djdj {{"&dkk$  ! !hdl ;;   z _Table.AddRows..s:DIIr3)keyrN) _CheckRowsr!sortedrlistrGrEappend)r(rowsrNs` r-r:z_Table.AddRowssOODDL $**tDz)/F GDDJ A c$i- D A $..a$q1u+"F Q D A $..a$q1u+"F jjQ 1fa c$i-r3cd|_|rP|j|g}|jD]&}|j||r|j |(||_yg|_y)z@Deletes each row in the table matching any of the row_templates.TN)r!_CheckRowTemplatesrrRr])r(rQkeeprMs r-r0z_Table.DeleteRowssYDL m, d#  4 ++c djdjr3c\||j|g|s[|jsO|jsCtjdj |j j|jg}|jD])}|s|j||s|j|+|S)z?Returns the list of rows that match row_template, None for all.z"[{}] cache table [{}] has expired.) r`rrrCacheTableExpiredformatrrrrOr])r(rLignore_expirationmatchedrMs r-Selectz _Table.Selects |n- T__T]]  ( ( . 5 5kk  + ,,Gzz  c2s Nr3)rYrYrrFrU)NF)__name__ __module__ __qualname____doc__rr2r@rErOrRr:r0rg __classcell__r,s@r-r r 's? JK'4>8*     r3r c8eZdZdZdfd ZdZdZddZxZS)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. ctt| t||||d}t |g|_i|_d|_tj|_ tjj|j||_d|_d|_tjj%|js0|st'j(dj+|jtjj%|js.t'j,dj+|jd|_t/j0|jd|_|j j3 |j5y#t&j6$r|j9d wxYw) N)createrr5__lock__Fz Persistent cache [{}] not found.z[{}] is not a persistent cache.T timeout_secscommit)rrorr setrr'r&rNow_startrrrr _lock_path_lock _persistentexistsr CacheNotFoundrd CacheInvalidr FileLockLockInitializeMetadatar"Close)r(rrqrr5 lock_namer,s r-rzCache.__init__sZ %VWg GII;'DDLDN'++-DKggll499i8DODJD 77>>$)) $ && . 5 5dii @B B WW^^DOO ,  # # + 2 2499 = ??d>>$//Bdj jjoo       jjj  s F'Gc|jd|jr'tj|jd|_yy)z)Permanently deletes the persistent cache.FrvN)rr}r RmTreerr1s r-r2z Cache.Deletes6JJeJ  ll499dr3c|jsgtj|jdd|_t j |jd|_|jjt|jjDcgc]}|js|c}D]}|j|jjr|jjyycc}w)z(Commits all operations up to this point.iTrsrtN)r|rmkdirrr}r rr{rr\r'valuesr!r@r&)r(rVtables r-Commitz Cache.Commits ::hhtyy% d>>$//Bdj jjoo$,,"5"5"7E"7Q199q"7EF mmoG ~~ nnFs C9'C9c|r|j|jr!|jjd|_d|_d|_y)z~Closes the cache, optionally committing any changes. Args: commit: Commits any changes before closing if True. N)rr|Unlockr&r')r(rws r-rz Cache.Closes<  kkm zz jjdjDNDLr3)TNN)T) rhrirjrkrr2rrrlrms@r-roros" <  r3ro)rk __future__rrrr8rKr#rgooglecloudsdk.core.cacherrrgooglecloudsdk.core.utilr rI six.movesr Tabler CacheUsingMetadataTableror3r-rs]  ''  04;* K " ( (K\PN 2 2Pr3