Inheritance diagram for Ntp.Analyzer.Graph.PeerGraph:

Collaboration diagram for Ntp.Analyzer.Graph.PeerGraph:

[legend]

Public Member Functions
	PeerGraph (IPeerGraphConfiguration configuration, Host host, Peer peer)

Public Member Functions inherited from Ntp.Analyzer.Graph.GraphBase
Stream	Generate ()

Stream	Render ()

Protected Member Functions
override void	AddPlots ()

override void	LoadData ()

override void	PreRender ()

Protected Member Functions inherited from Ntp.Analyzer.Graph.DispersionGraph
	DispersionGraph (IDispersionGraphConfiguration configuration)

Protected Member Functions inherited from Ntp.Analyzer.Graph.GraphBase
	GraphBase (IGraphBaseConfiguration baseConfig)

LinePlot	SetupPlot (string name, Color color, IList time, IList data)

Protected Attributes
override string	YLabel => "Milliseconds"

Protected Attributes inherited from Ntp.Analyzer.Graph.DispersionGraph
readonly List< double >	Jitter

readonly List< double >	Offset

readonly List< DateTime >	Time

Protected Attributes inherited from Ntp.Analyzer.Graph.GraphBase
TimeSpan	GraphTimeSpan => new TimeSpan(baseConfig.Timespan, 0, 0, 0)

Private Member Functions
void	CleanSeries ()
	Cleans the value series from values out side boundaries. More...

Private Attributes
readonly List< double >	balance = new List<double>()

readonly IPeerGraphConfiguration	config

readonly List< double >	delay = new List<double>()

readonly Host	host

readonly Peer	peer

readonly Dictionary< DateTime, HostReading >	timedReading

Additional Inherited Members
Public Attributes inherited from Ntp.Analyzer.Graph.GraphBase
IEnumerable< StreamDestination >	Destinations => destinations

string	ImageFileExtension => "png"

Properties inherited from Ntp.Analyzer.Graph.GraphBase
PlotSurface2D	Surface `[get, private set]`

abstract string	YLabel `[get]`

Properties inherited from Ntp.Analyzer.Export.IStreamGenerator
IEnumerable< StreamDestination >	Destinations `[get]`

Detailed Description

Definition at line 33 of file PeerGraph.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Graph.PeerGraph.PeerGraph	(	IPeerGraphConfiguration	configuration,
		Host	host,
		Peer	peer
	)

inline

Definition at line 35 of file PeerGraph.cs.

             : base(configuration)
         {
             config = configuration;
             this.host = host;
             this.peer = peer;
 
             timedReading = new Dictionary<DateTime, HostReading>();
         }

Member Function Documentation

override void Ntp.Analyzer.Graph.PeerGraph.AddPlots ( )

inlineprotectedvirtual

Reimplemented from Ntp.Analyzer.Graph.DispersionGraph.

Definition at line 54 of file PeerGraph.cs.

         {
             base.AddPlots();
 
             if (config.Delay.HasValue)
             {
                 var delayPlot = SetupPlot("Delay", Color.DarkOrange, Time, delay);
                 Surface.Add(delayPlot, PlotSurface2D.XAxisPosition.Bottom, PlotSurface2D.YAxisPosition.Left);
             }
 
             if (config.Balance.HasValue)
             {
                 var balancePlot = SetupPlot("Balanced offset", Color.DarkViolet, Time, balance);
                 Surface.Add(balancePlot, PlotSurface2D.XAxisPosition.Bottom, PlotSurface2D.YAxisPosition.Left);
             }
         }

void Ntp.Analyzer.Graph.PeerGraph.CleanSeries ( )

inlineprivate

Cleans the value series from values out side boundaries.

Definition at line 152 of file PeerGraph.cs.

         {
             double totalOffset = 0.0;
             double totalJitter = 0.0;
             double totalDelay = 0.0;
             double totalBalance = 0.0;
 
             // Calculate mean value
             for (int i = 0; i < Time.Count; i++)
             {
                 totalOffset += Math.Abs(Offset[i]);
                 totalJitter += Math.Abs(Jitter[i]);
                 totalDelay += Math.Abs(delay[i]);
                 totalBalance += Math.Abs(balance[i]);
             }
 
             double avgOffset = totalOffset/Time.Count;
             double avgJitter = totalJitter/Time.Count;
             double avgDelay = totalDelay/Time.Count;
             double avgBalance = totalBalance/Time.Count;
 
             var indexes = new List<int>();
 
             // Find invalid values
             for (int i = 0; i < Time.Count; i++)
             {
                 if (Math.Abs(Offset[i]) > avgOffset*config.FilterFactor ||
                     Math.Abs(Jitter[i]) > avgJitter*config.FilterFactor ||
                     Math.Abs(delay[i]) > avgDelay*config.FilterFactor ||
                     Math.Abs(balance[i]) > avgBalance*config.FilterFactor)
                 {
                     indexes.Add(i);
                 }
             }
 
             // Remove invalid values
             for (int i = indexes.Count - 1; i >= 0; i--)
             {
                 Time.RemoveAt(indexes[i]);
                 Offset.RemoveAt(indexes[i]);
                 Jitter.RemoveAt(indexes[i]);
                 delay.RemoveAt(indexes[i]);
                 balance.RemoveAt(indexes[i]);
             }
         }

override void Ntp.Analyzer.Graph.PeerGraph.LoadData ( )

inlineprotectedvirtual

Implements Ntp.Analyzer.Graph.GraphBase.

Definition at line 71 of file PeerGraph.cs.

References Ntp.Analyzer.Data.Sql.FilteredSqlDatabaseMapper< T >.FilterHost, Ntp.Analyzer.Data.Sql.FilteredSqlDatabaseMapper< T >.FilterPeer, Ntp.Analyzer.Data.Sql.FilteredSqlDatabaseMapper< T >.FilterTime, Ntp.Analyzer.Data.DataFace.HostReadings, Ntp.Analyzer.Data.DataFace.Instance, and Ntp.Analyzer.Data.DataFace.PeerReadings.

         {
             FilteredSqlDatabaseMapper<PeerReading> peerMapper = DataFace.Instance.PeerReadings;
             peerMapper.FilterHost = host;
             peerMapper.FilterPeer = peer;
             peerMapper.FilterTime = DateTime.UtcNow.Subtract(GraphTimeSpan);
 
             if (config.Balance.HasValue)
             {
                 foreach (var reading in peerMapper)
                 {
                     Time.Add(config.GraphTime == DateTimeKind.Local ? reading.LocalTime : reading.UtcTime);
 
                     if (config.Offset.HasValue) Offset.Add(reading.Offset*config.Offset.Value);
                     else Offset.Add(0.0);
 
                     if (config.Jitter.HasValue) Jitter.Add(reading.Jitter*config.Jitter.Value);
                     else Jitter.Add(0.0);
 
                     if (config.Delay.HasValue) delay.Add(reading.Delay*config.Delay.Value);
                     else delay.Add(0.0);
 
                     balance.Add(0.0);
                 }
             }
             else
             {
                 FilteredSqlDatabaseMapper<HostReading> hostMapper = DataFace.Instance.HostReadings;
                 hostMapper.FilterHost = host;
                 hostMapper.FilterTime = DateTime.UtcNow.Subtract(GraphTimeSpan);
 
                 // Prepare balance data
                 foreach (var hostReading in hostMapper)
                 {
                     var indexTime = config.GraphTime == DateTimeKind.Local
                         ? hostReading.RoundedLocalTime
                         : hostReading.RoundedUtcTime;
 
                     if (!timedReading.ContainsKey(indexTime))
                         timedReading.Add(indexTime, hostReading);
                 }
 
                 // Add
                 foreach (var reading in peerMapper)
                 {
                     Time.Add(config.GraphTime == DateTimeKind.Local ? reading.LocalTime : reading.UtcTime);
 
                     if (config.Offset.HasValue) Offset.Add(reading.Offset*config.Offset.Value);
                     else Offset.Add(0.0);
 
                     if (config.Jitter.HasValue) Jitter.Add(reading.Jitter*config.Jitter.Value);
                     else Jitter.Add(0.0);
 
                     if (config.Delay.HasValue) delay.Add(reading.Delay*config.Delay.Value);
                     else delay.Add(0.0);
 
                     var indexTime = config.GraphTime == DateTimeKind.Local
                         ? reading.RoundedLocalTime
                         : reading.RoundedUtcTime;
 
                     if (timedReading.ContainsKey(indexTime))
                         balance.Add(reading.Offset - timedReading[indexTime].Offset);
                     else
                         balance.Add(0.0);
                 }
             }
 
             if (config.FilterFactor.HasValue)
                 CleanSeries();
         }

override void Ntp.Analyzer.Graph.PeerGraph.PreRender ( )

inlineprotectedvirtual

Reimplemented from Ntp.Analyzer.Graph.GraphBase.

Definition at line 142 of file PeerGraph.cs.

         {
             base.PreRender();
 
             Surface.Title = config.GetTitle(peer);
         }

Member Data Documentation

readonly List<double> Ntp.Analyzer.Graph.PeerGraph.balance = new List<double>()

private

Definition at line 45 of file PeerGraph.cs.

readonly IPeerGraphConfiguration Ntp.Analyzer.Graph.PeerGraph.config

private

Definition at line 46 of file PeerGraph.cs.

readonly List<double> Ntp.Analyzer.Graph.PeerGraph.delay = new List<double>()

private

Definition at line 47 of file PeerGraph.cs.

readonly Host Ntp.Analyzer.Graph.PeerGraph.host

private

Definition at line 48 of file PeerGraph.cs.

readonly Peer Ntp.Analyzer.Graph.PeerGraph.peer

private

Definition at line 49 of file PeerGraph.cs.

readonly Dictionary<DateTime, HostReading> Ntp.Analyzer.Graph.PeerGraph.timedReading

private

Definition at line 50 of file PeerGraph.cs.

override string Ntp.Analyzer.Graph.PeerGraph.YLabel => "Milliseconds"

protected

Definition at line 52 of file PeerGraph.cs.

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

Ntp.Analyzer/Graph/PeerGraph.cs

Public Member Functions

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation