<s> import time <EOL> import threading <EOL> from tests import success , failure <EOL> def run ( ssh ) : <EOL> p_ret = None <EOL> def waiter ( ) : <EOL> ret , out , err = ssh ( '<STR_LIT>' ) <EOL> p_ret = ret <EOL> t = threading . Thread ( target = waiter ) <EOL> t . start ( ) <EOL> time . sleep ( <NUM_LIT:3> ) <EOL> ret , out , err = ssh ( '<STR_LIT>' ) <EOL> if ret != <NUM_LIT:0> : <EOL> return failure ( '<STR_LIT>' ) <EOL> t . join ( ) <EOL> if p_ret != <NUM_LIT:0> : <EOL> return failure ( '<STR_LIT>' ) <EOL> return success ( ) </s>
