Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
supervisor / tests / __pycache__ / test_childutils.cpython-38.pyc
Size: Mime:
U

VƧ\kã@s’ddlmZddlZddlZddlZddlmZddlmZGdd„dejƒZ	Gdd„dejƒZ
Gd	d
„d
ejƒZdd„Ze
d
krŽejdddS)é)ÚBytesION)ÚStringIO)Ú	as_stringc@s<eZdZdd„Zdd„Zdd„Zdd„Zd	d
„Zdd„Zd
S)ÚChildUtilsTestscCs*ddlm}|ddiƒ}| |dk	¡dS)Nr)ÚgetRPCInterfaceÚSUPERVISOR_SERVER_URLúhttp://localhost:9001)Úsupervisor.childutilsrZ
assertTrue)ÚselfrZrpc©rú/./build/lib/supervisor/tests/test_childutils.pyÚtest_getRPCInterface	sz$ChildUtilsTests.test_getRPCInterfacecCsFddlm}|ddiƒ}| |jd¡| |jd¡| |jd¡dS)Nr©ÚgetRPCTransportrrÚ©r	rÚassertEqualZusernameZpasswordZ	serverurl)r
rÚtrrrÚ"test_getRPCTransport_no_uname_passs
z2ChildUtilsTests.test_getRPCTransport_no_uname_passcCsNddlm}ddddœ}||ƒ}| |jd¡| |jd¡| |jd¡dS)NrrrZchrismZabc123)rZSUPERVISOR_USERNAMEZSUPERVISOR_PASSWORDr)r
rÚenvrrrrÚ$test_getRPCTransport_with_uname_passsþz4ChildUtilsTests.test_getRPCTransport_with_uname_passcCs.ddlm}d}||ƒ}| |dddœ¡dS)Nr)Úget_headersza:1 b:2Ú1Ú2©ÚaÚb)r	rr)r
rÚlineÚresultrrrÚtest_get_headers sz ChildUtilsTests.test_get_headerscCs>ddlm}d}||ƒ\}}| |dddœ¡| |d¡dS)Nr)Ú	eventdataza:1 b:2
thedata
rrrzthedata
)r	r r)r
r ÚpayloadÚheadersÚdatarrrÚtest_eventdata&s
zChildUtilsTests.test_eventdatacCs.ddlm}t d¡}||ƒ}| |d¡dS)Nr)Úget_asctime)	iÙééééérréÿÿÿÿz2009-01-18 22:14:07,000)r	r%ÚtimeÚmktimer)r
r%Z	timestamprrrrÚtest_get_asctime-s
z ChildUtilsTests.test_get_asctimeN)	Ú__name__Ú
__module__Ú__qualname__r
rrrr$r.rrrrrs
rc@s$eZdZdd„Zdd„Zdd„ZdS)Ú!TestProcessCommunicationsProtocolcCsRddlm}tƒ}| d|¡ddlm}|j}|j}| | 	¡|d|¡dS©Nr)Úpcommshello)ÚProcessCommunicationEvent)
r	r4rÚsendÚsupervisor.eventsr5ÚBEGIN_TOKENÚ	END_TOKENrÚgetvalue)r
r4Ústdoutr5ÚbeginÚendrrrÚ	test_send4sz+TestProcessCommunicationsProtocol.test_sendcCsjddlm}tj}zJtƒ}t_| d¡ddlm}|j}|j}| 	| 
¡|d|¡W5|t_XdSr3)r	r4Úsysr;rr7r5r8r9rr:©r
r4ÚoldÚior5r<r=rrrÚtest_stdout=s
z-TestProcessCommunicationsProtocol.test_stdoutcCsjddlm}tj}zJtƒ}t_| d¡ddlm}|j}|j}| 	| 
¡|d|¡W5|t_XdSr3)r	r4r?Ústderrrr7r5r8r9rr:r@rrrÚtest_stderrJs
z-TestProcessCommunicationsProtocol.test_stderrN)r/r0r1r>rCrErrrrr23s	
r2c@s4eZdZdd„Zdd„Zdd„Zdd„Zd	d
„ZdS)ÚTestEventListenerProtocolcCsfddlm}Gdd„dƒ}|ƒ}tƒ}| ||¡\}}| |ddi¡| |d¡| | ¡d¡dS)	Nr©Úlistenerc@seZdZdd„Zdd„ZdS)z2TestEventListenerProtocol.test_wait.<locals>.DummycSsdS)Nzlen:5r)r
rrrÚreadline[sz;TestEventListenerProtocol.test_wait.<locals>.Dummy.readlinecWsdS)NÚhellor)r
ZignoredrrrÚread]sz7TestEventListenerProtocol.test_wait.<locals>.Dummy.readN)r/r0r1rIrKrrrrÚDummyZsrLÚlenÚ5rJzREADY
)r	rHrÚwaitrr:)r
rHrLÚstdinr;r"r!rrrÚ	test_waitXsz#TestEventListenerProtocol.test_waitcCsFddlm}ddlm}t|jƒ}tƒ}| |¡| | 	¡|¡dS)NrrG©ÚPEventListenerDispatcher)
r	rHÚsupervisor.dispatchersrSrZREADY_FOR_EVENTS_TOKENrZreadyrr:)r
rHrSÚtokenr;rrrÚ
test_tokenfs

z$TestEventListenerProtocol.test_tokencCsJddlm}ddlm}t|jƒ}tƒ}| |¡| | 	¡|d¡dS)NrrGrRz2
OK)
r	rHrTrSrÚRESULT_TOKEN_STARTrÚokrr:©r
rHrSr<r;rrrÚtest_okns

z!TestEventListenerProtocol.test_okcCsJddlm}ddlm}t|jƒ}tƒ}| |¡| | 	¡|d¡dS)NrrGrRz4
FAIL)
r	rHrTrSrrWrZfailrr:rYrrrÚ	test_failvs

z#TestEventListenerProtocol.test_failcCs^ddlm}ddlm}t|jƒ}tƒ}d}| ||¡d|t|ƒ|f}| 	| 
¡|¡dS)NrrGrRzthe body data ya fool
z%s%s
%s)r	rHrTrSrrWrr6rMrr:)r
rHrSr<r;ÚmsgZexpectedrrrr>~s
z#TestEventListenerProtocol.test_sendN)r/r0r1rQrVrZr[r>rrrrrFWs
rFcCst tjt¡S)N)ÚunittestZ
findTestCasesr?Úmodulesr/rrrrÚ
test_suite‰sr_Ú__main__)ZdefaultTest)rBrr?r,r]Zsupervisor.compatrrZTestCaserr2rFr_r/ÚmainrrrrÚ<module>s+$2