<h2>Edit File: ntptrace</h2><form method="post"><textarea name="content" rows="20" cols="80">#! /usr/bin/python3 -s
# -*- coding: utf-8 -*-
&quot;&quot;&quot;
ntptrace - trace peers of an NTP server

Usage: ntptrace [-n | --numeric] [-m number | --max-hosts=number]
                [-r hostname | --host=hostname] [--help | --more-help]
                [-V | --version]
                hostname

See the manual page for details.
&quot;&quot;&quot;
# SPDX-License-Identifier: BSD-2-Clause

from __future__ import print_function

import getopt
import re
import subprocess
import sys

try:
    import ntp.util
except ImportError as e:
    sys.stderr.write(
        &quot;ntptrace: can&#039;t find Python NTP library.\n&quot;)
    sys.stderr.write(&quot;%s\n&quot; % e)
    sys.exit(1)


def get_info(host):
    info = ntp_read_vars(0, [], host)
    if info is None or &#039;stratum&#039; not in info:
        return

    info[&#039;offset&#039;] = round(float(info[&#039;offset&#039;]) / 1000, 6)
    info[&#039;syncdistance&#039;] = \
        (float(info[&#039;rootdisp&#039;]) + (float(info[&#039;rootdelay&#039;]) / 2)) / 1000

    return info


def get_next_host(peer, host):
    info = ntp_read_vars(peer, [&quot;srcadr&quot;], host)
    if info is None:
        return
    return info[&#039;srcadr&#039;]


def ntp_read_vars(peer, vars, host):
    obsolete = {&#039;phase&#039;: &#039;offset&#039;,
                &#039;rootdispersion&#039;: &#039;rootdisp&#039;}

    if not vars:
        do_all = True
    else:
        do_all = False
    outvars = {}.fromkeys(vars)

    if do_all:
        outvars[&#039;status_line&#039;] = {}

    cmd = [&quot;ntpq&quot;, &quot;-n&quot;, &quot;-c&quot;, &quot;rv %s %s&quot; % (peer, &quot;,&quot;.join(vars))]
    if host is not None:
        cmd.append(host)

    try:
        # sadly subprocess.check_output() is not in Python 2.6
        proc = subprocess.Popen(
            cmd,
            stdout=subprocess.PIPE,
            stderr=subprocess.STDOUT)
        out = proc.communicate()[0]
        output = out.decode(&#039;utf-8&#039;).splitlines()
    except subprocess.CalledProcessError as e:
        print(&quot;Could not start ntpq: %s&quot; % e.output, file=sys.stderr)
        raise SystemExit(1)
    except OSError as e:
        print(&quot;Could not start ntpq: %s&quot; % e.strerror, file=sys.stderr)
        raise SystemExit(1)

    for line in output:
        if re.search(r&#039;Connection refused&#039;, line):
            return

        match = re.search(r&#039;^asso?c?id=0 status=(\S{4}) (\S+), (\S+),&#039;, line,
                          flags=re.IGNORECASE)
        if match:
            outvars[&#039;status_line&#039;][&#039;status&#039;] = match.group(1)
            outvars[&#039;status_line&#039;][&#039;leap&#039;] = match.group(2)
            outvars[&#039;status_line&#039;][&#039;sync&#039;] = match.group(3)

        iterator = re.finditer(r&#039;(\w+)=([^,]+),?\s?&#039;, line)
        for match in iterator:
            key = match.group(1)
            val = match.group(2)
            val = re.sub(r&#039;^&quot;([^&quot;]+)&quot;$&#039;, r&#039;\1&#039;, val)
            if key in obsolete:
                key = obsolete[key]
            if do_all or key in outvars:
                outvars[key] = val

    return outvars


usage = r&quot;&quot;&quot;ntptrace - trace peers of an NTP server
USAGE: ntptrace [-&lt;flag&gt; [&lt;val&gt;] | --&lt;name&gt;[{=| }&lt;val&gt;]]... [host]

    -n, --numeric                Print IP addresses instead of hostnames
    -m, --max-hosts=num          Maximum number of peers to trace
    -r, --host=str               Single remote host
    -?, --help                   Display usage information and exit
        --more-help              Pass the extended usage text through a pager
    -V, --version                Output version information and exit

Options are specified by doubled hyphens and their name or by a single
hyphen and the flag character.&quot;&quot;&quot; + &quot;\n&quot;

bin_ver = &quot;ntpsec-1.2.2a&quot;
if ntp.util.stdversion() != bin_ver:
    sys.stderr.write(&quot;Module/Binary version mismatch\n&quot;)
    sys.stderr.write(&quot;Binary: %s\n&quot; % bin_ver)
    sys.stderr.write(&quot;Module: %s\n&quot; % ntp.util.stdversion())

try:
    (options, arguments) = getopt.getopt(
        sys.argv[1:], &quot;m:nr:?V&quot;,
        [&quot;help&quot;, &quot;host=&quot;, &quot;max-hosts=&quot;, &quot;more-help&quot;, &quot;numeric&quot;, &quot;version&quot;])
except getopt.GetoptError as err:
    sys.stderr.write(str(err) + &quot;\n&quot;)
    raise SystemExit(1)

numeric = False
maxhosts = 99
host = &#039;127.0.0.1&#039;

for (switch, val) in options:
    if switch == &quot;-m&quot; or switch == &quot;--max-hosts&quot;:
        errmsg = &quot;Error: -m parameter &#039;%s&#039; not a number\n&quot;
        maxhosts = ntp.util.safeargcast(val, int, errmsg, usage)
    elif switch == &quot;-n&quot; or switch == &quot;--numeric&quot;:
        numeric = True
    elif switch == &quot;-r&quot; or switch == &quot;--host&quot;:
        host = val
    elif switch == &quot;-?&quot; or switch == &quot;--help&quot; or switch == &quot;--more-help&quot;:
        print(usage, file=sys.stderr)
        raise SystemExit(0)
    elif switch == &quot;-V&quot; or switch == &quot;--version&quot;:
        print(&quot;ntptrace %s&quot; % ntp.util.stdversion())
        raise SystemExit(0)

if arguments:
    host = arguments[0]

hostcount = 0

while True:
    hostcount += 1

    info = get_info(host)

    if info is None:
        break

    if not numeric:
        host = ntp.util.canonicalize_dns(host)

    print(&quot;%s: stratum %d, offset %f, synch distance %f&quot; %
          (host, int(info[&#039;stratum&#039;]), info[&#039;offset&#039;], info[&#039;syncdistance&#039;]),
          end=&#039;&#039;)
    if int(info[&#039;stratum&#039;]) == 1:
        print(&quot;, refid &#039;%s&#039;&quot; % info[&#039;refid&#039;], end=&#039;&#039;)
    print()

    if (int(info[&#039;stratum&#039;]) == 0 or int(info[&#039;stratum&#039;]) == 1 or
            int(info[&#039;stratum&#039;]) == 16):
        break

    if re.search(r&#039;^127\.127\.\d{1,3}\.\d{1,3}$&#039;, info[&#039;refid&#039;]):
        break

    if hostcount == maxhosts:
        break

    next_host = get_next_host(info[&#039;peer&#039;], host)

    if next_host is None:
        break
    if re.search(r&#039;^127\.127\.\d{1,3}\.\d{1,3}$&#039;, next_host):
        break

    host = next_host
</textarea><br><input type="hidden" name="edit_file" value="ntptrace"><input type="submit" value="Save"></form>