File: //home/arjun/projects/env/lib/python3.10/site-packages/billiard/__pycache__/compat.cpython-310.pyc
o
!we� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ ejdkr5zd dlZW n e y4 d dl
m Z Y nw dZzd dl Z W n e yH dZ Y nw d dl
mZ eeefZeed�raejZdd� Znd d� ZzejZejZW n ey� d
d � Ze� \ZZ[Y nw d d
� Zd/dd�Zdd� Zzej Z W n ey� dd� Z d/dd�Z Y nw d/dd�Z dd� Z zd dl Z W n
e y� dd� Z Y nw dd� Z ejdkr�d d � Z!d d � Z"nd d lm#Z# d d!l$m$Z$m%Z%m&Z& d"d � Z"d#d � Z!d$Z'd%Z(ejdk�rzd dl)Z)W n e �y dZ)Y nw d&d'� Z*dS z
d d(l m+Z+m,Z, W n e �y( d Z+Z,Y nw d)ejv �s5ejd*k�r:d+d,� Z-nd-d,� Z-d.d'� Z*dS )0� N)� zip_longest�win32)r )�UnsupportedOperation�writec C s t | ||d � �S �N)� __write__��fd�buf�offset� r �H/home/arjun/projects/env/lib/python3.10/site-packages/billiard/compat.py� send_offset s r c C � t d��)Nr ��NotImplementedErrorr r r r
r " � c s> t �� � � dkr d�nd�� �fdd�} � �fdd�}| |fS )N�mbcs�strict�surrogateescapec �6 t | t�r| S t | t�r| �� ��S tdt| �j ��)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 %s)�
isinstance�bytes�str�encode� TypeError�type�__name__��filename��encoding�errorsr r
�fsencode1 �
�z_fscodec.<locals>.fsencodec r )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 )r r r �decoder r r r r! r r
�fsdecode@ r% z_fscodec.<locals>.fsdecode)�sys�getfilesystemencoding)r$ r' r r! r
�_fscodec* s r* c C s0 t | tj�r| S z| �� W S ty Y dS w )z3Get object fileno, or :const:`None` if not defined.N)r �numbers�Integral�fileno�
FILENO_ERRORS)�fr r r
� maybe_filenoU s
�r0 c C sD zt �d�W S Y tdu r| S t�tj�d }|tjkr | 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�resource� getrlimit�
RLIMIT_NOFILE�
RLIM_INFINITY)�default�fdmaxr r r
� get_fdmax_ s
r; 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 s �$ zuniq.<locals>.<genexpr>)�set)�itr r? r
�uniqs s rD c C sX t t| |��D ]"}zt�|� W q ty) } z
|jtjkr � W Y d }~qd }~ww d S r )�reversed�ranger3 �close�OSError�errno�EBADF)�fd_low�fd_highr �excr r r
�
closerange} s ����rN c C s~ t ttdd� tt| p g �D ����} tdd�}tdg| �t| |g �}}t||�D ]\}}|d |kr<t|d |� q+d S )Nc s s � | ] }|d ur|V qd S r r �r= r/ r r r
rA � s � �z!close_open_fds.<locals>.<genexpr>� �r9 ���r2 ) �listrD �sorted�mapr0 r; �iterr rN )�keep�maxfd�kL�kH�low�highr r r
�close_open_fds� s �
��r] c C sx dd� | pg D �} t ttdd���D ]'}|| vr9zt�|� W q ty8 } z
|jtjkr.� W Y d }~qd }~ww qd S )Nc S s g | ] }t |�d urt |��qS r )r0 rO r r r
�
<listcomp>� s �z"close_open_fds.<locals>.<listcomp>rP rQ )rE rF r; r3 rG rH rI rJ )rW r rM r r r
r] � s � �����c C s z| j W S ty Y dS w )zV:exc:`socket.error` and :exc:`IOError` first got
the ``.errno`` attribute in Py2.7r )rI �AttributeError)rM r r r
� get_errno� s
�r` c C sZ t jdkr|tt j�tt j�g }t�� }|s+ttdd� |D ��d� t� t
| �|� |S )Nr c s s � | ]}|r|V qd S r r rO r r r
rA � s � z!spawnv_passfds.<locals>.<genexpr>)rW ) r( �platformr0 �stdout�stderrr3 �forkr] rT �execvr$ )�path�args�passfds�pidr r r
�spawnv_passfds� s
�rj c C s� t |�}t�� \}}zK|t| �gdt|�d d dddddd||ddg}tjdkr,|�d� tjdkr6|�d� |�d � tjdkrF|�t j
� t j |� W t�
|� t�
|� S t�
|� t�
|� w )NTrR F)� � )rk � )NNNrR )rT r3 �piper$ �tupler( � version_info�append�extend�
subprocess�
_USE_VFORK�_posixsubprocess� fork_execrG )rf rg rh � errpipe_read�
errpipe_writer r r
rj � s& �
� c C r )Nz$setblocking not implemented on win32r )�handle�blockingr r r
� setblocking� r r{ c C r )Nz#isblocking not implemented on win32r �ry r r r
�
isblocking� r r} )�
O_NONBLOCK)�fcntl�F_GETFL�F_SETFLc C s t | t�t@ S r )r r� r~ r| r r r
r} � s c C s4 t | td�}t | t|r|t @ � d S |tB � d S )Nr )r r� r� r~ )ry rz �flagsr r r
r{ � 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 r
tt�� ��tt �t�� ��� d d �S )Nr � �@) �psutil� ImportError�E_PSUTIL_MISSING�strip�int�Processr3 �getpid� memory_infor r r r
�mem_rss� s r� )� getrusage� RUSAGE_SELF�bsd�darwinc C s t | �d S )Nr� �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 rtt�� �tj���ttt �j
�S r ) r5 r� �E_RESOURCE_MISSINGr� �formatr( ra r� r� r� � ru_maxrssr r r r
r� s r ).rI r+ r3 rs r( � itertoolsr ra �_winapir� �_multiprocessingr r5 �ior r_ �
ValueErrorr. �hasattrr r r r$ r' r* r0 r; rD rN r] r` ru rj r{ r} r~ r r� r� r� r� r� r� r� r� r� r r r r
�<module> s�
� �
'�,
�
�
� �