Searched refs:mScheduler (Results 1 – 6 of 6) sorted by relevance
83 private CommandScheduler mScheduler; field in CommandSchedulerTest160 mScheduler = new TestableCommandScheduler(); in setUp()166 if (mScheduler != null) { in tearDown()167 mScheduler.shutdown(); in tearDown()199 mScheduler.start(); in testRun_empty()200 while (!mScheduler.isAlive()) { in testRun_empty()203 mScheduler.shutdown(); in testRun_empty()205 mScheduler.join(); in testRun_empty()220 mScheduler.start(); in testAddConfig_configHelp()221 mScheduler.addCommand(args); in testAddConfig_configHelp()[all …]
34 private ICommandScheduler mScheduler; field in CommandRunner79 mScheduler = getCommandScheduler(); in run()80 mScheduler.start(); in run()81 mScheduler.addCommand(args); in run()86 mScheduler.shutdownOnEmpty(); in run()89 mScheduler.join(getCheckDeviceTimeout()); in run()92 if (mScheduler.getReadyCommandCount() > 0) { in run()95 mScheduler.removeAllCommands(); in run()96 mScheduler.shutdown(); in run()99 mScheduler.join(); in run()[all …]
93 protected ICommandScheduler mScheduler; field in Console155 mScheduler.shutdownOnEmpty(); in run()157 mScheduler.shutdown(); in run()160 if (!mScheduler.handoverShutdown(mHandoverPort)) { in run()184 mScheduler.shutdownHard(); in run()240 mScheduler = scheduler; in setCommandScheduler()391 mScheduler.addCommandFile(cmdfileName, extraArgs); in runCmdfile()394 if (mScheduler.shouldShutdownOnCmdfileError()) { in runCmdfile()396 mScheduler.shutdown(); in runCmdfile()509 mScheduler.displayInvocationsInfo(new PrintWriter(System.out, true)); in addDefaultCommands()[all …]
45 private ICommandScheduler mScheduler; field in TradefedSandboxRunner109 mScheduler = getCommandScheduler(); in run()110 mScheduler.start(); in run()111 mScheduler.execCommand( in run()120 mScheduler.shutdownOnEmpty(); in run()123 mScheduler.join(); in run()126 mErrorCode = mScheduler.getLastInvocationExitCode(); in run()133 && mScheduler.getLastInvocationThrowable() != null) { in run()135 printStackTrace(mScheduler.getLastInvocationThrowable()); in run()
48 private ScheduledExecutorService mScheduler; field in MonkeyPairedBase76 mScheduler = Executors.newScheduledThreadPool(1); in scheduleRecurringCommand()77 mScheduler.scheduleAtFixedRate(new Runnable() { in scheduleRecurringCommand()91 mScheduler.shutdownNow(); in stopRecurringCommand()93 mScheduler.awaitTermination(mCompanionRecurringInterval, TimeUnit.SECONDS); in stopRecurringCommand()
66 private final ICommandScheduler mScheduler; field in RemoteManager108 mScheduler = null; in RemoteManager()120 mScheduler = scheduler; in RemoteManager()336 if (!mScheduler.handoverShutdown(port)) { in processStartHandover()346 mScheduler.handoverInitiationComplete(); in processHandoverInitComplete()354 mScheduler.completeHandover(); in processHandoverComplete()394 if (!mScheduler.addCommand(c.getCommandArgs(), c.getTotalTime())) { in processAdd()408 mScheduler.addCommandFile(c.getCommandFile(), c.getExtraArgs()); in processAddCommandFile()439 mScheduler.execCommand(tracker, device, c.getCommandArgs()); in processExecCommand()