+
    oi	                     2   R t ^ RIt^ RIHt ^ RIt^ RItR R ltR R lt	R.t
]R8X  dm   ]! R	4       ^ RIt]! ^d4       FJ  t]P                   ! 4       w  tt]'       d    M-]^
,          ^ 8X  g   K1  ]'       g   K;  ]! R
],          4       KL  	  ]! R4       R# R# )zFunctions for parallel computation on multiple cores.

Introduced in Python-RSA 3.1.

.. note::

    Requires Python 2.6 or newer.

N)
Connectionc                4    V ^8  d   QhR\         R\        RR/# )   nbitspipereturnN)intr   )formats   "o/Users/tonyclaw/.openclaw/workspace/scripts/youtube-playlists/venv/lib/python3.14/site-packages/rsa/parallel.py__annotate__r       s!      s *      c                      \         P                  P                  V 4      p\         P                  P	                  V4      '       g   KG  VP                  V4       R# )TN)rsarandnumread_random_odd_intprimeis_primesend)r   r   integers   && r
   _find_primer       s?    
++11%8 99g&&IIgr   c                <    V ^8  d   QhR\         R\         R\         /# )r   r   poolsizer   )r   )r	   s   "r
   r   r   *   s!     % %C %3 %3 %r   c                   \         P                  ! RR7      w  r# \        V4       Uu. uF   p\         P                  ! \        W3R7      NK"  	  ppV F  pVP                  4        K  	  VP                  4       pVP                  4        VP                  4        V F  pVP                  4        K  	  V# u upi   TP                  4        TP                  4        i ; i)a%  Returns a prime number that can be stored in 'nbits' bits.

Works in multiple threads at the same time.

>>> p = getprime(128, 3)
>>> rsa.prime.is_prime(p-1)
False
>>> rsa.prime.is_prime(p)
True
>>> rsa.prime.is_prime(p+1)
False

>>> from rsa import common
>>> common.bit_size(p) == 128
True

F)duplex)targetargs)	mpPiperangeProcessr   startrecvclose	terminate)r   r   	pipe_recv	pipe_send_procspresults   &&      r
   getprimer*   *   s    &  WWE2Y	RWX`RabRaQ;e5GHRabAGGI  ! 	  M c 	s   B9 &B4+B9 4B9 9"Cr*   __main__z'Running doctests 1000x or until failurez%i timeszDoctests done)__doc__multiprocessingr   multiprocessing.connectionr   	rsa.primer   rsa.randnumr   r*   __all____name__printdoctestr   counttestmodfailurestests r   r
   <module>r:      s     1  %P ,z	
34s#OO-52:?uu*u$%  
/ r   