| Server IP : 127.0.0.1 / Your IP : 216.73.216.109 Web Server : Apache/2.4.54 (Win64) OpenSSL/1.1.1q PHP/8.1.10 System : Windows NT DESKTOP-E5T4RUN 10.0 build 19045 (Windows 10) AMD64 User : SERVERWEB ( 0) PHP Version : 8.1.10 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/cygwin64/lib/python3.6/multiprocessing/__pycache__/ |
Upload File : |
3 �1�a � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZddlmZmZ ddl m Z dgZ ej dkrvd dl Z G dd� de�Zn,G d d� de�Zd d � Zd d � Zejee� G dd� de�ZG dd� de�ZdS )� N� )� reduction�assert_spawning)�util� BufferWrapper�win32c @ s, e Zd Zej� Zdd� Zdd� Zdd� ZdS )�Arenac C sz || _ xTtd�D ]@}dtj� t| j�f }tjd||d�}tj� dkrHP |j � qW t d��|| _ || _ | j | j f| _ d S )N�d z pym-%d-%sr )�tagnamer z Cannot find name for new mmap���)�size�range�os�getpid�next�_rand�mmap�_winapiZ GetLastError�close�FileExistsError�name�buffer�_state)�selfr �ir �buf� r �/usr/lib/python3.6/heap.py�__init__" s zArena.__init__c C s t | � | jS )N)r r )r r r r � __getstate__1 s zArena.__getstate__c C s, | \| _ | _| _tjd| j | jd�| _d S )Nr )r r )r r r r r )r �stater r r � __setstate__5 s zArena.__setstate__N) �__name__� __module__� __qualname__�tempfileZ_RandomNameSequencer r r r! r r r r r s r c @ s e Zd Zddd�ZdS )r r c C s� || _ || _|d kr�tjdtj� tj� d�\| _}tj|� tj | tj | jf� t | jddd��^}d }||kr�d| }x t || �D ]}|j |� q�W ~|j d|| � |j� |ks�t�W d Q R X tj| j| j �| _d S ) Nr zpym-%d-)�prefix�dir�wbF)�closefdi � r i )r �fdr% Zmkstempr r r Z get_temp_dir�unlink�Finalizer �openr �write�tell�AssertionErrorr r )r r r+ r �f�bsZzeros�_r r r r @ s" zArena.__init__Nr )r )r" r# r$ r r r r r r > s c C s( | j dkrtd��t| jtj| j �ffS )Nr zDArena is unpicklable because forking was enabled when it was createdr )r+ � ValueError� rebuild_arenar r ZDupFd)�ar r r � reduce_arenaS s r8 c C s t | |j� �S )N)r �detach)r Zdupfdr r r r6 Y s r6 c @ sZ e Zd ZdZejfdd�Zedd� �Zdd� Z dd � Z d d � Z d d � Z dd� Z dd� ZdS )�Heap� c C sJ t j� | _tj� | _|| _g | _i | _i | _ i | _ t � | _ g | _ g | _d S )N)r r �_lastpid� threadingZLock�_lock�_size�_lengths� _len_to_seq�_start_to_block�_stop_to_block�set�_allocated_blocks�_arenas�_pending_free_blocks)r r r r r r f s z Heap.__init__c C s |d }| | | @ S )Nr r )�nZ alignment�maskr r r �_roundups s z Heap._roundupc C s� t j| j|�}|t| j�krj| jt| j|�tj�}| jd9 _t j d|� t |�}| j j |� |d|fS | j| }| j| }|j� }|s�| j|= | j|= |\}}}| j||f= | j||f= |S )N� z"allocating a new mmap of length %dr )�bisectZ bisect_leftr@ �lenrJ �maxr? r �PAGESIZEr �infor rF �appendrA �poprB rC ) r r r �length�arena�seq�block�start�stopr r r �_mallocy s" z Heap._mallocc C s� |\}}}y| j ||f }W n tk r0 Y nX | j|�\}}y| j||f }W n tk rf Y nX | j|�\}}|||f}|| }y| j| j|� W n. tk r� |g| j|< tj| j|� Y nX || j||f< || j ||f< d S )N) rC �KeyError�_absorbrB rA rQ rL Zinsortr@ ) r rV rT rW rX Z prev_blockr4 Z next_blockrS r r r �_free� s( z Heap._freec C s^ |\}}}| j ||f= | j||f= || }| j| }|j|� |sV| j|= | jj|� ||fS )N)rB rC rA �remover@ )r rV rT rW rX rS rU r r r r[ � s z Heap._absorbc C sF x@y| j j� }W n tk r& P Y nX | jj|� | j|� qW d S )N)rG rR � IndexErrorrE r] r\ )r rV r r r �_free_pending_blocks� s zHeap._free_pending_blocksc C s` t j� | jkst�| jjd�s,| jj|� n0z"| j� | j j |� | j |� W d | jj � X d S )NF) r r r< r1 r> �acquirerG rQ r_ rE r] r\ �release)r rV r r r �free� s z Heap.freec C s� d| kot jk n s t�tj� | jkr4| j� | j�h | j� | j t |d�| j �}| j |�\}}}|| }||k r�| j |||f� |||f}| jj|� |S Q R X d S )Nr r )�sys�maxsizer1 r r r< r r> r_ rJ rN � _alignmentrY r\ rE �add)r r rT rW rX Znew_stoprV r r r �malloc� s z Heap.mallocN)r" r# r$ re r rO r � staticmethodrJ rY r\ r[ r_ rb rg r r r r r: b s r: c @ s" e Zd Ze� Zdd� Zdd� ZdS )r c C sN d| kot jk n s t�tjj|�}||f| _tj| tjj |fd� d S )Nr )�args) rc rd r1 r �_heaprg r r r- rb )r r rV r r r r � s zBufferWrapper.__init__c C s& | j \\}}}}t|j�||| � S )N)r � memoryviewr )r rT rW rX r r r r �create_memoryview� s z BufferWrapper.create_memoryviewN)r" r# r$ r: rj r rl r r r r r � s )rL r r rc r% r= �contextr r � r �__all__�platformr �objectr r8 r6 �registerr: r r r r r �<module> s$