Module Import alias Import alias Import alias Import alias Import alias Import alias Import alias Import alias Import alias Import alias Import alias identifier Import alias identifier Import alias identifier ImportFrom alias FunctionDef arguments args NameParam NameParam defaults Str NameLoad body Assert CompareIn Str AttributeLoad NameLoad attr Assert CompareIn Str AttributeLoad NameLoad attr Assert CompareIn Str AttributeLoad NameLoad attr Assert CompareIn Str AttributeLoad NameLoad attr Assign NameStore Call NameLoad Call AttributeLoad Call AttributeLoad NameLoad attr Str attr Str Assign NameStore Call AttributeLoad NameLoad attr Str Assert CompareIn NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str Assign NameStore IfExp CompareEq NameLoad SubscriptLoad NameLoad Index Num NameLoad NameLoad Return Call NameLoad NameLoad NameLoad NameLoad NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body TryExcept body Assign NameStore Num Assign NameStore ListLoad Assign NameStore ListLoad FunctionDef arguments args NameParam defaults body Return BoolOpOr CompareIn Str NameLoad CompareIn Str NameLoad decorator_list For NameStore Call NameLoad NameLoad Str body AugAssignAdd NameStore Num If BoolOpOr CompareIn SubscriptLoad NameLoad Index Num TupleLoad Str Str UnaryOpNot NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr orelse If Call NameLoad Call AttributeLoad Str attr NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr NameLoad Assign NameStore ListLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr If Call NameLoad Call AttributeLoad Str attr NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr NameLoad If NameLoad body Assign NameStore SubscriptLoad Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Index Num Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad BinOpAdd NameLoad Str With Call NameLoad NameLoad Str NameStore body For NameStore NameLoad body Print NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Call NameLoad NameLoad NameLoad orelse Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad handlers ExceptHandler body Expr Call AttributeLoad NameLoad attr Str NameLoad Call AttributeLoad NameLoad attr decorator_list ClassDef bases NameLoad body Assign NameStore Str Assign NameStore Num FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assert CompareIn AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assert Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr BinOpMod Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Return SubscriptLoad AttributeLoad NameLoad attr Index Num decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Raise Call NameLoad Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Raise Call NameLoad Str decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Dict Str Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr TryFinally body TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr Str Str Expr Call AttributeLoad NameLoad attr NameLoad Return Call AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str NameLoad Call AttributeLoad NameLoad attr Return NameLoad finalbody Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Str Expr Call AttributeLoad NameLoad attr Str NameLoad If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad body Expr Call AttributeLoad NameLoad attr Str Return For NameStore Call AttributeLoad NameLoad attr NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad If Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad body Expr Call NameLoad NameLoad NameLoad TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Str Expr Call AttributeLoad NameLoad attr ListLoad BinOpMod Str TupleLoad NameLoad NameLoad keyword NameLoad handlers ExceptHandler body Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad body Return For NameStore Call NameLoad Num body TryExcept body Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad handlers ExceptHandler body If CompareEq NameLoad Num body Expr Call AttributeLoad NameLoad attr Str NameLoad Call AttributeLoad NameLoad attr Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad keyword NameLoad If CompareNotEq NameLoad Num body Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad NameLoad Raise Call NameLoad BinOpMod Str TupleLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Assign NameStore ListLoad Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Assign TupleStore NameStore NameStore NameStore Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Return NameLoad decorator_list NameLoad decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore NameLoad Assign NameStore Call AttributeLoad NameLoad attr While UnaryOpNot NameLoad body Assign NameStore Call AttributeLoad NameLoad attr If UnaryOpNot NameLoad body If CompareGt BinOpSub Call AttributeLoad NameLoad attr NameLoad Num body Raise Call NameLoad Str Expr Call AttributeLoad NameLoad attr Num TryFinally body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad finalbody Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr While NameLoad body Assign NameStore NameLoad Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num TryExcept body Expr Call AttributeLoad NameLoad attr TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad If CompareNotEq NameLoad Str body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Return NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr ExceptHandler type AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad If CompareNotEq NameLoad Str body Expr Call AttributeLoad NameLoad attr Str NameLoad orelse Expr Call AttributeLoad NameLoad attr Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Str keyword Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Str decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr If CompareEq Call NameLoad AttributeLoad NameLoad attr Num body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr ListLoad decorator_list FunctionDef arguments args NameParam defaults body Return Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body TryFinally body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr finalbody Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body While UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr body TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type AttributeLoad NameLoad attr name NameStore body If CompareEq AttributeLoad NameLoad attr Num body Expr Call AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Str Str keyword Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Str Str Expr Call AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults Call AttributeLoad NameLoad attr NameLoad Str decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults Call AttributeLoad NameLoad attr NameLoad Str decorator_list FunctionDef arguments args NameParam NameParam defaults body For TupleStore NameStore NameStore AttributeLoad NameLoad attr body TryExcept body Expr Call NameLoad NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign TupleStore NameStore NameStore NameLoad TryExcept body If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Str orelse If UnaryOpNot CompareIn NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Str orelse If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Str orelse Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Return CompareEq NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Return CompareEq NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body If NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body With AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad If CompareEq Call NameLoad AttributeLoad NameLoad attr BinOpSub Call NameLoad AttributeLoad NameLoad attr Num body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list
N/A N/A logging N/A os N/A os.path N/A socket N/A time N/A threading N/A traceback N/A shutil N/A subprocess N/A ufora N/A ufora.core.SubprocessRunner SubprocessRunner N/A ufora.distributed.ServerUtils.SimpleServer SimpleServer N/A ufora.distributed.util.common common ufora.test.TestScriptRunner TestScriptRunner createTestRunner N/A N/A testDir timeout N/A test_scripts/clusterperf None N/A N/A N/A TEST_LOOPER_MULTIBOX_OWN_IP N/A os environ N/A N/A TEST_LOOPER_MULTIBOX_IP_LIST N/A os environ N/A N/A TEST_LOOPER_TEST_ID N/A os environ N/A N/A TEST_OUTPUT_DIR N/A os environ N/A machinesInCluster N/A sorted N/A N/A N/A N/A os getenv TEST_LOOPER_MULTIBOX_IP_LIST split , N/A ownAddress N/A N/A os getenv TEST_LOOPER_MULTIBOX_OWN_IP N/A N/A ownAddress machinesInCluster N/A testId N/A N/A os getenv TEST_LOOPER_TEST_ID N/A testRunnerClass N/A N/A ownAddress N/A machinesInCluster N/A 0 MultiMachineMasterRunner MultiMachineWorkerRunner N/A N/A testRunnerClass machinesInCluster ownAddress testId testDir timeout timeout N/A extractErrorMessagesFromLogfile N/A N/A logfile targetDir N/A N/A N/A N/A N/A lineNumber 0 N/A curBlock N/A N/A output N/A contains N/A N/A msg N/A N/A N/A N/A N/A  ERROR  msg N/A  CRITICAL  msg N/A N/A line N/A open logfile r N/A N/A lineNumber 1 N/A N/A N/A N/A line N/A 0 N/A N/A curBlock N/A N/A N/A N/A curBlock append N/A N/A line rstrip N/A N/A N/A contains N/A N/A join curBlock N/A N/A N/A N/A output append N/A N/A join curBlock N/A curBlock N/A N/A N/A N/A curBlock append N/A N/A line rstrip N/A N/A contains N/A N/A join curBlock N/A N/A N/A N/A output append N/A N/A join curBlock N/A output N/A N/A fname N/A N/A N/A N/A os path split logfile N/A 1 N/A finalFname N/A N/A N/A os path join targetDir N/A fname _errors.txt N/A N/A open finalFname w resultFile N/A N/A o output N/A N/A resultFile o N/A N/A N/A logging info Checked %s lines of %s to produce %s lines of error messages in %s lineNumber logfile N/A len output finalFname N/A N/A N/A N/A logging info Checked %s lines of %s, but found no error messages lineNumber logfile N/A N/A N/A N/A N/A N/A logging error Failed to extract error messages from %s:
%s logfile N/A N/A traceback format_exc N/A MultiMachineTestRunner N/A object N/A N/A ProtoclVersion 0.0.3 N/A TestControlPort 34532 __init__ N/A N/A self machinesInCluster ownAddress testId testDir timeout N/A None N/A N/A N/A self machinesInCluster machinesInCluster N/A N/A self ownAddress ownAddress N/A N/A N/A self ownAddress N/A self machinesInCluster N/A N/A self testId testId N/A N/A self testDir testDir N/A N/A self timeout timeout N/A N/A N/A N/A os path exists N/A self testDir N/A test directory '%s' does not exist N/A self testDir N/A clusterMaster N/A N/A self N/A N/A N/A N/A N/A self machinesInCluster N/A 0 N/A property isClusterMaster N/A N/A self N/A N/A N/A N/A N/A self clusterMaster N/A self ownAddress N/A property serviceName N/A N/A self N/A N/A N/A N/A NotImplementedError Must be implemented by derived class N/A property run_ N/A N/A self N/A N/A N/A N/A NotImplementedError Must be implemented by derived class N/A getWorkerEnvironment N/A N/A self N/A N/A N/A env N/A dict N/A os environ N/A N/A N/A env update N/A UFORA_MANAGER_ADDRESS UFORA_WORKER_OWN_ADDRESS N/A self clusterMaster N/A self ownAddress N/A env N/A run N/A N/A self N/A N/A N/A N/A N/A logging info machinesInCluster: %s, ownAddress: %s, master: %s, isMaster: %s N/A self machinesInCluster N/A self ownAddress N/A self clusterMaster N/A self isClusterMaster N/A N/A N/A N/A N/A outputDir N/A N/A N/A os path join N/A N/A os getenv TEST_OUTPUT_DIR cluster N/A N/A N/A os makedirs outputDir N/A N/A N/A self run_ N/A N/A N/A Exception N/A e N/A N/A N/A N/A logging error Error running multi-machine test: %s
%s e N/A N/A traceback format_exc N/A False N/A N/A N/A N/A self postExecutionCleanup outputDir N/A postExecutionCleanup N/A N/A self outputDir N/A N/A N/A N/A N/A self removePath N/A N/A N/A os path join outputDir cumulus_disk_storage N/A logDir N/A N/A N/A os path join outputDir logs N/A N/A N/A logging info searching for logs in %s logDir N/A N/A N/A N/A N/A os path exists logDir N/A N/A N/A N/A logging info Log directory %s does not exist N/A N/A logfile N/A N/A os listdir logDir N/A N/A fullPath N/A N/A N/A os path join logDir logfile N/A N/A N/A N/A os path isfile fullPath N/A N/A N/A extractErrorMessagesFromLogfile fullPath outputDir N/A N/A N/A targetLogPath N/A N/A N/A os path join outputDir cumulus_logs.tar.gz N/A N/A N/A subprocess call N/A N/A tar czf %s %s N/A targetLogPath logDir shell True N/A N/A N/A N/A N/A N/A logging error Tried to copy %s to %s but failed: %s logDir targetLogPath N/A N/A traceback format_exc N/A removePath N/A N/A path N/A N/A N/A N/A N/A N/A N/A os path exists path N/A N/A N/A tries N/A range 3 N/A N/A N/A N/A N/A N/A shutil rmtree path N/A True N/A N/A N/A N/A N/A tries 2 N/A N/A N/A N/A logging warn Failed to remove the path %s three times because:
%s path N/A N/A traceback format_exc N/A False N/A staticmethod controlService N/A N/A self serviceName controlArg env N/A None None N/A N/A N/A N/A logging info Attempting to %s service %s controlArg serviceName N/A binDir N/A N/A N/A os path join N/A ufora rootPythonPath ufora/scripts/init N/A exitCode N/A N/A self runCommandAndLogOutput binDir serviceName controlArg env env N/A N/A exitCode 0 N/A N/A N/A N/A logging error Failed to %s %s. Exit code: %s controlArg serviceName exitCode N/A N/A Exception N/A Failed to %s %s. Exit code: %s N/A controlArg serviceName exitCode N/A N/A N/A logging info Service %s successfully completed %s command serviceName controlArg N/A runCommandAndLogOutput N/A N/A path command argument env N/A None None N/A N/A toRun N/A N/A N/A N/A os path join path command N/A argument N/A N/A N/A N/A toRun append argument N/A N/A N/A logging info Running command: %s toRun N/A N/A exitCode stdOut stdErr N/A N/A SubprocessRunner callAndReturnResultAndOutput toRun env env N/A N/A N/A logging info Exit code: %s exitCode N/A N/A N/A logging info %s STDOUT> %s command stdOut N/A N/A N/A logging info %s STDERR> %s command stdErr N/A exitCode N/A staticmethod N/A MultiMachineWorkerRunner N/A MultiMachineTestRunner N/A __init__ N/A N/A self machinesInCluster ownAddress testId testDir timeout N/A None N/A N/A N/A N/A N/A super MultiMachineWorkerRunner self __init__ machinesInCluster ownAddress testDir testDir timeout N/A serviceName N/A N/A self N/A N/A N/A worker N/A property run_ N/A N/A self N/A N/A N/A  This function starts the ufora worker and SLEEPS FOREVER.
        The process gets killed after the master machine reports its test result, as part
        of the test-looper heartbeat protocol.
         N/A sock None N/A t0 N/A N/A time time N/A N/A sock N/A N/A sock N/A N/A self connectToMaster N/A N/A sock N/A N/A N/A N/A N/A N/A time time t0 60.0 N/A N/A N/A Exception Failed to connect to master machine within specified timeout N/A N/A N/A time sleep 1.0 N/A N/A N/A N/A N/A self startWorker N/A N/A N/A self waitForStopCommand sock N/A N/A N/A N/A logging info Stopping worker... N/A N/A N/A self stopWorker N/A connectToMaster N/A N/A self N/A N/A N/A N/A N/A logging info Connecting to master at %s:%s N/A self clusterMaster N/A MultiMachineWorkerRunner TestControlPort N/A True N/A N/A socketError None N/A sock N/A N/A socket socket N/A socket AF_INET N/A socket SOCK_STREAM N/A N/A N/A sock setsockopt N/A socket SOL_SOCKET N/A socket SO_REUSEADDR 1 N/A N/A N/A N/A N/A sock connect N/A N/A self clusterMaster N/A MultiMachineWorkerRunner TestControlPort N/A N/A N/A common writeString sock N/A MultiMachineTestRunner ProtoclVersion N/A N/A N/A common writeString sock N/A self testId N/A response N/A N/A common readString sock N/A N/A response ok:start_worker N/A N/A N/A N/A logging error Error response from cluster master: %s response N/A N/A N/A sock close N/A sock None N/A N/A N/A logging info Connected to cluster master. Response: %s response N/A sock N/A N/A N/A N/A common SocketException N/A N/A socketError N/A N/A traceback format_exc N/A N/A N/A socket error N/A N/A socketError N/A N/A traceback format_exc N/A socketError N/A N/A N/A N/A sock close N/A N/A N/A logging info Waiting for master. %s socketError N/A N/A N/A time sleep 0.5 N/A waitForStopCommand N/A N/A sock N/A N/A N/A message N/A N/A common readString sock N/A N/A message ok:stop_worker N/A N/A N/A N/A logging error Expected stop command from server. Received: %s message N/A N/A N/A N/A logging info Received 'stop' command from master N/A staticmethod startWorker N/A N/A self N/A N/A N/A N/A N/A self controlService ufora-worker start env N/A N/A self getWorkerEnvironment N/A stopWorker N/A N/A self N/A N/A N/A N/A N/A self controlService ufora-worker stop N/A N/A MultiMachineMasterRunner N/A MultiMachineTestRunner N/A __init__ N/A N/A self machinesInCluster ownAddress testId testDir timeout N/A None N/A N/A N/A N/A N/A super MultiMachineMasterRunner self __init__ machinesInCluster ownAddress testDir testDir timeout N/A N/A self testControlServer N/A N/A SimpleServer SimpleServer N/A MultiMachineMasterRunner TestControlPort N/A N/A N/A self testControlServer _onConnect N/A self onConnect N/A N/A self serverThread None N/A N/A self lock N/A N/A threading Lock N/A N/A self allWorkersConnectedEvent N/A N/A threading Event N/A N/A N/A len N/A self machinesInCluster 1 N/A N/A N/A N/A N/A self allWorkersConnectedEvent set N/A N/A self connectedWorkers N/A N/A serviceName N/A N/A self N/A N/A N/A manager N/A property run_ N/A N/A self N/A N/A N/A N/A N/A N/A N/A self startTestControlServer N/A N/A N/A self waitForAllWorkers N/A N/A N/A self startMaster N/A N/A N/A self startWorkers N/A N/A N/A self runTests N/A N/A N/A N/A self stopWorkers N/A N/A N/A self stopMaster N/A N/A N/A self stopTestControlServer N/A startTestControlServer N/A N/A self N/A N/A N/A N/A N/A logging info Starting test control service on port %s N/A MultiMachineMasterRunner TestControlPort N/A N/A self serverThread N/A N/A threading Thread target N/A self serverListenLoop N/A N/A N/A N/A self serverThread start N/A serverListenLoop N/A N/A self N/A N/A N/A N/A N/A N/A N/A self testControlServer shouldStop N/A N/A N/A N/A N/A N/A N/A self testControlServer runListenLoop N/A N/A N/A N/A socket error N/A e N/A N/A N/A N/A e errno 98 N/A N/A N/A N/A time sleep 1.0 N/A stopTestControlServer N/A N/A self N/A N/A N/A N/A N/A logging info Stopping test control server N/A N/A N/A N/A self testControlServer stop N/A N/A N/A logging info waiting for server thread to join N/A N/A N/A N/A self serverThread join N/A N/A N/A logging info Test control server stopped N/A waitForAllWorkers N/A N/A self N/A N/A N/A N/A N/A logging info Waiting for all workers to come online N/A N/A N/A N/A self allWorkersConnectedEvent wait N/A startMaster N/A N/A self N/A N/A N/A N/A N/A self controlService start N/A N/A N/A self controlService ufora-worker start env N/A N/A self getWorkerEnvironment N/A stopMaster N/A N/A self N/A N/A N/A N/A N/A logging info Stopping ufora cluster N/A N/A N/A self controlService ufora-worker stop N/A N/A N/A self controlService stop N/A startWorkers N/A N/A self N/A N/A N/A N/A N/A self forEachWorker N/A N/A N/A workerSocket N/A N/A N/A common writeString workerSocket ok:start_worker N/A stopWorkers N/A N/A self N/A N/A N/A N/A N/A logging info Signalling all workers to stop N/A N/A N/A self forEachWorker N/A N/A N/A workerSocket N/A N/A N/A common writeString workerSocket ok:stop_worker N/A forEachWorker N/A N/A self func N/A N/A N/A N/A workerSocket address N/A self connectedWorkers N/A N/A N/A N/A N/A func workerSocket N/A N/A N/A N/A socket error N/A N/A N/A N/A logging error Socket error from worker %s: %s address N/A N/A traceback format_exc N/A N/A N/A workerSocket close N/A runTests N/A N/A self N/A N/A N/A scriptRunner N/A TestScriptRunner testRoot N/A self testDir defaultTimeout N/A self timeout N/A N/A N/A scriptRunner run N/A onConnect N/A N/A self workerSocket address N/A N/A N/A N/A host port address N/A N/A N/A N/A N/A N/A self protocolHandshake workerSocket N/A N/A N/A N/A logging error Control protocol version mismatch. Worker: %s host N/A N/A N/A self endSession workerSocket error:protocol_version_mismatch N/A N/A N/A N/A host N/A self machinesInCluster N/A N/A N/A N/A logging error Unexpected worker. Worker: %s host N/A N/A N/A self endSession workerSocket error:unknown_worker_address N/A N/A N/A N/A N/A self verifyTestId workerSocket N/A N/A N/A N/A logging error Unexpected testId. Worker: %s. host N/A N/A N/A self endSession workerSocket error:test_id_mismatch N/A N/A N/A N/A self addConnectedWorker N/A workerSocket host N/A N/A N/A N/A socket error N/A N/A N/A N/A logging error Socket error from worker %s: %s host N/A N/A traceback format_exc N/A protocolHandshake N/A N/A self workerSocket N/A N/A N/A workerVersion N/A N/A common readString workerSocket N/A N/A workerVersion N/A MultiMachineTestRunner ProtoclVersion N/A verifyTestId N/A N/A self workerSocket N/A N/A N/A workerTestId N/A N/A common readString workerSocket N/A N/A workerTestId N/A self testId N/A endSession N/A N/A self workerSocket message N/A None N/A N/A message N/A N/A N/A N/A common writeString workerSocket message N/A N/A N/A workerSocket close N/A addConnectedWorker N/A N/A self worker N/A N/A N/A N/A self lock N/A N/A N/A N/A logging info Worker connectd: %s worker N/A N/A N/A N/A self connectedWorkers append worker N/A N/A N/A len N/A self connectedWorkers N/A N/A len N/A self machinesInCluster 1 N/A N/A N/A N/A logging info All workers connected N/A N/A N/A N/A self allWorkersConnectedEvent set N/A N/A