Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/contrib/__pycache__/rdb.cpython-39.pyc
Ðазад
a t�h� � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ dZ dZ ej � d�pRdZ eej � d �pde �ZdgZeed �Zd Zd Zd ZdZG dd� de�Zdd� Zddd�ZdS )a6 Remote Debugger. Introduction ============ This is a remote debugger for Celery tasks running in multiprocessing pool workers. Inspired by a lost post on dzone.com. Usage ----- .. code-block:: python from celery.contrib import rdb from celery import task @task() def add(x, y): result = x + y rdb.set_trace() return result Environment Variables ===================== .. envvar:: CELERY_RDB_HOST ``CELERY_RDB_HOST`` ------------------- Hostname to bind to. Default is '127.0.0.1' (only accessible from localhost). .. envvar:: CELERY_RDB_PORT ``CELERY_RDB_PORT`` ------------------- Base port to bind to. Default is 6899. The debugger will try to find an available port starting from the base port. The selected port will be logged by the worker. � N)�Pdb)�current_process)�CELERY_RDB_HOST�CELERY_RDB_PORT� DEFAULT_PORT�Rdb�debugger� set_tracei� r z 127.0.0.1r � _getframezs{self.ident}: Couldn't find an available port. Please specify one using the CELERY_RDB_PORT environment variable. z�{self.ident}: Ready to connect: telnet {self.host} {self.port} Type `exit` in session to continue. {self.ident}: Waiting for client... z5{self.ident}: Now in session with {self.remote_addr}.z4{self.ident}: Session with {self.remote_addr} ended.c s� e Zd ZdZdZdZdZeedde j f� fdd� Z ddd �Z d d � Z d d � Zdd� Zdd� Zdd� Ze ZZdd� Ze ZZdd� Z� ZS )r zRemote debugger.zRemote DebuggerN�d r c s� d| _ || _tjtjf| _| �||||�\| _}| j�d� | j� d� | j � d|� �| _ || _ || _ | �tj| d�� | j�� \| _}| j�d� d�dd� |D ��| _| �tj| d�� | j�d� | _ t_t_t� jd| j| jd � d S ) NT� �:��selfc s s | ]}t |�V qd S �N)�str)�.0�v� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/contrib/rdb.py� <genexpr>n � z Rdb.__init__.<locals>.<genexpr>�rw�tab)Z completekey�stdin�stdout)�active�out�sysr r � _prev_handles�get_avail_port�_sock� setblocking�listen�me�ident�host�port�say�BANNER�format�accept�_client�joinZ remote_addr�SESSION_STARTED�makefile�_handle�super�__init__)r r& r' Zport_search_limitZ port_skewr � this_port�address�� __class__r r r2 [ s( � �z Rdb.__init__c C s� z t � j�d�\}}t|�}W n ty0 Y n0 d }t|�D ]�}t�tjtj�}|� tj tj d� || | }z|� ||f� W nD t y� } z,| jtjtjfv r�W Y d } ~ q>� W Y d } ~ q>d } ~ 0 0 ||f S q>ttj| d���d S )N�-r r )r �name�split�int� ValueError�range�socket�AF_INET� SOCK_STREAM� setsockopt� SOL_SOCKET� SO_REUSEADDR�bind�OSError�errnoZ EADDRINUSE�EINVAL� Exception�NO_AVAILABLE_PORTr* ) r r& r' Z search_limitZskew�_r3 �ir! �excr r r r t s$ zRdb.get_avail_portc C s t || jd� d S )N)�file)�printr )r �mr r r r( � s zRdb.sayc C s | S r r r r r r � __enter__� s z Rdb.__enter__c G s | � � d S r )�_close_session)r �exc_infor r r �__exit__� s z Rdb.__exit__c C sx | j \| _| _\t_t_| jrt| jd ur4| j�� | jd urH| j�� | jd ur\| j�� d| _| � t j | d�� d S )NFr ) r r r r r r0 �closer, r! r( � SESSION_ENDEDr* r r r r rP � s zRdb._close_sessionc C s | � � | �� dS �Nr )rP Z set_continue�r �argr r r � do_continue� s zRdb.do_continuec C s | � � | �� dS rU )rP �set_quitrV r r r �do_quit� s z Rdb.do_quitc C s t �d � d S r )r �settracer r r r rY � s z Rdb.set_quit)r r )�__name__� __module__� __qualname__�__doc__r$ Z _prev_outsr! r r r r r2 r r( rO rR rP rX Zdo_cZdo_contrZ Zdo_qZdo_exitrY � __classcell__r r r5 r r T s" � r c C s( t d } | du s| js$t� } t d< | S )z8Return the current debugger instance, or create if none.r N)�_currentr r )Zrdbr r r r � s r c C s | du rt � j} t� �| �S )z:Set break-point at current location, or a specified frame.N)�_frame�f_backr r )�framer r r r � s r )N)r_ rE �osr= r Zpdbr Zbilliard.processr �__all__r �environ�getr r: r ra �getattrrb rH r) r. rT r r r r r r r �<module> s& * [
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка