aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/SideChains/RealTimeGraphEx/Controllers/GraphControllerBase.cs
blob: c045ca03adf4b1c1309e4225d621b5e6f78f3519 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;

namespace RealTimeGraphEx.Controllers
{
    public abstract class GraphControllerBase : DependencyObject
    {
        protected Action clearMethod;
        protected Action startThreadMethod;
        protected Action<bool> pausedMethod;
        protected Action<bool> changeRenderModeMethod;
        protected Action pushMarkerMethod;

        public bool IsPaused
        {
            get { return (bool)GetValue(IsPausedProperty); }
            set { SetValue(IsPausedProperty, value); }
        }
        public static readonly DependencyProperty IsPausedProperty =
            DependencyProperty.Register("IsPaused", typeof(bool), typeof(GraphControllerBase), new PropertyMetadata(false, new PropertyChangedCallback(PausedChanged)));

        private static void PausedChanged(DependencyObject d, DependencyPropertyChangedEventArgs e)
        {
            var control = d as GraphControllerBase;
            if (control.pausedMethod != null)
            {
                control.pausedMethod(control.IsPaused);
            }
        }


        internal void RegisterMethods(Action clear, Action startThread, Action<bool> paused, Action<bool> renderMode, Action pushMarker)
        {
            changeRenderModeMethod = renderMode;
            pausedMethod = paused;
            clearMethod = clear;
            startThreadMethod = startThread;
            pushMarkerMethod = pushMarker;
        }

        public abstract void Clear();

        public virtual void ChangeRenderMode(bool enabled)
        {
            changeRenderModeMethod(enabled);
        }

        internal abstract void ClearPoints();

        public void PushMarkerLine()
        {
            if (pushMarkerMethod != null)
            {
                pushMarkerMethod();
            }
        }
    }
}
y.Points.Count)); if (min != null) { lock (min.Points) { foreach (var series in dataSeriesCollection) { lock (series.Points) { if (series.Points.Count > min.Points.Count) { series.Points.RemoveRange(min.Points.Count, series.Points.Count - min.Points.Count); } } } } } } } } public ObservableCollection<DataYSeries> DataSeriesCollection { get { return (ObservableCollection<DataSeries.DataYSeries>)GetValue(DataSeriesCollectionProperty); } set { SetValue(DataSeriesCollectionProperty, value); } } public static readonly DependencyProperty DataSeriesCollectionProperty = DependencyProperty.Register("Controller", typeof(ObservableCollection<DataYSeries>), typeof(GraphMultiController), new PropertyMetadata(null, new PropertyChangedCallback(SetCrossThreadFields))); private static void SetCrossThreadFields(DependencyObject d, DependencyPropertyChangedEventArgs e) { (d as GraphMultiController).OnSetCrossModelFields(); } protected virtual void OnSetCrossModelFields() { this.Dispatcher.Invoke(() => { dataSeriesCollection = DataSeriesCollection; }, System.Windows.Threading.DispatcherPriority.Send); } public GraphMultiController() : base() { DataSeriesCollection = new ObservableCollection<DataSeries.DataYSeries>(); } public override void Clear() { if (clearMethod != null) { clearMethod(); } dataSeriesCollection.ToList().ForEach(x => x.ClearPoints()); } internal override void ClearPoints() { dataSeriesCollection.ToList().ForEach(x => x.ClearPoints()); } public virtual void PushData(List<double> values) { lock (_lock) { if (startThreadMethod != null) { startThreadMethod(); } dataSeriesCollection.ToList().ForEach(x => x.PushData(values)); } } public virtual void PushData(double[] values) { lock (_lock) { if (startThreadMethod != null) { startThreadMethod(); } dataSeriesCollection.ToList().ForEach(x => x.PushData(values)); } } public virtual void PushData(params List<double>[] arrays) { PushData(arrays.ToList()); } public virtual void PushData(List<List<double>> arrays) { lock (_lock) { if (startThreadMethod != null) { startThreadMethod(); } for (int i = 0; i < arrays.Count; i++) { dataSeriesCollection[i].PushData(arrays[i]); } } } public virtual void PushData(List<double> array, int dataSeriesIndex) { lock (_lock) { if (startThreadMethod != null) { startThreadMethod(); } dataSeriesCollection[dataSeriesIndex].PushData(array); } } public virtual void PushDataSingles(List<double> values) { lock (_lock) { if (startThreadMethod != null) { startThreadMethod(); } for (int i = 0; i < values.Count; i++) { dataSeriesCollection[i].PushData(values[i]); } } } internal virtual List<List<double>> GetAndClearAllPoints() { List<List<double>> pointsCollection = new List<List<double>>(); lock (_lock) { foreach (var series in dataSeriesCollection) { pointsCollection.Add(series.Points.GetAndClearAllPoints()); } } return pointsCollection; } public void AddSeries(DataYSeries dataSeries) { DataSeriesCollection.Add(dataSeries); } } }