blob: f4f7eb9cfeaeff65ff4160390c95cce96f629ae5 (
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tango.Transport.Adapters
{
/// <summary>
/// Experimental...
/// </summary>
/// <seealso cref="Tango.Transport.TransportAdapterBase" />
public class MultiTransportAdapter : TransportAdapterBase
{
public class MultiTransportAdapterDataAvailableEventArgs : EventArgs
{
public ITransportAdapter Adapter { get; set; }
public byte[] Data { get; set; }
}
public class MultiTransportAdapterStateChangedEventArgs : EventArgs
{
public ITransportAdapter Adapter { get; set; }
public TransportComponentState State { get; set; }
}
public event EventHandler<MultiTransportAdapterDataAvailableEventArgs> AdapterDataAvailable;
public event EventHandler<MultiTransportAdapterStateChangedEventArgs> AdapterStateChangedAvailable;
public ReadOnlyCollection<ITransportAdapter> Adapters { get; private set; }
public MultiTransportAdapter()
{
Adapters = new ReadOnlyCollection<ITransportAdapter>(new List<ITransportAdapter>());
ComponentName = "Multi Transport Adapter";
}
public override void Write(byte[] data, bool immidiate = false)
{
Adapters.ToList().ForEach(x => x.Write(data));
}
public void Write(byte[] data, ITransportAdapter adapter)
{
adapter.Write(data);
}
public override async Task Connect()
{
foreach (var adapter in Adapters.ToList().Where(x => x.State != TransportComponentState.Connected))
{
await adapter.Connect();
}
}
public override async Task Disconnect()
{
foreach (var adapter in Adapters.ToList())
{
await adapter.Disconnect();
}
}
public override void Dispose()
{
foreach (var adapter in Adapters.ToList())
{
adapter.Dispose();
}
}
public void AddAdapter(ITransportAdapter adapter)
{
List<ITransportAdapter> list = Adapters.ToList();
list.Add(adapter);
Adapters = new ReadOnlyCollection<ITransportAdapter>(list);
adapter.DataAvailable += Adapter_DataAvailable;
adapter.StateChanged += Adapter_StateChanged;
}
public void RemoveAdapter(ITransportAdapter adapter)
{
List<ITransportAdapter> list = Adapters.ToList();
list.Remove(adapter);
Adapters = new ReadOnlyCollection<ITransportAdapter>(list);
adapter.DataAvailable -= Adapter_DataAvailable;
adapter.StateChanged -= Adapter_StateChanged;
}
public void ClearAdapters()
{
foreach (var adapter in Adapters.ToList())
{
adapter.DataAvailable -= Adapter_DataAvailable;
adapter.StateChanged -= Adapter_StateChanged;
}
Adapters = new ReadOnlyCollection<ITransportAdapter>(new List<ITransportAdapter>());
}
private void Adapter_StateChanged(object sender, TransportComponentState state)
{
AdapterStateChangedAvailable?.Invoke(this, new MultiTransportAdapterStateChangedEventArgs()
{
Adapter = sender as ITransportAdapter,
State = state,
});
}
private void Adapter_DataAvailable(object sender, byte[] data)
{
OnDataAvailable(data);
AdapterDataAvailable?.Invoke(this, new MultiTransportAdapterDataAvailableEventArgs()
{
Adapter = sender as ITransportAdapter,
Data = data,
});
}
}
}
|
