Ñò Vù¥Oc@sôddklZlZddklZddklZddklZddklZl Z l Z l Z ddk l Z ddkZddkZddkZddkZddkZdd klZlZddkZdd klZddkZeid ƒZd Zd Zeiiei dƒZ!eiiei dƒZ"dZ#defd„ƒYZ$dee%fd„ƒYZ&d„Z'e(djohe'ƒZ)e)i*dƒZ+e)i*dƒo&ei,e_-eiƒi.ei-ƒne e&de)de+ƒndS(iÿÿÿÿ(tSimpleXMLRPCServertSimpleXMLRPCRequestHandler(tSubscriptionManager(t Messenger(ttime(texportedtassertCompatabletassertAuthenticatedt runserver(t authenticateNi(tVERSIONtzephyr(t ServerKilledtxmlrpcis0.0.0.0scerts/server_public.pemscerts/server_private.pemtZephyrXMLRPCServertZephyrXMLRPCRequestHandlercBseZd„Zd„ZRS(cGs!tid||iƒ|ŒdS(Ns%s - (tloggertdebugtaddress_string(tselftformattargs((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyt log_messagescCs!tid||iƒ|ŒdS(Ns%s - (RterrorR(RRR((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyt log_errors(t__name__t __module__RR(((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyRs cBs}eZdZeeeeiee d„Z d„Z d„Z d„Z ed„ƒZed„ƒZed„ƒZd„ZRS( sXML-RPCcCs«||_||_||_tt|ƒi||fdtdtƒti ƒti ƒ|_ t t iƒƒ|_ t t|i ƒƒ|_t t|i d|ƒƒ|_dS(Nt allow_nonetrequestHandlertdb_path(tuse_ssltkeyfiletcertfiletsuperRt__init__tTrueRR tinittsendertusernameRt preferencest PreferencesRt subscriptionsRt messenger(RthosttporttssltdbRR ((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyR"!s   ( cCsR|io1ti|id|id|idtƒ|_ntt|ƒi ƒdS(NRR t server_side( RR-t wrap_sockettsocketRR R#R!Rt server_bind(R((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyR22s 1cCs™yvt|ƒ}|djotSyt|idƒƒWntj otdƒ‚nX|djot|i|dƒSyt|idƒƒWntj otdƒ‚nX|}xI|i dƒD]8}t ||ƒ}t |dt ƒpt d ƒ‚qËqËWy||ŒSWn]t j oQ}tit titiƒd ƒd tƒƒid |ii|ifƒnXWntj otƒ‚nXdS( NtgetServerVersionisMinimum version unspecified.R is!No authentication token provided.t.t_exportsMethod not supported.iÿÿÿÿRs%s: %s(tlistR Rtpopt IndexErrort TypeErrorR R&RtsplittgetattrtFalsetAttributeErrort Exceptiontloggingt getLoggertinspectt getmodulettraceRRt __class__tmessagetKeyboardInterruptR (Rtmethodtparamstobjtite((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyt _dispatch7s4   Qc Csà|iiƒ\}}tiƒ}|djou|djohtititiƒ}z>y!|id ƒ|iƒd}Wntij onXWd|iƒXnh|d6|d6t|i ƒd6|i p|i pd d 6S( Nslocalhost.localdomains 127.0.0.1smit.eduiPitHOSTtPORTtSSLttCERT_PUB(smit.eduiP( R1t getsocknametgetfqdntAF_INETt SOCK_DGRAMtconnectRtclosetintRR R(RtaddrR,R+ts((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pytgetInfoYs    cCstƒ|iS(sReturns the uptime in seconds.(Rt start_time(R((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pytuptimenscCs|iS(N(R&(R((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pytgetUsertscCstS(N(R#(R((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pytpingyscCsEtƒ|_|iiƒztt|ƒiƒWd|iiƒXdS(N(RR\R*tstartR!Rt serve_forevertquit(R((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyRa}s   (RRtTYPEt DEFAULT_HOSTt DEFAULT_PORTR<tsettingst ZEPHYR_DBtDEFAULT_SERVER_KEYtDEFAULT_SERVER_CERTR"R2RLR[RR]R^R_Ra(((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyRs  " cCs^ddk}|iddƒ}|idddddtd td d d d ƒ|iddddd ddtd dƒ|iddddd ddtd dƒ|iddddd ddtd dƒ|iddddd ddtdt d dƒ|id d!dd"dtd td d d d#ƒ|id$d%dd&dtd td d d d'ƒt |i ƒƒS((Niÿÿÿÿt descriptions˜A server for receiving, storing, sending, and searching zephyrs over XMLRPC.s-ss--ssltdestR-tdefaulttconsttactiont store_constthelpsUse ssl.s-ks --keyfileRtstoresThe server's private key.s-cs--certR sThe server's public key.s-as --addressR+sAddress to listen on.s-ps--portR,ttypesPort to listen on.s-fs--forktdoforksDaemonize the server.s-ds--debugRsLog debugging output.( targparsetArgumentParsert add_argumentR<R#RhRiRdRXRetvarst parse_args(Rttparser((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyRx…sV   t__main__RsRR(sZephyrXMLRPCServer(/RRR)RR*RRtserverRRRRtauthR R'R?tosR-R1RPR R Rft exceptionsR RAR@RReRdtpathtjointDATA_DIRRiRht__all__RtobjectRRxRRR7RstDEBUGt LOG_LEVELtsetLevel(((s@/mit/zmobile/testing/lib/python2.6/site-packages/zserv/xmlrpc.pyts6"$  f >