File: //opt/alt/python37/lib/python3.7/site-packages/rsa/__pycache__/parallel.cpython-37.pyc
B
��fe � @ s� d Z ddlZddlmZ ddlZddlZeedd�dd�Z eeed�dd �Z
d gZ e d
kr�e
d � ddlZx>ed �D ]2Ze�� \ZZer�P ed
dkrterte
de � qtW e
d� dS )z�Functions for parallel computation on multiple cores.
Introduced in Python-RSA 3.1.
.. note::
Requires Python 2.6 or newer.
� N)�
Connection)�nbits�pipe�returnc C s0 x*t j�| �}t j�|�r|�|� d S qW d S )N)�rsaZrandnumZread_random_odd_int�primeZis_prime�send)r r �integer� r
�=/opt/alt/python37/lib/python3.7/site-packages/rsa/parallel.py� _find_prime s
r )r �poolsizer c sx t jdd�\}�z:� �fdd�t|�D �}x|D ] }|�� q0W |�� }W d|�� ��� X x|D ] }|�� qdW |S )aU 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)Zduplexc s g | ]}t jt� �fd ��qS ))�target�args)�mp�Processr )�.0�_)r � pipe_sendr
r �
<listcomp>A s z getprime.<locals>.<listcomp>N)r ZPipe�range�start�recv�close� terminate)r r
Z pipe_recvZprocs�p�resultr
)r r r �getprime* s
r �__main__z'Running doctests 1000x or until failure�d �
z%i timesz
Doctests done)�__doc__�multiprocessingr Zmultiprocessing.connectionr Z rsa.primer Z rsa.randnum�intr r �__all__�__name__�print�doctestr �count�testmodZfailures�testsr
r
r
r �<module> s"
(