Ntp.Analyzer.Import.NtpctlHostImporter Class Reference

Inheritance diagram for Ntp.Analyzer.Import.NtpctlHostImporter:

Collaboration diagram for Ntp.Analyzer.Import.NtpctlHostImporter:

Protected Member Functions
override void	Initialize ()
override void	ReadFromStream ()
Protected Member Functions inherited from Ntp.Analyzer.Import.NtpctlImporter< HostReading >
	NtpctlImporter (int hostId, LogBase log)
AssociationEntry	ParseLines (string peer, string stats)

Protected Attributes
override string	ErrorMessage => LogMessage.ImportHostError
Protected Attributes inherited from Ntp.Analyzer.Import.NtpctlImporter< HostReading >
override string	Arguments
override string	Command

Package Functions
	NtpctlHostImporter (Host host, ReadingBulk bulk, LogBase log)

Private Member Functions
void	CreateEntry (AssociationEntry entry)

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

Detailed Description

Definition at line 30 of file NtpctlHostImporter.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Import.NtpctlHostImporter.NtpctlHostImporter ( Host  host, ReadingBulk  bulk, LogBase  log  )

inlinepackage

Definition at line 32 of file NtpctlHostImporter.cs.

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

Member Function Documentation

void Ntp.Analyzer.Import.NtpctlHostImporter.CreateEntry ( AssociationEntry  entry )

inlineprivate

Definition at line 78 of file NtpctlHostImporter.cs.

References Ntp.Analyzer.Objects.AssociationEntry.Jitter, Ntp.Analyzer.Objects.NamedObject.Name, Ntp.Analyzer.Objects.AssociationEntry.Offset, and Ntp.Analyzer.Objects.AssociationEntry.Remote.

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

            Peer peer;

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

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

            var reading = new HostReading(host, peer, bulk, entry.Offset, entry.Jitter);
            Entries.Add(reading);
        }

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

inlineprotected

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

inlineprotected

Definition at line 55 of file NtpctlHostImporter.cs.

        {
            // Skip header
            Reader.ReadLine();
            Reader.ReadLine();

            // Find SysPeer
            while (Reader.Peek() != -1)
            {
                string peer = Reader.ReadLine();
                string stat = Reader.ReadLine();
                var entry = ParseLines(peer, stat);

                if (entry.TallyCode != TallyCode.SysPeer)
                    continue;

                CreateEntry(entry);
                return;
            }

            Log.OpenNtpUnsynced();
        }

Member Data Documentation

readonly ReadingBulk Ntp.Analyzer.Import.NtpctlHostImporter.bulk

private

Definition at line 39 of file NtpctlHostImporter.cs.

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

protected

Definition at line 43 of file NtpctlHostImporter.cs.

readonly Host Ntp.Analyzer.Import.NtpctlHostImporter.host

private

Definition at line 40 of file NtpctlHostImporter.cs.

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

private

Definition at line 41 of file NtpctlHostImporter.cs.

---

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

• Ntp.Analyzer.Import/NtpctlHostImporter.cs