Topコマンドを作ってみた

Topコマンド (php)

<?php
define('PAPYRUS_USERLOG', 'Top');
define('ENABLE_PEAK_DUMP', TRUE);
define('PEAK_THRESHOLD', 400);
define('DUMP_LOG_BASE', 'dump_');

$file = PAPYRUS_USERLOG . '.0.log';
$begin = 0;
$finish = 0;
$chunk = 0;
$processList = [];
$errorList = [];
$timeList = [];
$sortedList = [];
$sortTimeList = [];
$loadList = [];
$peakList = [ 5 => 0, 15 => 0, 60 => 0 ];
$dumpList = [];
$lastChunk = '';
$peakDumped = false;

try {
    if ( !is_readable($file) ) {
        throw new Exception($file . ' is not readable.');
    }

    if ( !ENABLE_PEAK_DUMP ) {
        $peakDumped = TRUE;
    }

    $fileSize = filesize($file);
    $lastFileSize = $fileSize;
    $startUp = time();

    while (true) {
        clearstatcache(true, $file);

        $fileSize = filesize($file);
        $current = time();

        if ($lastFileSize != $fileSize) {
            if ($fileSize < $lastFileSize) {
                $lastFileSize = 0;
            }

            $fileContents = file_get_contents($file, false, null, $lastFileSize, $fileSize);

            parseLog($fileContents);

            $lastFileSize = $fileSize;
        }

        createLoad();
        createPeak();
        createSortedList();
        refreshSortedTime();

        clearTerminal();

        // 上段
        printHeader();
        echo ' ';
        printLoad();
        echo ' ';
        printPeak();
        echo ' ';
        printFooter();
        echo PHP_EOL;

        echo PHP_EOL;

        printSortedList();

        echo PHP_EOL;

        printError();

        if ( !$peakDumped ) {
            cleanDumpList();

            if ( $peakList[5] >= PEAK_THRESHOLD ) {
                dumpProcess();
                $peakDumped = TRUE;
            }
        }

        sleep(1);
    }
} catch (Exception $e) {
    echo $e->getMessage() . PHP_EOL;
}


function parseLog($infile)
{
    global $lastChunk, $begin, $finish, $chunk, $processList, $errorList, $timeList, $startUp, $current, $peakDumped, $dumpList;

    foreach ( explode("\n", $infile) as $inline ) {
        if ( $lastChunk !== '' ) {
            $inline = $lastChunk . $inline;
            $lastChunk = '';
            //$chunk--;
        }

        if ( strpos($inline, "\r") !== FALSE ) {
            $lastChunk = $inline;
            $chunk++;
            continue;
        }

        $inline = trim($inline);

        if ($inline == '') {
            continue;
        }

        $cols = explode('] ', $inline);

        if ( !isset($cols[1]) ) {
            $errorList[] = 'invalid line: ' . trim($inline);
            continue;
        }

        if ( $cols[1] == PAPYRUS_USERLOG . ' log opened (PC)' ) {
            $startUp = $current;
            $begin = 0;
            $finish = 0;
            $errorList = [];
            $processList = [];
            $timeList = [];
            //$errorList[] = $cols[1];
            continue;
        }

        $cols = explode(',', $cols[1]);

        if ( count($cols) != 4 ) {
            continue;
        }

        $value = $cols[0] . ',' . $cols[1] . ',' . $cols[2];

        if ( $cols[3] == 'begin' ) {
            $begin++;
            $processList[] = $value;
            $timeList[] = $current;

            if ( !$peakDumped ) {
                $dumpList[] = [ $current, $value ];
            }
        } else if ( $cols[3] == 'finish' ) {
            $key = array_search( $value, $processList );

            if ( $key !== FALSE ) {
                unset($processList[$key]);
                $finish++;
            } else {
                if ($current - $startUp >= 10) {
                    $errorList[] = 'process not found: ' . $value;
                }
            }
        }
    }
}


// 端末を消去
function clearTerminal()
{
    pclose( popen('cls', 'w') );
}


// ヘッダ部分を表示
function printHeader()
{
    global $begin, $finish, $running, $chunk;

    $running = $begin - $finish;

    printf('Papyrus: %d begin, %d finish, %d running, %d chunk', $begin, $finish, $running, $chunk);
}


function createLoad()
{
    global $timeList, $loadList, $current;

    $loadList = [ 5 => 0, 15 => 0, 60 => 0 ];

    foreach ($timeList as $key => $timestamp) {
        if ($current - $timestamp <= 60) {
            $loadList[60]++;

            if ($current - $timestamp <= 5) {
                $loadList[5]++;
            }

            if ($current - $timestamp <= 15) {
                $loadList[15]++;
            }
        } else {
            unset( $timeList[$key] );
        }
    }
}


function createPeak()
{
    global $loadList, $peakList;

    foreach ($loadList as $key => $value) {
        if ( $peakList[$key] < $loadList[$key] ) {
            $peakList[$key] = $loadList[$key];
        }
    }
}


function printLoad()
{
    global $loadList;

    printf('Load: %d, %d, %d', $loadList[5], $loadList[15], $loadList[60]);
}


function printPeak()
{
    global $peakList;

    printf('Peak: %d, %d, %d', $peakList[5], $peakList[15], $peakList[60]);
}


// プロセス一覧を作る
function createSortedList()
{
    global $sortedList, $processList, $sortTimeList, $current;

    $sortedList = [];

    foreach ($processList as $line) {
        if ( array_key_exists($line, $sortedList) ) {
            $sortedList[$line]++;
        } else {
            $sortedList[$line] = 1;

            if ( !array_key_exists($line, $sortTimeList) ) {
                $sortTimeList[$line] = $current;
            }
        }
    }

    ksort($sortedList);
}


// プロセス一覧を表示
function printSortedList()
{
    global $sortedList, $sortTimeList, $current;

    echo 'Time Num State Function Script';
    echo PHP_EOL;

    foreach ($sortedList as $line => $num) {
        $past = $current - $sortTimeList[$line];
        $cols = explode(',', $line);
        printf('%04d %3d %-10s %-18s %s', $past, $num, $cols[1], $cols[2], $cols[0]);
        echo PHP_EOL;
    }
}


// プロセスの経過時間一覧を整理
function refreshSortedTime()
{
    global $sortTimeList, $sortedList;

    foreach (array_keys($sortTimeList) as $line) {
        if ( !array_key_exists($line, $sortedList) ) {
            unset($sortTimeList[$line]);
        }
    }
}


// 概要部分を表示
function printFooter()
{
    global $errorList;

    printf( 'Error: %d', count($errorList) );

    /*
    global $sortedList, $sortTimeList, $errorList;

    printf('Sorted:%d Time:%d Error:%d', count($sortedList), count($sortTimeList), count($errorList));
    */
}


// エラーを表示
function printError()
{
    global $errorList;

    foreach ($errorList as $line) {
        echo $line . PHP_EOL;
    }
}


function dumpProcess()
{
    global $dumpList;

    $filename = DUMP_LOG_BASE . date('YmdHis') . '.log';

    $fp = fopen($filename, 'w');

    if (!$fp) {
        throw new Exception('could not open ' . $filename);
    }

    foreach ($dumpList as $data) {
        fputs($fp, date('Y/m/d H:i:s', $data[0]) . ' ' . $data[1] . PHP_EOL);
    }

    fclose($fp);
}


function cleanDumpList()
{
    global $dumpList, $current;

    foreach ($dumpList as $key => $data) {
        if ( $current - $data[0] > 5 ) {
            unset($dumpList[$key]);
        } else {
            break;
        }
    }
}