Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/contrib/__pycache__/ |
a
��Sh� � @ 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 �</usr/local/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�join� remote_addr�SESSION_STARTED�makefile�_handle�super�__init__)r r& r' Zport_search_limitZ port_skewr � this_port�address�� __class__r r r3 [ 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�errno�
EADDRINUSE�EINVAL� Exception�NO_AVAILABLE_PORTr* )
r r& r' Z search_limitZskew�_r4 �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 r1 �closer, r! r( �
SESSION_ENDEDr* r r r r rR � s
zRdb._close_sessionc C s | � � | �� dS �Nr )rR Z set_continue�r �argr r r � do_continue� s zRdb.do_continuec C s | � � | �� dS rW )rR �set_quitrX r r r �do_quit� s z Rdb.do_quitc C s t �d � d S r )r �settracer r r r r[ � s z Rdb.set_quit)r r )�__name__�
__module__� __qualname__�__doc__r$ Z
_prev_outsr! r r r r r3 r r( rQ rT rR rZ Zdo_cZdo_contr\ Zdo_qZdo_exitr[ �
__classcell__r r r6 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)ra rF �osr> r �pdbr Zbilliard.processr �__all__r �environ�getr r; r rc �getattrrd rJ r) r/ rV r r r r r r r �<module> s& *
[