sspmod_statistics_Aggregator Class Reference

Collaboration diagram for sspmod_statistics_Aggregator:

Public Member Functions
	__construct ($fromcmdline=false)
	Constructor. More...
	dumpConfig ()
	debugInfo ()
	loadMetadata ()
	getMetadata ()
	saveMetadata ()
	aggregate ($debug=false)
	store ($results)

Private Member Functions
	cummulateData ($previous, $newdata)

Static Private Member Functions
static	getDifCol ($content, $colrule)

Private Attributes
	$statconfig
	$statdir
	$inputfile
	$statrules
	$offset
	$metadata
	$fromcmdline
	$starttime
	$timeres

Detailed Description

Definition at line 6 of file Aggregator.php.

Constructor & Destructor Documentation

__construct()

sspmod_statistics_Aggregator::__construct

(

$fromcmdline = false

)

Constructor.

Definition at line 21 of file Aggregator.php.

References $fromcmdline, and SimpleSAML_Configuration\getConfig().

    {
        $this->fromcmdline = $fromcmdline;
        $this->statconfig = SimpleSAML_Configuration::getConfig('module_statistics.php');

        $this->statdir = $this->statconfig->getValue('statdir');
        $this->inputfile = $this->statconfig->getValue('inputfile');
        $this->statrules = $this->statconfig->getValue('statrules');
        $this->timeres = $this->statconfig->getValue('timeres');
        $this->offset = $this->statconfig->getValue('offset', 0);
        $this->metadata = null;

        $this->starttime = time();
    }

Here is the call graph for this function:

Member Function Documentation

aggregate()

sspmod_statistics_Aggregator::aggregate

(

$debug = false

)

Definition at line 73 of file Aggregator.php.

References $action, Sabre\VObject\$debug, $fileslot, $i, $results, $rule, $type, exit, and loadMetadata().

                                              {
        $this->loadMetadata();

        if (!is_dir($this->statdir)) {
            throw new Exception('Statistics module: output dir do not exists [' . $this->statdir . ']');
        }

        if (!file_exists($this->inputfile)) {
            throw new Exception('Statistics module: input file do not exists [' . $this->inputfile . ']');
        }

        $file = fopen($this->inputfile, 'r');

        if ($file === false) {
            throw new Exception('Statistics module: unable to open file [' . $this->inputfile . ']');
        }

        $logparser = new sspmod_statistics_LogParser(
            $this->statconfig->getValue('datestart', 0), $this->statconfig->getValue('datelength', 15), $this->statconfig->getValue('offsetspan', 44)
        );
        $datehandler = array(
            'default' => new sspmod_statistics_DateHandler($this->offset),
            'month' => new  sspmod_statistics_DateHandlerMonth($this->offset),
        );

        $notBefore = 0;
        $lastRead = 0;
        $lastlinehash = '-';

        if (isset($this->metadata)) {
            $notBefore = $this->metadata['notBefore'];
            $lastlinehash = $this->metadata['lastlinehash'];
        }

        $lastlogline = 'sdfsdf'; 
        $lastlineflip = false;
        $results = array();

        $i = 0;
        // Parse through log file, line by line
        while (!feof($file)) {
            $logline = fgets($file, 4096);

            // Continue if STAT is not found on line
            if (!preg_match('/STAT/', $logline)) {
                continue;
            }

            $i++;
            $lastlogline = $logline;

            // Parse log, and extract epoch time and rest of content.
            $epoch = $logparser->parseEpoch($logline);
            $content = $logparser->parseContent($logline);
            $action = trim($content[5]);

            if ($this->fromcmdline && ($i % 10000) == 0) {
                echo("Read line " . $i . "\n");
            }

            if ($debug) {
                echo("----------------------------------------\n");
                echo('Log line: ' . $logline . "\n");
                echo('Date parse [' . substr($logline, 0, $this->statconfig->getValue('datelength', 15)) . '] to [' . date(DATE_RFC822, $epoch) . ']' . "\n");
                echo htmlentities(print_r($content, true));
                if ($i >= 13) {
                    exit;
                }
            }

            if ($epoch > $lastRead) {
                $lastRead = $epoch;
            }

            if ($epoch === $notBefore) {
                if (!$lastlineflip) {
                    if (sha1($logline) === $lastlinehash) { 
                        $lastlineflip = true;
                    }
                    continue;
                }
            }

            if ($epoch < $notBefore) {
                continue;
            }

            // Iterate all the statrules from config.
            foreach ($this->statrules as $rulename => $rule) {
                $type = 'aggregate';

                if (array_key_exists('type', $rule)) {
                    $type = $rule['type'];
                }

                if ($type !== 'aggregate') {
                    continue;
                }

                foreach ($this->timeres as $tres => $tresconfig ) {
                    $dh = 'default';
                    if (isset($tresconfig['customDateHandler'])) {
                        $dh = $tresconfig['customDateHandler'];
                    }

                    $timeslot = $datehandler['default']->toSlot($epoch, $tresconfig['slot']);
                    $fileslot = $datehandler[$dh]->toSlot($epoch, $tresconfig['fileslot']);

                    if (isset($rule['action']) && ($action !== $rule['action'])) {
                        continue;
                    }

                    $difcol = self::getDifCol($content, $rule['col']);

                    if (!isset($results[$rulename][$tres][$fileslot][$timeslot]['_'])) {
                        $results[$rulename][$tres][$fileslot][$timeslot]['_'] = 0;
                    }
                    if (!isset($results[$rulename][$tres][$fileslot][$timeslot][$difcol])) {
                        $results[$rulename][$tres][$fileslot][$timeslot][$difcol] = 0;
                    }

                    $results[$rulename][$tres][$fileslot][$timeslot]['_']++;
                    $results[$rulename][$tres][$fileslot][$timeslot][$difcol]++;
                }
            }
        }
        $this->metadata['notBefore'] = $lastRead;
        $this->metadata['lastline'] = $lastlogline;
        $this->metadata['lastlinehash'] = sha1($lastlogline);
        return $results;
    }

Here is the call graph for this function:

cummulateData()

sspmod_statistics_Aggregator::cummulateData (   $previous,   $newdata  )

private

Definition at line 220 of file Aggregator.php.

References $data, and $key.

Referenced by store().

    {
        $dataset = array();
        foreach (func_get_args() as $item) {
            foreach ($item as $slot => $dataarray) {
                if (!array_key_exists($slot, $dataset)) {
                    $dataset[$slot] = array();
                }
                foreach ($dataarray as $key => $data) {
                    if (!array_key_exists($key, $dataset[$slot])) {
                        $dataset[$slot][$key] = 0;
                    }
                    $dataset[$slot][$key] += $data;
                }
            }
        }
        return $dataset;
    }

Here is the caller graph for this function:

debugInfo()

sspmod_statistics_Aggregator::debugInfo

(

)

Definition at line 43 of file Aggregator.php.

    {
        echo 'Memory usage           : ' . number_format(memory_get_usage() / (1024*1024), 2) . " MB\n";
    }

dumpConfig()

sspmod_statistics_Aggregator::dumpConfig

(

)

Definition at line 36 of file Aggregator.php.

    {
        echo 'Statistics directory   : ' . $this->statdir . "\n";
        echo 'Input file             : ' . $this->inputfile . "\n";
        echo 'Offset                 : ' . $this->offset . "\n";
    }

getDifCol()

static sspmod_statistics_Aggregator::getDifCol (   $content,   $colrule  )

staticprivate

Definition at line 205 of file Aggregator.php.

    {
        if (is_int($colrule)) {
            return trim($content[$colrule]);
        } elseif (is_array($colrule)) {
            $difcols = array();
            foreach ($colrule as $cr) {
                $difcols[] = trim($content[$cr]);
            }
            return join('|', $difcols);
        } else {
            return 'NA';
        }
    }

getMetadata()

sspmod_statistics_Aggregator::getMetadata

(

)

Definition at line 58 of file Aggregator.php.

References $metadata.

    {
        return $this->metadata;
    }

loadMetadata()

sspmod_statistics_Aggregator::loadMetadata

(

)

Definition at line 48 of file Aggregator.php.

References $filename, and $metadata.

Referenced by aggregate().

    {
        $filename = $this->statdir . '/.stat.metadata';
        $metadata = null;
        if (file_exists($filename)) {
            $metadata = unserialize(file_get_contents($filename));
        }
        $this->metadata = $metadata;
    }

Here is the caller graph for this function:

saveMetadata()

sspmod_statistics_Aggregator::saveMetadata

(

)

Definition at line 63 of file Aggregator.php.

References $filename, and $starttime.

Referenced by store().

    {
        $this->metadata['time'] = time() - $this->starttime;
        $this->metadata['memory'] = memory_get_usage();
        $this->metadata['lastrun'] = time();

        $filename = $this->statdir . '/.stat.metadata';
        file_put_contents($filename, serialize($this->metadata), LOCK_EX);
    }

Here is the caller graph for this function:

store()

sspmod_statistics_Aggregator::store

(

$results

)

Definition at line 239 of file Aggregator.php.

References $end, $filename, $results, $start, cummulateData(), and saveMetadata().

    {
        $datehandler = array(
            'default' => new sspmod_statistics_DateHandler($this->offset),
            'month' => new  sspmod_statistics_DateHandlerMonth($this->offset),
        );

        // Iterate the first level of results, which is per rule, as defined in the config.
        foreach ($results as $rulename => $timeresdata) {
            // Iterate over time resolutions
            foreach ($timeresdata as $tres => $resres) {
                $dh = 'default';
                if (isset($this->timeres[$tres]['customDateHandler'])) {
                    $dh = $this->timeres[$tres]['customDateHandler'];
                }

                $filenos = array_keys($resres);
                $lastfile = $filenos[count($filenos) - 1];

                // Iterate the second level of results, which is the fileslot.
                foreach ($resres as $fileno => $fileres) {
                    // Slots that have data.
                    $slotlist = array_keys($fileres);

                    // The last slot.
                    $maxslot = $slotlist[count($slotlist) - 1];

                    // Get start and end slot number within the file, based on the fileslot.
                    $start = (int)$datehandler['default']->toSlot(
                        $datehandler[$dh]->fromSlot($fileno, $this->timeres[$tres]['fileslot']), 
                        $this->timeres[$tres]['slot']
                    );
                    $end = (int)$datehandler['default']->toSlot(
                        $datehandler[$dh]->fromSlot($fileno+1, $this->timeres[$tres]['fileslot']), 
                        $this->timeres[$tres]['slot']
                    );

                    // Fill in missing entries and sort file results
                    $filledresult = array();
                    for ($slot = $start; $slot < $end; $slot++) {
                        if (array_key_exists($slot,  $fileres)) {
                            $filledresult[$slot] = $fileres[$slot];
                        } else {
                            if ($lastfile == $fileno && $slot > $maxslot) {
                                $filledresult[$slot] = array('_' => null);
                            } else {
                                $filledresult[$slot] = array('_' => 0);
                            }
                        }
                    }

                    $filename = $this->statdir . '/' . $rulename . '-' . $tres . '-' . $fileno . '.stat';
                    if (file_exists($filename)) {
                        $previousData = unserialize(file_get_contents($filename));
                        $filledresult = $this->cummulateData($previousData, $filledresult);     
                    }

                    // store file
                    file_put_contents($filename, serialize($filledresult), LOCK_EX);
                }
            }
        }
        $this->saveMetadata();
    }

Here is the call graph for this function:

Field Documentation

$fromcmdline

sspmod_statistics_Aggregator::$fromcmdline

private

Definition at line 14 of file Aggregator.php.

Referenced by __construct().

$inputfile

sspmod_statistics_Aggregator::$inputfile

private

Definition at line 10 of file Aggregator.php.

$metadata

sspmod_statistics_Aggregator::$metadata

private

Definition at line 13 of file Aggregator.php.

Referenced by getMetadata(), and loadMetadata().

$offset

sspmod_statistics_Aggregator::$offset

private

Definition at line 12 of file Aggregator.php.

$starttime

sspmod_statistics_Aggregator::$starttime

private

Definition at line 15 of file Aggregator.php.

Referenced by saveMetadata().

$statconfig

sspmod_statistics_Aggregator::$statconfig

private

Definition at line 8 of file Aggregator.php.

$statdir

sspmod_statistics_Aggregator::$statdir

private

Definition at line 9 of file Aggregator.php.

$statrules

sspmod_statistics_Aggregator::$statrules

private

Definition at line 11 of file Aggregator.php.

$timeres

sspmod_statistics_Aggregator::$timeres

private

Definition at line 16 of file Aggregator.php.

---

The documentation for this class was generated from the following file:

• libs/composer/vendor/simplesamlphp/simplesamlphp/modules/statistics/lib/Aggregator.php