python (3.11.7)
eTR @ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd Zd Zd"dZ G d dej ZdZdZ G d d
e j Zi Z ej d Z ej d Z G d d Z G d
d Z d Z G d d Z G d de j e Z! G d de Z" G d d Z#d Z$d Z% G d d Z&d Z'e(d k rd d l)m*Z* e*d d ! dS dS )# Nc 0 t j | }|S N)marshalloads)mscos ?/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/idlelib/rpc.py
unpickle_coder
- s 0 r B
I c @ t j | }t |ffS r )r dumpsr
)r r s r pickle_coder 3 s! H r B 2% r c t j }t || }| | | S r )ioBytesIO CodePicklerdumpgetvalue)objprotocolfps r r
r
9 s< 4
AAx AFF3KKK ::<<r c . e Zd Zej eiej ZdS )r N)__name__
__module__ __qualname__typesCodeTyper copyregdispatch_table r r r r B s" nkLW5KLNNNr r i z 127.0.0.1c . e Zd ZddZd Zd Zd Zd ZdS ) RPCServerNc Z |t }t j | || d S r )
RPCHandler socketserver TCPServer__init__)selfaddr handlerclasss r r( zRPCServer.__init__K s. %L ''dLAAAAAr c d S r r! r) s r server_bindzRPCServer.server_bindP s
J r c F | j | j d S r )socketconnectserver_addressr- s r server_activatezRPCServer.server_activateT s(
D /00000r c | j | j fS r )r0 r2 r- s r get_requestzRPCServer.get_request] s D{D ///r c # t $ r t j }t d| t d| t dt j j z | t d|| t dt | | t j | t d| t d| t j d Y d S xY w)
Nz)
----------------------------------------filezUnhandled server exception!z
Thread: %szClient Address: z Request: z#
*** Unrecoverable, server exiting!z(----------------------------------------r )
SystemExitsys
__stderr__print threadingcurrent_threadnamerepr traceback print_excos_exit)r) requestclient_addresserfs r handle_errorzRPCServer.handle_errora s
.C -c * * * * /c : : : : ,!9!;!;!@@s K K K K $n3 ? ? ? ? +tG}}3 7 7 7 7 S ) ) ) ) 8s C C C C &s # # # # HQKKKKKKs
C C'r )r r r r( r. r3 r5 rH r! r r r# r# I sh B B B B
1 1 10 0 0 r r# c e Zd ZdZd dZd Zd Zd Zd Zd Z d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd Zd Zd Zd ZdZdZdZd Zd Z d Z d Z d Z d Z d Z!dS )!SocketIOr Nc t j | _ ||| _ || _ |t
}|| _ i | _ i | _ d S r ) r= r>
sockthread debuggingsock objecttableobjtable responsescvars)r) rN rP rM s r r( zSocketIO.__init__ sJ #244 &DN "H
r c R | j }d | _ || d S d S r )rN close)r) rN s r rT zSocketIO.close s/ y JJLLLLL r c 0 t j d d S Nr )rC rD r- s r exithookzSocketIO.exithook s +
r c | j sd S | j dz t t j j z }|D ]}|dz t | z }t
|t j d S )N r7 ) rM locationstrr= r> r? r< r: r; )r) argssas r debugzSocketIO.debug sv ~ F MC #i&>&@&@&E"F"F F ! !AC#a&& AA
acn%%%%%%r c || j |< d S r )rP )r) oidobjects r registerzSocketIO.register s #
cr c : | j |= d S # t $ r Y d S w xY wr )rP KeyErrorr) ra s r
unregisterzSocketIO.unregister s9
c""" DD s
c & | d| |\ }\ }}}}n# t $ r Y dS w xY w|| j vrdd|fS | j | }|dk ri } t || d| fS |dk ri }
t ||
d|
fS t || sdd|fS t
|| } |d k r0 | |i |} t | t rt | } d| fS |d
k r!t || ||ff d S dd |z fS # t $ r t $ r t $ r t $ r}
d
|
fcY d }
~
S d }
~
w d}t! ||| |fz t" j t' j t" j Y dS xY w)Nz
localcall:)ERRORzBad request formatri zUnknown object id: __methods__OK__attributes__zUnsupported method name: CALLQUEUE)QUEUEDNz Unsupported message type: %sCALLEXCzU*** Internal Error: rpc.py:SocketIO.localcall()
Object: %s
Method: %s
Args: %s
r7 ) EXCEPTIONN)r_ TypeErrorrP _getmethods_getattributeshasattrgetattr
isinstance RemoteObject remoteref
request_queueputr9 KeyboardInterruptOSError Exceptionr< r: r; rA rB )r) seqrE howra
methodnamer\ kwargsr methods
attributesmethodretexmsgs r localcallzSocketIO.localcall sT
<))) 33: 0C0#z4 3 3 3222 3 dm # # :3 : :; ;mC & &G W % % %'? " ) ) )J 3
+ + +*% %sJ'' I G G GH Hj)) 'f}} fd-f-- c<00 )#C..C c{" !!3v(>"?@@@&& !?#!EFF # # # r? " " " " " " '<C #fd++#. A A A A S^ 4 4 4 4&&&s7
#
1115D '%D D (F=E FAFc | d|| | |||| }| | S )Nzremotecall:asynccall: )r_ asynccall asyncreturnr) ra r r\ r r s r
remotecallzSocketIO.remotecall sD
+S*===nnS*dF;; $$$r c | d|| | |||| }| | S )Nzremotequeue:asyncqueue: )r_
asyncqueuer r s r remotequeuezSocketIO.remotequeue sD
-sJ???ooc:tV<< $$$r c d||||ff}| }t j | j k r t j }|| j |< | d|z |||| | ||f |S )Nrm z
asynccall:%d:newseqr= r> rL ConditionrR r_
putmessager) ra r r\ r rE r cvars r r zSocketIO.asynccall s CT6:;kkmm # % % 8 8 &((D "DJsO
Oc)CT6JJJ g'''
r c d||||ff}| }t j | j k r t j }|| j |< | d|z |||| | ||f |S )Nrn zasyncqueue:%d:r r s r r zSocketIO.asyncqueue s S*dF ;<kkmm # % % 8 8 &((D "DJsO
$s*S*dFKKK g'''
r c | d|z | |d }| d|z | | | S )Nz#asyncreturn:%d:call getresponse(): 皙?)waitzasyncreturn:%d:response: )r_ getresponsedecoderesponse)r) r responses r r zSocketIO.asyncreturn s`
83>???##Cd#33
/#5AAA""8,,,r c z |\ }}|dk r|S |dk rd S |dk r| d d S |dk r+| d | d S |dk r%| d| t | |d k r| d
| |t || ) Nrk ro rq zdecoderesponse: EXCEPTIONEOFzdecoderesponse: EOFri z decoderesponse: Internal ERROR:rp z decoderesponse: Call Exception:)r_ decode_interrupthook RuntimeError SystemError)r) r r whats r r zSocketIO.decoderesponse s T $;;K (??4 + JJ2 3 3 34 %<< JJ, - - - % % ' ' '4 '>> JJ8$ ? ? ? t$$ $ ) JJ8$ ? ? ?J#t$$$r c t r )EOFErrorr- s r r z SocketIO.decode_interrupthook s
r c | d d d S # t $ r | d Y d S w xY w)Nr )myseqr zmainloop:return)r r r_ r- s r mainloopzSocketIO.mainloop s` 4d 3 3 3 3 3 JJ( ) ) ) FF s ??c z | || }|"|\ }}|dk r|| | f}|S )Nrk ) _getresponse_proxify)r) r r r r r s r r zSocketIO.getresponse" sJ $$UD11 ICd{{
d 3 33r c t |t rt | |j S t |t r"t t | j | S |S r )rw RemoteProxyRPCProxyra listmapr )r) r s r r zSocketIO._proxify* sW c; ' ' +D#'** * c4 1DM3//00 0
r c | d| t j | j u r | || }||S | j | }| || j vr | || j v | j | }| d|d| | j |= | j |= | |S )Nz_getresponse:myseq:Tz
_getresponse:z : thread woke up: response: )
r_ r= r> rL pollresponserR acquirerQ r release)r) r r r r s r r zSocketIO._getresponse2 s
(%000 # % % 8 8
$ ,,UD99'#O
$ :e$D LLNNNt~-- t~--~e,H JJJ xx)
*
*
*u%
5! LLNNNOr c ( | j dz x| _ }|S )N )nextseq)r) r s r r zSocketIO.newseqH s !\A -- s
r c f | d|d z t | }n=# t j $ r+ t dt | t j w xY wt j dt | |z }t | dk r t j g | j gg \ }}}| j
|d t }n$# t t f$ r t# d w xY w||d }t | dk d S d S )Nzputmessage:%d:r zCannot pickle:r7 <izsocket no longer exists)r_ r
pickle
PicklingErrorr< r@ r: r; structpacklenselectrN sendBUFSIZEAttributeErrorrr r} )r) messager] rwxns r r zSocketIO.putmessageL s0
#gaj0111 gAA# "DMM G G G G
Kc!ff % % )!ffqjj
9 -TYK<<1aINN1XgX;//"I.
9
9
9 7888
9!""A
!ffqjjjjjjs 0 :A*&AC. .!Dr c | t | j | j k rt j | j gg g | \ }}}t | dk rd S | j t }n# t $ r t w xY wt | dk rt | xj |z
c_ | | S rV ) _stage0r buffbufneedr rN filenorecvr r} r _stage1)r) r r r r r] s r
pollpacketzSocketIO.pollpacket` s ty>>DL ( ( mTY%5%5%7%7$8"b$GGGAq!1vv{{t
INN7++
1vv{{ IINII LLNNN||~~ s ; B B-c | j dk rdt | j dk rN| j d d }| j dd | _ t j d| d | _ d| _ d S d S d S )Nr r r )bufstater r r unpackr )r) r] s r r zSocketIO._stage0p sr =A #di..A"5"5 "1"
A !""
DI!=q11!4DL DMMM "5"5r c | j dk rZt | j | j k r?| j d | j }| j | j d | _ d| _ d| _ |S d S d S )Nr r r )r r r r )r) packets r r zSocketIO._stage1w sj =A #di..DL"@"@Y} }-F $,--0DI DL DMM "@"@r c | | }|d S t j | }n# t j $ r t dt
j t dt | t
j t j t
j t dt
j w xY w|S )Nz-----------------------r7 zcannot unpickle packet:)
r r r UnpicklingErrorr< r: r; r@ rA print_stack)r) r r r s r pollmessagezSocketIO.pollmessage s && >4 l6**GG% +#. A A A A +T&\\ O O O O !s~ 6 6 6 6 +#. A A A A s
0 BB?c N t d }|\ }}|d|ff}| | n# t j $ r Y nw xY w | | }|d S n1# t $ r | Y d S t $ r Y d S w xY w|\ }}|d }| d||fz |dv ro| d|z |
|| }| d||fz |dk r| ||f n|d k r 8||k r|S | j |d } | F| || j
|< | | )
NTr rk zpollresponse:%d:myseq:%s)rm rn z pollresponse:%d:localcall:call:z%pollresponse:%d:localcall:response:%srm rn )response_queuegetr queueEmptyr r
handle_EOFr r_ r rR r rQ notifyr )
r) r r qmsgr r r resqr cvs
r r zSocketIO.pollresponse s ,0
)%))!,, !%
X x 01(((( ;
**400? 4 #
!!!tt!
tt
ICq'C JJ1S%L@ A A A'''
<sBCCC >>#t44
B !8_ - . . .&==OOS(O4444G^^ Z^^C.. >JJLLL*.DN3'IIKKKJJLLLs' ? AAA/ / B B B c < | | d | j D ]U}| j | }| d| j |< | | V| d S )Nr )r N)EOFhookr_ rR r rQ r r rW )r) keyr s r r zSocketIO.handle_EOF s 5
< : CC B JJLLL"/DN3 IIKKK JJLLLL
r c d S r r! r- s r r zSocketIO.EOFhook s
L r )NN)"r r r r r( rT rW r_ rc rg r r r r r r r r r r r r r r r r r r r r r r r r r! r r rJ rJ s G & & &$ $ $ ,' ,' ,'\% % %
% % %
- - - % % %* , DGH G G GR
r rJ c e Zd ZdS )rx N)r r r r! r r rx rx s Dr rx c R t | }| t |< t | S r )idrO r )r ra s r ry ry s%
S''CK s r c e Zd Zd ZdS )r c || _ d S r )ra rf s r r( zRemoteProxy.__init__ s
r N)r r r r( r! r r r r s# r r c ( e Zd ZdZdZd Zd Zd ZdS )r% Fz#Sc | |_ t | | t j | ||| d S r )current_handlerrJ r( r& BaseRequestHandler)r) rN r* svrs r r( zRPCHandler.__init__ sC "$%%%'00tT3GGGGGr c 0 | d S r )r r- s r handlezRPCHandler.handle s 2
r c " t | | S r r rf s r get_remote_proxyzRPCHandler.get_remote_proxy c"""r N)r r r rM rZ r( r r r! r r r% r% sN IHH H H
# # # # #r r% c F e Zd ZdZdZdZej ej fdZ d Z
d Z dS ) RPCClientFz#Cr c t j || | _ | j | | j d d S Nr )r0 listening_sockbindlisten)r) addressfamilytypes r r( zRPCClient.__init__ sJ $mFD 9 9 ))) ""1%%%%%r c " | j \ }}| j r t d|t j |d t k r t | | d S t d|t j t )Nz ****** Connection request from r7 r z** Invalid host: )
r acceptrM r< r: r; LOCALHOSTrJ r( r} )r) working_sockr s r r zRPCClient.accept s $ 3 : : < < g > S 3W3> R R R R 1: " " dL 1 1 1 1 1 %wS^ D D D DMr c " t | | S r r rf s r r zRPCClient.get_remote_proxy" r r N) r r r rM rZ r r0 AF_INET SOCK_STREAMr( r r r! r r r r s_ IHG'-~F<N & & & &
# # # # #r r c . e Zd ZdZdZd Zd Zd Zd ZdS )r Nc " || _ || _ d S r )sockiora )r) r ra s r r( zRPCProxy.__init__+ s r c R | j | | j | rt | j | j | S | j | || j v r%| j | j d|fi }|S t | )N__getattribute__)
_RPCProxy__methods_RPCProxy__getmethodsr MethodProxyr ra _RPCProxy__attributes_RPCProxy__getattributesr r )r) r? values r __getattr__zRPCProxy.__getattr__/ s > ! > d # # < t{DHd;; ; $ " " " 4$ $ $K**485G,07B8 8EL && &r c T | j | j ddi | _ d S )Nrl r! )r r ra r r- s r __getattributeszRPCProxy.__getattributes= s/ K 2 2480@"b J Jr c T | j | j ddi | _ d S )Nrj r! )r r ra r r- s r __getmethodszRPCProxy.__getmethodsA s, //0=r2G Gr ) r r r r r r( r r r r! r r r r & sb IL ' ' ' J J JG G G G Gr r c t | D ]&}t | | }t | rd||< 't | t r| j D ]}t
|| d S d S r )dirrv callablerw r __bases__rs )r r r? attrsupers r rs rs E s C sD!! D>> GDM#t (] ( (E w ' ' ' '( ( ( (r c r t | D ]&}t | | }t | sd||< 'd S r )r rv r )r r r? r s r rt rt P sI C ! !sD!!~~ ! Jt ! !r c e Zd Zd Zd ZdS )r c 0 || _ || _ || _ d S r )r ra r? )r) r ra r? s r r( zMethodProxy.__init__Y s r c T | j | j | j || }|S r )r r ra r? )r) r\ r r s r __call__zMethodProxy.__call__^ s& &&txD&II r N)r r r r( r& r! r r r r W s2
r r c | d S d t _ t | } t j | n]# t $ rP d}| |d }| |d }t j | Y nw xY wt j d | t _ d S )Nasciibackslashreplacestrict
) builtins_r@ r: stdoutwriteUnicodeEncodeErrorencodedecode)r textencodingbytess r displayhookr6 f s C }HJ ;;D
H&899||Hh//
JTHJJJs A AB B __main__)mainzidlelib.idle_test.test_rpcr ) verbosityr )+r, r r r rC r r r r0 r& r r: r= rA r r
r r
Picklerr r r r' r# rO Queuerz r rJ rx ry r r r% r r rs rt r r6 r unittestr8 r! r r <module>r= s 8
M M M M M&. M M M . . . . . & . . .d A
Q e
e
e
e
e
e
e
e
R
# # # # # 0( # # #$# # # # # # # #4 G G G G G G G G> ( ( (! ! ! & z D %444444 r 
Browse
Usage
Versions