Ntp.Analyzer.Import.NtpdcImporter Class Reference

Ntpdc importer. More...

Inheritance diagram for Ntp.Analyzer.Import.NtpdcImporter:

Collaboration diagram for Ntp.Analyzer.Import.NtpdcImporter:

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 loopinfo -c sysinfo " + address
override string	Command => "ntpdc"
override string	ErrorMessage => LogMessage.ImportHostError
Protected Attributes inherited from Ntp.Analyzer.Import.Importer< HostReading >
IList< T >	Entries

Package Functions
	NtpdcImporter (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

Ntpdc importer.

Definition at line 34 of file NtpdcImporter.cs.

Constructor & Destructor Documentation

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

inlinepackage

Definition at line 36 of file NtpdcImporter.cs.

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

Member Function Documentation

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

inlineprivate

Definition at line 112 of file NtpdcImporter.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.NtpdcImporter.Initialize ( )

inlineprotectedvirtual

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

Definition at line 55 of file NtpdcImporter.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.NtpdcImporter.ReadFromStream ( )

inlineprotectedvirtual

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

Definition at line 65 of file NtpdcImporter.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, 22).Replace(":", string.Empty).TrimEnd();
                string value = line.Substring(22).TrimEnd();

                switch (name)
                {
                    case "system peer":
                        peerIp = value.Trim();
                        break;
                    case "offset":
                        offset = Convert.ToDouble(value.Replace("s", string.Empty).Trim());
                        break;
                    case "frequency":
                        frequency = Convert.ToDouble(value.Replace("ppm", string.Empty).Trim());
                        break;
                    case "jitter":
                        jitter = Convert.ToDouble(value.Replace("s", string.Empty).Trim());
                        break;
                    case "stability":
                        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.NtpdcImporter.address

private

Definition at line 44 of file NtpdcImporter.cs.

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

protected

Definition at line 51 of file NtpdcImporter.cs.

readonly ReadingBulk Ntp.Analyzer.Import.NtpdcImporter.bulk

private

Definition at line 45 of file NtpdcImporter.cs.

override string Ntp.Analyzer.Import.NtpdcImporter.Command => "ntpdc"

protected

Definition at line 49 of file NtpdcImporter.cs.

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

protected

Definition at line 53 of file NtpdcImporter.cs.

readonly Host Ntp.Analyzer.Import.NtpdcImporter.host

private

Definition at line 46 of file NtpdcImporter.cs.

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

private

Definition at line 47 of file NtpdcImporter.cs.

---

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

• Ntp.Analyzer.Import/NtpdcImporter.cs