Ntp.Analyzer.Import.NtpqHostImporter Class Reference

Ntpq host importer. More...

Inheritance diagram for Ntp.Analyzer.Import.NtpqHostImporter:

Collaboration diagram for Ntp.Analyzer.Import.NtpqHostImporter:

Protected Member Functions
override void	Initialize ()
override void	ReadFromStream ()
Protected Member Functions inherited from Ntp.Analyzer.Import.Importer< HostReading >
	Importer (LogBase log)

Protected Attributes
override string	Arguments => "-nc kerninfo -c sysinfo " + address
override string	Command => "ntpq"
override string	ErrorMessage => LogMessage.ImportHostError
Protected Attributes inherited from Ntp.Analyzer.Import.Importer< HostReading >
IList< T >	Entries

Package Functions
	NtpqHostImporter (string address, Host host, ReadingBulk bulk, LogBase log)

Private Member Functions
void	CreateEntry (string peerIp, double offset, double jitter, double frequency, double stability)

Private Attributes
readonly string	address
readonly ReadingBulk	bulk
readonly Host	host
List< Peer >	peers

Additional Inherited Members
Public Member Functions inherited from Ntp.Analyzer.Import.Importer< HostReading >
void	Execute ()
IEnumerator< T >	GetEnumerator ()
Properties inherited from Ntp.Analyzer.Import.Importer< HostReading >
abstract string	Arguments [get]
abstract string	Command [get]
abstract string	ErrorMessage [get]
LogBase	Log [get]
StreamReader	Reader [get, private set]

Detailed Description

Ntpq host importer.

Definition at line 34 of file NtpqHostImporter.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Import.NtpqHostImporter.NtpqHostImporter ( string  address, Host  host, ReadingBulk  bulk, LogBase  log  )

inlinepackage

Definition at line 36 of file NtpqHostImporter.cs.

            : base(log)
        {
            this.address = address;
            this.host = host;
            this.bulk = bulk;
        }

Member Function Documentation

void Ntp.Analyzer.Import.NtpqHostImporter.CreateEntry ( string  peerIp, double  offset, double  jitter, double  frequency, double  stability  )

inlineprivate

Definition at line 112 of file NtpqHostImporter.cs.

References Ntp.Analyzer.Objects.NamedObject.Name.

        {
            IEnumerable<Peer> peerList = peers.Where(p => p.Ip == peerIp).ToList();

            Peer peer;

            switch (peerList.Count())
            {
                case 1:
                    peer = peerList.Single();
                    break;
                case 0:
                    Log.PeerNotFound(host.Name, peerIp);
                    return;
                default:
                    Log.MultiplePeersFound(host.Name, peerIp);
                    return;
            }

            Log.Syncing(host.Name, peer.Name);

            var reading = new HostReading(host, peer, bulk, offset, jitter, frequency, stability);
            Entries.Add(reading);
        }

override void Ntp.Analyzer.Import.NtpqHostImporter.Initialize ( )

inlineprotectedvirtual

Reimplemented from Ntp.Analyzer.Import.Importer< HostReading >.

Definition at line 55 of file NtpqHostImporter.cs.

References Ntp.Analyzer.Data.DataFace.Instance, and Ntp.Analyzer.Data.DataFace.Peers.

        {
            base.Initialize();

            if (host == null)
                return;

            peers = DataFace.Instance.Peers.ToList();
        }

override void Ntp.Analyzer.Import.NtpqHostImporter.ReadFromStream ( )

inlineprotectedvirtual

Implements Ntp.Analyzer.Import.Importer< HostReading >.

Definition at line 65 of file NtpqHostImporter.cs.

        {
            string peerIp = null;
            double offset = 0;
            double frequency = 0;
            double jitter = 0;
            double stability = 0;

            while (Reader.Peek() != -1)
            {
                string line = Reader.ReadLine();

                if (string.IsNullOrWhiteSpace(line) || line.Length < 24)
                    continue;

                string name = line.Substring(0, 19).Replace(":", string.Empty).TrimEnd();
                string value = line.Substring(19).Trim();

                switch (name)
                {
                    case "system peer":
                        peerIp = value.Replace(":123", string.Empty).Trim();
                        break;
                    case "pll offset":
                        offset = Convert.ToDouble(value.Replace("s", string.Empty).Trim());
                        break;
                    case "pll frequency":
                        frequency = Convert.ToDouble(value.Replace("ppm", string.Empty).Trim());
                        break;
                    case "clock jitter":
                        jitter = Convert.ToDouble(value.Replace("s", string.Empty).Trim());
                        break;
                    case "clock wander":
                        stability = Convert.ToDouble(value.Replace("ppm", string.Empty).Trim());
                        break;
                }
            }

            if (peerIp != null && peerIp.StartsWith("0.0.0.0"))
            {
                Log.NoSyncing(host.Name);
                return;
            }

            CreateEntry(peerIp, offset, jitter, frequency, stability);
        }

Member Data Documentation

readonly string Ntp.Analyzer.Import.NtpqHostImporter.address

private

Definition at line 44 of file NtpqHostImporter.cs.

override string Ntp.Analyzer.Import.NtpqHostImporter.Arguments => "-nc kerninfo -c sysinfo " + address

protected

Definition at line 51 of file NtpqHostImporter.cs.

readonly ReadingBulk Ntp.Analyzer.Import.NtpqHostImporter.bulk

private

Definition at line 45 of file NtpqHostImporter.cs.

override string Ntp.Analyzer.Import.NtpqHostImporter.Command => "ntpq"

protected

Definition at line 49 of file NtpqHostImporter.cs.

override string Ntp.Analyzer.Import.NtpqHostImporter.ErrorMessage => LogMessage.ImportHostError

protected

Definition at line 53 of file NtpqHostImporter.cs.

readonly Host Ntp.Analyzer.Import.NtpqHostImporter.host

private

Definition at line 46 of file NtpqHostImporter.cs.

List<Peer> Ntp.Analyzer.Import.NtpqHostImporter.peers

private

Definition at line 47 of file NtpqHostImporter.cs.

---

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

• Ntp.Analyzer.Import/NtpqHostImporter.cs