File: //usr/local/lib/python3.9/site-packages/billiard/__pycache__/compat.cpython-39.pyc
a
X>h� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ ejdkrlz d dlZW qp e yh d dl
m Z Y qp0 ndZz d dl Z W n e y� dZ Y n0 d dl
mZ eeefZeed�r�ejZdd� Znd d� ZzejZejZW n( e�y d
d � Ze� \ZZ[Y n0 d d
� Zd/dd�Zdd� Zz
ej Z W n& e�yP dd� Z d0dd�Z Y n 0 d1dd�Z dd� Z z d dl Z W n e �y� dd� Z Y n
0 dd� Z ejdk�r�d d � Z!d d � Z"n0d d lm#Z# d d!l$m$Z$m%Z%m&Z& d"d � Z"d#d � Z!d$Z'd%Z(ejdk�r(z d dl)Z)W n e �y dZ)Y n0 d&d'� Z*ndzd d(l m+Z+m,Z, W n e �yX d Z+Z,Y n0 d)ejv �srejd*k�r|d+d,� Z-nd-d,� Z-d.d'� Z*dS )2� N)� zip_longest�win32)r )�UnsupportedOperation�writec C s t | ||d � �S �N)� __write__��fd�buf�offset� r �9/usr/local/lib/python3.9/site-packages/billiard/compat.py� send_offset s r c C s t d��d S )Nr ��NotImplementedErrorr r r r
r " s c s> t �� � � dkrd�nd�� �fdd�} � �fdd�}| |fS )N�mbcs�strict�surrogateescapec s: t | t�r| S t | t�r$| �� ��S tdt| �j ��dS )a
Encode filename to the filesystem encoding with 'surrogateescape'
error handler, return bytes unchanged. On Windows, use 'strict'
error handler if the file system encoding is 'mbcs' (which is the
default encoding).
�expect bytes or str, not %sN)�
isinstance�bytes�str�encode� TypeError�type�__name__��filename��encoding�errorsr r
�fsencode1 s
�z_fscodec.<locals>.fsencodec s: t | t�r| S t | t�r$| �� ��S tdt| �j ��dS )a
Decode filename from the filesystem encoding with 'surrogateescape'
error handler, return str unchanged. On Windows, use 'strict' error
handler if the file system encoding is 'mbcs' (which is the default
encoding).
r N)r r r �decoder r r r r r r
�fsdecode@ s
�z_fscodec.<locals>.fsdecode)�sys�getfilesystemencoding)r! r# r r r
�_fscodec* s r& c C s2 t | tj�r| S z
| �� W S ty, Y n0 dS )z3Get object fileno, or :const:`None` if not defined.N)r �numbers�Integral�fileno�
FILENO_ERRORS)�fr r r
� maybe_filenoU s
r, c C sH z t �d�W S Y n0 tdu r&| S t�tj�d }|tjkrD| S |S )z�Return the maximum number of open file descriptors
on this system.
:keyword default: Value returned if there's no file
descriptor limit.
� SC_OPEN_MAXN� )�os�sysconf�resourceZ getrlimitZ
RLIMIT_NOFILEZ
RLIM_INFINITY)�defaultZfdmaxr r r
� get_fdmax_ s
r3 c s t � � � fdd�| D �S )z7Return all unique elements in ``it``, preserving order.c 3 s$ | ] }|� vr� � |�p|V qd S r )�add)�.0�obj��seenr r
� <genexpr>v � zuniq.<locals>.<genexpr>)�set)�itr r7 r
�uniqs s r= c C sZ t t| |��D ]F}zt�|� W q tyR } z|jtjkr>� W Y d }~qd }~0 0 qd S r )�reversed�ranger/ �close�OSError�errno�EBADF)Zfd_lowZfd_highr �excr r r
�
closerange} s rE c C s~ t ttdd� tt| pg �D ����} tdd�}tdg| �t| |g � }}t||�D ]"\}}|d |krVt|d |� qVd S )Nc s s | ]}|d ur|V qd S r r �r5 r+ r r r
r9 � s z!close_open_fds.<locals>.<genexpr>� �r2 ���r. ) �listr= �sorted�mapr, r3 �iterr rE )�keepZmaxfdZkLZkH�low�highr r r
�close_open_fds� s �
rQ c C sx dd� | p g D �} t ttdd���D ]N}|| vr$zt�|� W q$ typ } z|jtjkr\� W Y d }~q$d }~0 0 q$d S )Nc S s g | ]}t |�d urt |��qS r )r, rF r r r
�
<listcomp>� s �z"close_open_fds.<locals>.<listcomp>rG rH )r> r? r3 r/ r@ rA rB rC )rN r rD r r r
rQ � s � c C s" z| j W S ty Y dS 0 dS )zV:exc:`socket.error` and :exc:`IOError` first got
the ``.errno`` attribute in Py2.7r N)rB �AttributeError)rD r r r
� get_errno� s rT c C sZ t jdkr"|tt j�tt j�g }t�� }|sVttdd� |D ��d� t� t
| �|� |S )Nr c s s | ]}|r|V qd S r r rF r r r
r9 � r: z!spawnv_passfds.<locals>.<genexpr>)rN ) r$ �platformr, �stdout�stderrr/ �forkrQ rK �execvr! )�path�args�passfds�pidr r r
�spawnv_passfds� s
�r^ c C s� t |�}t�� \}}z�|t| �gdt|�d d dddddd||ddg}tjdkrX|�d� tjdkrl|�d� |�d � tjdkr�|�t j
� t j |� W t�
|� t�
|� S t�
|� t�
|� 0 d S )NTrI F)� � )r_ � )NNNrI )rK r/ �piper! �tupler$ � version_info�append�extend�
subprocessZ
_USE_VFORK�_posixsubprocess� fork_execr@ )rZ r[ r\ � errpipe_read�
errpipe_writer r r
r^ � s, �
� �
c C s t d��d S )Nz$setblocking not implemented on win32r )�handle�blockingr r r
� setblocking� s rn c C s t d��d S )Nz#isblocking not implemented on win32r �rl r r r
�
isblocking� s rp )�
O_NONBLOCK)�fcntl�F_GETFL�F_SETFLc C s t | t�t@ S r )rr rs rq ro r r r
rp � s c C s. t | td�}t | t|r |t @ n|tB � d S )Nr )rr rs rt rq )rl rm �flagsr r r
rn � s
�z�
On Windows, the ability to inspect memory usage requires the psutil library.
You can install it using pip:
$ pip install psutil
z�
Your platform ({0}) does not seem to have the `resource.getrusage' function.
Please open an issue so that we can add support for this platform.
c C s2 t d u rtt�� ��tt �t�� ��� d d �S )Nr � �@) �psutil� ImportError�E_PSUTIL_MISSING�strip�int�Processr/ �getpidZ memory_infor r r r
�mem_rss� s r~ )� getrusage� RUSAGE_SELFZbsd�darwinc C s t | �d S )Nrv �r{ ��vr r r
� maxrss_to_kb s r� c C s t | �S r r� r� r r r
r� s c C s* t d u r tt�� �tj���ttt �j
�S r ) r1 rx �E_RESOURCE_MISSINGrz �formatr$ rU r� r r� Z ru_maxrssr r r r
r~ s )N)N)N).rB r' r/ rg r$ � itertoolsr rU Z_winapirx �_multiprocessingr r1 �ior rS �
ValueErrorr* �hasattrr r r r! r# r& r, r3 r= rE rQ rT rh r^ rn rp rq rr rs rt ry r� rw r~ r r� r� r r r r
�<module> s�
'