ó
P'—^c           @@  s·   d  d l  m Z d  d l m Z d  d l m Z m Z d  d l m Z m	 Z	 m
 Z
 d e f d „  ƒ  YZ d e f d „  ƒ  YZ e ƒ  Z d	 e f d
 „  ƒ  YZ d e f d „  ƒ  YZ d S(   i    (   t   absolute_import(   t   Events(   t   Polaroidt   evcam(   t   AppCaset   patcht   restore_loggingt   TRefc           B@  s&   e  Z e Z e Z d  „  Z d „  Z RS(   c         C@  s   t  |  _ d  S(   N(   t   Truet   called(   t   self(    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   __call__   s    c         C@  s   t  |  _ d  S(   N(   t   Falset   active(   R
   (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   cancel   s    (   t   __name__t
   __module__R   R   R   R	   R   R   (    (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR      s   	t	   MockTimerc           B@  s   e  Z g  Z d  „  Z RS(   c         O@  s   |  j  j | ƒ t ƒ  S(   N(   t	   installedt   appendR   (   R
   t   secst   funt   argst   kwargs(    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   call_repeatedly   s    (   R   R   R   R   (    (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR      s   t   test_Polaroidc           B@  s>   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z d „  Z RS(   c         C@  s   |  j  j j ƒ  |  _ d  S(   N(   t   appt   eventst   Statet   state(   R
   (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   setup   s    c         C@  sˆ   t  |  j d |  j ƒ} |  j | j |  j ƒ |  j | j |  j ƒ |  j | j ƒ |  j | j ƒ |  j | j ƒ |  j | j	 ƒ d  S(   NR   (
   R   R   R   t   assertIst
   assertTruet   freqt   cleanup_freqt   loggert   assertFalset   maxrate(   R
   t   x(    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   test_constructor!   s    c         C@  sá   t  |  j d |  j ƒ} t | _ | j ƒ  | j ƒ  |  j | j t j	 ƒ |  j | j
 t j	 ƒ |  j | j j ƒ |  j | j j ƒ | j ƒ  |  j | j j ƒ |  j | j j ƒ |  j | j j ƒ |  j | j j ƒ d  S(   NR   (   R   R   R   t   timert   __exit__t	   __enter__t   assertInt   captureR   R   t   cleanupR    t   _trefR   t   _ctrefR$   R	   (   R
   R&   (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   test_install_timers*   s    	


c         @  s_   t  |  j d |  j ƒ} t g ‰  ‡  f d †  } | j j | ƒ | j ƒ  |  j ˆ  d ƒ d  S(   NR   c          @  s   t  ˆ  d <d  S(   Ni    (   R   (   R   (   t   cleanup_signal_sent(    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   handler=   s    i    (   R   R   R   R   t   cleanup_signalt   connectR-   R    (   R
   R&   R2   (    (   R1   sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   test_cleanup9   s    	
c         @  s„   t  |  j d |  j ƒ} t g ‰  ‡  f d †  } | j j | ƒ | j ƒ  |  j ˆ  d ƒ t ˆ  d <| j ƒ  |  j ˆ  d ƒ d  S(   NR   c          @  s   t  ˆ  d <d  S(   Ni    (   R   (   R   (   t   shutter_signal_sent(    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR2   H   s    i    (	   R   R   R   R   t   shutter_signalR4   t   shutterR    R,   (   R
   R&   R2   (    (   R6   sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   test_shutter__captureD   s    	


c         @  s“   t  |  j d |  j d d ƒ} d g ‰  ‡  f d †  } | j j | ƒ x2 t d ƒ D]$ } | j ƒ  | j ƒ  | j ƒ  qS W|  j ˆ  d d ƒ d  S(   NR   R%   s   1/hi    c          @  s   ˆ  d c d 7<d  S(   Ni    i   (    (   R   (   R6   (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR2   W   s    i   i   (   R   R   R   R7   R4   t   rangeR8   t   assertEqual(   R
   R&   R2   t   i(    (   R6   sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   test_shutter_maxrateS   s    	

(   R   R   R   R'   R0   R5   R9   R=   (    (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR      s   						t
   test_evcamc           B@  s[   e  Z d  e f d „  ƒ  YZ d e f d „  ƒ  YZ d „  Z d „  Z e d ƒ d „  ƒ Z	 RS(   t   MockReceiverc           B@  s   e  Z e Z d  „  Z RS(   c         K@  s   |  j  j r t ƒ  ‚ n  d  S(   N(   t	   __class__t   raise_keyboard_interruptt   KeyboardInterrupt(   R
   R   (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR,   g   s    (   R   R   R   RA   R,   (    (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR?   d   s   t
   MockEventsc           B@  s   e  Z d  „  Z RS(   c         O@  s
   t  j ƒ  S(   N(   R>   R?   (   R
   R   R   (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   Receiverm   s    (   R   R   RD   (    (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyRC   k   s   c         C@  s(   |  j  ƒ  |  j _ |  j |  j j _ d  S(   N(   RC   R   R   (   R
   (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR   p   s    c         C@  s›   t  ƒ  Œ t t d t d |  j ƒt t d t d d d |  j ƒt |  j _ z3 |  j t	 ƒ  t t d t d |  j ƒWd  QXWd  t
 |  j _ XWd  QXd  S(   NR(   R   t   loglevelt   CRITICAL(   R   R   R   R(   R   R   R?   RA   t   assertRaisest
   SystemExitR   (   R
   (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR>   t   s    
#s   celery.platforms.create_pidlockc         C@  s0   t  t d t d d d |  j ƒ| j d ƒ d  S(   NR(   t   pidfiles   /var/pidR   (   R   R   R(   R   t   assert_called_with(   R
   t   create_pidlock(    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   test_evcam_pidfile   s    (
   R   R   t   objectR?   R   RC   R   R>   R   RL   (    (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyR>   b   s
   		N(   t
   __future__R    t   celery.eventsR   t   celery.events.snapshotR   R   t   celery.tests.caseR   R   R   RM   R   R   R(   R   R>   (    (    (    sC   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/events/test_snapshot.pyt   <module>   s   	F