<h2>Edit File: ntpsweep</h2><form method="post"><textarea name="content" rows="20" cols="80">#! /usr/bin/python3 -s
# -*- coding: utf-8 -*-
&quot;&quot;&quot;
ntpsweep - print various information about given NTP servers
USAGE: ntpsweep [-&lt;flag&gt; [&lt;val&gt;] | --&lt;name&gt;[{=| }&lt;val&gt;]]... [hostfile]

    -h, --host=str             Host to execute actions on
    -l, --host-list=str        Comma-delimited list of Hosts to
                                   execute actions on
    -p, --peers                Recursively list all peers a host syncs to
    -m, --maxlevel=num         Traverse peers up to this level
                                   (4 is a reasonable number)
    -s, --strip=str            Strip this string from hostnames
    -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;
# SPDX-License-Identifier: BSD-2-Clause
#
# Python translation by ESR of a Perl script written long ago by
# Hans Lambermont &lt;ntpsweep@lambermont.dyndns.org&gt;
#
# It is unclear how useful this will be under modern conditions (e.g. most
# hosts refuse to be queried, and requests to them will just time out).

from __future__ import print_function

import os
import sys
import getopt

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


def ntp_peers(host):
    &quot;&quot;&quot;Return: a list of peer IP addrs for a specified host,
            empty list if query failed.
    &quot;&quot;&quot;
    try:
        with os.popen(&quot;ntpq -npw &quot; + host) as rp:
            hostlines = rp.readlines()[2:]      # Drop display header
            # Strip tally mark from first field
            return [ln.split()[0][1:] for
                    ln in hostlines if ln[0] in &quot; x.-+#*o&quot;]
    except OSError:
        return []


def scan_host(host, level):
    stratum = 0
    offset = 0
    daemonversion = &quot;&quot;
    system = &quot;&quot;
    processor = &quot;&quot;
    known_host = False

    if host in known_host_info:
        known_host = True
    else:
        session = ntp.packet.ControlSession()
        session.openhost(host)
        sysvars = session.readvar()

        # got answers ? If so, go on.
        if isinstance(sysvars, dict):
            stratum = sysvars[&#039;stratum&#039;]
            offset = sysvars[&#039;offset&#039;]
            daemonversion = sysvars[&#039;version&#039;]
            system = sysvars[&#039;system&#039;]
            processor = sysvars[&#039;processor&#039;]

            # Shorten daemon_version string.
            # daemonversion =~ s/(|Mon|Tue|Wed|Thu|Fri|Sat|Sun).*$//
            daemonversion = daemonversion.replace(&quot;version=&quot;, &quot;&quot;)
            daemonversion = daemonversion.replace(&quot;ntpd &quot;, &quot;&quot;)
            daemonversion = daemonversion.replace(&quot;(&quot;, &quot;&quot;).replace(&quot;)&quot;, &quot;&quot;)
            daemonversion = daemonversion.replace(&quot;beta&quot;, &quot;b&quot;)
            daemonversion = daemonversion.replace(&quot;multicast&quot;, &quot;mc&quot;)

            # Shorten system string. Note, the assumptions here
            # are very old, reflecting ancient big-iron Unixes
            system = system.replace(&quot;UNIX/&quot;, &quot;&quot;)
            system = system.replace(&quot;RELEASE&quot;, &quot;r&quot;)
            system = system.replace(&quot;CURRENT&quot;, &quot;c&quot;)

            # Shorten processor string
            processor = processor.replace(&quot;unknown&quot;, &quot;&quot;)

        # got answers ? If so, go on.
        if daemonversion and recurse:
            # Consider doing something more intelligent on failure
            # than simply returning an empty list.  Though it might
            # be the right thing to do under modern conditions in
            # which most hosts will refuse to be queried.
            known_host_peers[host] = ntp_peers(host)

        # Collect info on host
        if stratum:
            known_host_info[host] = &quot;%2d %9.3f %-11s %-12s %s&quot;  \
                                    % (stratum, offset, daemonversion[:11],
                                       system[:12], processor[0:9])
        else:
            # Stratum level 0 is considered invalid
            known_host_info[host] = &quot; ?&quot;

    if stratum or known_host:   # Valid or known host
        printhost = (&#039; &#039; * level) + (ntp.util.canonicalize_dns(host) or host)
        # Shorten host string
        if strip:
            printhost = printhost.replace(strip, &quot;&quot;)
        # append number of peers in brackets if requested and valid
        if (recurse and (known_host_info[host] != &quot; ?&quot;) and
           (host in known_host_peers)):
            printhost += &quot; (%d)&quot; % len(known_host_peers[host])
        # Finally print complete host line
        print(&quot;%-32s %s&quot; % (printhost[:32], known_host_info[host]))
        if recurse and (maxlevel == 0 or level &lt; maxlevel):
            trace.append(host)
            # Loop through peers
            for peer in known_host_peers[host]:
                if peer in trace:
                    # we&#039;ve detected a loop!
                    printhost = (&#039; &#039; * (level + 1)) + &quot;= &quot; + peer
                    # Shorten host string
                    if strip:
                        printhost = printhost.replace(strip, &quot;&quot;)
                    print(&quot;%-32s&quot; % printhost[:32])
                else:
                    # FIXME: Ugh! Magic-address assumption.
                    # Needed to deal with peers running legacy NTP.
                    # Might cause problems in the future.  First
                    # part of the guard is an attempt to skip
                    # NTPsec-style clock IDs.
                    if peer[0].isdigit() and not peer.startswith(&quot;127&quot;):
                        scan_host(peer, level + 1)
    else:   # We did not get answers from this host
        printhost = (&#039; &#039; * level) + (ntp.util.canonicalize_dns(host) or host)
        if strip:
            printhost = printhost.replace(strip, &quot;&quot;)
        print(&quot;%-32s  ?&quot; % printhost[:32])


if __name__ == &#039;__main__&#039;:
    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;h:l:m:ps:?V&quot;,
            [&quot;host=&quot;, &quot;host-list=&quot;, &quot;maxlevel=&quot;, &quot;peers&quot;, &quot;strip=&quot;, &quot;version&quot;])
    except getopt.GetoptError as err:
        sys.stderr.write(str(err) + &quot;\n&quot;)
        raise SystemExit(1)
    hostlist = []
    maxlevel = 1
    recurse = False
    strip = &quot;&quot;
    for (switch, val) in options:
        if switch == &quot;-h&quot; or switch == &quot;--host&quot;:
            hostlist = [val]
        elif switch == &quot;-l&quot; or switch == &quot;--host-list&quot;:
            hostlist = val.split(&quot;,&quot;)
        elif switch == &quot;-m&quot; or switch == &quot;--maxlevel&quot;:
            errmsg = &quot;Error: -m parameter &#039;%s&#039; not a number\n&quot;
            maxlevel = ntp.util.safeargcast(val, int, errmsg, __doc__)
        elif switch == &quot;-p&quot; or switch == &quot;--peers&quot;:
            recurse = True
        elif switch == &quot;-s&quot; or switch == &quot;--strip&quot;:
            strip = val
        elif switch == &quot;-?&quot; or switch == &quot;--help&quot;:
            print(__doc__, file=sys.stderr)
            raise SystemExit(0)
        elif switch == &quot;-V&quot; or switch == &quot;--version&quot;:
            print(&quot;ntpsweep %s&quot; % ntp.util.stdversion())
            raise SystemExit(0)

    try:
        if arguments:
            hostlist += [ln.strip() for ln in open(arguments[0]).readlines()]
    except IOError:
        sys.stderr.write(&quot;Host file not found.\n&quot;)
        raise SystemExit(1)

    if not hostlist:
        hostlist = [&quot;localhost&quot;]

    # Print header
    print(&quot;&quot;&quot;\
Host                             st offset(s) version     system       processor
--------------------------------+--+---------+-----------+------------+---------\
&quot;&quot;&quot;)

    known_host_info = {}
    known_host_peers = {}
    trace = []
    for host in hostlist:
        try:
            scan_host(host, 0)
        except ntp.packet.ControlException as e:
            sys.stderr.write(e.message + &quot;\n&quot;)
            continue
    sys.exit(0)

# end
</textarea><br><input type="hidden" name="edit_file" value="ntpsweep"><input type="submit" value="Save"></form>