ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txdav
/
common
/
datastore
/
work
/
Filename :
inbox_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 m Z d d l Z e � Z d e e e j � f d � � YZ d e e e j � f d � � YZ d e e e j � f d � � YZ d S( sL Remove orphaned and old inbox items, and inbox items references old events i����( t fromTable( t Selectt Count( t WorkItemt RegeneratingWorkItem( t Logger( t inlineCallbackst succeed( t config( t schemat _HOME_STATUS_NORMALNt InboxCleanupWorkc B s5 e Z d Z e d � � Z d � Z e d � � Z RS( t inbox_cleanupc 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/inbox_cleanup.pyt _enqueue( s s InboxCleanupWork.initialSchedule( R t InboxCleanupt Enabledt inTransactionR t None( t clst storeR R ( ( R s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_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/inbox_cleanup.pyt regenerateInterval0 s c c s� t j } t t | j � g d | �j | j � Vd d } | rU t j d | � n� t j } t | j g d | d | j t k �j | j � V} t j j } x? | D]7 } t j | j d | d | d �V| t j j 7} q� Wd S( Nt Fromi sW Inbox cleanup work: Can't schedule per home cleanup because {} work items still queued.t WhereR t homeID( R t CLEANUP_ONE_INBOX_WORKR R t HOME_IDt ont transactiont logt errort CALENDAR_HOMEt RESOURCE_IDt STATUSR R R t StartDelaySecondst CleanupOneInboxWorkR t StaggerSeconds( R t coiwt queuedCleanupOneInboxWorkItemst cht homeRowsR t homeRow( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyt doWork6 s& !( t __name__t __module__t groupt classmethodR R R R0 ( ( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyR " s R) c B s& e Z e d � � Z e d � � Z RS( c C s | j j | j k S( N( t tableR R ( R ( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyt <lambda>W t c c sK t t j j � d k rGt j j � t j d t t j j � � } t | j j | j | � V� } | rG| j j | j � V} t j d d | j � d | �t | � t j j k r� | j d � V} xy | j | � VD] } | j � Vq� WqDt j j } xG | D]< } t j | j d | d | j d | �V| t j j 7} qWqGn d S( Ni t dayssI Inbox cleanup work in home: {homeUID}, deleting old items: {oldItemNames}t homeUIDt oldItemNamest inboxR R t resourceName( R R R t ItemLifetimeDayst datetimet utcnowt timedeltat setR" t! listInboxItemsInHomeCreatedBeforeR t calendarHomeWithResourceIDR# t infot uidt lent InboxRemoveWorkThresholdt childWithNamet objectResourcesWithNamest removet RemovalStaggerSecondst InboxRemoveWorkR ( R t cutoffR: t homeR; t itemR ( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyR0 Y s" + &( R1 R2 t propertyR3 R R0 ( ( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyR) U s RL c B s& e Z e d � � Z e d � � Z RS( c C s+ | j j | j k j | j j | j k � S( N( R5 R R t Andt RESOURCE_NAMER< ( R ( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyR6 z R7 c c su | j j | j � V} | d k rq | j d � V} | d k rq | j | j � V} | d k rn | j � Vqn qq n d S( NR; ( R" RC R R RH t objectResourceWithNameR< RJ ( R RN R; RO ( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyR0 | s ( R1 R2 RP R3 R R0 ( ( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyRL x 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 R> R# t INBOX_CLEANUP_WORKR R R) t INBOX_REMOVE_WORKRL ( ( ( s< /opt/cpanel-ccs/txdav/common/datastore/work/inbox_cleanup.pyt <module> s "3"#