-ķ ™ŗ‘;csÓdkZdkZdkZdkZdkZdkZdkZdkZ dkZ!dkZ/dei fd„ƒYZ >dfd„ƒYZ œdfd„ƒYZ µddfd „Z Ād fd „ƒYZŻdd fd „ZēdkZčdkZźdeifd„ƒYZ2edjoˆ3dkZ4deijo 5eZn 7e Z9dGH:eƒZ;dGH<eiidddƒGH=dGH>eiiƒGHndS(Ns RPC_Errorcs/0RS(N((((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys RPC_Error/ss rpc_proxycs§>@dZBd„ZJd„Z\d„Z_d„Zgd„Zkd„Znd„Zqd „Ztd „Z wd d d dddddgZ yd„Z RS(Nics'BD||id<E||idii’’’’(sselfs__send_request__sNonesr(sselfsr((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys__remote_repr__gscskl|id|ƒSdS(Ni(sselfs__send_request__sargs(sselfsargs((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys__remote_call__kscsno|id|ƒSdS(Ni(sselfs__send_request__skey(sselfskey((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys__remote_getitem__nscs qr|id||fƒSdS(Ni(sselfs__send_request__skeysvalue(sselfskeysvalue((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys__remote_setitem__qscstu|idtƒSdS(Ni(sselfs__send_request__sNone(sself((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys__remote_len__tsscallsgetattrssetattrsreprsdelsgetitemssetitemslencs>yz|ioC{|d}|d|ii|i|i|t|dƒfGHn„t i |if|ƒ}†|ii |ƒˆ|ii ƒ}Žt i|ƒ\}}|djo4’|io“d|GHn”t|i|ƒSnK•|djo–t|‚n+˜|io™dt|ƒGHnš|SdS(NisRPC: ==> %s:%08x:%s:%sisRPC: <== proxy(%08x)s RPC: <== %s(sselfsDEBUGsargsskindsconnsaddresssoids_request_types_sreprsmarshalsdumpsspackets send_packetsreceive_packetsdatasloadssvalues rpc_proxys RPC_Error(sselfsargsskindsvaluesdataspacket((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys__send_request__ys   6  ( sDEBUGs__init__s __getattr__s __setattr__s__del__s__remote_repr__s__remote_call__s__remote_getitem__s__remote_setitem__s__remote_len__s_request_types_s__send_request__(((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys rpc_proxy>s          !srpc_connectioncs>œžhZ d„Z¤d„Z©d„Z²d„ZRS(Ncs  ”||_¢|iƒdS(N(saddresssselfsconnect(sselfsaddress((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys__init__ s csA¤„tititiƒ}¦|i|iƒ§||_dS(N(ssocketsAF_INETs SOCK_STREAMsssconnectsselfsaddress(sselfss((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pysconnect¤scs‘©Ŗti|iidƒdƒ}«g}¬xG¬|o<­|iidƒ}®|i|ƒÆ|t |ƒ}q3W°ti |dƒSdS(Niii s( sstringsatoisselfssocketsrecvs packet_lenspacketsdatasappendslensjoin(sselfspackets packet_lensdata((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pysreceive_packet©s!  cs*²³|iidt|ƒ|fƒdS(Ns%08x%s(sselfssocketssendslenspacket(sselfspacket((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys send_packet²s(scaches__init__sconnectsreceive_packets send_packet(((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pysrpc_connectionœs     s localhosti*"cs|µ¶tii|ƒ oP·t|ƒ}¹|iƒ}ŗti|ƒ\}»t ||ƒti|s.(sstringsjoinsselfspathsid(sself((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys__repr__Śs(s__init__s __getattr__s__method_caller__s__repr__(((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys fastrpc_proxyĀs  i,"csUŻŽtii|ƒ o)ßt|ƒ}ąt|ƒti|.calc.sum (1,2,3)iiis9calling .calc.nonexistent(), expect an exception!(smarshalssocketsstringstimes exceptionssselectssysstypesserrnos StandardErrors RPC_Errors rpc_proxysrpc_connections rpc_connects fastrpc_proxysfastrpc_connectsasynchatsfifos async_chatsasync_fastrpc_clients__name__sargvsconnectscscalcssums nonexistent(sfastrpc_connectsasync_fastrpc_clientsrpc_connectionsasynchatsstringsconnects rpc_connectserrnoscsfifossyssselectssockets rpc_proxystimes exceptionss fastrpc_proxysmarshalstypess RPC_Error((sI/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/rpc_client.pys?s:         ^   H