One Hat Cyber Team
Your IP :
18.188.189.204
Server IP :
192.145.235.60
Server :
Linux ngx365.inmotionhosting.com 5.14.0-427.33.1.el9_4.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Aug 30 09:45:56 EDT 2024 x86_64
Server Software :
Apache
PHP Version :
8.2.27
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
opt
/
saltstack
/
salt
/
lib
/
python3.10
/
__pycache__
/
View File Name :
asyncore.cpython-310.pyc
o �If,O � @ sx d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZ ejdedd� ee e eeeeh�Zze W n eyY i ZY nw dd� ZG d d � d e �Z e e e fZ d d � Z!d d� Z"dd� Z#dd� Z$d)dd�Z%d)dd�Z&e&Z'd*dd�Z(G d d � d �Z)G d d � d e)�Z*d d!� Z+d+d"d#�Z,ej-d$kr�G d%d&� d&�Z.G d'd(� d(e)�Z/dS dS ),a� Basic infrastructure for asynchronous socket service clients and servers. There are only two ways to have a program on a single processor do "more than one thing at a time". Multi-threaded programming is the simplest and most popular way to do it, but there is another very different technique, that lets you have nearly all the advantages of multi-threading, without actually using multiple threads. it's really only practical if your program is largely I/O bound. If your program is CPU bound, then pre-emptive scheduled threads are probably what you really need. Network servers are rarely CPU-bound, however. If your operating system supports the select() system call in its I/O library (and nearly all do), then you can use it to juggle multiple communication channels at once; doing other work while your I/O is taking place in the "background." Although this strategy can seem strange and complex, especially at first, it is in many ways easier to understand and control than multi-threaded programming. The module documented here solves many of the difficult problems for you, making the task of building sophisticated high-performance network servers and clients a snap. � N) �EALREADY� EINPROGRESS� EWOULDBLOCK� ECONNRESET�EINVAL�ENOTCONN� ESHUTDOWN�EISCONN�EBADF� ECONNABORTED�EPIPE�EAGAIN� errorcodezlThe asyncore module is deprecated and will be removed in Python 3.12. The recommended replacement is asyncio� )� stacklevelc C sB zt �| �W S tttfy | tv rt| Y S d| Y S w )NzUnknown error %s)�os�strerror� ValueError� OverflowError� NameErrorr )�err� r �./opt/saltstack/salt/lib/python3.10/asyncore.py� _strerrorK s �r c @ s e Zd ZdS )�ExitNowN)�__name__� __module__� __qualname__r r r r r S s r c C �2 z| � � W d S ty � | �� Y d S �N)�handle_read_event�_reraised_exceptions� handle_error��objr r r �readX � r% c C r r )�handle_write_eventr! r" r# r r r �write` r& r( c C r r )�handle_expt_eventr! r" r# r r r � _exceptionh r& r* c C s� z0|t j@ r | �� |t j@ r| �� |t j@ r | �� |t jt jB t j B @ r.| � � W d S W d S t yX } z |j t vrB| �� n | � � W Y d }~d S W Y d }~d S d }~w ty_ � | �� Y d S r )�select�POLLINr �POLLOUTr' �POLLPRIr) �POLLHUP�POLLERR�POLLNVAL� handle_close�OSError�errno� _DISCONNECTEDr" r! )r$ �flags�er r r � readwritep s( � �� r8 � c C s6 |d u rt }|r�g }g }g }t|�� �D ]&\}}|�� }|�� }|r'|�|� |r1|js1|�|� |s5|r:|�|� qg | krJ| krJ|krSn nt�| � d S t � |||| �\}}}|D ]}|� |�}|d u rlq`t |� q`|D ]}|� |�}|d u rqst |� qs|D ]}|� |�}|d u r�q�t |� q�d S d S r )� socket_map�list�items�readable�writable�append� accepting�time�sleepr+ �getr% r( r* ) �timeout�map�r�wr7 �fdr$ Zis_rZis_wr r r �poll� sF �" � rI c C s� |d u rt }| d urt| d �} t�� }|r^t|�� �D ]&\}}d}|�� r.|tjtjB O }|� � r:|j s:|tj O }|rB|� ||� q |�| �}|D ]\}}|� |�}|d u rXqJt||� qJd S d S )Ni� r )r: �intr+ rI r; r< r= r, r. r> r@ r- �registerrC r8 )rD rE ZpollsterrH r$ r6 rF r r r �poll2� s. � � rL � >@Fc C s� |d u rt }|rttd�rt}nt}|d u r#|r!|| |� |sd S d S |r:|dkr>|| |� |d }|r<|dks)d S d S d S d S )NrI r � )r: �hasattrr+ rL rI )rD Zuse_pollrE �countZpoll_funr r r �loop� s � �rQ c @ s2 e Zd ZdZdZdZdZdZdZe dh�Z dAdd�Z dd� Z dBdd �Z dBd d �Zejejfd d �ZdBdd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Z d"d#� Z d$d%� Z dCd'd(�Z d)d*� Z d+d,� Z!d-d.� Z"d/d0� Z#d1d2� Z$d3d4� Z%d5d6� Z&d7d8� Z'd9d:� Z(d;d<� Z)d=d>� Z*d?d@� Z+dS )D� dispatcherFN�warningc C s� |d u rt | _n|| _d | _|rK|�d� | �||� d| _z|�� | _W d S tyJ } z|j t t fv r9d| _n| � |� � W Y d }~d S d }~ww d | _ d S )NFT)r: �_map�_fileno� setblocking� set_socket� connected� getpeername�addrr3 r4 r r � del_channel�socket)�self�sockrE r r r r �__init__� s& ��� zdispatcher.__init__c C s� | j jd | j j g}| jr| jr|�d� n| jr |�d� | jd ur@z |�d| j � W n ty? |�t| j�� Y nw dd� |�t | �f S )N�.Z listeningrX z%s:%dz <%s at %#x>� ) � __class__r r r@ rZ r? rX � TypeError�repr�join�id)r] �statusr r r �__repr__ s �zdispatcher.__repr__c C s |d u r| j }| || j< d S r )rT rU )r] rE r r r � add_channel s zdispatcher.add_channelc C s, | j }|d u r | j}||v r||= d | _ d S r )rU rT )r] rE rH r r r r[ s zdispatcher.del_channelc C s. ||f| _ t�||�}|�d� | �|� d S �NF)Zfamily_and_typer\ rV rW )r] �family�typer^ r r r � create_socket s zdispatcher.create_socketc C s || _ |�� | _| �|� d S r )r\ �filenorU ri �r] r^ rE r r r rW % s zdispatcher.set_socketc C sB z| j �t jt j| j �t jt j�dB � W d S ty Y d S w )NrN )r\ � setsockopt� SOL_SOCKET� SO_REUSEADDR� getsockoptr3 �r] r r r �set_reuse_addr* s �� � �zdispatcher.set_reuse_addrc C � dS �NTr rt r r r r= ; � zdispatcher.readablec C rv rw r rt r r r r> > rx zdispatcher.writablec C s( d| _ tjdkr|dkrd}| j�|�S )NT�nt� )r@ r �namer\ �listen)r] �numr r r r| E s zdispatcher.listenc C s || _ | j�|�S r )rZ r\ �bind)r] rZ r r r r~ K s zdispatcher.bindc C sn d| _ d| _| j�|�}|tttfv s |tkr!tj dkr!|| _ d S |dt fv r0|| _ | � � d S t |t| ��)NFTry r )rX � connectingr\ � connect_exr r r r r r{ rZ r �handle_connect_eventr3 r )r] �addressr r r r �connectO s zdispatcher.connectc C sd z | j �� \}}W ||fS ty Y d S ty1 } z|jtttfv r,W Y d }~d S � d }~ww r )r\ �acceptrc r3 r4 r r r )r] �connrZ �whyr r r r� ] s ���zdispatcher.acceptc C sf z | j �|�}|W S ty2 } z |jtkr W Y d }~dS |jtv r-| �� W Y d }~dS � d }~ww �Nr )r\ �sendr3 r4 r r5 r2 )r] �data�resultr� r r r r� k s ��zdispatcher.sendc C s` z| j �|�}|s| �� W dS |W S ty/ } z|jtv r*| �� W Y d }~dS � d }~ww �N� )r\ �recvr2 r3 r4 r5 )r] Z buffer_sizer� r� r r r r� x s ��zdispatcher.recvc C sp d| _ d| _d| _| �� | jd ur6z| j�� W d S ty5 } z|jtt fvr*� W Y d }~d S d }~ww d S rj ) rX r@ r r[ r\ �closer3 r4 r r )r] r� r r r r� � s ����zdispatcher.closec C s t j�dt|� � d S )Nzlog: %s )�sys�stderrr( �str)r] �messager r r �log� s zdispatcher.log�infoc C s" || j vrtd||f � d S d S )Nz%s: %s)�ignore_log_types�print)r] r� rl r r r �log_info� s �zdispatcher.log_infoc C s> | j r | �� d S | js| jr| �� | �� d S | �� d S r )r@ � handle_acceptrX r r� � handle_readrt r r r r � s z dispatcher.handle_read_eventc C s@ | j �t jt j�}|dkrt|t|���| �� d| _d| _d S )Nr TF) r\ rs rq �SO_ERRORr3 r �handle_connectrX r �r] r r r r r� � s z dispatcher.handle_connect_eventc C s* | j rd S | js| jr| �� | �� d S r )r@ rX r r� � handle_writert r r r r' � s z dispatcher.handle_write_eventc C s2 | j �t jt j�}|dkr| �� d S | �� d S r� )r\ rs rq r� r2 � handle_exptr� r r r r) � s z dispatcher.handle_expt_eventc C sT t � \}}}}zt| �}W n dt| � }Y | �d||||f d� | �� d S )Nz)<__repr__(self) failed for object at %0x>z:uncaptured python exception, closing channel %s (%s:%s %s)�error)�compact_tracebackrd rf r� r2 )r] �nil�t�v�tbinfoZ self_reprr r r r" � s �� zdispatcher.handle_errorc C � | � dd� d S )Nz!unhandled incoming priority eventrS �r� rt r r r r� � � zdispatcher.handle_exptc C r� )Nzunhandled read eventrS r� rt r r r r� � r� zdispatcher.handle_readc C r� )Nzunhandled write eventrS r� rt r r r r� � r� zdispatcher.handle_writec C r� )Nzunhandled connect eventrS r� rt r r r r� � r� zdispatcher.handle_connectc C s" | � � }|d ur| j|� d S d S r )r� �handle_accepted)r] �pairr r r r� � s �zdispatcher.handle_acceptc C s |� � | �dd� d S )Nzunhandled accepted eventrS )r� r� )r] r^ rZ r r r r� � s zdispatcher.handle_acceptedc C s | � dd� | �� d S )Nzunhandled close eventrS )r� r� rt r r r r2 � s zdispatcher.handle_close�NNr )r� ),r r r �debugrX r@ r �closingrZ � frozensetr� r_ rh ri r[ r\ �AF_INET� SOCK_STREAMrm rW ru r= r> r| r~ r� r� r� r� r� r� r� r r� r' r) r" r� r� r� r� r� r� r2 r r r r rR � sL rR c @ s6 e Zd Zd dd�Zdd� Zdd� Zdd � Zd d � ZdS ) �dispatcher_with_sendNc C s t �| ||� d| _d S r� )rR r_ � out_bufferro r r r r_ s z dispatcher_with_send.__init__c C s. d}t �| | jd d� �}| j|d � | _d S )Nr i )rR r� r� )r] Znum_sentr r r � initiate_send s z"dispatcher_with_send.initiate_sendc C s | � � d S r )r� rt r r r r� s z!dispatcher_with_send.handle_writec C s | j pt| j�S r )rX �lenr� rt r r r r> s z dispatcher_with_send.writablec C s0 | j r | �dt|� � | j| | _| �� d S )Nz sending %s)r� r� rd r� r� )r] r� r r r r� s zdispatcher_with_send.sendr� )r r r r_ r� r� r> r� r r r r r� s r� c C s� t �� \} }}g }|std��|r'|�|jjj|jjjt|j �f� |j }|s~|d \}}}d� dd� |D ��}|||f| ||fS )Nztraceback does not exist���ra c S s g | ]}d | �qS )z [%s|%s|%s]r )�.0�xr r r � <listcomp>- s z%compact_traceback.<locals>.<listcomp>) r� �exc_info�AssertionErrorr? �tb_frame�f_code� co_filename�co_namer� � tb_lineno�tb_nextre )r� r� �tbr� �file�function�liner� r r r r� s �� r� c C s� | d u rt } t| �� �D ]1}z|�� W q ty/ } z|jtkr"n|s%� W Y d }~q d }~w ty6 � |s<� Y q | �� d S r ) r: r; �valuesr� r3 r4 r r! �clear)rE Z ignore_allr� r r r � close_all0 s$ � � r� �posixc @ sN e Zd Zdd� Zdd� Zdd� Zdd� Zdd d �ZeZeZ d d � Z dd� Z d S )� file_wrapperc C s t �|�| _d S r )r �duprH �r] rH r r r r_ U r� zfile_wrapper.__init__c C s* | j dkrtjd| t| d� | �� d S )Nr zunclosed file %r)�source)rH �warnings�warn�ResourceWarningr� rt r r r �__del__X s � zfile_wrapper.__del__c G � t j| jg|�R � S r )r r% rH �r] �argsr r r r� ^ � zfile_wrapper.recvc G r� r )r r( rH r� r r r r� a r� zfile_wrapper.sendNc C s$ |t jkr|t jkr|sdS td��)Nr z-Only asyncore specific behaviour implemented.)r\ rq r� �NotImplementedError)r] �levelZoptname�buflenr r r rs d s �zfile_wrapper.getsockoptc C s( | j dk rd S | j }d| _ t�|� d S )Nr r� )rH r r� r� r r r r� o s zfile_wrapper.closec C s | j S r )rH rt r r r rn v s zfile_wrapper.filenor ) r r r r_ r� r� r� rs r% r( r� rn r r r r r� P s r� c @ s e Zd Zddd�Zdd� ZdS )�file_dispatcherNc C sN t �| d |� d| _z|�� }W n ty Y nw | �|� t�|d� d S )NTF)rR r_ rX rn �AttributeError�set_filer � set_blocking)r] rH rE r r r r_ { s � zfile_dispatcher.__init__c C s" t |�| _| j�� | _| �� d S r )r� r\ rn rU ri r� r r r r� � s zfile_dispatcher.set_filer )r r r r_ r� r r r r r� y s r� )r9 N)rM FNNrj )0�__doc__r+ r\ r� rA r� r r4 r r r r r r r r r r r r r r� �DeprecationWarningr� r5 r: r r � Exceptionr �KeyboardInterrupt� SystemExitr! r% r( r* r8 rI rL Zpoll3rQ rR r� r� r� r{ r� r� r r r r �<module> sT <� � � ' * )�