pbot/PBot/LagChecker.pm

# File: LagChecker.pm
# Author: pragma_
#
# Purpose: sends PING command to IRC server and times duration for PONG reply in
# order to maintain lag history and average.

# This Source Code Form is subject to the terms of the Mozilla Public
# License, v. 2.0. If a copy of the MPL was not distributed with this
# file, You can obtain one at http://mozilla.org/MPL/2.0/.

package PBot::LagChecker;

use parent 'PBot::Class';

use warnings; use strict;
use feature 'unicode_strings';

use Time::HiRes qw(gettimeofday tv_interval);
use Time::Duration;

sub initialize {
    my ($self, %conf) = @_;
    $self->{lag_average}    = undef;    # average of entries in lag history, in seconds
    $self->{lag_string}     = undef;    # string representation of lag history and lag average
    $self->{lag_history}    = [];       # history of previous PING/PONG timings
    $self->{pong_received}  = undef;    # tracks pong replies; undef if no ping sent; 0 if ping sent but no pong reply yet; 1 if ping/pong completed
    $self->{ping_send_time} = undef;    # when last ping was sent

    # maximum number of lag history entries to retain
    $self->{pbot}->{registry}->add_default('text', 'lagchecker', 'lag_history_max', $conf{lag_history_max} // 3);

    # lagging is true if lag_average reaches or exceeds this threshold, in milliseconds
    $self->{pbot}->{registry}->add_default('text', 'lagchecker', 'lag_threshold', $conf{lag_threshhold} // 2000);

    # how often to send PING, in seconds
    $self->{pbot}->{registry}->add_default('text', 'lagchecker', 'lag_history_interval', $conf{lag_history_interval} // 10);

    $self->{pbot}->{registry}->add_trigger('lagchecker', 'lag_history_interval', sub { $self->lag_history_interval_trigger(@_) });

    $self->{pbot}->{timer}->register(
        sub { $self->send_ping },
        $self->{pbot}->{registry}->get_value('lagchecker', 'lag_history_interval'),
        'lag check'
    );

    $self->{pbot}->{commands}->register(sub { $self->lagcheck(@_) }, "lagcheck", 0);
    $self->{pbot}->{event_dispatcher}->register_handler('irc.pong', sub { $self->on_pong(@_) });
}

sub lag_history_interval_trigger {
    my ($self, $section, $item, $newvalue) = @_;
    $self->{pbot}->{timer}->update_interval('lag check', $newvalue);
}

sub send_ping {
    my $self = shift;
    return unless defined $self->{pbot}->{conn};
    $self->{ping_send_time} = [gettimeofday];
    $self->{pong_received}  = 0;
    $self->{pbot}->{conn}->sl("PING :lagcheck");
}

sub on_pong {
    my $self = shift;

    $self->{pong_received} = 1;

    my $elapsed = tv_interval($self->{ping_send_time});
    push @{$self->{lag_history}}, [$self->{ping_send_time}[0], $elapsed * 1000];

    my $len = @{$self->{lag_history}};

    my $lag_history_max = $self->{pbot}->{registry}->get_value('lagchecker', 'lag_history_max');

    while ($len > $lag_history_max) {
        shift @{$self->{lag_history}};
        $len--;
    }

    $self->{lag_string} = "";
    my $comma = "";

    my $lag_total = 0;
    foreach my $entry (@{$self->{lag_history}}) {
        my ($send_time, $lag_result) = @$entry;

        $lag_total += $lag_result;
        my $ago = concise ago(gettimeofday - $send_time);
        $self->{lag_string} .= $comma . "[$ago] " . sprintf "%.1f ms", $lag_result;
        $comma = "; ";
    }

    $self->{lag_average} = $lag_total / $len;
    $self->{lag_string} .= "; average: " . sprintf "%.1f ms", $self->{lag_average};
    return 0;
}

sub lagging {
    my $self = shift;

    if (defined $self->{pong_received} and $self->{pong_received} == 0) {
        # a ping has been sent (pong_received is not undef) and no pong has been received yet
        my $elapsed = tv_interval($self->{ping_send_time});
        return $elapsed >= $self->{pbot}->{registry}->get_value('lagchecker', 'lag_threshold');
    }

    return 0 if not defined $self->{lag_average};
    return $self->{lag_average} >= $self->{pbot}->{registry}->get_value('lagchecker', 'lag_threshold');
}

sub lagstring {
    my $self = shift;
    my $lag  = $self->{lag_string} || "initializing";
    return $lag;
}

sub lagcheck {
    my ($self, $from, $nick, $user, $host, $arguments) = @_;

    if (defined $self->{pong_received} and $self->{pong_received} == 0) {
        # a ping has been sent (pong_received is not undef) and no pong has been received yet
        my $elapsed   = tv_interval($self->{ping_send_time});
        my $lag_total = $elapsed;
        my $len       = @{$self->{lag_history}};

        my $lagstring = "";
        my $comma     = "";

        foreach my $entry (@{$self->{lag_history}}) {
            my ($send_time, $lag_result) = @$entry;
            $lag_total += $lag_result;
            my $ago = concise ago(gettimeofday - $send_time);
            $lagstring .= $comma . "[$ago] " . sprintf "%.1f ms", $lag_result;
            $comma = "; ";
        }

        $lagstring .= $comma . "[waiting for pong] $elapsed";

        my $average = $lag_total / ($len + 1);
        $lagstring .= "; average: " . sprintf "%.1f ms", $average;
        return $lagstring;
    }

    return "My lag: " . $self->lagstring;
}

1;