Collaboration diagram for ilSessionStatistics:

Static Public Member Functions
static	isActive ()
	Is session statistics active at all? More...

static	createRawEntry (string $a_session_id, int $a_session_type, int $a_timestamp, int $a_user_id)
	Create raw data entry. More...

static	closeRawEntry ($a_session_id, ?int $a_context=null, $a_expired_at=null)
	Close raw data entry. More...

static	aggretateRaw (int $a_now)
	Aggregate raw session data (older than given time) More...

static	aggregateRawHelper (int $a_begin, int $a_end)
	Aggregate statistics data for one slot. More...

static	getNumberOfSessionsByType (int $a_from, int $a_to)
	Get session counters by type (opened, closed) More...

static	getLastAggregation ()
	Get timestamp of last aggregation. More...

Static Protected Member Functions
static	getCurrentSlot (int $a_now)
	Get next slot to aggregate. More...

static	getNumberOfActiveRawSessions (int $a_time)

static	getRawData (int $a_begin, int $a_end)
	Read raw data for timespan. More...

static	createNewAggregationSlot (int $a_now)
	Create new slot (using table lock) More...

static	deleteAggregatedRaw (int $a_now)
	Remove already aggregated raw data. More...

Private Attributes
const int	SLOT_SIZE = 15

Detailed Description

Definition at line 21 of file class.ilSessionStatistics.php.

Member Function Documentation

◆ aggregateRawHelper()

static ilSessionStatistics::aggregateRawHelper	(	int	$a_begin,
		int	$a_end
	)

static

Aggregate statistics data for one slot.

Definition at line 263 of file class.ilSessionStatistics.php.

                                                                       : void
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        // "relevant" closing types
        $separate_closed = [
            ilSession::SESSION_CLOSE_USER,
            ilSession::SESSION_CLOSE_EXPIRE,
            ilSession::SESSION_CLOSE_LOGIN
        ];
 
        // gather/process data (build event timeline)
        $closed_counter = $events = [];
        $opened_counter = 0;
        foreach (self::getRawData($a_begin, $a_end) as $item) {
            // open/close counters are _not_ time related
 
            // we could filter for undefined/invalid closing contexts
            // and ignore those items, but this would make any debugging
            // close to impossible
            // "closed_other" would have been a good idea...
 
            // session opened
            if ($item['start_time'] >= $a_begin) {
                $opened_counter++;
                $events[$item['start_time']][] = 1;
            }
            // session closed
            if ($item['end_time'] && $item['end_time'] <= $a_end) {
                if (in_array($item['end_context'], $separate_closed, true)) {
                    if (!isset($closed_counter[$item['end_context']])) {
                        $closed_counter[$item['end_context']] = 0;
                    }
 
                    $closed_counter[$item['end_context']]++;
                } else {
                    $closed_counter[0] = ($closed_counter[0] ?? 0) + 1;
                }
                $events[$item['end_time']][] = -1;
            }
        }
 
        // initialising active statistical values
        $active_begin = self::getNumberOfActiveRawSessions($a_begin - 1);
        $active_end = $active_min = $active_max = $active_avg = $active_begin;
 
        // parsing events / building avergages
        if (count($events)) {
            $last_update_avg = $a_begin - 1;
            $slot_seconds = self::SLOT_SIZE * 60;
            $active_avg = 0;
 
            // parse all open/closing events
            ksort($events);
            foreach ($events as $ts => $actions) {
                // actions which occur in the same second are "merged"
                foreach ($actions as $action) {
                    // max
                    if ($action > 0) {
                        $active_end++;
                    }
                    // min
                    else {
                        $active_end--;
                    }
                }
 
                // max
                if ($active_end > $active_max) {
                    $active_max = $active_end;
                }
 
                // min
                if ($active_end < $active_min) {
                    $active_min = $active_end;
                }
 
                // avg
                $diff = $ts - $last_update_avg;
                $active_avg += $diff / $slot_seconds * $active_end;
                $last_update_avg = $ts;
            }
 
            // add up to end of slot if needed
            if ($last_update_avg < $a_end) {
                $diff = $a_end - $last_update_avg;
                $active_avg += $diff / $slot_seconds * $active_end;
            }
 
            $active_avg = round($active_avg);
        }
        unset($events);
 
        // save aggregated data
        $fields = [
            'active_min' => ['integer', $active_min],
            'active_max' => ['integer', $active_max],
            'active_avg' => ['integer', $active_avg],
            'active_end' => ['integer', $active_end],
            'opened' => ['integer', $opened_counter],
            'closed_manual' => ['integer', (int) ($closed_counter[ilSession::SESSION_CLOSE_USER] ?? 0)],
            'closed_expire' => ['integer', (int) ($closed_counter[ilSession::SESSION_CLOSE_EXPIRE] ?? 0)],
            'closed_login' => ['integer', (int) ($closed_counter[ilSession::SESSION_CLOSE_LOGIN] ?? 0)],
            'closed_misc' => ['integer', (int) ($closed_counter[0] ?? 0)],
        ];
        $ilDB->update(
            'usr_session_stats',
            $fields,
            [
                'slot_begin' => ['integer', $a_begin],
                'slot_end' => ['integer', $a_end]
            ]
        );
    }

References $DIC, $ilDB, getNumberOfActiveRawSessions(), ILIAS\Repository\int(), ilSession\SESSION_CLOSE_EXPIRE, ilSession\SESSION_CLOSE_LOGIN, and ilSession\SESSION_CLOSE_USER.

Referenced by aggretateRaw().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ aggretateRaw()

static ilSessionStatistics::aggretateRaw ( int $a_now )

static

Aggregate raw session data (older than given time)

Definition at line 243 of file class.ilSessionStatistics.php.

                                                   : void
    {
        if (!self::isActive()) {
            return;
        }
 
        $slot = self::createNewAggregationSlot($a_now);
        while (is_array($slot)) {
            self::aggregateRawHelper($slot[0], $slot[1]);
            $slot = self::createNewAggregationSlot($a_now);
        }
 
        // #12728
        self::deleteAggregatedRaw($a_now);
    }

References aggregateRawHelper(), createNewAggregationSlot(), and deleteAggregatedRaw().

Referenced by ilSessionStatisticsGUI\adminSync(), and ilAuthDestroyExpiredSessionsCron\run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ closeRawEntry()

static ilSessionStatistics::closeRawEntry	(		$a_session_id,
		?int	$a_context = `null`,
			$a_expired_at = `null`
	)

static

Close raw data entry.

Parameters

int \| array	$a_session_id
int	$a_context
int \| bool	$a_expired_at

Definition at line 73 of file class.ilSessionStatistics.php.

                                                                                                     : void
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        if (!self::isActive()) {
            return;
        }
 
        // single entry
        if (!is_array($a_session_id)) {
            if ($a_expired_at) {
                $end_time = $a_expired_at;
            } else {
                $end_time = time();
            }
            $sql = 'UPDATE usr_session_stats_raw' .
                ' SET end_time = ' . $ilDB->quote($end_time, 'integer');
            if ($a_context) {
                $sql .= ',end_context = ' . $ilDB->quote($a_context, 'integer');
            }
            $sql .= ' WHERE session_id = ' . $ilDB->quote($a_session_id, 'text') .
                ' AND end_time IS NULL';
            $ilDB->manipulate($sql);
        }
        // batch closing
        elseif (!$a_expired_at) {
            $sql = 'UPDATE usr_session_stats_raw' .
                ' SET end_time = ' . $ilDB->quote(time(), 'integer');
            if ($a_context) {
                $sql .= ',end_context = ' . $ilDB->quote($a_context, 'integer');
            }
            $sql .= ' WHERE ' . $ilDB->in('session_id', $a_session_id, false, 'text') .
                ' AND end_time IS NULL';
            $ilDB->manipulate($sql);
        }
        // batch with individual timestamps
        else {
            foreach ($a_session_id as $id => $ts) {
                $sql = 'UPDATE usr_session_stats_raw' .
                    ' SET end_time = ' . $ilDB->quote($ts, 'integer');
                if ($a_context) {
                    $sql .= ',end_context = ' . $ilDB->quote($a_context, 'integer');
                }
                $sql .= ' WHERE session_id = ' . $ilDB->quote($id, 'text') .
                    ' AND end_time IS NULL';
                $ilDB->manipulate($sql);
            }
        }
    }

References $DIC, $id, and $ilDB.

Referenced by ilSession\_destroy().

Here is the caller graph for this function:

◆ createNewAggregationSlot()

static ilSessionStatistics::createNewAggregationSlot ( int $a_now )

staticprotected

Create new slot (using table lock)

Returns: array begin, end

Definition at line 210 of file class.ilSessionStatistics.php.

                                                                  : ?array
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $ilAtomQuery = $ilDB->buildAtomQuery();
        $ilAtomQuery->addTableLock('usr_session_stats');
 
        $ilAtomQuery->addQueryCallable(function (ilDBInterface $ilDB) use ($a_now, &$slot) {
            // if we had to wait for the lock, no current slot should be returned here
            $slot = self::getCurrentSlot($a_now);
            if (!is_array($slot)) {
                $slot = null;
                return;
            }
 
            // save slot to mark as taken
            $fields = [
                'slot_begin' => ['integer', $slot[0]],
                'slot_end' => ['integer', $slot[1]],
            ];
            $ilDB->insert('usr_session_stats', $fields);
        });
 
        $ilAtomQuery->run();
 
        return $slot;
    }

References $DIC, $ilDB, and getCurrentSlot().

Referenced by aggretateRaw().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ createRawEntry()

static ilSessionStatistics::createRawEntry	(	string	$a_session_id,
		int	$a_session_type,
		int	$a_timestamp,
		int	$a_user_id
	)

static

Create raw data entry.

Definition at line 40 of file class.ilSessionStatistics.php.

                                                                                                                      : void
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        if (!$a_user_id || !$a_session_id || !self::isActive()) {
            return;
        }
 
        // #9669: if a session was destroyed and somehow the session id is still
        // in use there will be a id-collision for the raw-entry
 
        $ilDB->replace(
            'usr_session_stats_raw',
            [
                'session_id' => ['text', $a_session_id]
            ],
            [
                'type' => ['integer', $a_session_type],
                'start_time' => ['integer', $a_timestamp],
                'user_id' => ['integer', $a_user_id]
            ]
        );
    }

References $DIC, and $ilDB.

◆ deleteAggregatedRaw()

static ilSessionStatistics::deleteAggregatedRaw ( int $a_now )

staticprotected

Remove already aggregated raw data.

Definition at line 383 of file class.ilSessionStatistics.php.

                                                             : void
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        // we are rather defensive here - 7 days BEFORE current aggregation
        $cut = $a_now - (60 * 60 * 24 * 7);
 
        $ilDB->manipulate(
            'DELETE FROM usr_session_stats_raw' .
            ' WHERE start_time <= ' . $ilDB->quote($cut, 'integer')
        );
    }

References $DIC, and $ilDB.

Referenced by aggretateRaw().

Here is the caller graph for this function:

◆ getCurrentSlot()

static ilSessionStatistics::getCurrentSlot ( int $a_now )

staticprotected

Get next slot to aggregate.

Returns: array begin, end

Definition at line 130 of file class.ilSessionStatistics.php.

                                                        : ?array
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        // get latest slot in db
        $sql = 'SELECT MAX(slot_end) previous_slot_end' .
            ' FROM usr_session_stats';
        $res = $ilDB->query($sql);
        $row = $ilDB->fetchAssoc($res);
        $previous_slot_end = $row['previous_slot_end'];
 
        // no previous slot?  calculate last complete slot
        // should we use minimum session raw date instead? (problem: table lock)
        if (!$previous_slot_end) {
            $slot = (int) (floor(date('i') / self::SLOT_SIZE));
            // last slot of previous hour
            if (!$slot) {
                $current_slot_begin = mktime((int) date('H', $a_now) - 1, 60 - self::SLOT_SIZE, 0);
            }
            // "normalize" to slot
            else {
                $current_slot_begin = mktime((int) date('H', $a_now), ($slot - 1) * self::SLOT_SIZE, 0);
            }
        } else {
            $current_slot_begin = $previous_slot_end + 1;
        }
 
        $current_slot_end = $current_slot_begin + (60 * self::SLOT_SIZE) - 1;
 
        // no complete slot: nothing to do yet
        if ($current_slot_end < $a_now) {
            return [$current_slot_begin, $current_slot_end];
        }
        return null;
    }

References $DIC, $ilDB, $res, ILIAS\Repository\int(), and SLOT_SIZE.

Referenced by createNewAggregationSlot().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getLastAggregation()

static ilSessionStatistics::getLastAggregation ( )

static

Get timestamp of last aggregation.

Definition at line 447 of file class.ilSessionStatistics.php.

                                               : ?int
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $sql = 'SELECT max(slot_end) latest FROM usr_session_stats';
        $res = $ilDB->query($sql);
        $row = $ilDB->fetchAssoc($res);
        if ($row['latest']) {
            return (int) $row['latest'];
        }
        //TODO check if return null as timestamp causes issues
        return null;
    }

References $DIC, $ilDB, and $res.

Referenced by ilSessionStatisticsGUI\renderCurrentBasics().

Here is the caller graph for this function:

◆ getNumberOfActiveRawSessions()

static ilSessionStatistics::getNumberOfActiveRawSessions ( int $a_time )

staticprotected

Definition at line 168 of file class.ilSessionStatistics.php.

                                                                       : int
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $sql = 'SELECT COUNT(*) counter FROM usr_session_stats_raw' .
            ' WHERE (end_time IS NULL OR end_time >= ' . $ilDB->quote($a_time, 'integer') . ')' .
            ' AND start_time <= ' . $ilDB->quote($a_time, 'integer') .
            ' AND ' . $ilDB->in('type', ilSessionControl::$session_types_controlled, false, 'integer');
        $res = $ilDB->query($sql);
        $row = $ilDB->fetchAssoc($res);
        return (int) $row['counter'];
    }

References $DIC, $ilDB, $res, and ilSessionControl\$session_types_controlled.

Referenced by aggregateRawHelper().

Here is the caller graph for this function:

◆ getNumberOfSessionsByType()

static ilSessionStatistics::getNumberOfSessionsByType	(	int	$a_from,
		int	$a_to
	)

static

Get session counters by type (opened, closed)

Definition at line 401 of file class.ilSessionStatistics.php.

                                                                            : array
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $sql = 'SELECT SUM(opened) opened, SUM(closed_manual) closed_manual,' .
            ' SUM(closed_expire) closed_expire,' .
            ' SUM(closed_login) closed_login, SUM(closed_misc) closed_misc' .
            ' FROM usr_session_stats' .
            ' WHERE slot_end > ' . $ilDB->quote($a_from, 'integer') .
            ' AND slot_begin < ' . $ilDB->quote($a_to, 'integer');
        $res = $ilDB->query($sql);
        return $ilDB->fetchAssoc($res);
    }

References $DIC, $ilDB, and $res.

Referenced by ilSessionStatisticsGUI\buildData().

Here is the caller graph for this function:

◆ getRawData()

static ilSessionStatistics::getRawData	(	int	$a_begin,
		int	$a_end
	)

staticprotected

Read raw data for timespan.

Definition at line 186 of file class.ilSessionStatistics.php.

                                                                  : array
    {
        global $DIC;
 
        $ilDB = $DIC['ilDB'];
 
        $sql = 'SELECT start_time,end_time,end_context FROM usr_session_stats_raw' .
            ' WHERE start_time <= ' . $ilDB->quote($a_end, 'integer') .
            ' AND (end_time IS NULL OR end_time >= ' . $ilDB->quote($a_begin, 'integer') . ')' .
            ' AND ' . $ilDB->in('type', ilSessionControl::$session_types_controlled, false, 'integer') .
            ' ORDER BY start_time';
        $res = $ilDB->query($sql);
        $all = [];
        while ($row = $ilDB->fetchAssoc($res)) {
            $all[] = $row;
        }
        return $all;
    }

References $DIC, $ilDB, $res, and ilSessionControl\$session_types_controlled.

◆ isActive()

static ilSessionStatistics::isActive ( )

static

Is session statistics active at all?

Definition at line 28 of file class.ilSessionStatistics.php.

                                     : bool
    {
        global $DIC;
 
        $ilSetting = $DIC['ilSetting'];
 
        return (bool) $ilSetting->get('session_statistics', '1');
    }

References $DIC, and $ilSetting.

Field Documentation

◆ SLOT_SIZE

const int ilSessionStatistics::SLOT_SIZE = 15

private

Definition at line 23 of file class.ilSessionStatistics.php.

Referenced by getCurrentSlot().

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

components/ILIAS/Authentication/classes/class.ilSessionStatistics.php

Static Public Member Functions

Static Protected Member Functions

Private Attributes

Detailed Description

Member Function Documentation

◆ aggregateRawHelper()

◆ aggretateRaw()

◆ closeRawEntry()

◆ createNewAggregationSlot()

◆ createRawEntry()

◆ deleteAggregatedRaw()

◆ getCurrentSlot()

◆ getLastAggregation()

◆ getNumberOfActiveRawSessions()

◆ getNumberOfSessionsByType()

◆ getRawData()

◆ isActive()

Field Documentation

◆ SLOT_SIZE