File: //usr/lib/python2.7/site-packages/azurelinuxagent/ga/periodic_operation.pyo
�
d�bc @ sR d d l Z d d l Z d d l m Z d d l m Z d e f d � � YZ d S( i����N( t logger( t ustrt PeriodicOperationc B sS e Z d Z e j d d � Z d � Z d � Z d � Z d � Z e
d � � Z RS( s�
Instances of PeriodicOperation are tasks that are executed only after the given
time period has elapsed.
NOTE: the run() method catches any exceptions raised by the operation and logs them as warnings.
t minutesi< c C sd | j j | _ t | t j � r' | n t j d | � | _ t j j � | _ d | _
d | _ d S( Nt seconds( t __class__t __name__t _namet
isinstancet datetimet timedeltat _periodt utcnowt _next_run_timet Nonet
_last_warningt _last_warning_time( t selft period( ( sI /usr/lib/python2.7/site-packages/azurelinuxagent/ga/periodic_operation.pyt __init__$ s
- c C s� y] | j t j j � k r\ z! t j d | j � | j � Wd t j j � | j | _ Xn Wn� t k
r� } d j | j t
| � � } | | j k s� | j d k s� t j j � | j | j k r� t j | � t j j � | _ | | _ q� n Xd S( Ns Executing {0}...sK Error in {0}: {1} --- [NOTE: Will not log the same error for the next hour]( R
R R R t verboseR t
_operationR t Exceptiont formatR R R R t _LOG_WARNING_PERIODt warn( R t et warning( ( sI /usr/lib/python2.7/site-packages/azurelinuxagent/ga/periodic_operation.pyt run+ s !=
c C s | j S( N( R
( R ( ( sI /usr/lib/python2.7/site-packages/azurelinuxagent/ga/periodic_operation.pyt
next_run_time: s c C s
t � � d S( sn
Derived classes must override this with the definition of the operation they need to perform
N( t NotImplementedError( R ( ( sI /usr/lib/python2.7/site-packages/azurelinuxagent/ga/periodic_operation.pyR = s c C s t g | D] } | j � ^ q
� } | t j j � } | j d d | j d | j d } | d k r{ t j | � n d S( s�
Takes a list of operations, finds the operation that should be executed next (that with the closest next_run_time)
and sleeps until it is time to execute that operation.
i i g $@i i Ng ��.Ag ��.A( t minR R R t daysR t microsecondst timet sleep( t
operationst opt next_operation_timet sleep_timedeltat
sleep_seconds( ( sI /usr/lib/python2.7/site-packages/azurelinuxagent/ga/periodic_operation.pyt sleep_until_next_operationC s
%' ( R t
__module__t __doc__R R
R R R R R t staticmethodR) ( ( ( sI /usr/lib/python2.7/site-packages/azurelinuxagent/ga/periodic_operation.pyR s ( R R" t azurelinuxagent.commonR t azurelinuxagent.common.futureR t objectR ( ( ( sI /usr/lib/python2.7/site-packages/azurelinuxagent/ga/periodic_operation.pyt <module> s