Ntp.Analyzer.Process.Description.PeerStatJob Class Reference

Job which read statistics about peers and saves the result to a database. More...

Inheritance diagram for Ntp.Analyzer.Process.Description.PeerStatJob:

Collaboration diagram for Ntp.Analyzer.Process.Description.PeerStatJob:

Public Member Functions
	PeerStatJob (StatConfiguration config, LogBase log)
Public Member Functions inherited from Ntp.Common.Process.JobDescription
override string	ToString ()
	Returns a string that represents the current JobDescription. More...

Public Attributes
override string	JobType => "Peer statistics"
override int	Priority => 2
override ThreadType	ThreadType => ThreadType.MultiThreaded
Public Attributes inherited from Ntp.Common.Process.JobDescription
string	Name => Configuration.ConfigName
	Gets the name. More...

Protected Member Functions
override void	InternalExecute ()
	Implementing method for descendants. More...
Protected Member Functions inherited from Ntp.Common.Process.JobDescription
	JobDescription (IJobConfiguration config, LogBase log)
	Initializes a new instance of the JobDescription class. More...

Private Member Functions
void	Import ()
	Import statistics. More...
void	Initialize ()
	Initialize database context. More...
void	SaveResult ()
	Saves the result of the import to database. More...

Private Attributes
readonly List< PeerActivity >	activities
readonly StatConfiguration	config
readonly List< AssociationEntry >	entries
Host	host
List< Peer >	peers
readonly List< PeerReading >	readings

Additional Inherited Members
Package Functions inherited from Ntp.Common.Process.JobDescription
void	Execute ()
	Perform execution of this instance. More...
Properties inherited from Ntp.Common.Process.JobDescription
IJobConfiguration	Configuration [get]
	Gets the configuration for the job. More...
abstract string	JobType [get]
	Gets the type of the job as text. More...
LogBase	Log [get]
	Gets the log to use when registering events. More...
abstract int	Priority [get]
	Gets the priority to use when scheduling jobs. More...
abstract ThreadType	ThreadType [get]
	Gets a value indicating whether this JobDescription should run as a single thread. More...

Detailed Description

Job which read statistics about peers and saves the result to a database.

Definition at line 38 of file PeerStatJob.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Process.Description.PeerStatJob.PeerStatJob ( StatConfiguration  config, LogBase  log  )

inline

Definition at line 40 of file PeerStatJob.cs.

            : base(config, log)
        {
            this.config = config;
            readings = new List<PeerReading>();
            activities = new List<PeerActivity>();
            entries = new List<AssociationEntry>();
        }

Member Function Documentation

void Ntp.Analyzer.Process.Description.PeerStatJob.Import ( )

inlineprivate

Import statistics.

Definition at line 80 of file PeerStatJob.cs.

References a, b, Ntp.Analyzer.Import.ImportFactory.CreatePeerImporter(), e, Ntp.Analyzer.Import.Importer< T >.Execute(), Ntp.Analyzer.Data.DataFace.Instance, Ntp.Analyzer.Objects.NamedObject.Name, Ntp.Analyzer.Data.DataFace.PeerActivities, and Ntp.Analyzer.Data.DataFace.ReadingBulks.

        {
            var bulk = config.Bulk == null
                ? new ReadingBulk(host.Name, config.TimeStamp)
                : DataFace.Instance.ReadingBulks.Single(b => b.Name == config.Bulk.Name);

            var importer = ImportFactory.CreatePeerImporter(config.ServerName, config.ServerType, host, Log);
            entries.AddRange(importer);

            // Read values
            try
            {
                importer.Execute();
            }
            catch (Exception e)
            {
                Log.PeerImportError(e);
                return;
            }

            // Generate statistics
            foreach (var entry in entries)
            {
                // Find peer in database.
                var currentEntry = entry;
                IEnumerable<Peer> peerList = peers.Where(p => p.Ip == currentEntry.Remote).ToList();
                Peer peer;

                if (peerList.Count() == 1)
                {
                    peer = peerList.Single();
                }
                else if (!peerList.Any())
                {
                    Log.PeerIpNotFound(entry);
                    continue;
                }
                else
                {
                    Log.PeerIpAmbiguous(entry);
                    continue;
                }

                var reading = new PeerReading(host, peer, bulk, entry);
                readings.Add(reading);

                // Update timestamp
                var activity = DataFace.Instance.PeerActivities.
                    SingleOrDefault(a => Equals(a.Host, reading.Host) && Equals(a.Peer, reading.Peer));

                if (activity != null)
                {
                    activity.LastActive = bulk.Time;
                }
                else
                {
                    activity = new PeerActivity(reading.Peer, host, bulk.Time);
                }

                activities.Add(activity);
            }
        }

Here is the call graph for this function:

void Ntp.Analyzer.Process.Description.PeerStatJob.Initialize ( )

inlineprivate

Initialize database context.

Definition at line 146 of file PeerStatJob.cs.

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

        {
            // Clear any previous readings
            entries.Clear();
            readings.Clear();
            activities.Clear();

            peers = DataFace.Instance.Peers.ToList();
            host = DataFace.Instance.Hosts.SingleOrDefault(h => h.Id == config.HostId);

            if (host == null)
            {
                Log.HostNotFound(config.HostId);
            }
        }

override void Ntp.Analyzer.Process.Description.PeerStatJob.InternalExecute ( )

inlineprotectedvirtual

Implementing method for descendants.

Implements Ntp.Common.Process.JobDescription.

Definition at line 63 of file PeerStatJob.cs.

References e.

        {
            try
            {
                Initialize();
                Import();
                SaveResult();
            }
            catch (Exception e)
            {
                Log.PeerImportError(e);
            }
        }

void Ntp.Analyzer.Process.Description.PeerStatJob.SaveResult ( )

inlineprivate

Saves the result of the import to database.

Definition at line 165 of file PeerStatJob.cs.

References Ntp.Analyzer.Data.DataFace.AssociationEntries, Ntp.Analyzer.Data.DataFace.Instance, Ntp.Analyzer.Data.DataFace.PeerActivities, and Ntp.Analyzer.Data.DataFace.PeerReadings.

        {
            foreach (var reading in readings)
            {
                DataFace.Instance.PeerReadings.Save(reading);
            }

            foreach (var activity in activities)
            {
                DataFace.Instance.PeerActivities.Save(activity);
            }

            foreach (var entry in entries)
            {
                DataFace.Instance.AssociationEntries.Delete(entry.Remote, entry.HostId);
                DataFace.Instance.AssociationEntries.Save(entry);
            }
        }

Member Data Documentation

readonly List<PeerActivity> Ntp.Analyzer.Process.Description.PeerStatJob.activities

private

Definition at line 49 of file PeerStatJob.cs.

readonly StatConfiguration Ntp.Analyzer.Process.Description.PeerStatJob.config

private

Definition at line 51 of file PeerStatJob.cs.

readonly List<AssociationEntry> Ntp.Analyzer.Process.Description.PeerStatJob.entries

private

Definition at line 52 of file PeerStatJob.cs.

Host Ntp.Analyzer.Process.Description.PeerStatJob.host

private

Definition at line 54 of file PeerStatJob.cs.

override string Ntp.Analyzer.Process.Description.PeerStatJob.JobType => "Peer statistics"

Definition at line 59 of file PeerStatJob.cs.

List<Peer> Ntp.Analyzer.Process.Description.PeerStatJob.peers

private

Definition at line 55 of file PeerStatJob.cs.

override int Ntp.Analyzer.Process.Description.PeerStatJob.Priority => 2

Definition at line 61 of file PeerStatJob.cs.

readonly List<PeerReading> Ntp.Analyzer.Process.Description.PeerStatJob.readings

private

Definition at line 53 of file PeerStatJob.cs.

override ThreadType Ntp.Analyzer.Process.Description.PeerStatJob.ThreadType => ThreadType.MultiThreaded

Definition at line 57 of file PeerStatJob.cs.

---

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

• Ntp.Analyzer.Process/Description/PeerStatJob.cs