Skip to content

Commit

Permalink
Merge pull request #271 from haristku/fix/269-fix-monitor-windows-error
Browse files Browse the repository at this point in the history 
disable monitor interactive paging on windows #269
  • Loading branch information
@AltamashShaikh
AltamashShaikh authored Oct 23, 2024
2 parents 45214e2 + 06b1286 commit ff5b947
Showing 1 changed file with 87 additions and 50 deletions.
137 changes: 87 additions & 50 deletions Commands/Monitor.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,14 @@ class Monitor extends ConsoleCommand
protected function configure()
{
$this->setName('queuedtracking:monitor');
$this->setDescription("Shows and updates the current state of the queue every 2 seconds.\n Key ,=first page, .=last page, 0-9=move to page section, arrow LEFT=prev page, RIGHT=next page, UP=next 10 pages, DOWN=prev 10 pages, q=quit");
if ($this->interactiveCapability()) {
$this->setDescription("Shows and updates the current state of the queue every 2 seconds.\n Key ,=first page, .=last page, 0-9=move to page section, arrow LEFT=prev page, RIGHT=next page, UP=next 10 pages, DOWN=prev 10 pages, q=quit");
} else {
$this->setDescription("Shows and updates the current state of the queue every 2 seconds.");
}
$this->addRequiredValueOption('iterations', null, 'If set, will limit the number of monitoring iterations done.');
$this->addRequiredValueOption('perpage', 'p', 'Number of queue worker displayed per page.', 16);
$this->addRequiredValueOption('rowperpage', 'r', 'Number of queue worker displayed per page.', 16);
$this->addRequiredValueOption('jumptopage', 'p', 'Jump to page (p).', 1);
}

/**
Expand Down Expand Up @@ -66,14 +71,16 @@ protected function doExecute(): int
));
$iterationCount = 0;

$qCurrentPage = 1;
$qCurrentPage = $this->getJumpToPageFromArg();
$qCount = count($queues);
$qPerPAge = min(max($this->getPerPageFromArg(), 1), $qCount);
$qPageCount = ceil($qCount / $qPerPAge);

readline_callback_handler_install('', function () {
});
stream_set_blocking(STDIN, false);
if ($this->interactiveCapability()) {
readline_callback_handler_install('', function () {
});
stream_set_blocking(STDIN, false);
}

$output->writeln(str_repeat("-", 30));
$output->writeln("<fg=black;bg=white;options=bold>" . str_pad(" Q INDEX", 10) . str_pad(" | REQUEST SETS", 20) . "</>");
Expand All @@ -88,7 +95,7 @@ protected function doExecute(): int

while (1) {
if (microtime(true) - $lastStatsTimer >= 2 || $keyPressed != "") {
$output->write("\e[" . ($qPerPAge + 5) . "A");
$output->write("\e[" . ($qPerPAge + 5) . "A\e[0G");

$qCurrentPage = min(max($qCurrentPage, 1), $qPageCount);
$memory = $backend->getMemoryStats(); // I know this will only work with redis currently as it is not defined in backend interface etc. needs to be refactored once we add another backend
Expand Down Expand Up @@ -120,7 +127,7 @@ protected function doExecute(): int
$output->writeln("<fg=black;bg=white;options=bold>" . str_pad(" " . ($qCount) . " Q", 10) . " | " . str_pad(number_format($sumInQueue) . " R", 16) . "</>");
$output->writeln(str_repeat("-", 30));
$output->writeln(sprintf(
"Q [%s-%s] | <info>page %s/%s</> | <comment>press (0-9.,q) or arrow(L,R,U,D)</> | diff/sec %s \n" .
"Q [%s-%s] | <info>page %s/%s</>" . ($this->interactiveCapability() ? " | <comment>press (0-9.,q) or arrow(L,R,U,D)</>" : " | <error>use -p arg to jump to specific page</>") . " | diff/sec %s \n" .
"%s used memory (%s peak). <info>%d</> workers active." . str_repeat(" ", 15),
($idx - $qPerPAge + 1),
$idx,
Expand All @@ -143,44 +150,46 @@ protected function doExecute(): int
$lastStatsTimer = microtime(true);
}

$keyStroke = stream_get_contents(STDIN, 3);
$keyPressed = strlen($keyStroke) == 3 ? $keyStroke[2] : (strlen($keyStroke) > 0 ? $keyStroke[0] : "");
if ($keyPressed != "" and in_array($keyPressed, array(".", ",", "0", "1", "2", "3", "4", "5", "6", "7", "8", "9", "A", "B", "C", "D", "q"))) {
switch ($keyPressed) {
case "0":
case "1":
case "2":
case "3":
case "4":
case "5":
case "6":
case "7":
case "8":
case "9":
$keyPressed = $keyPressed != "0" ? $keyPressed : "10";
$qCurrentPage = floor(($qCurrentPage - 0.1) / 10) * 10 + (int)$keyPressed;
break;
case "C":
$qCurrentPage++;
break;
case "D":
$qCurrentPage--;
break;
case "A":
$qCurrentPage += 10;
break;
case "B":
$qCurrentPage -= 10;
break;
case ",":
$qCurrentPage = 1;
break;
case ".":
$qCurrentPage = $qPageCount;
break;
case "q":
$output->writeln('');
die;
if ($this->interactiveCapability()) {
$keyStroke = stream_get_contents(STDIN, 3);
$keyPressed = strlen($keyStroke) == 3 ? $keyStroke[2] : (strlen($keyStroke) > 0 ? $keyStroke[0] : "");
if ($keyPressed != "" and in_array($keyPressed, array(".", ",", "0", "1", "2", "3", "4", "5", "6", "7", "8", "9", "A", "B", "C", "D", "q"))) {
switch ($keyPressed) {
case "0":
case "1":
case "2":
case "3":
case "4":
case "5":
case "6":
case "7":
case "8":
case "9":
$keyPressed = $keyPressed != "0" ? $keyPressed : "10";
$qCurrentPage = floor(($qCurrentPage - 0.1) / 10) * 10 + (int)$keyPressed;
break;
case "C":
$qCurrentPage++;
break;
case "D":
$qCurrentPage--;
break;
case "A":
$qCurrentPage += 10;
break;
case "B":
$qCurrentPage -= 10;
break;
case ",":
$qCurrentPage = 1;
break;
case ".":
$qCurrentPage = $qPageCount;
break;
case "q":
$output->writeln('');
die;
}
}
}

Expand Down Expand Up @@ -212,21 +221,49 @@ private function getIterationsFromArg()
}

/**
* Loads the `perpage` argument from the commands arguments.
* Loads the `rowperpage` argument from the commands arguments.
*
* @return int|null
*/
private function getPerPageFromArg()
{
$perPage = $this->getInput()->getOption('perpage');
$perPage = $this->getInput()->getOption('rowperpage');
if (!is_numeric($perPage)) {
throw new \Exception('perpage needs to be numeric');
throw new \Exception('rowperpage needs to be numeric');
} else {
$perPage = (int)$perPage;
if ($perPage <= 0) {
throw new \Exception('perpage needs to be a non-zero positive number');
throw new \Exception('rowperpage needs to be a non-zero positive number');
}
}
return $perPage;
}

/**
* Loads the `jumptopage` argument from the commands arguments.
*
* @return int|null
*/
private function getJumpToPageFromArg()
{
$perPage = $this->getInput()->getOption('jumptopage');
if (!is_numeric($perPage)) {
throw new \Exception('jumptopage needs to be numeric');
} else {
$perPage = (int)$perPage;
if ($perPage <= 0) {
throw new \Exception('jumptopage needs to be a non-zero positive number');
}
}
return $perPage;
}

/**
*
* @return bool
*/
private function interactiveCapability()
{
return function_exists('readline_callback_handler_install');
}
}

0 comments on commit ff5b947

Please sign in to comment.