Free cookie consent management tool by TermsFeed Policy Generator

source: branches/OptimizationNetworks/HeuristicLab.Optimization.Networks/3.3/InputPort.cs @ 11406

Last change on this file since 11406 was 11406, checked in by swagner, 9 years ago

#2205: Worked on basic infrastructure for optimization networks

File size: 3.0 KB
Line 
1#region License Information
2/* HeuristicLab
3 * Copyright (C) 2002-2014 Heuristic and Evolutionary Algorithms Laboratory (HEAL)
4 *
5 * This file is part of HeuristicLab.
6 *
7 * HeuristicLab is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation, either version 3 of the License, or
10 * (at your option) any later version.
11 *
12 * HeuristicLab is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with HeuristicLab. If not, see <http://www.gnu.org/licenses/>.
19 */
20#endregion
21
22using HeuristicLab.Common;
23using HeuristicLab.Core;
24using HeuristicLab.Persistence.Default.CompositeSerializers.Storable;
25using System;
26
27namespace HeuristicLab.Optimization.Networks {
28  [Item("InputPort", "An asynchronous input port of an optimization network node.")]
29  [StorableClass]
30  public class InputPort<T> : Port<T>, IInputPort<T> where T : class, IItem {
31    [Storable]
32    private IOutputPort<T> outputPort;
33    public IOutputPort<T> OutputPort {
34      get { return outputPort; }
35      set {
36        if (outputPort != value) {
37          DeregisterOutputPortEvents();
38          outputPort = value;
39          RegisterOutputPortEvents();
40          OnOutputPortChanged();
41        }
42      }
43    }
44    IOutputPort IInputPort.OutputPort {
45      get { return outputPort; }
46    }
47
48    [StorableConstructor]
49    protected InputPort(bool deserializing) : base(deserializing) { }
50    protected InputPort(InputPort<T> original, Cloner cloner) : base(original, cloner) {
51      outputPort = cloner.Clone(original.outputPort);
52      RegisterOutputPortEvents();
53    }
54    public InputPort() : base("InputPort") { }
55    public InputPort(string name) : base(name) { }
56    public InputPort(string name, string description) : base(name, description) { }
57
58    [StorableHook(HookType.AfterDeserialization)]
59    private void AfterDeserialization() {
60      RegisterOutputPortEvents();
61    }
62
63    public override IDeepCloneable Clone(Cloner cloner) {
64      return new InputPort<T>(this, cloner);
65    }
66
67    public event EventHandler OutputPortChanged;
68    protected void OnOutputPortChanged() {
69      var handler = OutputPortChanged;
70      if (handler != null) handler(this, EventArgs.Empty);
71    }
72
73    protected void RegisterOutputPortEvents() {
74      outputPort.ValueChanged += OutputPort_ValueChanged;
75     
76    }
77    protected void DeregisterOutputPortEvents() {
78      outputPort.ValueChanged -= OutputPort_ValueChanged;
79    }
80    protected void OutputPort_ValueChanged(object sender, EventArgs e) {
81      Value = (T)OutputPort.Value.Clone();
82      //DISCUSS: clone value?
83      //DISCUSS: switch threads to decouple value propagation and to make communication asynchronous -> should be done in Node?
84    }
85  }
86}
Note: See TracBrowser for help on using the repository browser.