ó
ç'ÊUc           @   s¯  d  d l  m Z d  d l m Z m Z m Z m Z d  d l m	 Z	 m
 Z
 d  d l m Z d  d l m Z d e	 f d „  ƒ  YZ d „  Z d	 e f d
 „  ƒ  YZ d e j f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e j f d  „  ƒ  YZ d! e f d" „  ƒ  YZ d# S($   iÿÿÿÿ(   t
   test_queue(   t   MarshalFifoDiskQueuet   MarshalLifoDiskQueuet   PickleFifoDiskQueuet   PickleLifoDiskQueue(   t   Itemt   Field(   t   Request(   t
   ItemLoadert   TestItemc           B   s   e  Z e ƒ  Z RS(    (   t   __name__t
   __module__R   t   name(    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR	      s   c         C   s   |  |  S(   N(    (   t   x(    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt   _test_procesor
   s    t
   TestLoaderc           B   s   e  Z e Z e e ƒ Z RS(    (   R
   R   R	   t   default_item_classt   staticmethodR   t   name_out(    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR      s   t   MarshalFifoDiskQueueTestc           B   s)   e  Z d  Z d „  Z d „  Z d „  Z RS(   i † c         C   s   t  |  j d |  j ƒS(   Nt	   chunksize(   R   t   qdirR   (   t   self(    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt   queue   s    c         C   s‡   |  j  ƒ  } | j d ƒ | j d ƒ | j i d d 6ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  i d d 6ƒ d  S(   Nt   ai{   t   dict(   R   t   pusht   assertEqualt   pop(   R   t   q(    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt   test_serialize   s    c         C   s5   d d  l  } |  j ƒ  } |  j t | j d „  ƒ d  S(   Niÿÿÿÿc         S   s   |  S(   N(    (   R   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt   <lambda>%   s    (   t   twisted.persisted.stylesR   t   assertRaisest
   ValueErrorR   (   R   t   twistedR   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt   test_nonserializable_object!   s    (   R
   R   R   R   R   R$   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR      s   			t"   ChunkSize1MarshalFifoDiskQueueTestc           B   s   e  Z d  Z RS(   i   (   R
   R   R   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR%   '   s   t"   ChunkSize2MarshalFifoDiskQueueTestc           B   s   e  Z d  Z RS(   i   (   R
   R   R   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR&   *   s   t"   ChunkSize3MarshalFifoDiskQueueTestc           B   s   e  Z d  Z RS(   i   (   R
   R   R   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR'   -   s   t"   ChunkSize4MarshalFifoDiskQueueTestc           B   s   e  Z d  Z RS(   i   (   R
   R   R   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR(   0   s   t   PickleFifoDiskQueueTestc           B   s2   e  Z d  Z d „  Z d „  Z d „  Z d „  Z RS(   i † c         C   s   t  |  j d |  j ƒS(   NR   (   R   R   R   (   R   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR   8   s    c         C   s]   |  j  ƒ  } t d d ƒ } | j | ƒ | j ƒ  } t | t ƒ sI t ‚ |  j | | ƒ d  S(   NR   t   foo(   R   R	   R   R   t
   isinstancet   AssertionErrorR   (   R   R   t   it   i2(    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt   test_serialize_item;   s    c         C   su   |  j  ƒ  } t ƒ  } | j | ƒ | j ƒ  } t | t ƒ sC t ‚ | j t k sX t ‚ |  j | j	 d ƒ d ƒ d  S(   NR   t   xx(
   R   R   R   R   R+   R,   R   R	   R   R   (   R   R   t   lt   l2(    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt   test_serialize_loaderC   s    	c         C   s†   |  j  ƒ  } t d ƒ } | | j d <| j | ƒ | j ƒ  } t | t ƒ sS t ‚ |  j | j | j ƒ | j d | k s‚ t ‚ d  S(   Ns   http://www.example.comt   request(	   R   R   t   metaR   R   R+   R,   R   t   url(   R   R   t   rt   r2(    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt    test_serialize_request_recursiveL   s    (   R
   R   R   R   R/   R3   R9   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR)   4   s
   				t!   ChunkSize1PickleFifoDiskQueueTestc           B   s   e  Z d  Z RS(   i   (   R
   R   R   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR:   V   s   t!   ChunkSize2PickleFifoDiskQueueTestc           B   s   e  Z d  Z RS(   i   (   R
   R   R   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR;   Y   s   t!   ChunkSize3PickleFifoDiskQueueTestc           B   s   e  Z d  Z RS(   i   (   R
   R   R   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR<   \   s   t!   ChunkSize4PickleFifoDiskQueueTestc           B   s   e  Z d  Z RS(   i   (   R
   R   R   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR=   _   s   t   MarshalLifoDiskQueueTestc           B   s#   e  Z d  „  Z d „  Z d „  Z RS(   c         C   s   t  |  j ƒ S(   N(   R   t   path(   R   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR   e   s    c         C   s‡   |  j  ƒ  } | j d ƒ | j d ƒ | j i d d 6ƒ |  j | j ƒ  i d d 6ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ d  S(   NR   i{   R   (   R   R   R   R   (   R   R   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR   h   s    c         C   s5   d d  l  } |  j ƒ  } |  j t | j d „  ƒ d  S(   Niÿÿÿÿc         S   s   |  S(   N(    (   R   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR   u   s    (   R    R   R!   R"   R   (   R   R#   R   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR$   q   s    (   R
   R   R   R   R$   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR>   c   s   			t   PickleLifoDiskQueueTestc           B   s,   e  Z d  „  Z d „  Z d „  Z d „  Z RS(   c         C   s   t  |  j ƒ S(   N(   R   R?   (   R   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR   z   s    c         C   s]   |  j  ƒ  } t d d ƒ } | j | ƒ | j ƒ  } t | t ƒ sI t ‚ |  j | | ƒ d  S(   NR   R*   (   R   R	   R   R   R+   R,   R   (   R   R   R-   R.   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR/   }   s    c         C   su   |  j  ƒ  } t ƒ  } | j | ƒ | j ƒ  } t | t ƒ sC t ‚ | j t k sX t ‚ |  j | j	 d ƒ d ƒ d  S(   NR   R0   (
   R   R   R   R   R+   R,   R   R	   R   R   (   R   R   R1   R2   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR3   …   s    	c         C   s†   |  j  ƒ  } t d ƒ } | | j d <| j | ƒ | j ƒ  } t | t ƒ sS t ‚ |  j | j | j ƒ | j d | k s‚ t ‚ d  S(   Ns   http://www.example.comR4   (	   R   R   R5   R   R   R+   R,   R   R6   (   R   R   R7   R8   (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR9   Ž   s    (   R
   R   R   R/   R3   R9   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyR@   x   s   				N(    t   queuelib.testsR    t   tt   scrapy.squeuesR   R   R   R   t   scrapy.itemR   R   t   scrapy.httpR   t   scrapy.loaderR   R	   R   R   t   FifoDiskQueueTestR   R%   R&   R'   R(   R)   R:   R;   R<   R=   t   LifoDiskQueueTestR>   R@   (    (    (    s6   /home/travis/build/scrapy/scrapy/tests/test_squeues.pyt   <module>   s&   "	"