ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txdav
/
common
/
datastore
/
work
/
Filename :
revision_cleanup.pyc
back
Copy
� �t�ac @ s� d Z d d l m Z d d l m Z m Z d d l m Z m Z d d l m Z d d l m Z m Z d d l m Z d d l m Z d d l Z e � Z d e e e j � f d � � YZ d e e e j � f d � � YZ e d � � Z d S( s% Remove old and unused REVISION rows i����( t fromTable( t Selectt Max( t SingletonWorkItemt RegeneratingWorkItem( t Logger( t inlineCallbackst succeed( t config( t schemaNt FindMinValidRevisionWorkc B s> e Z d Z e d � � Z d � Z d � Z e d � � Z RS( t find_min_revisionc s9 � f d � } t j j r+ | j d | � St d � Sd S( Nc s t j | � � S( N( R t reschedule( t txn( t seconds( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyt _enqueue( s s( FindMinValidRevisionWork.initialSchedule( R t RevisionCleanupt Enabledt inTransactionR t None( t clst storeR R ( ( R s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyt initialSchedule& s c C s t t j j � d d d S( sP Return the interval in seconds between regenerating instances. i i< ( t floatR R t CleanupPeriodDays( t self( ( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyt regenerateInterval0 s c C s) t j j � t j d t t j j � � S( Nt days( t datetimet utcnowt timedeltaR R R t SyncTokenLifetimeDays( R ( ( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyt dateCutoff6 s c c s� t | j j d � V� } | j � } d } x� t j t j t j t j f D]l } t t | j � g d | d | j | k �j | j � V} | rJ | d d } | | k r� | } q� qJ qJ W| | k r� | j j d | d � Vt j | j d d �Vn d S( Ns MIN-VALID-REVISIONi t Fromt Wherei R ( t intt transactiont calendarserverValueR R t CALENDAR_OBJECT_REVISIONSt NOTIFICATION_OBJECT_REVISIONSt ADDRESSBOOK_OBJECT_REVISIONSt ABO_MEMBERSR R t REVISIONt MODIFIEDt ont updateCalendarserverValuet RevisionCleanupWorkR ( R t minValidRevisiont dateLimitt maxRevOlderThanDatet tablet revisionRowst tableMaxRevision( ( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyt doWork9 s( ( t __name__t __module__t groupt classmethodR R R R R5 ( ( ( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyR " s R. c B s e Z d Z e d � � Z RS( t group_revsion_cleanupc c s. t | j j d � V� } | j j | � Vd S( Ns MIN-VALID-REVISION( R# R$ R% t deleteRevisionsBefore( R R/ ( ( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyR5 a s ( R6 R7 R8 R R5 ( ( ( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyR. ] s c c s t | j d � V� } t j j � t j d | � } d } x� t j t j t j t j f D]i } t t | j � g d | d | j | k �j | � V} | rZ | d d } | | k r� | } q� qZ qZ W| | k r� | j d | d � Vt j | d d �Vn d S( Ns MIN-VALID-REVISIONR i R! R" i ( R# R% R R R R R& R' R( R) R R R* R+ R, R- R. R ( R t backSecondsR/ R0 R1 R2 R3 R4 ( ( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyt _triggerRevisionCleanupk s* ( t __doc__t twext.enterprise.dal.recordR t twext.enterprise.dal.syntaxR R t twext.enterprise.jobs.workitemR R t twext.python.logR t twisted.internet.deferR R t twistedcaldav.configR t! txdav.common.datastore.sql_tablesR R t logt FIND_MIN_VALID_REVISION_WORKR t REVISION_CLEANUP_WORKR. R= ( ( ( s? /opt/cpanel-ccs/txdav/common/datastore/work/revision_cleanup.pyt <module> s ";"