<h2>Edit File: ntpwait</h2><form method="post"><textarea name="content" rows="20" cols="80">#! /usr/bin/python3 -s
# -*- coding: utf-8 -*-
&quot;&quot;&quot;\
ntpwait - Wait for ntpd to stabilize the system clock.
USAGE: ntpwait [-n tries] [-s sleeptime] [-v] [-h]

    -n, --tries=num              Number of times to check ntpd
    -s, --sleep=num              How long to sleep between tries
    -v, --verbose                Be verbose
    -h, --help                   Issue help
    -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.

A spurious &#039;not running&#039; message can result from queries being disabled.
&quot;&quot;&quot;
# SPDX-License-Identifier: BSD-2-Clause

# Because we&#039;ve actually seen this fail on a ^C during import of ntp.packet.
import signal
import sys
signal.signal(signal.SIGINT, lambda signal, frame: sys.exit(2))

import getopt
import re
import time
import socket

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


class Unbuffered(object):
    def __init__(self, stream):
        self.stream = stream

    def write(self, data):
        self.stream.write(data)
        self.stream.flush()

    def __getattr__(self, attr):
        return getattr(self.stream, attr)


if __name__ == &quot;__main__&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;hn:s:vV&quot;, [
            &quot;tries=&quot;, &quot;sleep=&quot;, &quot;verbose&quot;, &quot;help&quot;, &quot;version&quot;
        ])
    except getopt.GetoptError as err:
        sys.stderr.write(str(err) + &quot;\n&quot;)
        raise SystemExit(2)
    tries = 100
    sleep = 6
    verbose = 0
    for (switch, val) in options:
        if switch in (&quot;-n&quot;, &quot;--tries&quot;):
            errmsg = &quot;Error: -n parameter &#039;%s&#039; not a number\n&quot;
            tries = ntp.util.safeargcast(val, int, errmsg, __doc__)
        elif switch in (&quot;-s&quot;, &quot;--sleep&quot;):
            errmsg = &quot;Error: -s parameter &#039;%s&#039; not a number\n&quot;
            sleep = ntp.util.safeargcast(val, int, errmsg, __doc__)
        elif switch in (&quot;-v&quot;, &quot;--verbose&quot;):
            verbose += 1
        elif switch in (&quot;-h&quot;, &quot;--help&quot;):
            sys.stdout.write(__doc__)
            raise SystemExit(0)
        elif switch in (&quot;-V&quot;, &quot;--version&quot;):
            print(&quot;ntpwait %s&quot; % ntp.util.stdversion())
            raise SystemExit(0)

    # Autoflush stdout
    sys.stdout = Unbuffered(sys.stdout)

    basetime = ntp.util.monoclock()
    if verbose:
        sys.stdout.write(&quot;Waiting for ntpd to synchronize...  &quot;)

    for i in range(1, tries):
        session = ntp.packet.ControlSession()
        # session.debug = 4
        if not session.openhost(&quot;localhost&quot;):
            if verbose:
                sys.stdout.write(&quot;\bntpd is not running!\n&quot;)
            continue

        msg = None
        try:
            msg = session.doquery(2)     # Request system variables
        except ntp.packet.ControlException as e:
            sys.stderr.write(&quot;localhost: timed out, nothing received\n&quot;)
            sys.stderr.write(e.message)
        except socket.error:
            if verbose:
                sys.stdout.write(&quot;\b&quot; + &quot;*+:.&quot;[i % 4])
            time.sleep(sleep)
            continue

        if verbose &gt;= 2:
            sys.stderr.write(repr(session.response) + &quot;\n&quot;)

        if msg and msg.startswith(&quot;***&quot;):
            if verbose:
                sys.stdout.write(&quot;\b&quot; + msg + &quot;\n&quot;)
            sys.exit(1)

        m = re.search(r&quot;leap=([^,]*),&quot;, repr(session.response))
        if m:
            leap = int(m.group(1))
        else:
            sys.stdout.write(&quot;\bLeap status not available\n&quot;)
            sys.exit(1)

        if leap == ntp.magic.LEAP_NOTINSYNC:
            if verbose:
                sys.stdout.write(&quot;\b&quot; + &quot;*+:.&quot;[i % 4])
            if i &lt; tries:
                time.sleep(sleep)
            continue

        if leap in (ntp.magic.LEAP_NOWARNING, ntp.magic.LEAP_ADDSECOND,
                    ntp.magic.LEAP_DELSECOND):
            # We could check &quot;sync&quot; here to make sure we like the source...
            if verbose:
                sys.stdout.write(&quot;\bOK! (%.1f seconds)\n&quot; %
                                 (ntp.util.monoclock() - basetime))
            sys.exit(0)

        sys.stdout.write(&quot;\bUnexpected &#039;leap&#039; status &lt;%s&gt;\n&quot; % leap)
        sys.exit(1)

    if verbose:
        sys.stdout.write(&quot;\bNo!\nntpd did not synchronize.\n&quot;)
    sys.exit(1)

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