⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.24
Server IP:
50.6.168.112
Server:
Linux server-617809.webnetzimbabwe.com 5.14.0-570.25.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 9 04:57:09 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.4.10
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
opt
/
alt
/
python311
/
lib64
/
python3.11
/
__pycache__
/
View File Name :
asyncore.cpython-311.opt-1.pyc
xn0 d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZ dZ ej eed ee e eeeeh Z e n # e$ r i ZY nw xY wd Z G d d e Z e e e fZ!d Z"d Z#d Z$d Z%d dZ&d dZ'e'Z(d dZ) G d d Z* G d de* Z+d Z,d!dZ-ej. dk r G d d Z/ G d d e* Z0dS 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 ECONNRESETEINVALENOTCONN ESHUTDOWNEISCONNEBADF ECONNABORTEDEPIPEEAGAIN errorcodeznThe {name} module is deprecated and will be removed in Python {remove}. The recommended replacement is asyncio) )removec t j | S # t t t f$ r | t v rt | cY S d| z cY S w xY w)NzUnknown error %s)osstrerror ValueError OverflowError NameErrorr )errs //opt/alt/python311/lib64/python3.11/asyncore.py _strerrorr I se '{3 y 1 ' ' ' ) S> ! ! !!3&&&&'s -A A A c e Zd ZdS )ExitNowN)__name__ __module__ __qualname__ r r r Q s Dr" r c | | d S # t $ r | Y d S xY wN)handle_read_event_reraised_exceptions handle_errorobjs r readr* V X ;c | | d S # t $ r | Y d S xY wr$ )handle_write_eventr& r' r( s r writer/ ^ sX r, c | | d S # t $ r | Y d S xY wr$ )handle_expt_eventr& r' r( s r _exceptionr2 f r+ r, c D |t j z r| |t j z r| |t j z r| |t j t j z t j z z r| d S d S # t $ rH}|j t vr| n| Y d }~d S Y d }~d S d }~wt $ r | Y d S xY wr$ )selectPOLLINr% POLLOUTr. POLLPRIr1 POLLHUPPOLLERRPOLLNVAL handle_closeOSErrorerrno _DISCONNECTEDr' r& )r) flagses r readwriterA n sT 6= $ ! ! # # # 6> ! % " " $ $ $ 6> ! $ ! ! # # # FNV^3foE F 7- ' ' s B&B, , D 67C99#D c |t }|rog }g }g }t | D ]{\ }}| }| }|r| | |r |j s| | |s|r| | |g |cxk r |cxk r|k rn nt j | d S t j |||| \ }}}|D ])}| | }|t | *|D ])}| | }|t | *|D ]+}| | }|t | *d S d S r$ ) socket_maplistitemsreadablewritableappend acceptingtimesleepr4 getr* r/ r2 ) timeoutmaprwr@ fdr) is_ris_ws r pollrU s { " BBCIIKK(( GB<<>>D<<>>D CM t a 1 Jw F-1a111a B''"++C{ IIII B''"++C{ #JJJJ B''"++C{ sOOOOE" " < r" c . |t }| t | dz } t j }|rt | D ]y\ }}d}| r |t j t j z z }| r|j s|t j z }|r| || z| | }|D ]/\ }}| | }| t || .d S d S )Ni r )rD intr4 rU rE rF rG r5 r7 rH rJ r6 registerrM rA )rN rO pollsterrR r) r? rP s r poll2rZ s' {gdl##{}}H "CIIKK(( - -GBE||~~ 8 77||~~ (cm ( ' -!!"e,,, MM' " " " "IB''"++C{ c5 ! ! ! !!" " " "r" >@Fc |t }|r t t d rt }nt }||r || | |d S d S |r!|dk r || | |dz }|r |dk d S d S d S d S )NrU r )rD hasattrr4 rZ rU )rN use_pollrO countpoll_funs r looprb s { GFF++ } # HWc " " " # # # # # eaii HWc " " "AIE eaiiii iir" c e Zd ZdZdZdZdZdZdZ e dh Z d#dZ d Z d$dZ d$dZej ej fdZd$d Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d Z d Z d%dZ d Z d Z!d Z"d Z#d Z$d Z%d Z&d Z'd Z(d Z)d! Z*d" Z+dS )& dispatcherFNwarningc | t | _ n|| _ d | _ |r| d | || d| _ | | _ d S # t $ r>}|j t t fv rd| _ n| | Y d }~d S d }~ww xY wd | _ d S )NFT)rD _map_fileno setblocking set_socket connected getpeernameaddrr< r= r r del_channelsocket)selfsockrO r s r __init__zdispatcher.__init__ s ;"DIIDI U # # # OOD# & & & !DN , , . . 96 222 &+DNN $$S))) #NNNNN DKKKs A. . B683B11B6c | j j dz | j j z g}| j r | j r| d n | j r| d | j V | d| j z n7# t $ r* | t | j Y nw xY wdd | t | fz S )N. listeningrk z%s:%dz <%s at %#x> ) __class__r r rJ rm rI rk TypeErrorreprjoinid)rp statuss r __repr__zdispatcher.__repr__ s .+C/0KKL > 'di ' MM+ & & & & ^ ' MM+ & & & 9 / g 12222 / / / d49oo..... / 0 0"T(( ;;;s & B 1B87B8c , || j }| || j < d S r$ )rg rh )rp rO s r add_channelzdispatcher.add_channel s ;)C DLr" c B | j }|| j }||v r||= d | _ d S r$ )rh rg )rp rO rR s r rn zdispatcher.del_channel s0 \ ;)C 99B r" c ||f| _ t j || }| d | | d S NF)family_and_typero ri rj )rp familytyperq s r create_socketzdispatcher.create_socket sK %t| }VT** r" c p || _ | | _ | | d S r$ )ro filenorh r rp rq rO s r rj zdispatcher.set_socket# s2 {{}} r" c | j t j t j | j t j t j dz d S # t $ r Y d S w xY w)Nr] )ro setsockopt SOL_SOCKET SO_REUSEADDR getsockoptr< rp s r set_reuse_addrzdispatcher.set_reuse_addr( s K " "!6#6 &&v'8'-':< <>?@ DD s A A$ $ A21A2c dS NTr! r s r rG zdispatcher.readable9 tr" c dS r r! r s r rH zdispatcher.writable< r r" c t d| _ t j dk r|dk rd}| j | S )NTnt )rJ r namero listen)rp nums r r zdispatcher.listenC s7 7d??sQwwC{!!#&&&r" c D || _ | j | S r$ )rm ro bind)rp rm s r r zdispatcher.bindI s { %%%r" c L d| _ d| _ | j | }|t t t fv s|t k rt j dk r || _ d S |dt fv r || _ | d S t |t | )NFTr r )rk connectingro connect_exr r r r r r rm r handle_connect_eventr< r )rp addressr s r connectzdispatcher.connectM s k$$W-- ;+6 6 6 &==RW__ DI F 1g, DI % % ' ' ' ' '#y~.. .r" c | j \ }}||fS # t $ r Y d S t $ r'}|j t t t fv rY d }~d S d }~ww xY wr$ )ro acceptrx r< r= r r r )rp connrm whys r r zdispatcher.accept[ s ++--JD$ : 44 y[, ???ttttt s " A A AAA c | j | }|S # t $ rD}|j t k rY d }~dS |j t v r| Y d }~dS d }~ww xY wNr )ro sendr< r= r r> r; )rp dataresultr s r r zdispatcher.sendi s [%%d++FM yK''qqqqqm++!!###qqqqq s A,A'"A'&A''A,c | j | }|s| dS |S # t $ r.}|j t v r| Y d }~dS d }~ww xY wNr" )ro recvr; r< r= r> )rp buffer_sizer r s r r zdispatcher.recvv s ;##K00D !!###s yM))!!###sssss s 06 6 A. "A)(A))A.c d| _ d| _ d| _ | | j J | j d S # t $ r!}|j t t fvr Y d }~d S d }~ww xY wd S r ) rk rJ r rn ro closer< r= r r )rp r s r r zdispatcher.close s ; " !!##### 9Xu$555 655555 # "s A A8A33A8c d t j dt | z d S )Nzlog: %s )sysstderrr/ str)rp messages r logzdispatcher.log s) s7||344444r" infoc D || j vrt |d| d S d S )Nz: )ignore_log_typesprint)rp r r s r log_infozdispatcher.log_info s7 t, , , dddGG, - - - - - - ,r" c | j r| d S | j s1| j r| | d S | d S r$ )rJ handle_acceptrk r r handle_readr s r r% z dispatcher.handle_read_event s| > ,))+++ r" c | j t j t j }|dk r t |t | | d| _ d| _ d S )Nr TF) ro r r SO_ERRORr< r handle_connectrk r rp r s r r z dispatcher.handle_connect_event sa k$$V%6HH !88#y~~.. . r" c | j rd S | j s| j r| | d S r$ )rJ rk r r handle_writer s r r. z dispatcher.handle_write_event sQ > F~ , ,))+++ r" c | j t j t j }|dk r| d S | d S r )ro r r r r; handle_exptr s r r1 z dispatcher.handle_expt_event s[ k$$V%6HH !88 r" c t \ }}}} t | }n# dt | z }Y nxY w| d|d|d|d|d d | d S )Nz)<__repr__(self) failed for object at %0x>z-uncaptured python exception, closing channel z (:rv )error)compact_tracebackry r{ r r; )rp niltvtbinfo self_reprs r r' zdispatcher.handle_error s - / /Q6 O T II OCbhhNIII s % ;c 2 | dd d S )Nz!unhandled incoming priority eventre r r s r r zdispatcher.handle_expt s 99EEEEEr" c 2 | dd d S )Nzunhandled read eventre r r s r r zdispatcher.handle_read s ,i88888r" c 2 | dd d S )Nzunhandled write eventre r r s r r zdispatcher.handle_write s -y99999r" c 2 | dd d S )Nzunhandled connect eventre r r s r r zdispatcher.handle_connect s /;;;;;r" c J | }| | j | d S d S r$ )r handle_accepted)rp pairs r r zdispatcher.handle_accept s3 {{}} D $ ' ' ' ' r" c Z | | dd d S )Nzunhandled accepted eventre )r r )rp rq rm s r r zdispatcher.handle_accepted s* 0)<<<<<r" c Z | dd | d S )Nzunhandled close eventre )r r r s r r; zdispatcher.handle_close s( -y999 r" NNr$ )r ),r r r debugrk rJ r closingrm frozensetr rr r} r rn ro AF_INET SOCK_STREAMr rj r rG rH r r r r r r r r r r% r r. r1 r' r r r r r r r; r! r" r rd rd s4 EIIJG D y)-- @ < < <! ! ! ! $*>8J " ' ' ' & & & / / / $ 5 5 5. . . . (F F F9 9 9: : :< < <( ( ( = = = r" rd c . e Zd ZddZd Zd Zd Zd ZdS )dispatcher_with_sendNc L t | || d| _ d S r )rd rr out_bufferr s r rr z dispatcher_with_send.__init__ s% D$,,, r" c d}t | | j d d }| j |d | _ d S )Nr i )rd r r )rp num_sents r initiate_sendz"dispatcher_with_send.initiate_send s; ??4 %)@AA /())4r" c . | d S r$ )r r s r r z!dispatcher_with_send.handle_write s r" c : | j pt | j S r$ )rk lenr r s r rH z dispatcher_with_send.writable s N";s4?';';;r" c | j r%| dt | z | j |z | _ | d S )Nz sending %s)r r ry r r )rp r s r r zdispatcher_with_send.send sO : 5 MM,d3 4 4 4 /D0 r" r )r r r rr r r rH r r! r" r r r sd 5 5 5 < < < r" r c f t j \ } }}g }|st d |rQ| |j j j |j j j t |j f |j }|Q~|d \ }}}d d |D }|||f| ||fS )Nztraceback does not existrv c g | ]}d |z S )z [%s|%s|%s]r! ).0xs r <listcomp>z%compact_traceback.<locals>.<listcomp>+ s 666!\A%666r" ) r exc_infoAssertionErrorrI tb_framef_code co_filenameco_namer tb_linenotb_nextrz )r r tbr filefunctionliner s r r r s |~~HAq" F 9 7888 K * K & Z !":D(D 8866v666 7 7D (D !1a --r" c & | t } t | D ]Q} | # t $ r }|j t k rn|s Y d }~;d }~wt $ r |s Y OxY w| d S r$ ) rD rE valuesr r< r= r r& clear)rO ignore_allr s r close_allr . s { #**,, GGIIII w% # IIKKKKKs A A: A&&A:posixc B e Zd Zd Zd Zd Zd Zd dZeZeZ d Z d Z dS ) file_wrapperc 8 t j | | _ d S r$ )r duprR rp rR s r rr zfile_wrapper.__init__S s fRjjDGGGr" c | j dk r t j d| z t | | d S )Nr zunclosed file %r)source)rR warningswarnResourceWarningr r s r __del__zfile_wrapper.__del__V sD w!|| 04 7 %)+ + + + JJLLLLLr" c 0 t j | j g|R S r$ )r r* rR rp argss r r zfile_wrapper.recv\ s 747*T*** *r" c 0 t j | j g|R S r$ )r r/ rR r s r r zfile_wrapper.send_ s 8DG+d+++ +r" Nc h |t j k r|t j k r|sdS t d )Nr z-Only asyncore specific behaviour implemented.)ro r r NotImplementedError)rp leveloptnamebuflens r r zfile_wrapper.getsockoptb sA ***6?** +q% '5 6 6 6r" c d | j dk rd S | j }d| _ t j | d S )Nr r )rR r r r s r r zfile_wrapper.closem s1 w{{BDG HRLLLLLr" c | j S r$ )rR r s r r zfile_wrapper.filenot s 7Nr" r$ ) r r r rr r r r r r* r/ r r r! r" r r r N s ! ! ! + + + , , , 6 6 6 6 r" r c e Zd ZddZd ZdS )file_dispatcherNc t | d | d| _ | }n# t $ r Y nw xY w| | t j |d d S )NTF)rd rr rk r AttributeErrorset_filer set_blocking)rp rR rO s r rr zfile_dispatcher.__init__y s dC 0 0 0 !DN YY[[! MM" OB & & & & &s : AAc t | | _ | j | _ | d S r$ )r ro r rh r r s r r zfile_dispatcher.set_file s> &r**DK ;--//DL r" r$ )r r r rr r r! r" r r r w s7 ' ' ' ' r" r )rB N)r[ FNNr )1__doc__r4 ro r rK r r r= r r r r r r r r r r r r r _DEPRECATION_MSG _deprecatedr r r> rD r r Exceptionr KeyboardInterrupt SystemExitr& r* r/ r2 rA rU rZ poll3rb rd r r r r r r r! r" r <module>r) s 8 * N X / @ @ @ @ :xL% " # # JJ JJJ' ' ' i !2J? (% % % % N" " " "4 $a a a a a a a aP : 6. . .( > 7g' ' ' ' ' ' ' 'R * U s A# #A-,A-