a a,@sLddlmZddlZddlmZmZddlmZdZdZ GdddeZ dS) )print_functionN)BlackboxTestCaseBlackboxProcessError) Messagingzbin/smbcontrolZpingcs<eZdZfddZddZddZddZd d ZZS) SmbcontrolProcessBlockboxTestscs&tt||}t|d|_dS)N)lp_ctx)superrsetUpZ get_loadparmrmsg_ctx)selfr __class__I/usr/lib/python3/dist-packages/samba/tests/blackbox/smbcontrol_process.pyr !sz$SmbcontrolProcessBlockboxTests.setUpcCs:|j}g}|D]"}|jD]}||j|jfqq|SN)r Zirpc_all_serversZidsappendnamepid)r Zservices processesZserviceidrrrget_process_data&s   z/SmbcontrolProcessBlockboxTests.get_process_datacCs*|}|D]\}}||kr |Sq dSr)r)r rrZpnamerrrr get_process/s   z*SmbcontrolProcessBlockboxTests.get_processc Csd}d}|d}z|jdt|tfddWn.ty\}z|dWYd}~n d}~00z|jdt|||fd dWn6ty}zt||d WYd}~n d}~00z&|jdt|tfdd|d Wn$ty}z WYd}~n d}~00dS) NZinjectZsegvZ rpc_server%s %s %strying to ping rpc_servermsg!Unable to ping rpc_server process %s %s %s %szinjecting fault into rpc_serverz4Unable to inject a fault into the rpc_server processzCould ping rpc_server process)r check_runCOMMANDPINGrfailprint)r ZINJECTZFAULTrerrrtest_inject_fault6s.     z0SmbcontrolProcessBlockboxTests.test_inject_faultc Cs:d}d}d}|d}z|jdt|tfddWn.ty`}z|dWYd}~n d}~00t}z"|jd t|||fd |dWn:ty}z"t||d |WYd}~n d}~00z<|jdt|tfddt}||}||||Wn0ty4}z|dWYd}~n d}~00dS) NsleepZ ldap_serverrrrrrz"putting rpc_server to sleep for %dz(Failed to get rpc_server to sleep for %d) rrrr rr!timer"Z assertGreater) r ZSLEEPZDURATIONZDELTArr#startendZdurationrrr test_sleep\s6    $z)SmbcontrolProcessBlockboxTests.test_sleep) __name__ __module__ __qualname__r rrr$r+ __classcell__rrr rrs   &r) Z __future__rr(Z samba.testsrrZsamba.messagingrrr rrrrrs