/usr/lib/python2.6/site-packages/supervisor/
/usr/lib/python2.6/site-packages/supervisor
NameSizeModeActions
medusa/-0755rm
ui/-0755rm
datatypes.py66410644editdlrm
datatypes.pyc90950644editdlrm
datatypes.pyo90470644editdlrm
http.py265330644editdlrm
http.pyc227660644editdlrm
http.pyo227660644editdlrm
http_client.py62910644editdlrm
http_client.pyc87590644editdlrm
http_client.pyo86800644editdlrm
options.py554490644editdlrm
options.pyc494110644editdlrm
options.pyo494110644editdlrm
pidproxy.py17970644editdlrm
pidproxy.pyc26580644editdlrm
pidproxy.pyo26580644editdlrm
supervisorctl.py214970644editdlrm
supervisorctl.pyc200430644editdlrm
supervisorctl.pyo200430644editdlrm
supervisord.py274900644editdlrm
supervisord.pyc221170644editdlrm
supervisord.pyo220040644editdlrm
test.py1175440644editdlrm
test.pyc1172160644editdlrm
test.pyo1172160644editdlrm
web.py175630644editdlrm
web.pyc150220644editdlrm
web.pyo150220644editdlrm
xmlrpc.py326580644editdlrm
xmlrpc.pyc276600644editdlrm
xmlrpc.pyo275420644editdlrm
__init__.py80644editdlrm
__init__.pyc1420644editdlrm
__init__.pyo1420644editdlrm
Edit: /usr/lib/python2.6/site-packages/supervisor/test.pyc (117216B)
FATc@sdZddkZddkZddkZddkZddkZddkZddkZddkZddk Z ddk Z ddk Z ddk l Z ddk l Z ddkZddkZddkZddkZddklZddklZyeWneidZnXdZddkZdeifd YZd eifd YZd efd YZedZedZdefdYZdefdYZ deifdYZ!deifdYZ"deifdYZ#deifdYZ$deifdYZ%deifdYZ&d eifd!YZ'd"eifd#YZ(d$fd%YZ)d&fd'YZ*d(fd)YZ+d*fd+YZ,d,fd-YZ-d.Z.d/Z/d0fd1YZ0d2fd3YZ1d4fd5YZ2d6fd7YZ3d8fd9YZ4d:Z5e6d;jo!eidZei7d<d=ndS(>sTest suite for supervisord.py.iN(tStringIO(tdatetime(t ProcessStates(tSupervisorStatesitServerOptionsTestscBsteZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z RS( cCsddkl}|S(Ni(t ServerOptions(toptionsR(tselfR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt_getTargetClass$scCs |iS(N(R(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt_makeOne(sc Csdhtid6}ddkl}||}|i}||_|i|ii}ddk}|i |i ti|i |i d|i |i d|i |i d#|i |id |i |id |i |id |i |it|i |id |i |iti|i |ii|i|i |iid$|i |id|i |id|i |it|i |id|i |id|i |it|i t|id|id}|i |i d|i |i!d|i |i"d|i |i#t|i |i$t|i |i%d |i |i&d|i |i'd|i |i d|i |i(t)i*|i |i+d |i |i t,i-d|i |id|i |i.ddg|id}|i |i d|i |i!d|i |i"d|i |i#t|i |i$t/|i |i'd|i |i d|i |i(t)i1|i |i d|i |id|i |i.ddg|id} |i | i d|i | i!d|i | i"d|i | i#t|i | i$t|i | i'd|i | i |i2|i | i t,i-d|i | id|i | i.ddd g|i |i(t)i1t3i4i5t3i6} |i |i'd|i |i7d|i |i d!|i |i d|i |i t3i4i8| d|i |i d&|i |id |i |id |i |it3i4i8| d |i |it|i |i9d|i |id |i |iti|i |ii|i|i |iid'|i |id|i |id|i |it|i |id|i |iddS((Ns,[supervisord] http_port=127.0.0.1:8999 ; (default is to run no xmlrpc server) http_username=chrism ; (default is no username (open system)) http_password=foo ; (default is no password (open system)) directory=%(tempdir)s ; (default is not to cd during daemonization) backofflimit=10 ; (default 3) user=root ; (default is current user, required if root) umask=022 ; (default 022) logfile=supervisord.log ; (default supervisord.log) logfile_maxbytes=1000MB ; (default 50MB) logfile_backups=5 ; (default 10) loglevel=error ; (default info) pidfile=supervisord.pid ; (default supervisord.pid) nodaemon=true ; (default false) identifier=fleeb ; (default supervisor) childlogdir=%(tempdir)s ; (default tempfile.gettempdir()) nocleanup=true ; (default false) minfds=2048 ; (default 1024) minprocs=300 ; (default 200) [program:cat] command=/bin/cat priority=1 autostart=true autorestart=true user=root logfile=/tmp/cat.log stopsignal=KILL stopwaitsecs=5 startsecs=5 startretries=10 [program:cat2] command=/bin/cat autostart=true autorestart=false logfile_maxbytes = 1024 logfile_backups = 2 logfile = /tmp/cat2.log [program:cat3] command=/bin/cat exitcodes=0,1,127 ttempdiri(Rissupervisord.logiiii(ssupervisord.pidtfleebs 127.0.0.1i'#tchrismtfooii,iitcats/bin/catii s /tmp/cat.logt50MBitcat2is /tmp/cat2.logtcat3is/tmpii>(s 127.0.0.1i'#ii>(s 127.0.0.1i'#(:ttempfilet gettempdirRR t configfiletrealizet configroott supervisordtsockett assertEqualt directorytumasktlogfiletlogfile_maxbytestlogfile_backupstlogleveltpidfiletnodaemontTruet identifiert childlogdirt http_porttfamilytAF_INETtaddresst http_usernamet http_passwordt nocleanuptminfdstminprocstlentprogramstnametcommandtpriorityt autostartt autorestartt startsecst startretriestuidt stopsignaltsignaltSIGKILLt stopwaitsecst datatypest byte_sizet exitcodestFalsetNonetSIGTERMt AUTOMATICtostpathtabspathtgetcwdtgidtjoint passwdfile( RtsRtfptinstanceRRRRRthere((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_options+s,         ""cCscddkl}y|dddWn,tj o }|i|iddnXtddS(Ni(treadFiles /notthereii tFAILEDs Didn't raise(RROt ValueErrorRtargstAssertionError(RROtinst((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_readFile_faileds cCs5|i}|iddd}|i|ddS(Ns /not/therescan't find command '/not/there'(R tcheck_execv_argsR@R(RRLtresult((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt'test_check_execv_args_cant_find_commands cCs>|i}|iddtid}|i|ddS(Ns /etc/passwds*command at '/etc/passwd' is not executable(R RVR@RCtstatR(RRLRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt#test_check_execv_args_notexecutables  cCs>|i}|iddtid}|i|ddS(Nt/scommand at '/' is a directory(R RVR@RCRYR(RRLRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_check_execv_args_isdirs csddk}|itd}|id|i|i}ddkdd fdY}dd dY}||_||_d|_ |i |i t i idS( NitwR tPortcseZiZZRS((t__name__t __module__tAF_UNIXR&R(((tfnR(s3/usr/lib/python2.6/site-packages/supervisor/test.pyR^s tServercBseZRS((R_R`(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRcst(((RtmktemptopentwritetcloseR RR%t httpserverR tcleanuptfailIfRCRDtexists(RRtfRLR^Rc((RRbs3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_cleanup_afunix_unlinks          c sddk}|iztd}|id|i|i}ddkdd fdY}dd dY}||_||_d|_ t |_ |i |i tiiWdytiWntij onXXdS( NiR]R R^cseZiZZRS((R_R`RaR&R(((RbR(s3/usr/lib/python2.6/site-packages/supervisor/test.pyR^s RccBseZRS((R_R`(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRcsRd(((RReRfRgRhR RR%RiR R?tunlink_socketfileRjt failUnlessRCRDRltunlinkterror(RRRmRLR^Rc((RRbs3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_cleanup_afunix_nounlinks(           c Csddk}|i}z|i}t|_||_|i|iti i |t t |di d }|i|ti|iid}|i|idWdyti|Wntij onXXdS(Nitrissupervisord started with pid(RReR t DummyLoggertloggerR t write_pidfileRpRCRDRltintRftreadRtgetpidtdatat startswithRqRr(RRRbRLtpidtmsg((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_write_pidfile_oks       cCsgddk}d}|i}t|_||_|i|iid}|i|iddS(Nis/cannot/possibly/existiscould not write pidfile( RR RuRvR RwR{RpR|(RRRbRLR~((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_write_pidfile_fails     cCs|i}ti\}}ti|dti|d|i||ititi|d|i||ititi|ddS(NiR (R RCtpipeRyRgtclose_fdt assertRaisesRr(RRLtinnietoutie((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_close_fds   (R_R`RR RNRURXRZR\RnRsRRR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR#s         tTestBasecBs#eZdZdZdZRS(cCsdS(N((R((s3/usr/lib/python2.6/site-packages/supervisor/test.pytsetUp$scCsdS(N((R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttearDown'scOsOy|||Wn+tij o}|i|i|nXtddS(Ns Didnt raise(txmlrpctRPCErrorRtcodeRS(RRtcallableRRtkwRT((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt_assertRPCError*s (R_R`RRR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR#s  tMainXMLRPCInterfaceTestscBs,eZdZdZdZdZRS(cCstiS(N(Rt RPCInterface(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR4scOs|i||S(N(R(RRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR 7scCsBt}|i|}|i|ii||i|idS(N(tDummySupervisorR Rt supervisorRRptsystem(RRt interface((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_ctor:s cCst}|i|}ddkl}|itii||dg|itii||dg|itii||ddg|i||dgddS(Ni(ttraversesnotthere.hellossupervisor._readFilessupervisor.getIdentificationiR( RR RRRtFaultstUNKNOWN_METHODtINCORRECT_PARAMETERSR(RRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_traverse@s  (R_R`RR RR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR2s   cCs|djo h}nt|i}tii|d}ti|d>itprefixR]i(R@RfRyRCRDtsplittsyst executabletkeystreplacetupperRReRgRhtchmod(tfilet substitutionsR{tlasttkeyRttmpnamRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pytmakeExecutableOs    $   cCsLtiit}|pttii|dSttii|dS(Nsfixtures/spew.pysfixtures/unkillable_spew.py(RCRDtdirnamet__file__RRH(t unkillableRM((s3/usr/lib/python2.6/site-packages/supervisor/test.pytmakeSpewast'SupervisorNamespaceXMLRPCInterfaceTestscBsyeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(d'Z)d(Z*RS()cCstiS(N(RtSupervisorNamespaceRPCInterface(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRhscOs|i||S(N(R(RRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR kscCsdt}|i|}|id|i|idti|_|it i i |iddS(NR ( RR t_updateRt update_textRtSHUTDOWNtstateRRRtSHUTDOWN_STATE(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_updatens   cCsNt}|i|}|i}|i|ti|i|iddS(Nt getVersion(RR RRRt RPC_VERSIONR(RRRtversion((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_getVersionws   cCsQt}|i|}|i}|i||ii|i|iddS(NtgetIdentification(RR RRRR#R(RRRR#((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_getIdentification~s   cCsddkl}t}|i|}|i}|i}||}|i|d||i|d||i|iddS(Ni(tgetSupervisorStateDescriptiont statecodet statenametgetState(RRRR Rt get_stateRR(RRRRt stateinfoRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_getStates    cCsAt}|i|}|itii|idddddS(Ntoffsetitlengthi(RR RRRtNO_FILEtreadLog(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_readLog_unreadables c Cst}|i|}z|ii}t|d}|idd|i|iti i |i dddd|iti i |i ddddWdt i |XdS(Nsw+txiRiRi(RR RRRfRgRhRRRt BAD_ARGUMENTSRRCtremove(RRRRRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_readLog_badargss    cCs?t}|i|}|ii}zt|d}|idd|idd|i|idddd}|i|i d|i|dddd|idddd}|i|dd|idddd}|i|dd|idd dd}|i|d Wdt i |XdS( Nsw+RityRiRRiityyyy( RR RRRfRgRhRRRRCR(RRRRRmR{((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_readLogs$   cCs5t}|i|}|itii|idS(N(RR RRRRtclearLog(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clearLog_unreadables c Cst}|i|}|ii}zrt|d}|id|i|i}|i|i d|i|t |i t i i|Wdyt i|WnnXX|i|iiidit dS(Nsw+RRi(RR RRRfRgRhRRRR"RkRCRDRlRRvthandlerstreopened(RRRRRmRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_clearLogs      cCsKt}|i|}|i}|i|t|i|iddS(Ni(RR tshutdownRR"tmood(RRRtvalue((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_shutdowns   cCsKt}|i|}|i}|i|t|i|iddS(Ni(RR trestartRR"R(RRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_restarts   cCst}tdddt}t||}d|_th|d6}|i|}|id}|it i i |dS(NR s/bin/fooR3i ( t DummyOptionst DummyPConfigR?t DummyProcessR}RR t startProcessRRRtALREADY_STARTED(RRtconfigtprocessRRtcallback((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt!test_startProcess_already_starteds  cCs8t}|i|}|itii|iddS(NR (RR RRRtBAD_NAMER(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_startProcess_badnames  cCst}tdddt}t||ti}d|_th|d6}|i|}|i d}|i t i i |dS(NR s/bin/fooR3tabc(RRR?RRtSTOPPEDtspawnerrRR RRRRt SPAWN_ERROR(RRRRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_startProcess_spawnerrs  cCst}tdddtdd}t||dti}th|d6}|i|}|id}|i |t i |i |i t |i |idti|_tid|}|i |t dS( NR s/bin/fooR3R5g{Gz?RRg{Gz?(RRR?RRRRR RRthttpt NOT_DONE_YETtspawnedR"RtRUNNINGRttimetsleep(RRRRRRRRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_startProcesss    cCst}tdddt}t||dti}th|d6}|i|}|iddt}|i |t |i |i t |i |i ddS(NR s/bin/fooR3RtwaitR( RRR?RRRRR RRR"RR(RRRRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_startProcess_nowait s cCst}tdddtdd}t||dti}th|d6}|i|}|iddt }|i |t |i |i t |i |i ddS( NR s/bin/fooR3R5iRRR( RRR?RRRRR RR"RRR(RRRRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_startProcess_nostartsecss cCst}tdddt}t||ti}th|d6}|i|}|idd}|}t i d|i |i t |i |idti|_|itii|dS(NR s/bin/fooR3idg?R(RRR?RRRRR RRRRRR"RtBACKOFFRRRRtABNORMAL_TERMINATION(RRRRRRRRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_startProcess_abnormal_term#s    c Cs t}tdddddd}tdddd dd}t||ti}t||ti}th|d6|d6}|i|}|i}d d kl } d d k l } |i || |i || |i || t id |} t id |} |i t| d |i | ddd|i | dd| i|i | ddd|i | ddd|i | dd| i|i | ddd|i |id|i |it|i |itdS(NR s/bin/fooR2iR5g{Gz?tfoo2s /bin/foo2ii(R(Rg{Gz?iR0tstatust descriptiontOKR(RRRRRRR tstartAllProcessesRRRRRRRR.tSUCCESSRRR"( RRRtconfig2Rtprocess2RRRRRRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_startAllProcesses2s:        c Cst}tdddddd}tdddd dd}t||ti}t||ti}th|d6|d6}|i|}|id t}d d k l } d d k l } |i || |} |i t| d |i | ddd|i | dd| i|i | ddd|i | ddd|i | dd| i|i | ddddS(NR s/bin/fooR2iR5g{Gz?Rs /bin/foo2iRi(R(RiR0RRR(RRRRRRR RR?RRRRRR.R( RRRRRRRRRRRRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_startAllProcesses_nowait]s*    cCs8t}|i|}|itii|iddS(NR (RR RRRRt stopProcess(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stopProcess_badnameys cCs+t}tdd}t||ti}th|d6}|i|}|id}|i|i d|i i d}|i|i d|i|i d|i|id|i|ti|i|iti|i|t|it|i d|i|i ddS(NR s/bin/fooRii(RRRRRRR RRRt processestgettbackofftdelaytkillingRRRRR"R.(RRRRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stopProcesss  c CsOt}tdd}tdd}t||ti}t||ti}th|d6|d6}|i|}|i}|i|i dt i } x!|} | t i j oPqq|i } |i| hdd6dd6d d 6hdd6dd6d d 6g|it | d |i|it|i|itdS( NR s/bin/fooRs /bin/foo2tstopAllProcessesiPRR0RRi(RRRRRRR R RRRRRR.t stop_calledR"( RRRRRRRRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stopAllProcessess*      c Csth}|i|}td}td}ddkl}hdd6dd6|id6|d 6|d 6td 6}|i|}|i|d hd d6dd6|id6|d 6|d 6td 6dd6}|i|}|i|dhd d6dd6|id6|d 6|d 6td 6dd6} |i| }|i|dhdd6dd6|i d6|d 6|d 6td 6dd6} |i| }t t i |d } |i|| i thdd6dd6|i d6dd 6|d 6td 6dd6} |i| }|i|ddS(Nidii(RtrunningR0R}Rtstarttstoptnowspid 1, uptime 0:01:40tfatalitHosedRRds unknown error (try "tail fatal")tstoppediiis Not started(RR t_NOWRRRt_interpretProcessInfoRtFATALRRRt localtimetstrftimet _TIMEFORMAT( RRRRRRR RRtfatal2Rtstoptimetstopped2((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest__interpretProcessInfosd                  cCsqddkl}t}tdddd}t||}d|_d|_d |_th|d6}|i |}|i d}|i |i d |i |dd|i |d d|i |d d|i |d d|i |dd |i |d|i |i |dd|i |dd|i |dd|i|diddS(Ni(RR s/bin/fooRs/tmp/fleeb.barioi i tgetProcessInfoR0R}RRRRRt exitstatusiRRdRspid 111(RRRRRR}t laststarttlaststopRR RRRRRpR|(RRRRRRRR{((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_getProcessInfos*    c Csddkl}t}tdddddd}td d dd dd }t|||i}d |_d|_d|_t|||i }d|_d|_d|_t h|d6|d 6}|i |}|i } |i |id|i t| d | d} |i | dd|i | dd|i | dd |i | dd|i | dd|i | d|i|i | dd|i | dd|i | dd|i| did| d} |i | dd |i | dd |i | dd|i | d|i|i | dd|i | d|i |i | dd|i | dd|i | ddtti|id } |i | d| itdS(!Ni(Rtprocess1s /bin/process1R2iRs/tmp/process1.logRs /bin/process2is/tmp/process2.logioi i iiRR0R}RRRRRRRRdRspid 111Ri(RRRRRRR}R R!RRR tgetAllProcessInfoRRR.RpR|RRRRR( RRRtp1configtp2configR#RRRtinfotp1infotp2infot starttime((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_getAllProcessInfosX               cCst}tdddddd}t||}th|d6}|i|}|itii|i dddd ddS( NR#s /bin/process1R2iRs/tmp/process1.logRiR( RRRRR RRRRtreadProcessLog(RRRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_readProcessLog_unreadable6s  c Cst}tdddddd}t||}th|d6}|i|}z|ii}t|d}|idd |i |i t i i |idd d d d|i t i i |idd d d d Wdti|XdS( NR#s /bin/process1R2iRs/tmp/process1.logsw+RiRiR(RRRRR RRRfRgRhRRRRR,RCR(RRRRRRRRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_readProcessLog_badargsAs$     c Cst}tdddd}t||}th|d6}|i|}|iid}|ii}zt |d}|i dd|i dd|i |i dd d d d }|i |id |i |dddd|i dd dd d }|i |dd|i dd d d d}|i |dd|i dd d d d }|i |dWdti|XdS(NR s/bin/fooRs /tmp/fooooooosw+RiRRiRR,iiR(RRRRR RRRRRfRgRhR,RRRCR( RRRRRRRRmR{((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_readProcessLogWs,   cCs>t}|i|}|itii|iddddS(NRii (RR RRRRttailProcessLog(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tailProcessLog_bad_nameps c Cs/ddkl}t}tdddd}t||}th|d6}|i|}|iid}|i i }zt |d}|i ||i |iddd d t|\} } } |i|id |i| t|i| t||i| |Wd ti|Xd S( s:entire log is returned when offset==0 and logsize < lengthi(tlettersR s/bin/fooRs /tmp/fooooooosw+RiRR0N(tstringR2RRRRR RRRRRfRgRhR0R.RRR?RCR( RR2RRRRRRRmR{Rtoverflow((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tailProcessLog_allvs(     c Csddkl}t}tdddd}t||}th|d6}|i|}|iid}|i i }zt |d}|i ||i |iddt|d d \} } } |i|id |i| t|i| t||i| d |iddt|d d d \} } } |i|id |i| t|i| t||i| d Wdti|XdS(s*nothing is returned when offset <= logsizei(R2R s/bin/fooRs /tmp/fooooooosw+RRidR0RdiN(R3R2RRRRR RRRRRfRgRhR0R.RRR?RCR( RR2RRRRRRRmR{RR4((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tailProcessLog_nones6       c Cs-ddkl}t}tdddd}t||}th|d6}|i|}|iid}|i i }zt |d}|i ||i |iddd d d \} } } |i|id |i| t|i| t||i| |d Wdti|XdS(s3buffer overflow occurs when logsize > offset+lengthi(R2R s/bin/fooRs /tmp/fooooooosw+RiRiR0iN(R3R2RRRRR RRRRRfRgRhR0RRR"R.RCR( RR2RRRRRRRmR{RR4((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tailProcessLog_overflows&     c Csddkl}t}tdddd}t||}th|d6}|i|}|iid}|i i }|i dddd d \}} } |i |i d |i | t|i | d|i |d d S(s0nothing is returned if the log doesn't exist yeti(R2R s/bin/fooRs /tmp/foooooooRiRidR0RdN(R3R2RRRRR RRRRR0RRR?( RR2RRRRRRR{RR4((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tailProcessLog_unreadables   cCs8t}|i|}|itii|iddS(Ntspew(RR RRRRtclearProcessLog(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clearProcessLog_bad_names  cCsstdd}t}t||}h|d6}t|}|i|}|id|i|itdS(NR ( RRRRR R:Rt logsremovedR"(RtpconfigRRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clearProcessLogs    cCsutdd}t}t||}t|_h|d6}t|}|i|}|iti |i ddS(NR ( RRRR"terror_at_clearRR RRRR:(RR=RRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clearProcessLog_faileds    c Cstdd}tdd}t}t||}t||}h|d6|d6}t|}|i|}|i} | | |i|it|i|itdS(NR tbar( RRRRR tclearAllProcessLogsRR<R"( RR=tpconfig2RRRRRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clearAllProcessLogss   c Cs7tdd}tdd}t}t||}t||}t|_h|d6|d6}t|}|i|}|i} | | } |i|i t|i|i t |it | d|i| dhdd6t i id6dd6|i| d hdd6t i id6d d6dS( NR RAiiR0Rs FAILED: barRiR(RRRR"R?RR RBRR<R?R.RRRPR( RR=RCRRRRRRRtresults((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt!test_clearAllProcessLogs_onefailss*        (+R_R`RR RRRRRRRRRRRRRRRRRRRRRR R RR"R+R-R.R/R1R5R6R7R8R;R>R@RDRF(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRgsR               +     >  4     #    t#SystemNamespaceXMLRPCInterfaceTestscBsYeZdZdZdZdZdZdZdZdZ dZ RS( cCstiS(N(RtSystemNamespaceRPCInterface(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRscCs1t}ti|}|id|fgS(NR(RRRR(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR "s  cCs8|i}|i|id|i|iddS(NRR(R Rpt namespaces(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR*s cCsR|i}|i}|i|ii}|i|i||dS(N(R t listMethodstsortt _listMethodsRR(RRtmethodsR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_listMethods/s     cCsT|i}|itii|idg|id}|i|ddgdS(Nsfoo.barssystem.methodSignaturetarrayR3(R RRRtSIGNATURE_UNSUPPORTEDtmethodSignatureR(RRRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_methodSignature7s   cCsgddk}dddddddd d g }|i}|i}x|iD] }y|i|Wn#tij otd |nX|id d \}}|i |}t ||} | i } | i d | i !} |it| i} g} g}g}g}g}g}g}g}x| D]}|d djoH| i|d|i|d|i|d|i|dq.|d djoH|i|d|i|d|i|d|i|dq.|d dj o!td|d || fq.q.Wt| t|jo&tdt| t||fnx<| D]4}|it|tj|t||| fqbWx$|D]}|i||j|qWxZtt|D]F}||| |jo+d||| ||| f}t|qqWx0|D](}|it|tdj|q%Wt|d jotd|nx9|D]1}|it|tj|t||fqWx$|D]}|i||j|qWx?|D]7}|it|tdj|t||fqWx?|D]7}|it|tdj|t||fq$WqRWdS(NiRxtdoubleR3tbooleansdateTime.iso8601tbase64tbinaryROtstructs=methodSignature for %s raises RPCError (missing @return doc?)t.itparamiiiitreturns%unknown tag type %s for %s, parsed %ss6Incorrect documentation (%s args, %s doc params) in %ss Name wrong: (%s vs. %s in %s) %sRds'Duplicate @return values in docs for %s(RR RLRRQRRRSRRItgetattrt func_codet co_varnamest co_argcounttgettagststrt__doc__tappendR@R.RpttypeRxtrange(RRt _RPCTYPESRRMtktns_namet method_namet namespacetmethRtargnamestparsedtplinestptypestpnamestptextstrlinestrtypestrnamestrtextstthingtdoclinetdoctypeRR~tdoctexttdocname((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_allMethodDocs?s            & cCs|i}|ihdd6dgd6hdd6gd6g}ti}x|tijo |}qLW|i|d|id|i|d|idS(Nssystem.methodHelpt methodNametparamsssystem.listMethodsii(R t multicallRRRt methodHelpRJ(RRRRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_multicall_simplevalss  cCsg|i}|ihdd6g}ti}x|tijo |}q1W|i|dgdS(Nssupervisor.stopAllProcessesR{i(R R}RRR(RRRRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_multicall_nested_callbacks  cCsT|i}|itii|idg|id}|i||iidS(Nsfoo.barssystem.methodHelp(R RRRRPR~RRa(RRthelp((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_methodHelps   ( R_R`RR RRNRRRzRRR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRGs      ^ tSubprocessTestscBs^eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'RS(&cCstiS(N(Rt Subprocess(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRscOsti||S(N(RR(RtargR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCs\t}tdddd}|i||}|i|i||i|i||i|id|i|iid ht d6dd 6dd 6f|i|i d|i|id|i|i d|i|i d|i|i d|i|id|i|id|i|ih|i|id|i|id dS( NRsbin/catRs/tmp/temp123.logiis %(message)strotatingtbackupstmaxbytesRd(s/tmp/temp123.logis %(message)s(RRR RRRR tchildlogRRR?R}R!Rtadministrative_stopRRtpipesRR@t logbuffer(RRRRL((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRs& cCsxt}tdddd}|i||}|i|i|iidit|i|iidi tdS(Ntnottheres /notthereRs/tmp/fooi( RRR t removelogsRRRRR"tremoved(RRRRL((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_removelogss   cCs[t}tdddd}|i||}|i|i|iiditdS(NRs /notthereRs/tmp/fooi( RRR t reopenlogsRRRRR"(RRRRL((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_reopenlogss   cCs|t}tdddd}|i||}d|_|i|i|iidg|i|iiddgdS(NRs /notthereRs/tmp/fooR isnotthere output: foo( RRR Rt log_outputRRR{Rv(RRRRL((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_log_outputs   cCsXt}tdd}|i||}d|id<|i|i|iddS(Nttests/testRtstdout(RRR Rt drain_stdoutRR(RRRRL((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_drain_stdouts    cCst}tdd}|i||}d|id<|i|i|idt|i_ |i|i|iddS(NRs/testRtstderrRd( RRR Rt drain_stderrRRR"Rt log_stderr(RRRRL((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_drain_stderrs     cCst}tdd}|i||}t|i_d|ideZdZdZdZdZdZdZRS(cCsddkl}|S(Ni(tsupervisor_xmlrpc_handler(RR(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRscCs|i|S(N(R(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCsUt}|i|}|i|i|ddkl}|i|ii|dS(Ni(R(RR RRRRt rpcinterfacet __class__(RRthandlerR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRs  cCst}|i|}t|_ddk}|id d}tdddd}|i|||i i i }|i t |d|i |dd|i |d d |i t |id |id}|i|i|i|dS( Nitatbssupervisor.noSuchMethods /what/everiiu0XML-RPC method called: supervisor.noSuchMethod()iuKXML-RPC method supervisor.noSuchMethod() returned fault: [1] UNKNOWN_METHOD(RR(RR tDummyRPCServerRRRt DummyRequestR@tcontinue_requestRRvR{RR.t producersRRtloads(RRRRR{trequesttlogdatat xml_response((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt"test_continue_request_nosuchmethods       c CsLt}|i|}t|_ddk}|id d}tdddd}|i|||i i i }|i t |d|i |dd|i |dd|i t |id|id}|i|}|i |ddd |i |it|i |id d |i |id t |dS(Nissupervisor.getVersions /what/everiiu.XML-RPC method called: supervisor.getVersion()iu<XML-RPC method supervisor.getVersion() returned successfullys1.0s Content-Typestext/xmlsContent-Length((RR RRRRRR@RRRvR{RR.R R t_doneR"theaders( RRRRR{R R R tresponse((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt#test_continue_request_methodsuccesss(      cCst}|i|}t|_ddk}|id d}tdddd}|i|||i i i }|i t |d|i |dd|i|did|i|did |i t |id|i |id dS( Nissupervisor.raiseErrors /what/everiiu.XML-RPC method called: supervisor.raiseError()it TracebacksValueError: error i((RR RRRRRR@RRRvR{RR.RpR|tendswithR t_error(RRRRR{R R ((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_continue_request_500s    (R_R`RR RRRR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRs      tLogtailHandlerTestscBs5eZdZdZdZdZdZRS(cCsddkl}|S(Ni(tlogtail_handler(RR(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRscCs|i|S(N(R(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCst}tddd}t}ht||d6|_|i|}tdddd}|i||i |i ddS(NR s /logtail/fooi( RRR@RRRR Rthandle_requestRR(RRR=RRR ((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_handle_request_logfile_nones   cCst}tddd}t}ht||d6|_|i|}tdddd}|i||i |i ddS(NR s it/is/missings /logtail/fooi( RRRRRR RR@RRR(RRR=RRR ((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt#test_handle_request_logfile_missing"s   c Cs t}ti}|i}t}tddd|}ht||d6|_|i|}t dddd}|i ||i |i dddkl}|i |id|iti|ti|i |idd|i t|id |i |itdS( NR Rs /logtail/fooi(t http_dates Last-Modifieds Content-Types text/plaini(RRtNamedTemporaryFileR0RRRRR RR@RRRtmedusaRRtbuild_http_dateRCRYtST_MTIMER.R RR"( RRRmttRR=RR R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_handle_request,s       (R_R`RR RRR"(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRs    tSupervisordTestscBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZRS(cCsddkl}|S(Ni(t Supervisor(RR$(RR$((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR?scCs|i|S(N(R(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR CscCsyt}|i|}tddd}|g|_|idddtdt|i|id|i|it|i|i t|i|i t|i|i dgdgf|i|i t|i|i t|it|id |i|idi||i|it|i|it|i|it|i|it|i|itdS( NR s/bin/fooRRRRtfirstt setuid_calledt rlimits_seti(RR RR/tmainR"Rt realizeargstenvironment_processedtfds_cleaned_upR'tmake_logger_messagestautochildlogdir_clearedtautochildlogs_createdR.RRtpidfile_writtenthttpserver_openedt signals_sett daemonizedt cleaned_up(RRRR=((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_mainFs(   cCsgddkl}t}|i|}|i|i|id|_|i|i|idS(Ni(R( RRRR RRtACTIVERR(RRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR\s   cCsddkl}t}tddd}t|||i}tddd}t|||i}tdddd t}t|||i}td d d d t} t|| |i } td d dd t} t|| |i } t i } | d| _ |i |}h|d6|d6|d6| d 6| d 6|_ |i|i|it|i|it|i|it|i| it|i| itdS(Ni(Rtkilleds /bin/killedRrs /bin/errort notstarteds/bin/notstartedR3t wontstarttwonstarts/bin/wontstartt backingoffs/bin/backingoffi(RRRRRRRR"RRRRR Rtstart_necessaryRRR?(RRRtpconfig1R#RCRtpconfig3tprocess3tpconfig4tprocess4tpconfig5tprocess5RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_start_necessaryds6        c Cst}tddd}t||dti}tddd}t||dti}tddd}t||dti}tddd }t||dti} d | _d | _ |i |} h|d6|d6|d6| d6| _ | i |i |it|i |it|i |it|i | it|i | id |i | i d |i | id dS(NR#s /bin/process1RRs /bin/process2R>s /bin/process3R@s /bin/process4ii ii(RRRRRRRRRRR Rtstop_allRR R?R"R( RRR<R#RCRR=R>R?R@R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_stop_alls,    cCsBt}tddd}t||dti}d|_d|_d|_tddd}t||dti}d|_d|_d|_d|_ |i |}h|d6|d6|_ |i |i |id|i |id|i |id|i |id|i |id|i |iddS( NR#s /bin/process1Ri'iiRs /bin/process2(RRRRRRRRRR R Rt transitionR(RRR<R#RCRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_transitions*         c Cst}tddd}t||dti}tid|_tddd}t||dti}tid|_tddd }t||dti}|i|}h|d6|d6|d6|_ |i } |i | |gdS( NR#s /bin/process1RiRs /bin/process2iR>s /bin/process3( RRRRRRRRR Rt get_undeadR( RRR<R#RCRR=R>Rtundead((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_get_undeads   cCst}tddd}t||dti}tid|_tddd}t||dti}tid|_|i|}h|d6|d6|_|i |i |i t i dS(NR#s /bin/process1RiRs /bin/process2i(RRRRRRRR Rt kill_undeadRt killed_withR9R:(RRR<R#RCRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_kill_undeads  cCst}d|_tddd}t||}t|_d|_d|_d|_ h|d6|_ |i |}|i dt |i|iddS(NiRs /bin/process1tonce(ii(NN(ii(Rtwaitpid_returnRRR?tdrainedRR@R!RRR treapR"Rtfinished(RRR=RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_reaps      cCs_t}ti|_|i|}|i|i|id|i|iidddS(Niis(received SIGTERM indicating exit request( RR9RAR t handle_signalRRRvR{(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_handle_sigterms   cCs_t}ti|_|i|}|i|i|id|i|iidddS(Niis'received SIGINT indicating exit request( RR9tSIGINTR RTRRRvR{(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_handle_sigints   cCs_t}ti|_|i|}|i|i|id|i|iidddS(Niis(received SIGQUIT indicating exit request( RR9tSIGQUITR RTRRRvR{(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_handle_sigquits   cCs_t}ti|_|i|}|i|i|id|i|iidddS(Nis*received SIGHUP indicating restart request( RR9tSIGHUPR RTRRRvR{(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_handle_sighups   cCst}ti|_tddd}t||dti}tid|_|i |}h|d6|_ |i |i |i d|i |it|i |it|i |iidddS(NR#s /bin/process1Riis.received SIGUSR2 indicating log reopen request(RR9tSIGUSR2RRRRRRR RRTRRt logs_reopenedR"RvR{(RRR<R#R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_handle_sigusr2s   cCs_t}ti|_|i|}|i|i|id|i|iidddS(Niis#received SIGUSR1 indicating nothing( RR9tSIGUSR1R RTRRRvR{(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_handle_unknown_signal&s   (R_R`RR R4RRCRERGRJRMRSRURWRYR[R^R`(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR#>s        !    tControllerTestscBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(d'Z)d(Z*d)Z+RS(*cCsddkl}|S(Ni(t Controller(t supervisorctlRb(RRb((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR1scCs|i|S(N(R(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR 5scCs6t}|i|}|i|i|iddS(Ns> (tDummyClientOptionsR Rtprompt(RRt controller((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR8s cCs8t}|i|}|i}|i|tdS(N(RdR t_upcheckRR"(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test__upcheck=s  cCslt}|i|}t|_|id}|i|d|i|iii ddjdS(NRsDocumented commandsi( RdR RRtonecmdRR@RptgetvalueR(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_onecmdCs  cCsst}|i|}t|_|id}|i|d|iiid}|i|dddS(NRds isError: too few arguments( RdR RRtdo_tailRR@RjR(RRRfRWtlines((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tail_nonameMs  cCsst}|i|}t|_|id}|i|d|iiid}|i|dddS(Ns one two threes isError: too many arguments( RdR RRRlRR@RjR(RRRfRWRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tail_toomanyargsVs  cCst}|i|}t|_|id}|i|d|iiid}|it |d|i|dddS(NR s i is output line( RdR RRRlRR@RjRR.(RRRfRWRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tail_onearg_s  cCsyt}|i|}t|_|id}|iiid}|it|d|i|dddS(NRs iisNO_FILE: ERROR (no log file)( RdR RRRlRjRRR.(RRRfRWRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tail_no_fileis  cCsyt}|i|}t|_|id}|iiid}|it|d|i|dddS(NRPs iis)FAILED: ERROR (unknown error reading log)( RdR RRRlRjRRR.(RRRfRWRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tail_failedrs  cCsyt}|i|}t|_|id}|iiid}|it|d|i|dddS(NRs iis&BAD_NAME: ERROR (no such process name)( RdR RRRlRjRRR.(RRRfRWRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tail_bad_name{s  cCst}|i|}t|_|id}|i|d|iiid}|it |d|i|dddS(Ns-10 foos iis tput line( RdR RRRlRR@RjRR.(RRRfRWRm((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_tail_twoargss  cCsft}|i|}t|_|id}|i|dd}|i|ii|dS(NR s*foo RUNNING foo description (RdR RRt do_statusRR@Rj(RRRfRWtexpected((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_status_oneprocesss  cCsft}|i|}t|_|id}|i|dd}|i|ii|dS(NRds~foo RUNNING foo description bar FATAL bar description baz STOPPED baz description (RdR RRRuRR@Rj(RRRfRWRv((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_status_allprocessess  cCsst}|i|}t|_|id}|i|dd}|i|iiidd|dS(NRds$Error: start requires a process names i( RdR RRtdo_startRR@RjR(RRRfRWRv((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_start_fails  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRs"BAD_NAME: ERROR (no such process) (RdR RRRyRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_start_badnames  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRs)ALREADY_STARTED: ERROR (already started) (RdR RRRyRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_start_alreadystarteds  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRs!SPAWN_ERROR: ERROR (spawn error) (RdR RRRyRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_start_spawnerrors  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NR s foo: started (RdR RRRyRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_start_one_successs   cCs`t}|i|}t|_|id}|i|d|i|iiddS(Nsfoo barsfoo: started bar: started (RdR RRRyRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_start_manys  cCs`t}|i|}t|_|id}|i|d|i|iiddS(Ntalls7foo: started foo2: started failed: ERROR (spawn error) (RdR RRRyRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_start_alls  cCsst}|i|}t|_|id}|i|dd}|i|iiidd|dS(NRds#Error: stop requires a process names i( RdR RRtdo_stopRR@RjR(RRRfRWRv((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stop_fails  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRs"BAD_NAME: ERROR (no such process) (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stop_badnames  cCs`t}|i|}t|_|id}|i|d|i|iiddS(Nt NOT_RUNNINGs!NOT_RUNNING: ERROR (not running) (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stop_notrunnings  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRPsFAILED (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stop_faileds   cCs`t}|i|}t|_|id}|i|d|i|iiddS(NR s foo: stopped (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stop_one_success s   cCs`t}|i|}t|_|id}|i|d|i|iiddS(Nsfoo barsfoo: stopped bar: stopped (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_stop_many s  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRs;foo: stopped foo2: stopped failed: ERROR (no such process) (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRE s  cCsmt}|i|}t|_|id}|i|d|i|iiiddddS(NRds is&Error: restart requires a process name( RdR RRt do_restartRR@RjR(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_restart_fail" s  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NR sfoo: stopped foo: started (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_restart_one, s  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRsrfoo: stopped foo2: stopped failed: ERROR (no such process) foo: started foo2: started failed: ERROR (spawn error) (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_restart_all6 s  cCsxt}t|_t|ii_|i|}t|_|i d}|i |d|i |iii tdS(NRd( RdR?t interactivet_serverRt _restartableR RRt do_reloadRR@t _restarted(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_reload_failC s   cCsit}t|_|i|}t|_|id}|i|d|i|i i i t dS(NRd( RdR?RR RRRRR@RRRR"(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt test_reloadM s   cCsxt}t|_t|ii_|i|}t|_|i d}|i |d|i |iii tdS(NRd( RdR?RRRRR RRt do_shutdownRR@t _shutdown(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_shutdown_failV s   cCsit}t|_|i|}t|_|id}|i|d|i|i i i t dS(NRd( RdR?RR RRRRR@RRRR"(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR` s   cCsst}|i|}t|_|id}|i|dd}|i|iiidd|dS(NRds$Error: clear requires a process names i( RdR RRtdo_clearRR@RjR(RRRfRWRv((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clear_failm s  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRs"BAD_NAME: ERROR (no such process) (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clear_badnamev s  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NR s foo: cleared (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clear_one_success s   cCs`t}|i|}t|_|id}|i|d|i|iiddS(Nsfoo barsfoo: cleared bar: cleared (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clear_many s  cCs`t}|i|}t|_|id}|i|d|i|iiddS(NRs2foo: cleared foo2: cleared failed: ERROR (failed) (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_clear_all s  cCs`t}|i|}t|_|id}|i|d|i|iiddS(Ntbadnames&ERROR: url must be http:// or unix:// (RdR RRtdo_openRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_open_fail s  cCs`t}|i|}t|_|id}|i|d|i|iiddS(Nshttp://localhost:9002s~foo RUNNING foo description bar FATAL bar description baz STOPPED baz description (RdR RRRRR@Rj(RRRfRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_open_succeed s  (,R_R`RR RRhRkRnRoRpRqRrRsRtRwRxRzR{R|R}R~RRRRRRRRRERRRRRRRRRRRRRR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRa0sT         tTailFProducerTestscBs#eZdZdZdZRS(cCsddkl}|S(Ni(ttail_f_producer(RR(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCs|i|||S(N(R(RR tfilenamethead((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCs tdddd}ti}|idd|i|i}|i||d}|i}|i |dd|idd|i|i}|i |dd|i}|i |t i |i d|i|i}|i |ddS(Ns /logtail/fooRiPR]idis==> File truncated <== ( RR@RRRgtflushR0R tmoreRRRttruncate(RR RmR!tproducerRW((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_handle_more s$          (R_R`RR R(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s  tBasicAuthTransportTestscBs5eZdZddddZdZdZRS(cCsddkl}|S(Ni(tBasicAuthTransport(RR(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCs|i}||||S(N(R(Rtusernametpasswordt serverurltklass((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s cCse|iddd}|i|id|i|id|i|id|i|itdS(NRRR(R RRRRtverboseR?(RRL((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s cCs+|iddd}|i\}}dS(NRRR(R t getparser(RRLtparsert unmarshaller((s3/usr/lib/python2.6/site-packages/supervisor/test.pyttest_works_with_py25 sN(R_R`RR@R RR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s  RcBseZdZdZdZdZdZdZdZdZ dZ dZ dZ dZdZdZeidZdZdZdZdZdZdZd Zd Zd Zd Zd ZdZRS(iRdcCs||_||_t|_t|_t|_d|_t|_ ||_ t|_ d|_ t|_ d|_d|_h|_d|_t|_dS(NRd(RRRuRR?R<R R@t backoff_secsRRR?RLRPRtloggedRRRR](RRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt__init__ s                cCs t|_dS(N(R"R](R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCs'|iotdnt|_dS(Ntwhatever(R?RR"R<(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s cCs|iS(N(R(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCs"t|_t|_ti|_dS(N(R"R R?RRRR(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s  cCs ||_dS(N(RL(RR9((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCst|_ti|_dS(N(R"RRRR(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s cCs t|_dS(N(R"RP(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCsgS(N((R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCst|ii|iiS(N(tcmpRR2(Rtother((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt__cmp__! scCsgS(N((R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt readable_fds$ scCs |i|i|_d|_dS(NRd(RR(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR' scCs||f|_dS(N(RR(RR}R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR+ sN( R_R`R}R R!RRRRRR@RRRRRRRRRRRRRRRRRRRRR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s6           RcBsDeZdeeddddddeeeidddgdZRS(ii iicCs||_||_||_||_||_||_||_||_| |_| |_ | |_ | |_ | |_ ||_ ||_||_dS(N(R0R1R2R3R4R5R6R7RRRt log_stdoutRR8R;R>(RR0R1R2R3R4R5R6R7RRRRRR8R;R>((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR/ s                N(R_R`R"R@R?R9RAR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR. s     RucBsKeZdZdZeZZZZZdZ dZ dZ RS(cCs(t|_t|_t|_g|_dS(N(R?RRtclosedR{(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRH s   cGs%x|D]}|ii|qWdS(N(R{Rb(RRRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR'N scCs t|_dS(N(R"R(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pytreopenR scCs t|_dS(N(R"R(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRhT scCs t|_dS(N(R"R(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRV s( R_R`RR'twarntlogtdebugtcriticalttraceRRhR(((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRuG s     RcBsgeZdZd$Zd$Zd$Zd$ZdZdZ dZ dZ dZ dZ dZdZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'd Z(d!Z)d"Z*d#Z+RS(%icCsd|_d|_d|_|i|_d|_d|_t|_h|_ g|_ t|_ h|_ d|_ t|_d|_t|_t|_t|_t|_t|_t|_d|_t|_t|_t|_t|_d|_d|_h|_d|_d|_ d|_!d|_"d|_#h|_$h|_%g|_&d|_'d|_(d|_)d|_*t|_+t|_,dS( NRs/tmpii s /tmp/logfileii(NN(-R#R$R7t getLoggerRvt backofflimitRR?R+RR/R!t socket_mapRt mustreopenR@R)R+t rlimit_setR&R0R1R2R,R.R-R3R/RRORR9RRRRRRRRRRRR]R*(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRb sT                                        cOs+t}tg|_||f|_|S(N(RuRRR(RRRRRv((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s cCs ||_dS(N(R)(RRR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCs t|_dS(N(R"R+(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt cleanup_fds scCst|_dgS(NR'(R"R'(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt set_rlimits s cCs t|_dS(NR&(R"R&(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR s cCs t|_dS(N(R"R0(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pytopenhttpserver scCs t|_dS(N(R"R2(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt daemonize scCs t|_dS(N(R"R1(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt setsignals scCs|iS(N(R(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pytget_socket_map scCs||f|_dS(N(R,(Rt critical_msgst info_msgs((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt make_logger scCs t|_dS(N(R"R.(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pytcreate_autochildlogs scCs t|_dS(N(R"R-(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pytclear_autochildlogdir scCs t|_dS(N(R"R3(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRj scCs t|_dS(N(R"R/(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyRw scCs|iS(N(RO(R((s3/usr/lib/python2.6/site-packages/supervisor/test.pyR scCs t||S(N(R(RR((s3/usr/lib/python2.6/site-packages/supervisor/test.pyt make_process scCs.|iot|in||i|s|                   I.M