Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/jedi/inference/compiled/subprocess/__pycache__/__init__.cpython-39.pyc
Ðазад
a j�h�K � @ sf d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z mZ ddlmZmZ ddlmZ ddlmZ dd lmZ dd lmZmZmZ dd l m Z er�dd l m Z ej �!ej �"e#�d �Z$dZ%dd� Z&dd� Z'dd� Z(dd� Z)dd� Z*G dd� d�Z+G dd � d e+�Z,G d d � d e+�Z-G d d � d �Z.G d!d"� d"�Z/G d#d$� d$�Z0dS )%a� Makes it possible to do the compiled analysis in a subprocess. This has two goals: 1. Making it safer - Segfaults and RuntimeErrors as well as stdout/stderr can be ignored and dealt with. 2. Make it possible to handle different Python versions as well as virtualenvs. The architecture here is briefly: - For each Jedi `Environment` there is a corresponding subprocess which operates within the target environment. If the subprocess dies it is replaced at this level. - `CompiledSubprocess` manages exactly one subprocess and handles communication from the parent side. - `Listener` runs within the subprocess, processing each request and yielding results. - `InterpreterEnvironment` provides an API which matches that of `Environment`, but runs functionality inline rather than within a subprocess. It is thus used both directly in places where a subprocess is unnecessary and/or undesirable and also within subprocesses themselves. - `InferenceStateSubprocess` (or `InferenceStateSameProcess`) provide high level access to functionality within the subprocess from within the parent. Each `InterpreterState` has an instance of one of these, provided by its environment. � N)�partial)�Thread)�Dict� TYPE_CHECKING)� pickle_dump� pickle_load)�debug)�memoize_method)� functions)�DirectObjectAccess� AccessPath�SignatureParam)� InternalError��InferenceStatez __main__.py� c O sR t jdkr4z tj}W n ty* d}Y n0 ||d< dtjv |d< tj| i |��S )N�nti � creationflags�posix� close_fds)�os�name� subprocess�CREATE_NO_WINDOW�AttributeError�sys�builtin_module_names�Popen)�args�kwargsr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/jedi/inference/compiled/subprocess/__init__.py�_GeneralizedPopen6 s r" c C s t | jd�D ]}|�|� q d S )N� )�iter�readline�put)�outZqueue_�liner r r! �_enqueue_outputE s r) c C sL z,| � � }|�dd�}t�d|�d� � W q tjyD Y qHY q 0 q d S )N�utf-8�replacezstderr output: %s� )� get_nowait�decoder �warning�rstrip�queue�Empty)Z stderr_queuer( r r r! �_add_stderr_to_debugJ s r3 c C s t t| �S �N)�getattrr )r r r r! � _get_functionV s r6 c C sj z| � � | �� W n ty& Y n0 |�� | j| j| jfD ]$}z |�� W q@ tyb Y q@0 q@d S r4 )�kill�wait�OSError�join�stdin�stdout�stderr�close)�process�thread�streamr r r! �_cleanup_processZ s rB c @ s4 e Zd Zddd�dd�Zdd� Zdd � Zd d � ZdS ) �_InferenceStateProcessr N)�inference_state�returnc C s t �|�| _i | _d S r4 )�weakref�ref�_inference_state_weakref�_handles)�selfrD r r r! �__init__k s z _InferenceStateProcess.__init__c C sT t |�}z | �|�W S tyN t| �� |�}t| ||�}| �|� | Y S 0 d S r4 )�id�get_access_handle�KeyErrorr rH � AccessHandle�set_access_handle)rJ �obj�id_�access�handler r r! �get_or_create_access_handleo s z2_InferenceStateProcess.get_or_create_access_handlec C s | j | S r4 )rI )rJ rR r r r! rM y s z(_InferenceStateProcess.get_access_handlec C s || j |j< d S r4 )rI rL )rJ rT r r r! rP | s z(_InferenceStateProcess.set_access_handle)�__name__� __module__� __qualname__rK rU rM rP r r r r! rC j s rC c @ s e Zd ZdZdd� ZdS )�InferenceStateSameProcessz� Basically just an easy access to functions.py. It has the same API as InferenceStateSubprocess and does the same thing without using a subprocess. This is necessary for the Interpreter process. c C s t t|�| �� �S r4 )r r6 rH �rJ r r r r! � __getattr__� s z%InferenceStateSameProcess.__getattr__N)rV rW rX �__doc__r[ r r r r! rY � s rY c sB e Zd ZdZdddd�� fdd� Zdd � Zd d � Zd d � Z� ZS )�InferenceStateSubprocessa API to functionality which will run in a subprocess. This mediates the interaction between an `InferenceState` and the actual execution of functionality running within a `CompiledSubprocess`. Available functions are defined in `.functions`, though should be accessed via attributes on this class of the same name. This class is responsible for indicating that the `InferenceState` within the subprocess can be removed once the corresponding instance in the parent goes away. r �CompiledSubprocessN)rD �compiled_subprocessrE c s& t � �|� d| _|| _t| �| _d S )NF)�superrK �_used�_compiled_subprocessrL �_inference_state_id)rJ rD r_ �� __class__r r! rK � s z!InferenceStateSubprocess.__init__c s t |�� � �fdd�}|S )Nc s& d�_ �jj�j� | |d�}��|�S )NT)r r )ra rb �runrc �_convert_access_handles)r r �result��funcrJ r r! �wrapper� s � z5InferenceStateSubprocess.__getattr__.<locals>.wrapper)r6 )rJ r rk r ri r! r[ � s z$InferenceStateSubprocess.__getattr__c s� t |t�r t� �t|��� S t |t�r<t� fdd�|D ��S t |t�rX� fdd�|D �S t |t�r�z� �|j�}W q� ty� |� � � � � |� Y q�0 nt |t �r�t � �|j ��S |S )Nc 3 s | ]}� � |�V qd S r4 �rg ��.0�o�rJ r r! � <genexpr>� r# zCInferenceStateSubprocess._convert_access_handles.<locals>.<genexpr>c s g | ]}� � |��qS r rl rm rp r r! � <listcomp>� r# zDInferenceStateSubprocess._convert_access_handles.<locals>.<listcomp>) � isinstancer rg �tuple�listrO rM rL rN �add_subprocessrP r Zaccesses)rJ rQ r rp r! rg � s z0InferenceStateSubprocess._convert_access_handlesc C s | j r | jjs | j�| j� d S r4 )ra rb � is_crashed�delete_inference_staterc rp r r r! �__del__� s z InferenceStateSubprocess.__del__) rV rW rX r\ rK r[ rg ry � __classcell__r r rd r! r] � s � r] c @ sf e Zd ZdZdZddd�Zdd� Zedd � �Zd i fd d �Z d d� Z dd� Z d i fdd�Z dd� Z dS )r^ a� A subprocess which runs inference within a target environment. This class manages the interface to a single instance of such a process as well as the lifecycle of the process itself. See `.__main__` and `Listener` for the implementation of the subprocess and details of the protocol. A single live instance of this is maintained by `jedi.api.environment.Environment`, so that typically a single subprocess is used at a time. FNc C s$ || _ || _t�� | _dd� | _d S )Nc S s d S r4 r r r r r! �<lambda>� r# z-CompiledSubprocess.__init__.<locals>.<lambda>)� _executable� _env_vars� collections�deque� _inference_state_deletion_queue�_cleanup_callable)rJ � executableZenv_varsr r r! rK � s zCompiledSubprocess.__init__c C s t �� }d| jj| j| j|f S )Nz*<%s _executable=%r, is_crashed=%r, pid=%r>)r �getpidre rV r| rw )rJ �pidr r r! �__repr__� s �zCompiledSubprocess.__repr__c C s� t �d| j� tjd j}| jttj� tj� |��d� dd� tj d d� D ��f}t |t jt jt j| jd�}t�� | _tt|j| jfd� | _}d |_|�� t�| t||�| _ |S ) Nz Start environment subprocess %sZparso�.c s s | ]}t |�V qd S r4 )�str)rn �xr r r! rq r# z2CompiledSubprocess._get_process.<locals>.<genexpr>� )r; r< r= �env)�targetr T) r Zdbgr| r �modules�__file__� _MAIN_PATHr �path�dirnamer: � version_infor" r �PIPEr} r1 �Queue� _stderr_queuer r) r= Z_stderr_thread�daemon�startrF �finalizerB r� )rJ Z parso_pathr r? �tr r r! � _get_process� s6 �� � �z CompiledSubprocess._get_processr c C sP z| j �� }W n ty$ Y q4Y q 0 | �|d � q t|�s@J �| �||||�S r4 )r� �pop� IndexError�_send�callable)rJ �inference_state_id�functionr r Z delete_idr r r! rf s zCompiledSubprocess.runc C s | � d tjdi �S )Nr )r� r � get_sys_pathrp r r r! r� * s z CompiledSubprocess.get_sys_pathc C s d| _ | �� d S )NT)rw r� rp r r r! �_kill- s zCompiledSubprocess._killc C s. | j rtd| j ��||||f}zt|| �� jt� W n( ty^ | �� td| j ��Y n0 zt | �� j �\}}}W n� t �y } zzz| �� j � � �dd�} W n, ty� } zd| } W Y d } ~ n d } ~ 0 0 | �� t| j� td| j| | f ��W Y d } ~ n d } ~ 0 0 t| j� |�r*|f|_|�|S )Nz The subprocess %s has crashed.z2The subprocess %s was killed. Maybe out of memory?r* r+ z<empty/not available (%r)>z.The subprocess %s has crashed (%r, stderr=%s).)rw r r| r r� r; �PICKLE_PROTOCOL�BrokenPipeErrorr� r r< �EOFErrorr= �readr. � Exceptionr3 r� r ) rJ r� r� r r �dataZ is_exception� tracebackrh Z eof_errorr= �excr r r! r� 1 s> � �� zCompiledSubprocess._sendc C s | j �|� dS )af Indicate that an inference state (in the subprocess) is no longer needed. The state corresponding to the given id will become inaccessible and the id may safely be re-used to refer to a different context. Note: it is not guaranteed that the corresponding state will actually be deleted immediately. N)r� �append)rJ r� r r r! rx V s z)CompiledSubprocess.delete_inference_state)N)rV rW rX r\ rw rK r� r r� rf r� r� r� rx r r r r! r^ � s %r^ c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �ListeneraM Main loop for the subprocess which actually does the inference. This class runs within the target environment. It listens to instructions from the parent process, runs inference and returns the results. The subprocess has a long lifetime and is expected to process several requests, including for different `InferenceState` instances in the parent. See `CompiledSubprocess` for the parent half of the system. Communication is via pickled data sent serially over stdin and stdout. Stderr is read only if the child process crashes. The request protocol is a 4-tuple of: * inference_state_id | None: an opaque identifier of the parent's `InferenceState`. An `InferenceState` operating over an `InterpreterEnvironment` is created within this process for each of these, ensuring that each parent context has a corresponding context here. This allows context to be persisted between requests. Unless `None`, the local `InferenceState` will be passed to the given function as the first positional argument. * function | None: the function to run. This is expected to be a member of `.functions`. `None` indicates that the corresponding inference state is no longer needed and should be dropped. * args: positional arguments to the `function`. If any of these are `AccessHandle` instances they will be adapted to the local `InferenceState` before being passed. * kwargs: keyword arguments to the `function`. If any of these are `AccessHandle` instances they will be adapted to the local `InferenceState` before being passed. The result protocol is a 3-tuple of either: * (False, None, function result): if the function returns without error, or * (True, traceback, exception): if the function raises an exception c C s i | _ d S r4 )�_inference_statesrp r r r! rK � s zListener.__init__c C sV ddl m} z| j| }W n6 tyP ddlm} |d |� d�}|| j|< Y n0 |S )Nr r )�InterpreterEnvironment)�project� environment)�jedi.inferencer r� rN �jedir� )rJ r� r� r rD r� r r r! �_get_inference_state� s �z Listener._get_inference_statec C s� |d u r||i |��S |d u r(| j |= n�| �||�}t|�}t|�D ]$\}}t|t�rD|j�|j�||< qD|� � D ]$\}} t| t�rr|j�| j�||< qr||g|�R i |��S d S r4 ) r� r� ru � enumeraters rO r_ rM rL �items) rJ r� r� r r rD �i�arg�key�valuer r r! �_run� s z Listener._runc C s� t j}ttjd�t _t j}|j}|j}z t|�}W n tyL t d� Y n0 zdd | j |� f}W n2 t y� } zdt � � |f}W Y d }~n d }~0 0 t||t� q&d S )N�wr FT)r r< �openr �devnullr; �bufferr r� �exitr� r� r� � format_excr r� )rJ r< r; �payloadrh �er r r! �listen� s $zListener.listenN)rV rW rX r\ rK r� r� r� r r r r! r� l s $r� c @ s\ e Zd Zeeedd�dd�Zdd� Zdd� Zd d � Z d d � Z d d� Z dd� Z e dd� �ZdS )rO N)r rS rR rE c C s || _ || _|| _d S r4 )rS � _subprocessrL )rJ r rS rR r r r! rK � s zAccessHandle.__init__c C s || _ d S r4 )r� )rJ r r r r! rv � s zAccessHandle.add_subprocessc C s< z | j }W n ty* dt| j� }Y n0 d| jj|f S )N�#z <%s of %s>)rS r r� rL re rV )rJ �detailr r r! r� � s zAccessHandle.__repr__c C s | j S r4 �rL rp r r r! � __getstate__� s zAccessHandle.__getstate__c C s || _ d S r4 r� )rJ �stater r r! � __setstate__� s zAccessHandle.__setstate__c C s& |dv s|� d�rtd��t| j|�S )N)rL rS �_z$Something went wrong with unpickling)� startswithr r � _workaroundrZ r r r! r[ � s zAccessHandle.__getattr__c O sH |r0t |d t�r0| jj| j|g|�R i |��S | j|g|�R i |��S )z� TODO Currently we're passing slice objects around. This should not happen. They are also the only unhashable objects that we're passing around. r )rs �slicer� �get_compiled_method_returnrL �_cached_results�rJ r r r r r r! r� � s zAccessHandle._workaroundc O s | j j| j|g|�R i |��S r4 )r� r� rL r� r r r! r� � s z AccessHandle._cached_results)rV rW rX rC r �intrK rv r� r� r� r[ r� r r� r r r r! rO � s � rO )1r\ r~ r r r1 r r� rF � functoolsr � threadingr �typingr r Zjedi._compatibilityr r r� r Z jedi.cacher Z"jedi.inference.compiled.subprocessr Z jedi.inference.compiled.accessr r r Zjedi.api.exceptionsr r� r r� r: r� r� r� r� r" r) r3 r6 rB rC rY r] r^ r� rO r r r r! �<module> s@ V f
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка