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

doctorondemand / supervisor python

Repository URL to install this package:

Version: 
4.2.1  ▾
Details    
supervisor / tests / __pycache__ / test_xmlrpc.cpython-38.pyc
Size: Mime: 
U

VƧ\ۋã@s(ddlZddlmZddlmZddlmZddlmZddlmZGdd„dejƒZ	Gd	d
„d
ejƒZ
Gdd„dejƒZGd
d„dejƒZGdd„dejƒZ
Gdd„dejƒZGdd„dejƒZGdd„dejƒZGdd„dejƒZGdd„dejƒZGdd„dƒZGdd„deƒZGdd „d ƒZdS)!éN)ÚDummySupervisor)ÚDummyRequest)ÚDummySupervisorRPCNamespace©Ú	xmlrpclib)Úhttplibc@seZdZdd„Zdd„ZdS)ÚGetFaultDescriptionTestscCs*ddlm}| |jj¡}| |d¡dS)Nr©ÚxmlrpcÚSHUTDOWN_STATE)Ú
supervisorr
ÚgetFaultDescriptionÚFaultsrÚassertEqual©Úselfr
Zdesc©rú+./build/lib/supervisor/tests/test_xmlrpc.pyÚ(test_returns_description_for_known_faultszAGetFaultDescriptionTests.test_returns_description_for_known_faultcCs&ddlm}| d¡}| |d¡dS)Nrr	i?BZUNKNOWN)rr
r
rrrrrÚ&test_returns_unknown_for_unknown_faults
z?GetFaultDescriptionTests.test_returns_unknown_for_unknown_faultN)Ú__name__Ú
__module__Ú__qualname__rrrrrrr
src@s6eZdZdd„Zddd„Zdd„Zdd	„Zd
d„ZdS)
Ú
RPCErrorTestscCsddlm}|S)Nr©ÚRPCError)Úsupervisor.xmlrpcr)rrrrrÚ_getTargetClassszRPCErrorTests._getTargetClassNcCs| ¡||ƒS©N©r)rÚcodeÚextrarrrÚ_makeOneszRPCErrorTests._makeOnecCs,ddlm}| |jj¡}| |jd¡dS)Nrr	ÚFAILED©rr
r"rr#rÚtext©rr
ÚerrrÚ#test_sets_text_with_fault_name_onlysz1RPCErrorTests.test_sets_text_with_fault_name_onlycCs.ddlm}| |jjd¡}| |jd¡dS)Nrr	ZoopszFAILED: oopsr$r&rrrÚ(test_sets_text_with_fault_name_and_extra"sz6RPCErrorTests.test_sets_text_with_fault_name_and_extracCs8ddlm}| |jjd¡}| t|ƒd|jj¡dS)Nrr	z/nonexistentz%code=%r, text='NO_FILE: /nonexistent')rr
r"rZNO_FILErÚstrr&rrrÚ test___str___shows_code_and_text's


ÿz.RPCErrorTests.test___str___shows_code_and_text)N)rrrrr"r(r)r+rrrrrs

rc@seZdZdd„ZdS)ÚXMLRPCMarshallingTestscCsXddlm}| d¡}| |tjddd¡t dd¡}| |¡}| |t |¡¡dS)Nrr	é)r-T)ZmethodresponseÚfoo)rr
Zxmlrpc_marshalrrÚdumpsÚFault)rr
ÚdataZfaultrrrÚtest_xmlrpc_marshal/s

z*XMLRPCMarshallingTests.test_xmlrpc_marshalN)rrrr2rrrrr,.sr,c@s|eZdZdd„Zdd„Zdd„Zdd„Zd	d
„Zdd„Zd
d„Z	dd„Z
dd„Zdd„Zdd„Z
dd„Zdd„Zdd„ZdS)ÚXMLRPCHandlerTestscCsddlm}|S)Nr)Úsupervisor_xmlrpc_handler)rr4)rr4rrrr8sz"XMLRPCHandlerTests._getTargetClasscCs| ¡||ƒSrr)rÚsupervisordÚ
subinterfacesrrrr"<szXMLRPCHandlerTests._makeOnecCsLtƒ}dtƒfg}| ||¡}| |j|¡ddlm}| |jj|¡dS)Nrr)ÚRootRPCInterface)	rrr"rr5rr7ZrpcinterfaceÚ	__class__)rrr6Úhandlerr7rrrÚ	test_ctor?szXMLRPCHandlerTests.test_ctorcCs\Gdd„dƒ}tƒ}dtƒfg}| ||¡}| | |dƒ¡d¡| | |dƒ¡d¡dS)Nc@seZdZdd„ZdS)z4XMLRPCHandlerTests.test_match.<locals>.DummyRequest2cSs
||_dSr)Úuri)rr;rrrÚ__init__Isz=XMLRPCHandlerTests.test_match.<locals>.DummyRequest2.__init__N)rrrr<rrrrÚ
DummyRequest2Hsr=rz/RPC2Tz/nopeF)rrr"rÚmatch)rr=rr6r9rrrÚ
test_matchGszXMLRPCHandlerTests.test_matchcCs°tƒ}dtƒfg}| ||¡}t dd¡}tddddƒ}| ||¡|jjj	}| 
t|ƒd¡| 
|dd¡| 
|dd	¡| 
t|jƒd
¡|jd}| 
tjtj|¡dS)Nr)ÚaÚbzsupervisor.noSuchMethodú
/what/everééþÿÿÿz0XML-RPC method called: supervisor.noSuchMethod()éÿÿÿÿzKXML-RPC method supervisor.noSuchMethod() returned fault: [1] UNKNOWN_METHODr-r)rrr"rr/rÚcontinue_requestÚoptionsÚloggerr1rÚlenÚ	producersÚassertRaisesr0Úloads)rrr6r9r1ÚrequestÚlogdataÚxml_responserrrÚ"test_continue_request_nosuchmethodQs"

ÿ
ÿ
z5XMLRPCHandlerTests.test_continue_request_nosuchmethodc
Csþtƒ}dtƒfg}| ||¡}t dd¡}tddddƒ}| ||¡|jjj	}| 
t|ƒd¡| 
|dd¡| 
|dd	¡| 
t|jƒd
¡|jd}t 
|¡}ddlm}	| 
|dd|	¡| 
|jd
¡| 
|jdd¡| 
|jdt|ƒ¡dS)Nrrzsupervisor.getAPIVersionrBrCrDú1XML-RPC method called: supervisor.getAPIVersion()rEú?XML-RPC method supervisor.getAPIVersion() returned successfullyr-r©ÚAPI_VERSIONTúContent-Typeútext/xmlúContent-Length)rrr"rr/rrFrGrHr1rrIrJrLÚsupervisor.rpcinterfacerTÚ_doneÚheaders©
rrr6r9r1rMrNrOÚresponserTrrrÚ#test_continue_request_methodsuccesscs,

ÿ
ÿ

z6XMLRPCHandlerTests.test_continue_request_methodsuccessc
Csötƒ}dtƒfg}| ||¡}d}tddddƒ}| ||¡|jjj}| t	|ƒd¡| |dd¡| |dd¡| t	|j
ƒd	¡|j
d
}t |¡}d
dl
m}	| |d
d
|	¡| |jd¡| |jd
d¡| |jdt	|ƒ¡dS)Nrzp<?xml version="1.0" encoding="UTF-8"?><methodCall><methodName>supervisor.getAPIVersion</methodName></methodCall>rBrCrDrQrErRr-rrSTrUrVrW)rrr"rrFrGrHr1rrIrJrrLrXrTrYrZr[rrrÚ*test_continue_request_no_params_in_requestys,

ÿ
ÿ

z=XMLRPCHandlerTests.test_continue_request_no_params_in_requestcCs¦tƒ}dtƒfg}| ||¡}d}tddddƒ}| ||¡|jjj}| t	|ƒd¡| 
|d d¡¡| 
t|ƒ|dk¡| 
|d 
d¡¡| |jd¡dS)	NrzX<?xml version="1.0" encoding="UTF-8"?><methodCall><methodName></methodName></methodCall>rBr-rúXML-RPC request datazis invalid: no method name鐩rrr"rrFrGrHr1rrIÚ
assertTrueÚ
startswithÚreprÚendswithÚ_error©rrr6r9r1rMrNrrrÚ1test_continue_request_400_if_method_name_is_empty’s
zDXMLRPCHandlerTests.test_continue_request_400_if_method_name_is_emptycCs¦tƒ}dtƒfg}| ||¡}d}tddddƒ}| ||¡|jjj}| t	|ƒd¡| 
|d d¡¡| 
t|ƒ|dk¡| 
|d 
d¡¡| |jd¡dS)	Nrz#this is not an xml-rpc request bodyrBr-rr_úis invalid: unmarshallabler`rargrrrÚ1test_continue_request_400_if_loads_raises_not_xml¡s
zDXMLRPCHandlerTests.test_continue_request_400_if_loads_raises_not_xmlcCs¦tƒ}dtƒfg}| ||¡}d}tddddƒ}| ||¡|jjj}| t	|ƒd¡| 
|d d¡¡| 
t|ƒ|dk¡| 
|d 
d¡¡| |jd¡dS)	Nrz&<methodName></methodName><junk></junk>rBr-rr_rir`rargrrrÚ3test_continue_request_400_if_loads_raises_weird_xml¯s
zFXMLRPCHandlerTests.test_continue_request_400_if_loads_raises_weird_xmlcCsÌtƒ}dtƒfg}| ||¡}t dd¡}tddddƒ}| ||¡|jjj	}| 
t|ƒd¡| 
|dd¡| d|d	k¡| t
|ƒ|d	k¡| d
|d	k¡| d|d	k¡| 
|jd¡dS)
Nrrzsupervisor.raiseErrorrBrCrz.XML-RPC method called: supervisor.raiseError()úunexpected exceptionr-Ú	TracebackzValueError: erroréô©rrr"rr/rrFrGrHr1rrIrbrdrfrgrrrÚ<test_continue_request_500_if_rpcinterface_method_call_raises½s 

ÿzOXMLRPCHandlerTests.test_continue_request_500_if_rpcinterface_method_call_raisescCsÜtƒ}dtƒfg}| ||¡}t dd¡}tddddƒ}| ||¡|jjj	}| 
t|ƒd¡| 
|dd¡| 
|dd	¡| d
|dk¡| t
|ƒ|dk¡| d|dk¡| d
|dk¡| 
|jd¡dS)Nrrz"supervisor.getXmlRpcUnmarshallablerBérz;XML-RPC method called: supervisor.getXmlRpcUnmarshallable()r-zIXML-RPC method supervisor.getXmlRpcUnmarshallable() returned successfullyrlrCrmzTypeError: cannot marshalrnrorgrrrÚ0test_continue_request_500_if_xmlrpc_dumps_raisesÎs&

ÿ
ÿzCXMLRPCHandlerTests.test_continue_request_500_if_xmlrpc_dumps_raisescCsºGdd„dtƒ}tƒ}dtƒfd|ƒfg}| ||¡}t dd¡}tddddƒ}| ||¡|jj	j
}| t|ƒd¡| |d	d
¡| |dd¡| t|j
ƒd
¡| |jd¡dS)Nc@seZdZdd„ZdS)zUXMLRPCHandlerTests.test_continue_request_value_is_function.<locals>.DummyRPCNamespacecSsdd„}d|_|S)NcSsdS©Nr-r©rrrrÚinneråszhXMLRPCHandlerTests.test_continue_request_value_is_function.<locals>.DummyRPCNamespace.foo.<locals>.innergš™™™™™©?)Údelay©rrurrrr.äszYXMLRPCHandlerTests.test_continue_request_value_is_function.<locals>.DummyRPCNamespace.fooN©rrrr.rrrrÚDummyRPCNamespaceãsryrÚns1rúns1.foorBrCrDz XML-RPC method called: ns1.foo()rEz.XML-RPC method ns1.foo() returned successfullyrF)Úobjectrrr"rr/rrFrGrHr1rrIrJrY)rryrr6r9r1rMrNrrrÚ'test_continue_request_value_is_functionâs&ÿ

ÿ
ÿz:XMLRPCHandlerTests.test_continue_request_value_is_functionc	Cs2d}tƒ}dtƒfg}| ||¡}| |¡}|\}}ddl}| |d¡| |dd¡| |dd¡| |dd	¡| |d
d¡| |dd	¡| |d
d¡| |dd¡| |d| dddddd¡¡| |dd¡| |dd
ddœ¡| |dddddg¡| |dd digi¡dS)!NaŽ<?xml version="1.0"?>
        <methodCall>
        <methodName>examples.getStateName</methodName>
        <params>
        <param>
        <value><i4>41</i4></value>
        </param>
        <param>
        <value><string>foo</string></value>
        </param>
        <param>
        <value><string></string></value>
        </param>
        <param>
        <!-- xml-rpc spec allows strings without <string> tag -->
        <value>bar</value>
        </param>
        <param>
        <value></value>
        </param>
        <param>
        <value><boolean>1</boolean></value>
        </param>
        <param>
        <value><double>-12.214</double></value>
        </param>
        <param>
        <value>
        <dateTime.iso8601>19980717T14:08:55</dateTime.iso8601>
        </value>
        </param>
        <param>
        <value><base64>eW91IGNhbid0IHJlYWQgdGhpcyE=</base64></value>
        </param>
        <param>
        <struct>
        <member><name>j</name><value><i4>5</i4></value></member>
        <member><name>k</name><value>abc</value></member>
        </struct>
        </param>
        <param>
        <array>
          <data>
            <value><i4>12</i4></value>
            <value><string>abc</string></value>
            <value>def</value>
            <value><i4>34</i4></value>
          </data>
        </array>
        </param>
        <param>
        <struct>
          <member>
            <name>k</name>
            <value><array><data>
              <value><i4>1</i4></value>
              <struct></struct>
            </data></array></value>
          </member>
        </struct>
        </param>
        </params>
        </methodCall>
        rrzexamples.getStateNameé)r-r.rCÚrqZbarééTég!°rh‘m(ÀéiÎéééé7zyou can't read this!é	Úabc)ÚjÚké
éÚdefé"ér‹)rrr"rLÚdatetimer)	rÚsrr6r9ÚresultÚparamsÚmethodr‘rrrÚtest_iterparse_loads_methodcallùs(@
 z2XMLRPCHandlerTests.test_iterparse_loads_methodcallN)rrrrr"r:r?rPr]r^rhrjrkrprrr}r–rrrrr37s
r3c@sDeZdZdd„Zdd„Zdd„Zdd„Zd	d
„Zdd„Zd
d„Z	dS)Ú
TraverseTestscCsPddlm}Gdd„dƒ}Gdd„dƒ}|ƒ}|ƒ|_| |j|j|dg¡dS)Nrr	c@seZdZdS)zFTraverseTests.test_security_disallows_underscore_methods.<locals>.RootN©rrrrrrrÚRootQsr™c@seZdZdd„ZdS)zCTraverseTests.test_security_disallows_underscore_methods.<locals>.AcSsdS©NTrrtrrrÚ_dangerTszKTraverseTests.test_security_disallows_underscore_methods.<locals>.A._dangerN)rrrr›rrrrÚASsrœz	a._danger©rr
r@rKrÚtraverse©rr
r™rœÚrootrrrÚ*test_security_disallows_underscore_methodsOsÿz8TraverseTests.test_security_disallows_underscore_methodscCshddlm}Gdd„dƒ}Gdd„dƒ}Gdd„dƒ}|ƒ}|ƒ|_|ƒ|j_| |j|j|d	g¡dS)
Nrr	c@seZdZdS)zDTraverseTests.test_security_disallows_object_traversal.<locals>.RootNr˜rrrrr™]sr™c@seZdZdS)zATraverseTests.test_security_disallows_object_traversal.<locals>.ANr˜rrrrrœ_srœc@seZdZdd„ZdS)zATraverseTests.test_security_disallows_object_traversal.<locals>.BcSsdSršrrtrrrÚdangerbszHTraverseTests.test_security_disallows_object_traversal.<locals>.B.dangerN)rrrr¢rrrrÚBasr£z
a.b.danger©rr
r@rArKrrž©rr
r™rœr£r rrrÚ(test_security_disallows_object_traversal[s
ÿz6TraverseTests.test_security_disallows_object_traversalcCs:ddlm}Gdd„dƒ}|ƒ}| |j|j|dd¡dS)Nrr	c@seZdZdS)z9TraverseTests.test_namespace_name_not_found.<locals>.RootNr˜rrrrr™lsr™znotfound.hello)rr
rKrrž)rr
r™r rrrÚtest_namespace_name_not_foundjsÿz+TraverseTests.test_namespace_name_not_foundcCsPddlm}Gdd„dƒ}Gdd„dƒ}|ƒ}|ƒ|_| |j|j|dg¡dS)Nrr	c@seZdZdS)z6TraverseTests.test_method_name_not_found.<locals>.RootNr˜rrrrr™tsr™c@seZdZdS)z3TraverseTests.test_method_name_not_found.<locals>.ANr˜rrrrrœvsrœz
a.notfoundrrŸrrrÚtest_method_name_not_foundrsÿz(TraverseTests.test_method_name_not_foundcCshddlm}Gdd„dƒ}Gdd„dƒ}Gdd„dƒ}|ƒ}|ƒ|_|ƒ|j_| |j|j|d	g¡dS)
Nrr	c@seZdZdS)zGTraverseTests.test_method_name_exists_but_is_not_a_method.<locals>.RootNr˜rrrrr™sr™c@seZdZdS)zDTraverseTests.test_method_name_exists_but_is_not_a_method.<locals>.ANr˜rrrrrœsrœc@seZdZdS)zDTraverseTests.test_method_name_exists_but_is_not_a_method.<locals>.BNr˜rrrrr£ƒsr£za.br¤r¥rrrÚ+test_method_name_exists_but_is_not_a_method}s
ÿz9TraverseTests.test_method_name_exists_but_is_not_a_methodcCsTddlm}Gdd„dƒ}Gdd„dƒ}|ƒ}|ƒ|_| |j|j|ddd	g¡dS)
Nrr	c@seZdZdS)z+TraverseTests.test_bad_params.<locals>.RootNr˜rrrrr™sr™c@seZdZdd„ZdS)z(TraverseTests.test_bad_params.<locals>.AcSsd|S©NzHello %sr©rÚnamerrrÚhellosz.TraverseTests.test_bad_params.<locals>.A.helloN©rrrr­rrrrrœsrœúa.helloÚtherer!rrŸrrrÚtest_bad_params‹sÿzTraverseTests.test_bad_paramscCsVddlm}Gdd„dƒ}Gdd„dƒ}|ƒ}|ƒ|_| |ddg¡}| |d	¡dS)
Nrr	c@seZdZdS)z(TraverseTests.test_success.<locals>.RootNr˜rrrrr™™sr™c@seZdZdd„ZdS)z%TraverseTests.test_success.<locals>.AcSsd|Srªrr«rrrr­œsz+TraverseTests.test_success.<locals>.A.helloNr®rrrrrœ›srœr¯r°zHello there)rr
r@ržr)rr
r™rœr r“rrrÚtest_success—szTraverseTests.test_successN)
rrrr¡r¦r§r¨r©r±r²rrrrr—Nsr—c@s\eZdZdd„Zdd„Zdd„Zdd„Zd	d
„Zdd„Zd
d„Z	dd„Z
dd„Zdd„ZdS)ÚSupervisorTransportTestscCsddlm}|S)Nr)ÚSupervisorTransport)rr´)rr´rrrr¤sz(SupervisorTransportTests._getTargetClasscOs| ¡||ŽSrr©rÚargÚkwrrrr"¨sz!SupervisorTransportTests._makeOnecCsTddlm}| ddd¡}| ¡}| t||jƒ¡| |jd¡| |j	d¡dS)Nrr	ÚuserÚpasszunix:///foo/barÚ	localhostz/foo/bar)
rr
r"Ú_get_connectionrbÚ
isinstanceZUnixStreamHTTPConnectionrÚhostZ
socketfile)rr
Ú	transportÚconnrrrÚtest_ctor_unix«sz'SupervisorTransportTests.test_ctor_unixcCs| t|jddd¡dS)Nr¸r¹zunknown:///foo/bar)rKÚ
ValueErrorr"rtrrrÚtest_ctor_unknown³sÿz*SupervisorTransportTests.test_ctor_unknowncCsH| ddd¡}| ¡}| t|tjƒ¡| |jd¡| |jd¡dS)Nr¸r¹zhttp://127.0.0.1:9001/ú	127.0.0.1i)#©	r"r»rbr¼rZHTTPConnectionrr½Zport©rr¾r¿rrrÚtest__get_connection_http_9001¸s
z7SupervisorTransportTests.test__get_connection_http_9001cCsH| ddd¡}| ¡}| t|tjƒ¡| |jd¡| |jd¡dS)Nr¸r¹úhttp://127.0.0.1/rÃéPrÄrÅrrrÚtest__get_connection_http_80¿s
z5SupervisorTransportTests.test__get_connection_http_80cs`| ddd¡}tddƒ‰‡fdd„}||_| tj|jdd	d¡| |jd¡| ˆj	d
¡dS)Nr¸r¹rÇr`rcsˆSrrr©Z
dummy_connrrÚgetconnÉszGSupervisorTransportTests.test_request_non_200_response.<locals>.getconnrºú/T)
r"ÚDummyConnectionr»rKrÚ
ProtocolErrorrMrÚ
connectionÚclosed©rr¾rËrrÊrÚtest_request_non_200_responseÆs
ÿz6SupervisorTransportTests.test_request_non_200_responsecsî| ddd¡}tddƒ‰‡fdd„}||_| tj|jdd	d¡| |jd¡| ˆj	d
¡| ˆj
dd¡| ˆj
d
d	¡| ˆj
dd¡| ˆj
ddd¡| ˆj
ddd¡| ˆj
ddd¡| ˆj
ddd¡dS)Nr¸r¹rÇr`rcsˆSrrrrÊrrrËÔszCSupervisorTransportTests.test_request_400_response.<locals>.getconnrºrÌTrÚPOSTr-rCórqrWÚ0rUrVÚ
AuthorizationúBasic dXNlcjpwYXNzÚAccept)r"rÍr»rKrrÎrMrrÏrÐÚrequestargsrÑrrÊrÚtest_request_400_responseÑs*
ÿÿz2SupervisorTransportTests.test_request_400_responsecsö| ddd¡}d}td|ƒ‰‡fdd„}||_| dd	d
¡}| |jˆ¡| ˆjd¡| ˆjdd
¡| ˆjdd	¡| ˆjdd¡| ˆjddd¡| ˆjddd¡| ˆjddd¡| ˆjddd¡| |d¡dS)Nr¸r¹rÇzÁ<?xml version="1.0"?>
        <methodResponse>
        <params>
        <param>
        <value><string>South Dakota</string></value>
        </param>
        </params>
        </methodResponse>éÈcsˆSrrrrÊrrrËïszCSupervisorTransportTests.test_request_200_response.<locals>.getconnrºrÌrFrrÓr-rCrÔrqrWrÕrUrVrÖr×rØ)zSouth Dakota)r"rÍr»rMrrÏrÐrÙ)rr¾r\rËr“rrÊrÚtest_request_200_responseäs$
ÿz2SupervisorTransportTests.test_request_200_responsecsP| ddd¡}tddƒ‰‡fdd„}||_| dd	d
¡| ¡| ˆj¡dS)Nr¸r¹rÇrÛzH<?xml version="1.0"?>
        <methodResponse><params/></methodResponse>csˆSrrrrÊrrrËsz4SupervisorTransportTests.test_close.<locals>.getconnrºrÌr)r"rÍr»rMÚcloserbrÐrÑrrÊrÚ
test_closeÿs
z#SupervisorTransportTests.test_closeN)
rrrrr"rÀrÂrÆrÉrÒrÚrÜrÞrrrrr³£sr³c@sveZdZdd„Zddd„Zdd„Zdd	„Zd
d„Zdd
„Zdd„Z	dd„Z
dd„Zdd„Zdd„Z
dd„Zdd„ZdS)ÚTestDeferredXMLRPCResponsecCsddlm}|S)Nr)ÚDeferredXMLRPCResponse)rrà)rràrrrrsz*TestDeferredXMLRPCResponse._getTargetClassNcCs:|dkrtdddddƒ}|dkr,tƒ}d|_| ¡||ƒSrs)rÚDummyrvr)rrMÚcallbackrrrr"sz#TestDeferredXMLRPCResponse._makeOnecCsVtƒ}d|_|jd|d}| |j|¡| |jd¡| |jd¡| |jd¡dS)Nr-rM)rMrâgð?F)rárvr"rrârMÚfinished©rrâÚinstrrrr:sz$TestDeferredXMLRPCResponse.test_ctorcCs&| ¡}d|_| ¡}| |d¡dS)NTr)r"rãÚmorer©rrår“rrrÚtest_more_finished sz-TestDeferredXMLRPCResponse.test_more_finishedcs>ddlm‰‡fdd„}d|_|j|d}| | ¡ˆ¡dS)Nr©ÚNOT_DONE_YETcsˆSrrrrérrrâ(szTTestDeferredXMLRPCResponse.test_more_callback_returns_not_done_yet.<locals>.callbackr-©râ)Úsupervisor.httprêrvr"rrærärrérÚ'test_more_callback_returns_not_done_yet&s
zBTestDeferredXMLRPCResponse.test_more_callback_returns_not_done_yetcszddlm‰m‰‡‡fdd„}d|_|j|d}| | ¡d¡| t|jj	ƒd¡| 
d|jj	dk¡| 
|j¡dS)Nr©rrcsˆˆjƒ‚dSr)ÚUNKNOWN_METHODr©rrrrrâ0szOTestDeferredXMLRPCResponse.test_more_callback_raises_RPCError.<locals>.callbackr-rërï)rrrrvr"rrærIrMrJrbrãrärrðrÚ"test_more_callback_raises_RPCError.sz=TestDeferredXMLRPCResponse.test_more_callback_raises_RPCErrorcCsddd„}d|_|j|d}| | ¡d¡| t|jjƒd¡| d|jjdk¡| |j¡dS)NcSsdS)Nr‰rrrrrrâ:szMTestDeferredXMLRPCResponse.test_more_callback_returns_value.<locals>.callbackr-rër‰r)	rvr"rrærIrMrJrbrãrärrrÚ test_more_callback_returns_value9sz;TestDeferredXMLRPCResponse.test_more_callback_returns_valuecCsŽdd„}d|_|j|d}| | ¡d¡| |jjd¡| |j¡|jjj	j
j}| t|ƒd¡|d\}}| |d¡| d|k¡dS)	NcSstdƒ‚dS©Nr.)rÁrrrrrâDsz[TestDeferredXMLRPCResponse.test_more_callback_raises_unexpected_exception.<locals>.callbackr-rërnrzXML-RPC response callback errorrm)
rvr"rrærMrfrbrãZchannelZserverrHÚloggedrI)rrârårôÚsrcÚmsgrrrÚ.test_more_callback_raises_unexpected_exceptionCszITestDeferredXMLRPCResponse.test_more_callback_raises_unexpected_exceptioncCsT| ¡}d|j_|jj d¡| d¡| t|jjƒd¡| |jj	dd¡dS)Nú1.0zConnection: keep-aliver‰r-Ú
Connectionz
Keep-Alive)
r"rMÚversionÚheaderÚappendÚgetresponserrIrJrZ©rrårrrÚ'test_getresponse_http_10_with_keepaliveQs
zBTestDeferredXMLRPCResponse.test_getresponse_http_10_with_keepalivecCsF| ¡}d|j_| d¡| t|jjƒd¡| |jjdd¡dS)Nrør‰r-rùrÝ©r"rMrúrýrrIrJrZrþrrrÚ%test_getresponse_http_10_no_keepaliveYs

z@TestDeferredXMLRPCResponse.test_getresponse_http_10_no_keepalivecCsD| ¡}d|j_| d¡| t|jjƒd¡| d|jjk¡dS)Nú1.1r‰r-rù)	r"rMrúrýrrIrJrbrZrþrrrÚ&test_getresponse_http_11_without_close`s

zATestDeferredXMLRPCResponse.test_getresponse_http_11_without_closecCsT| ¡}|jj d¡d|j_| d¡| t|jjƒd¡| |jj	dd¡dS)NzConnection: closerr‰r-rùrÝ)
r"rMrûrürúrýrrIrJrZrþrrrÚ#test_getresponse_http_11_with_closegs
z>TestDeferredXMLRPCResponse.test_getresponse_http_11_with_closecCsF| ¡}d|j_| d¡| t|jjƒd¡| |jjdd¡dS)Nr‰r-rùrÝrrþrrrÚtest_getresponse_http_unknownos

z8TestDeferredXMLRPCResponse.test_getresponse_http_unknown)NN)rrrrr"r:rèrírñròr÷rÿrrrrrrrrrß
s
	
rßc@s–eZdZd%dd„Zdd„Zdd„Zdd	„Zd
d„Zdd
„Zdd„Z	dd„Z
dd„Zdd„Zdd„Z
dd„Zdd„Zdd„Zdd„Zd d!„Zd"d#„Zd$S)&ÚTestSystemNamespaceRPCInterfacercCsddlm}||ƒS)Nr)ÚSystemNamespaceRPCInterface)rr)rZ
namespacesrrrrr"wsz(TestSystemNamespaceRPCInterface._makeOnecCs(| ¡}| ¡}| |ddddg¡dS)Núsystem.listMethodsúsystem.methodHelpúsystem.methodSignatureúsystem.multicall)r"ÚlistMethodsrrçrrrÚtest_listMethods_gardenpath{sýþz;TestSystemNamespaceRPCInterface.test_listMethods_gardenpathcCsHGdd„dtƒ}|ƒ}| d|fg¡}| ¡}| |dddddg¡dS)	Nc@seZdZdd„Zdd„ZdS)z_TestSystemNamespaceRPCInterface.test_listMethods_omits_underscore_attrs.<locals>.DummyNamespacecSsdSrrrtrrrr.‰rÔzcTestSystemNamespaceRPCInterface.test_listMethods_omits_underscore_attrs.<locals>.DummyNamespace.foocSsdSrrrtrrrÚ_barŠrÔzdTestSystemNamespaceRPCInterface.test_listMethods_omits_underscore_attrs.<locals>.DummyNamespace._barN)rrrr.rrrrrÚDummyNamespaceˆsrrzr{rr	r
r)r|r"rr)rrrzrår“rrrÚ'test_listMethods_omits_underscore_attrs‡süþzGTestSystemNamespaceRPCInterface.test_listMethods_omits_underscore_attrscCs$| ¡}| d¡}| d|k¡dS)NrÚarray)r"Ú
methodHelprbrçrrrÚtest_methodHelp_known_method˜s
z<TestSystemNamespaceRPCInterface.test_methodHelp_known_methodcCs(ddlm}| ¡}| ||jd¡dS©Nrrz
wont.be.found)rrr"rKr©rrrårrrÚtest_methodHelp_unknown_methodsz>TestSystemNamespaceRPCInterface.test_methodHelp_unknown_methodcCs&| ¡}| d¡}| |ddg¡dS)Nr
rÚstring)r"ÚmethodSignaturerrçrrrÚ!test_methodSignature_known_method¢s
zATestSystemNamespaceRPCInterface.test_methodSignature_known_methodcCs(ddlm}| ¡}| ||jd¡dSr)rrr"rKrrrrrÚ#test_methodSignature_unknown_method§szCTestSystemNamespaceRPCInterface.test_methodSignature_unknown_methodcCsFddlm}Gdd„dtƒ}|ƒ}| d|fg¡}| ||jd¡dS)Nrrc@seZdZdd„ZdS)zYTestSystemNamespaceRPCInterface.test_methodSignature_with_bad_sig.<locals>.DummyNamespacecSsdS)z @param string name The thingNrrtrrrr.¯sz]TestSystemNamespaceRPCInterface.test_methodSignature_with_bad_sig.<locals>.DummyNamespace.fooNrxrrrrr®srrzr{)rrr|r"rKr)rrrrzrårrrÚ!test_methodSignature_with_bad_sig¬s
zATestSystemNamespaceRPCInterface.test_methodSignature_with_bad_sigcCsBddlm}| ¡}ddig}| |¡}| ||jddœg¡dS)Nr©rÚ
methodNamerz:INCORRECT_PARAMETERS: Recursive system.multicall forbidden©Z	faultCodeZfaultString©rrr"Ú	multicallrZINCORRECT_PARAMETERS©rrråÚcallsÚresultsrrrÚ#test_multicall_faults_for_recursionµs

ÿþzCTestSystemNamespaceRPCInterface.test_multicall_faults_for_recursioncCs>ddlm}| ¡}ig}| |¡}| ||jddœg¡dS)Nrrz#INCORRECT_PARAMETERS: No methodNamerrr!rrrÚ,test_multicall_faults_for_missing_methodNameÁs
ÿþzLTestSystemNamespaceRPCInterface.test_multicall_faults_for_missing_methodNamecCsBddlm}| ¡}ddig}| |¡}| ||jddœg¡dS)Nrrrzbad.stopProcessrïr)rrr"r rrïr!rrrÚ2test_multicall_faults_for_methodName_bad_namespaceÌs

ÿþzRTestSystemNamespaceRPCInterface.test_multicall_faults_for_methodName_bad_namespacecCs`ddlm}Gdd„dtƒ}|ƒ}| d|fg¡}ddig}| |¡}| ||jdd	œg¡dS)
Nrrc@seZdZdS)zoTestSystemNamespaceRPCInterface.test_multicall_faults_for_methodName_good_ns_bad_method.<locals>.DummyNamespaceNr˜rrrrrÙsrrzrzns1.badrïr)rrr|r"r rrï)rrrrzrår"r#rrrÚ7test_multicall_faults_for_methodName_good_ns_bad_method×s

ÿþzWTestSystemNamespaceRPCInterface.test_multicall_faults_for_methodName_good_ns_bad_methodcCs&| ¡}g}| |¡}| |g¡dSr)r"r r)rrår"r#rrrÚ4test_multicall_returns_empty_results_for_empty_callsås
zTTestSystemNamespaceRPCInterface.test_multicall_returns_empty_results_for_empty_callscCshGdd„dtƒ}|ƒ}| d|fg¡}ddgdœddgdœddgdœg}| |¡}| |dddg¡dS)	Nc@seZdZdd„ZdS)znTestSystemNamespaceRPCInterface.test_multicall_performs_noncallback_functions_serially.<locals>.DummyNamespacecSs|S)z  @param string name Process namerr«rrrÚsayíszrTestSystemNamespaceRPCInterface.test_multicall_performs_noncallback_functions_serially.<locals>.DummyNamespace.sayN)rrrr)rrrrrìsrrzzns1.sayZAlvin©rr”ZSimonZTheodore)r|r"r r)rrrzrår"r#rrrÚ6test_multicall_performs_noncallback_functions_seriallyës


ý
zVTestSystemNamespaceRPCInterface.test_multicall_performs_noncallback_functions_seriallycsddl‰ddlm‰m‰G‡‡‡fdd„dtƒ}|ƒ}| d|fg¡}ddiddig}| |¡}ˆjd	d
œ}ˆjdt	d
œ}| 
|||g¡dS)Nrrîcs&eZdZ‡‡fdd„Z‡fdd„ZdS)zeTestSystemNamespaceRPCInterface.test_multicall_catches_noncallback_exceptions.<locals>.DummyNamespacecsˆˆjdƒ‚dSró©ÚBAD_NAMErtrðrrÚbad_nameþsznTestSystemNamespaceRPCInterface.test_multicall_catches_noncallback_exceptions.<locals>.DummyNamespace.bad_namecstˆjƒ‚dSr©ÚOSErrorZENOENTrt©ÚerrnorrÚos_errorsznTestSystemNamespaceRPCInterface.test_multicall_catches_noncallback_exceptions.<locals>.DummyNamespace.os_errorN©rrrr.r3r©rrr2rrrýsrrzrúns1.bad_nameúns1.os_errorú
BAD_NAME: foorúFAILED: %s:2)r2rrrr|r"r r-r#r0r)rrrzrår"r#r.r3rr5rÚ-test_multicall_catches_noncallback_exceptionsús
ÿÿzMTestSystemNamespaceRPCInterface.test_multicall_catches_noncallback_exceptionsc
s°ddl‰ddlm‰m‰ddlm}G‡‡‡fdd„dtƒ}|ƒ}| d|fg¡}ddidd	ig}| |¡}|}||kr€|ƒ}qpˆj	d
dœ}ˆj
dtdœ}	| |||	g¡dS)
Nrrîrécs&eZdZ‡‡fdd„Z‡fdd„ZdS)zbTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespacecs‡‡fdd„}|S)Ncsˆˆjdƒ‚dSrór,rrðrrruszzTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespace.bad_name.<locals>.innerrrwrðrrr.szkTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespace.bad_namecs‡fdd„}|S)Ncstˆjƒ‚dSrr/rr1rrruszzTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespace.os_error.<locals>.innerrrwr1rrr3szkTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespace.os_errorNr4rr5rrrsrrzrr6r7r8rr9)
r2rrrrìrêr|r"r r-r#r0r)
rrêrrzrår"râr#r.r3rr5rÚ*test_multicall_catches_callback_exceptions
s$	
ÿÿzJTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptionscs„ddlm‰G‡fdd„dtƒ}|ƒ}| d|fg¡}dddid	œd
ddid	œg}| |¡}ˆ}|ˆkrp|ƒ}q`| |ddg¡dS)
Nrrécs,eZdZ‡fdd„Z‡fdd„Zdd„ZdS)zkTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespacecsˆˆˆdg|_dg|_dS)Nústop resultústart result)Ústop_resultsÚ
start_resultsrtrérrr<+s
ÿztTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.__init__cs‡‡fdd„}|S)Ncsˆj d¡}|ˆk	rdˆ_|S)NrT)r>ÚpopÚstopped)r“)rêrrrru0sz†TestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.stopProcess.<locals>.innerr©rr¬rurértrÚstopProcess/szwTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.stopProcesscs‡fdd„}|S)Ncsˆjstdƒ‚ˆj d¡S)NzThis should not raiser)rAÚ	Exceptionr?r@rrtrrru7sz‡TestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.startProcess.<locals>.innerrrBrrtrÚstartProcess6szxTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.startProcessN)rrrr<rCrErrérrr*srrzzns1.stopProcessr¬r.r*zns1.startProcessr<r=)rìrêr|r"r r)rrrzrår"râr#rrérÚ3test_multicall_performs_callback_functions_serially(s ÿÿþ
zSTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_seriallyN)r)rrrr"r
rrrrrrr$r%r&r'r(r+r:r;rFrrrrrvs"
	rc@s4eZdZdd„Zdd„Zdd„Zdd„Zd	d
„ZdS)ÚTest_gettagscCsddlm}||ƒS)Nr)Úgettags)rrH)rZcommentrHrrrÚ_callFUTIszTest_gettags._callFUTcCs"d}| |¡}| |ddg¡dS)Nz@foo©rNNNr)rr.rrr©rIr©rÚlinesr“rrrÚtest_one_atpartMs
þzTest_gettags.test_one_atpartcCs"d}| |¡}| |ddg¡dS)Nz
@foo arrayrJ)rr.rrrrKrLrrrÚtest_two_atpartsUs
þzTest_gettags.test_two_atpartscCs"d}| |¡}| |ddg¡dS)Nz@foo array namerJ)rr.rr¬rrKrLrrrÚtest_three_atparts]s
þzTest_gettags.test_three_atpartscCs"d}| |¡}| |ddg¡dS)Nz@foo array name textrJ)rr.rr¬r%rKrLrrrÚtest_four_atpartses
þzTest_gettags.test_four_atpartsN)rrrrIrNrOrPrQrrrrrGHs
rGc@s,eZdZdd„Zdd„Zdd„Zdd„Zd	S)
ÚTest_capped_intcCsddlm}||ƒS)Nr)Ú
capped_int)rrS)rÚvaluerSrrrrInszTest_capped_int._callFUTcCs| | d¡d¡dS)NZ42é*)rrIrtrrrÚtest_converts_value_to_integerrsz.Test_capped_int.test_converts_value_to_integercCs*ddlm}| | |jd¡|j¡dS©Nrrr-)Úsupervisor.compatrrrIZMININT©rrrrrÚtest_caps_value_below_minintusz,Test_capped_int.test_caps_value_below_minintcCs*ddlm}| | |jd¡|j¡dSrW)rXrrrIZMAXINTrYrrrÚtest_caps_value_above_maxintysz,Test_capped_int.test_caps_value_above_maxintN)rrrrIrVrZr[rrrrrRmsrRc@seZdZd	dd„Zdd„ZdS)
Ú
DummyResponserÛrÚreasoncCs||_||_||_dSr)ÚstatusÚbodyr]©rr^r_r]rrrr<szDummyResponse.__init__cCs|jSr)r_rtrrrÚread„szDummyResponse.readN)rÛrr])rrrr<rarrrrr\~s
r\c@seZdZdS)ráNr˜rrrrrá‡srác@s2eZdZdZddd„Zdd„Zd	d
„Zdd„Zd
S)rÍFrÛrr]cCst|||ƒ|_dSr)r\r\r`rrrr<ŒszDummyConnection.__init__cCs|jSr)r\rtrrrrýszDummyConnection.getresponsecOs||_||_dSr)rÙZ	requestkwrµrrrrM’szDummyConnection.requestcCs
d|_dSrš)rÐrtrrrrݖszDummyConnection.closeN)rÛrr])rrrrÐr<rýrMrÝrrrrr͊s

rÍ)ZunittestZsupervisor.tests.baserrrrXrrZTestCaserrr,r3r—r³rßrrGrRr\r|rárÍrrrrÚ<module>s*	UglS%	

Products

About

Resources

Contact Gemfury