⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.12
/
test
/
support
/
__pycache__
/
View File Name :
asyncore.cpython-312.pyc
CRhO d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZ ee e eeeeh Z e d Z G d de Zee e fZ d Z d Z d Z!d Z"dd Z#dd Z$e$Z%dd Z& G d d Z' G d de' Z(d Z)ddZ*ejV dk( r G d d Z, G d de' Z-yy# e$ r i ZY xw xY w) 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 errorcodec t j | S # t t t f$ r | t v r t | cY S d| z cY S w xY w)NzUnknown error %s)osstrerror ValueError OverflowError NameErrorr )errs ,/usr/lib/python3.12/test/support/asyncore.py _strerrorr J sI '{{3 y 1 ' ) S> !!3&&'s %AAAc e Zd Zy)ExitNowN)__name__ __module__ __qualname__ r r r R s r r c f | j y # t $ r | j Y y xY wN)handle_read_event_reraised_exceptions handle_errorobjs r readr' W 1 0c f | j y # t $ r | j Y y xY wr! )handle_write_eventr# r$ r% s r writer, _ s1 r) c f | j y # t $ r | j Y y xY wr! )handle_expt_eventr# r$ r% s r _exceptionr/ g r( r) c 6 |t j z r| j |t j z r| j |t j z r| j |t j t j z t j z z r| j y y # t $ rB}|j t vr| j n| j Y d }~y Y d }~y d }~wt $ r | j Y y xY wr! )selectPOLLINr" POLLOUTr+ POLLPRIr. POLLHUPPOLLERRPOLLNVAL handle_closeOSErrorerrno _DISCONNECTEDr$ r# )r& flagses r readwriter> o s 6== ! ! # 6>> ! " " $ 6>> ! ! ! # FNNV^^3fooE F G 77- ' s B.B2 2 D;3C88 Dc |t }|rHg }g }g }t |j D ]m \ }}|j }|j }|r|j | |r |j s|j | |s|s]|j | o g |cxk( r |cxk( r|k( rn nt j | y t j |||| \ }}}|D ]! }|j | }|t | # |D ]! }|j | }|t | # |D ]! }|j | }|t | # y y r! ) socket_maplistitemsreadablewritableappend acceptingtimesleepr1 getr' r, r/ ) timeoutmaprwr= fdr& is_ris_ws r pollrQ s5 { BBCIIK(GB<<>D<<>D CMM t ) a 1 JJw --1a11aB''"+C{ I B''"+C{ #J B''"+C{ sO = r c |t }| t | dz } t j }|rt |j D ] \ }}d}|j r$|t j t j z z }|j r |j s|t j z }|sn|j || |j | }|D ]% \ }}|j | }|t || ' y y )Ni r )r@ intr1 rQ rA rB rC r2 r4 rD rF r3 registerrI r> )rJ rK pollsterrN r& r< rL s r poll2rV s {gdl#{{}H CIIK(GBE||~ 77||~cmm '!!"e, ) MM' "IB''"+C{ c5 ! r c |t }|rt t d rt }nt }||r || | |r y y |r |dkD r || | |dz }|r|dkD ry y y y )NrQ r )r@ hasattrr1 rV rQ )rJ use_pollrK countpoll_funs r loopr] sh {GFF+ } Wc " eai Wc "AIE eaicicr 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+y)% dispatcherFNwarningc ` | t | _ n|| _ d | _ |rA|j d | j || d| _ |j | _ y d | _ y # t $ r<}|j t t fv rd| _ n| j | Y d }~y d }~ww xY w)NFT)r@ _map_fileno setblocking set_socket connected getpeernameaddrr9 r: r r del_channelsocket)selfsockrK r s r __init__zdispatcher.__init__ s ;"DIDI U # OOD# & !DN , , . DK 996 22 &+DN $$S) # s A( ( B-12B((B-c | j j dz | j j z g}| j r | j r|j d n | j r|j d | j |j d| j z ddj | t | fz S # t $ r' |j t | j Y Nw xY w)N. listeningrf z%s:%dz <%s at %#x> ) __class__r r rF rh rE rf TypeErrorreprjoinid)rk statuss r __repr__zdispatcher.__repr__ s ..++C/0K0KKL >>dii MM+ & ^^ MM+ & 99 / g 12 0"T( ;;; / d499o. /s C -C32C3c > | | j }| || j < y r! )rb rc )rk rK s r add_channelzdispatcher.add_channel s ;))C DLLr c T | j }| | j }||v r||= d | _ y r! )rc rb )rk rK rN s r ri zdispatcher.del_channel s. \\ ;))C 9B r c ||f| _ t j || }|j d | j | y NF)family_and_typerj rd re )rk familytyperl s r create_socketzdispatcher.create_socket s8 %t| }}VT* r c ^ || _ |j | _ | j | y r! )rj filenorc rz rk rl rK s r re zdispatcher.set_socket$ s$ {{} r c | j j t j t j | j j t j t j dz y # t $ r Y y w xY w)NrX )rj setsockopt SOL_SOCKET SO_REUSEADDR getsockoptr9 rk s r set_reuse_addrzdispatcher.set_reuse_addr) sj KK " "!!6#6#6 &&v'8'8'-':':<>?@ s A2A5 5 B Bc yNTr r s r rC zdispatcher.readable: r c yr r r s r rD zdispatcher.writable= r r c z d| _ t j dk( r|dkD rd}| j j | S )NTnt )rF r namerj listen)rk nums r r zdispatcher.listenD s4 77d?sQwC{{!!#&&r c F || _ | j j | S r! )rh rj bind)rk rh s r r zdispatcher.bindJ s {{ %%r c , d| _ d| _ | j j | }|t t t fv s |t k( rt j dk( r|| _ y |dt fv r|| _ | j y t |t | )NFTr r )rf connectingrj connect_exr r r r r r rh r handle_connect_eventr9 r )rk addressr s r connectzdispatcher.connectN s~ kk$$W- ;+6 6 &=RWW_ DI 1g, DI % % '#y~. .r c | j j \ }}||fS # t $ r Y y t $ r(}|j t t t fv rY d }~y d }~ww xY wr! )rj acceptrs r9 r: r r r )rk connrh whys r r zdispatcher.accept\ s_ ++-JD$ : yy[, ?? s # A A AAA c | j j | }|S # t $ rE}|j t k( rY d }~y|j t v r| j Y d }~y d }~ww xY wNr )rj sendr9 r: r r; r8 )rk dataresultr s r r zdispatcher.sendj s] [[%%d+FM yyK'm+!!# s A-A( "A('A((A-c | j j | }|s| j y|S # t $ r-}|j t v r| j Y d }~y d }~ww xY wNr )rj recvr8 r9 r: r; )rk buffer_sizer r s r r zdispatcher.recvw sb ;;##K0D !!# yyM)!!# s -2 2 A("A#"A##A(c d| _ d| _ d| _ | j | j | j j y y # t $ r#}|j t t fvr Y d }~y d }~ww xY wr} ) rf rF r ri rj closer9 r: r r )rk r s r r zdispatcher.close sr ;; " !!# # 99Xu$55 6 s A A;A66A;c Z t j j dt | z y )Nzlog: %s )sysstderrr, str)rk messages r logzdispatcher.log s s7|34r c B || j vrt |d| y y )Nz: )ignore_log_typesprint)rk r r s r log_infozdispatcher.log_info s" t,, , dG, - -r c | j r| j y | j s-| j r| j | j y | j y r! )rF handle_acceptrf r r handle_readr s r r" z dispatcher.handle_read_event sI >> ))+ r c | j j t j t j }|dk7 rt |t | | j d| _ d| _ y )Nr TF) rj r r SO_ERRORr9 r handle_connectrf r rk r s r r z dispatcher.handle_connect_event sT kk$$V%6%6H !8#y~. . r c | j ry | j s | j r| j | j y r! )rF rf r r handle_writer s r r+ z dispatcher.handle_write_event s4 >> ~~))+ r c | j j t j t j }|dk7 r| j y | j y r )rj r r r r8 handle_exptr s r r. z dispatcher.handle_expt_event sE kk$$V%6%6H !8 r c t \ }}}} t | }| j d|d|d|d|d d | j y # dt | z }Y BxY w)Nz)<__repr__(self) failed for object at %0x>z-uncaptured python exception, closing channel z (:rq )error)compact_tracebackrt rv r r8 )rk niltvtbinfo self_reprs r r$ zdispatcher.handle_error sj - /Q6 O T I OCbhNIs A A c ( | j dd y )Nz!unhandled incoming priority eventr` r r s r r zdispatcher.handle_expt s 99Er c ( | j dd y )Nzunhandled read eventr` r r s r r zdispatcher.handle_read s ,i8r c ( | j dd y )Nzunhandled write eventr` r r s r r zdispatcher.handle_write s -y9r c ( | j dd y )Nzunhandled connect eventr` r r s r r zdispatcher.handle_connect s /;r c H | j }| | j | y y r! )r handle_accepted)rk pairs r r zdispatcher.handle_accept s( {{} D $ ' r c H |j | j dd y )Nzunhandled accepted eventr` )r r )rk rl rh s r r zdispatcher.handle_accepted s 0)<r c H | j dd | j y )Nzunhandled close eventr` )r r r s r r8 zdispatcher.handle_close s -y9 r NNr! )info),r r r debugrf rF r closingrh frozensetr rm rx rz ri rj AF_INET SOCK_STREAMr re r rC rD r r r r r r r r r r" r r+ r. r$ r r r r r r r8 r r r r_ r_ s EIIJG D )- @ <! $*>>8J8J "' & / $ 5. (F9:<( =r r_ c , e Zd ZddZd Zd Zd Zd Zy)dispatcher_with_sendNc @ t j | || d| _ y r )r_ rm out_bufferr s r rm z dispatcher_with_send.__init__ s D$, r c v d}t j | | j d d }| j |d | _ y )Nr i )r_ r r )rk num_sents r initiate_sendz"dispatcher_with_send.initiate_send s4 ??4 %)@A //()4r c $ | j y r! )r r s r r z!dispatcher_with_send.handle_write s r c J | j xs t | j S r! )rf lenr r s r rD z dispatcher_with_send.writable s NN";s4??';;r c | j r | j dt | z | j |z | _ | j y )Nz sending %s)r r rt r r )rk r s r r zdispatcher_with_send.send s: :: MM,d3 4 //D0 r r )r r r rm r r rD r r r r r r s 5 < r r c t j } | j }|s t d g }|rr|j |j j j |j j j t |j f |j }|rr~|d \ }}}dj |D cg c] }d|z c} }|||ft | | |fS c c}w )Nztraceback does not existrq z [%s|%s|%s])r exception __traceback__AssertionErrorrE tb_framef_code co_filenameco_namer tb_linenotb_nextru r )exctbr filefunctionlinexr s r r r s --/C B 788 F KK * * KK & & ZZ !":D(D 88v6v!\A%v6 7D (D !49c4 77 7s = C"c | t } t | j D ] } |j | j y # t $ r!}|j t k( rn|s Y d }~Ld }~wt $ r |s Y _xY wr! ) r@ rA valuesr r9 r: r r# clear)rK ignore_allr s r close_allr 0 sx { #**, GGI IIK ww% # s A BA..Bposixc @ e Zd Zd Zd Zd Zd Zd dZeZeZ d Z d Z y) file_wrapperc 8 t j | | _ y r! )r duprN rk rN s r rm zfile_wrapper.__init__U s ffRjDGr c | j dk\ r t j d| z t | | j y )Nr zunclosed file %r)source)rN warningswarnResourceWarningr r s r __del__zfile_wrapper.__del__X s/ ww!| 04 7 %)+ JJLr c B t j | j g| S r! )r r' rN rk argss r r zfile_wrapper.recv^ s 77477*T* *r c B t j | j g| S r! )r r, rN r s r r zfile_wrapper.senda s 88DGG+d+ +r Nc j |t j k( r|t j k( r|syt d )Nr z-Only asyncore specific behaviour implemented.)rj r r NotImplementedError)rk leveloptnamebuflens r r zfile_wrapper.getsockoptd s4 ***6??*% '5 6 6r c t | j dk ry | j }d| _ t j | y )Nr r )rN r r r s r r zfile_wrapper.closeo s+ ww{BDG HHRLr c | j S r! )rN r s r r zfile_wrapper.filenov s 77Nr r! ) r r r rm r r r r r' r, r r r r r r r P s1 ! + , 6 r r c e Zd ZddZd Zy)file_dispatcherNc t j | d | d| _ |j }| j | t j |d y # t $ r Y 3w xY w)NTF)r_ rm rf r AttributeErrorset_filer set_blocking)rk rN rK s r rm zfile_dispatcher.__init__{ s[ dC 0 !DN YY[ MM" OOB & " s A A$#A$c t | | _ | j j | _ | j y r! )r rj r rc rz r s r r zfile_dispatcher.set_file s. &r*DK ;;--/DL r r! )r r r rm r r r r r r y s ' r r )g N)g >@FNNr} ).__doc__r1 rj r rG r r r: r r r r r r r r r r r r r r r; r@ r r Exceptionr KeyboardInterrupt SystemExitr# r' r, r/ r> rQ rV poll3r] r_ r r r r r r r r r <module>r! s B* :xL% " # ' i !2J? (% N"4 $a aP : 68*> 77g' 'R * U Q Js B9 9CC