ó
ć¨[Qc           @  sÜ   d  d l  m Z d  d l Z d  d l Z d  d l Z d   Z d   Z d g Z	 e
 d k rŘ e d  d  d l Z xW e d  D]I Z e j   \ Z Z e r  Pn  e r~ e d	 d
 k r~ e d e  q~ q~ We d  n  d S(   i˙˙˙˙(   t   print_functionNc         C  sP   xI t  rK t j j |   } | d O} t j j |  r | j |  d  Sq Wd  S(   Ni   (   t   Truet   rsat   randnumt   read_random_intt   primet   is_primet   send(   t   nbitst   pipet   integer(    (    sb   /home/tom/ab/x64lucid-deps/install/lib/python2.7/site-packages/rsa-3.1.1-py2.7.egg/rsa/parallel.pyt   _find_prime"   s    	
c         C  s   t  j d t  \ } } g  t |  D]$ } t  j d t d |  | f  ^ q% } g  | D] } | j   ^ qV | j   } g  | D] } | j   ^ q | S(   Nt   duplext   targett   args(	   t   mpt   Pipet   Falset   ranget   ProcessR   t   startt   recvt	   terminate(   R   t   poolsizet	   pipe_recvt	   pipe_sendt   _t   procst   pt   result(    (    sb   /home/tom/ab/x64lucid-deps/install/lib/python2.7/site-packages/rsa-3.1.1-py2.7.egg/rsa/parallel.pyt   getprime.   s    4R   t   __main__s'   Running doctests 1000x or until failureid   i
   i    s   %i timess   Doctests done(   t
   __future__R    t   multiprocessingR   t	   rsa.primeR   t   rsa.randnumR   R   t   __all__t   __name__t   printt   doctestR   t   countt   testmodt   failurest   tests(    (    (    sb   /home/tom/ab/x64lucid-deps/install/lib/python2.7/site-packages/rsa-3.1.1-py2.7.egg/rsa/parallel.pyt   <module>   s    		 	
