Add "--pool" and "--duration" flags to daemon CLI tools

Summary: Ref T12331. These changes are intended to make it easier to debug T12331 since I'm having difficulty reproducing the issue locally.

Test Plan:
  - Ran `bin/phd debug task --pool 4` and got an autoscaling pool.
  - Ran `bin/worker flood --duration 3` and got some 3-second-long tasks to execute with `bin/worker execute ...`.

Reviewers: chad

Reviewed By: chad

Maniphest Tasks: T12331

Differential Revision: https://secure.phabricator.com/D17431

Author: epriestley

src/applications/daemon/management/PhabricatorDaemonManagementDebugWorkflow.php

@@ -21,6 +21,12 @@ protected function didConstruct() {
             'name' => 'argv',
             'wildcard' => true,
           ),
+          array(
+            'name' => 'pool',
+            'param' => 'count',
+            'help' => pht('Maximum pool size.'),
+            'default' => 1,
+          ),
           array(
             'name' => 'as-current-user',
             'help' => pht(
@@ -43,6 +49,7 @@ public function execute(PhutilArgumentParser $args) {
     $config = array(
       'class' => array_shift($argv),
       'label' => 'debug',
+      'pool' => (int)$args->getArg('pool'),
       'argv' => $argv,
     );
 

src/infrastructure/daemon/workers/__tests__/PhabricatorTestWorker.php

@@ -24,7 +24,14 @@ public function getWaitBeforeRetry(PhabricatorWorkerTask $task) {
   }
 
   protected function doWork() {
-    switch (idx($this->getTaskData(), 'doWork')) {
+    $data = $this->getTaskData();
+
+    $duration = idx($data, 'duration');
+    if ($duration) {
+      usleep($duration * 1000000);
+    }
+
+    switch (idx($data, 'doWork')) {
       case 'fail-temporary':
         throw new Exception(pht('Temporary failure!'));
       case 'fail-permanent':

src/infrastructure/daemon/workers/management/PhabricatorWorkerManagementFloodWorkflow.php

@@ -11,12 +11,24 @@ protected function didConstruct() {
         pht(
           'Flood the queue with test tasks. This command is intended for '.
           'use when developing and debugging Phabricator.'))
-      ->setArguments(array());
+      ->setArguments(
+        array(
+          array(
+            'name' => 'duration',
+            'param' => 'seconds',
+            'help' => pht(
+              'Queue tasks which require a specific amount of wall time to '.
+              'complete. By default, tasks complete as quickly as possible.'),
+            'default' => 0,
+          ),
+        ));
   }
 
   public function execute(PhutilArgumentParser $args) {
     $console = PhutilConsole::getConsole();
 
+    $duration = (float)$args->getArg('duration');
+
     $console->writeOut(
       "%s\n",
       pht('Adding many test tasks to worker queue. Use ^C to exit.'));
@@ -25,7 +37,9 @@ public function execute(PhutilArgumentParser $args) {
     while (true) {
       PhabricatorWorker::scheduleTask(
         'PhabricatorTestWorker',
-        array());
+        array(
+          'duration' => $duration,
+        ));
 
       if (($n++ % 100) === 0) {
         $console->writeOut('.');