|
8 | 8 |
|
9 | 9 | namespace cs101_master_tcp |
10 | 10 | { |
11 | | - class MainClass |
12 | | - { |
| 11 | + class MainClass |
| 12 | + { |
13 | 13 |
|
14 | | - private static bool rcvdRawMessageHandler (object parameter, byte[] message, int messageSize) |
15 | | - { |
16 | | - Console.WriteLine ("RECV " + BitConverter.ToString (message, 0, messageSize)); |
| 14 | + private static bool rcvdRawMessageHandler (object parameter, byte[] message, int messageSize) |
| 15 | + { |
| 16 | + Console.WriteLine ("RECV " + BitConverter.ToString (message, 0, messageSize)); |
17 | 17 |
|
18 | | - return true; |
19 | | - } |
| 18 | + return true; |
| 19 | + } |
20 | 20 |
|
21 | | - private static void linkLayerStateChanged (object parameter, int address, lib60870.linklayer.LinkLayerState newState) |
22 | | - { |
23 | | - Console.WriteLine ("LL state event: " + newState.ToString ()); |
24 | | - } |
| 21 | + private static void linkLayerStateChanged (object parameter, int address, lib60870.linklayer.LinkLayerState newState) |
| 22 | + { |
| 23 | + Console.WriteLine ("LL state event: " + newState.ToString ()); |
| 24 | + } |
25 | 25 |
|
26 | | - private static bool asduReceivedHandler(object parameter, int address, ASDU asdu) |
27 | | - { |
28 | | - Console.WriteLine (asdu.ToString ()); |
| 26 | + private static bool asduReceivedHandler(object parameter, int address, ASDU asdu) |
| 27 | + { |
| 28 | + Console.WriteLine (asdu.ToString ()); |
29 | 29 |
|
30 | | - return true; |
31 | | - } |
| 30 | + return true; |
| 31 | + } |
32 | 32 |
|
33 | 33 |
|
34 | | - public static void Main (string[] args) |
35 | | - { |
36 | | - bool running = true; |
| 34 | + public static void Main (string[] args) |
| 35 | + { |
| 36 | + bool running = true; |
37 | 37 |
|
38 | | - // use Ctrl-C to stop the programm |
39 | | - Console.CancelKeyPress += delegate(object? sender, ConsoleCancelEventArgs e) { |
40 | | - e.Cancel = true; |
41 | | - running = false; |
42 | | - }; |
| 38 | + // use Ctrl-C to stop the programm |
| 39 | + Console.CancelKeyPress += delegate(object? sender, ConsoleCancelEventArgs e) { |
| 40 | + e.Cancel = true; |
| 41 | + running = false; |
| 42 | + }; |
43 | 43 |
|
44 | | - string hostname = "127.0.0.1"; |
45 | | - int tcpPort = 2404; |
| 44 | + string hostname = "127.0.0.1"; |
| 45 | + int tcpPort = 2404; |
46 | 46 |
|
47 | | - if (args.Length > 0) |
48 | | - hostname = args [0]; |
| 47 | + if (args.Length > 0) |
| 48 | + hostname = args [0]; |
49 | 49 |
|
50 | | - if (args.Length > 1) |
51 | | - int.TryParse (args [1], out tcpPort); |
| 50 | + if (args.Length > 1) |
| 51 | + int.TryParse (args [1], out tcpPort); |
52 | 52 |
|
53 | | - // Setup virtual serial port |
54 | | - TcpClientVirtualSerialPort port = new TcpClientVirtualSerialPort(hostname, tcpPort); |
55 | | - port.DebugOutput = false; |
56 | | - port.Start (); |
| 53 | + // Setup virtual serial port |
| 54 | + TcpClientVirtualSerialPort port = new TcpClientVirtualSerialPort(hostname, tcpPort); |
| 55 | + port.DebugOutput = false; |
| 56 | + port.Start (); |
57 | 57 |
|
58 | | - // Setup balanced CS101 master |
59 | | - LinkLayerParameters llParameters = new LinkLayerParameters(); |
60 | | - llParameters.AddressLength = 1; |
61 | | - llParameters.UseSingleCharACK = true; |
| 58 | + // Setup balanced CS101 master |
| 59 | + LinkLayerParameters llParameters = new LinkLayerParameters(); |
| 60 | + llParameters.AddressLength = 1; |
| 61 | + llParameters.UseSingleCharACK = true; |
62 | 62 |
|
63 | | - CS101Master master = new CS101Master (port, LinkLayerMode.BALANCED, llParameters); |
64 | | - master.DebugOutput = false; |
65 | | - master.OwnAddress = 1; |
| 63 | + CS101Master master = new CS101Master (port, LinkLayerMode.BALANCED, llParameters); |
| 64 | + master.DebugOutput = false; |
| 65 | + master.OwnAddress = 1; |
66 | 66 | master.SlaveAddress = 3; |
67 | | - master.SetASDUReceivedHandler (asduReceivedHandler, null); |
68 | | - master.SetLinkLayerStateChangedHandler (linkLayerStateChanged, null); |
69 | | - master.SetReceivedRawMessageHandler (rcvdRawMessageHandler, null); |
| 67 | + master.SetASDUReceivedHandler (asduReceivedHandler, null); |
| 68 | + master.SetLinkLayerStateChangedHandler (linkLayerStateChanged, null); |
| 69 | + master.SetReceivedRawMessageHandler (rcvdRawMessageHandler, null); |
70 | 70 |
|
71 | | - long lastTimestamp = SystemUtils.currentTimeMillis (); |
| 71 | + long lastTimestamp = SystemUtils.currentTimeMillis (); |
72 | 72 |
|
73 | | - // This will start a separate thread! |
74 | | - // alternativley you can you master.Run() inside the loop |
75 | | - master.Start (); |
| 73 | + // This will start a separate thread! |
| 74 | + // alternativley you can you master.Run() inside the loop |
| 75 | + master.Start (); |
76 | 76 |
|
77 | | - while (running) { |
| 77 | + while (running) { |
78 | 78 |
|
79 | | - if ((SystemUtils.currentTimeMillis() - lastTimestamp) >= 5000) { |
| 79 | + if ((SystemUtils.currentTimeMillis() - lastTimestamp) >= 5000) { |
80 | 80 |
|
81 | | - lastTimestamp = SystemUtils.currentTimeMillis (); |
| 81 | + lastTimestamp = SystemUtils.currentTimeMillis (); |
82 | 82 |
|
83 | | - if (master.GetLinkLayerState () == lib60870.linklayer.LinkLayerState.AVAILABLE) { |
84 | | - master.SendInterrogationCommand (CauseOfTransmission.ACTIVATION, 1, 20); |
85 | | - } else { |
86 | | - Console.WriteLine ("Link layer: " + master.GetLinkLayerState ().ToString ()); |
87 | | - } |
88 | | - } |
| 83 | + if (master.GetLinkLayerState () == lib60870.linklayer.LinkLayerState.AVAILABLE) { |
| 84 | + master.SendInterrogationCommand (CauseOfTransmission.ACTIVATION, 1, 20); |
| 85 | + } else { |
| 86 | + Console.WriteLine ("Link layer: " + master.GetLinkLayerState ().ToString ()); |
| 87 | + } |
| 88 | + } |
89 | 89 |
|
90 | | - Thread.Sleep (100); |
91 | | - } |
| 90 | + Thread.Sleep (100); |
| 91 | + } |
92 | 92 |
|
93 | | - master.Stop (); |
| 93 | + master.Stop (); |
94 | 94 |
|
95 | | - port.Stop (); |
96 | | - } |
97 | | - } |
| 95 | + port.Stop (); |
| 96 | + } |
| 97 | + } |
98 | 98 | } |
0 commit comments