Subversion Repositories group.electronics

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace nitdcscore {
    public class DcsBios {
        private UdpClient _udpReceiveClient = null;
        private UdpClient _udpSendClient = null;
        private Thread _listeningThread;

        private String _receiveFromIP = "239.255.50.10";
        private String _sendToIP = "127.0.0.1";
        private int _receivePort = 5010;
        private int _sendPort = 7778;
        private IPEndPoint _ipEndPointReceiver = null;
        private IPEndPoint _ipEndPointSender = null;

        private readonly DCSProtocolParser _parser;

        public DcsBios() {
            _parser = new DCSProtocolParser();
        }


        public void InitUDP() {
            try {
                _ipEndPointReceiver = new IPEndPoint(IPAddress.Any, _receivePort);
                _ipEndPointSender = new IPEndPoint(IPAddress.Parse(_sendToIP), _sendPort);

                _udpReceiveClient = new UdpClient();
                _udpReceiveClient.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
                _udpReceiveClient.Client.Bind(_ipEndPointReceiver);
                _udpReceiveClient.JoinMulticastGroup(IPAddress.Parse(_receiveFromIP));

                _udpSendClient = new UdpClient();
                _udpSendClient.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
                _udpSendClient.EnableBroadcast = true;

                if (_listeningThread != null) {
                    _listeningThread.Abort();
                }

                _listeningThread = new Thread(ReceiveData);
                _listeningThread.Start();
            } catch (Exception e) {
                if (_udpReceiveClient != null && _udpReceiveClient.Client.Connected) {
                    _udpReceiveClient.Close();
                    _udpReceiveClient = null;
                }
                if (_udpSendClient != null && _udpSendClient.Client.Connected) {
                    _udpSendClient.Close();
                    _udpSendClient = null;
                }
                Console.WriteLine(e.Message);
            }


        }

        public void ReceiveData() {
            try {
                while (true) {
                    var byteData = _udpReceiveClient.Receive(ref _ipEndPointReceiver);
                    for (int i=0; i<byteData.Length; i++) {
                        _parser.ProcessByte(byteData[i]);
                    }
                }
            } catch (Exception e) {
                Console.WriteLine(e.Message);
            }
        }

        public int SendData(string data) {
            var rslt = 0;
            try {
                var unicodeBytes = Encoding.Unicode.GetBytes(data);
                var asciiBytes = new List<byte>(data.Length);
                asciiBytes.AddRange(Encoding.Convert(Encoding.Unicode, Encoding.ASCII, unicodeBytes));
                rslt = _udpSendClient.Send(asciiBytes.ToArray(), asciiBytes.ToArray().Length, _ipEndPointSender);
            } catch (Exception e) {
                Console.WriteLine(e.Message);
            }

            return rslt;
        }

        public void Shutdown() {
            try {
                if (_listeningThread != null) {
                    _listeningThread.Abort();
                    _listeningThread = null;
                }
                _udpReceiveClient.Close();
                _udpSendClient.Close();
            } catch (Exception e) {
                Console.WriteLine(e.Message);
            }
        }

    }

    public enum DCSBiosStateEnum {
        WAIT_FOR_SYNC = 0,
        ADDRESS_LOW = 1,
        ADDRESS_HIGH = 2,
        COUNT_LOW = 3,
        COUNT_HIGH = 4,
        DATA_LOW = 5,
        DATA_HIGH = 6,
    }

    

    internal class DCSProtocolParser {
        private DCSBiosStateEnum _state;
        private uint _address;
        private uint _count;
        private uint _data;
        private byte _syncByteCount;

        internal DCSProtocolParser() {
            _state = DCSBiosStateEnum.WAIT_FOR_SYNC;
            _syncByteCount = 0;
        }

        internal void ProcessByte(byte b) {
            switch (_state) {
                case DCSBiosStateEnum.WAIT_FOR_SYNC:
                    break;
                case DCSBiosStateEnum.ADDRESS_LOW:
                    _address = b;
                    _state = DCSBiosStateEnum.ADDRESS_HIGH;
                    break;
                case DCSBiosStateEnum.ADDRESS_HIGH:
                    _address = (uint) (b << 8) | _address;
                    _state = _address != 0x5555 ? DCSBiosStateEnum.COUNT_LOW : DCSBiosStateEnum.WAIT_FOR_SYNC;
                    break;
                case DCSBiosStateEnum.COUNT_LOW:
                    _count = b;
                    _state = DCSBiosStateEnum.COUNT_HIGH;
                    break;
                case DCSBiosStateEnum.COUNT_HIGH:
                    _count = (uint)(b << 8) | _count;
                    _state = DCSBiosStateEnum.DATA_LOW;
                    break;
                case DCSBiosStateEnum.DATA_LOW:
                    _data = b;
                    _count--;
                    _state = DCSBiosStateEnum.DATA_HIGH;
                    break;
                case DCSBiosStateEnum.DATA_HIGH:
                    _data = (uint)(b << 8) | _data;
                    _count--;
                    if (_address == 0x10fa) {
                        uint aapCdupwrValue = (_data & 0x4000) >> 14;
                        //Console.WriteLine(_address.ToString("X") + ":" + aapCdupwrValue);
                    }
                        
                    _address += 2;
                    if (_count == 0)
                        _state = DCSBiosStateEnum.ADDRESS_LOW;
                    else
                        _state = DCSBiosStateEnum.DATA_LOW;
                    break;
            }
            if (b == 0x55)
                _syncByteCount++;
            else
                _syncByteCount = 0;
            if (_syncByteCount == 4) {
                _state = DCSBiosStateEnum.ADDRESS_LOW;
                _syncByteCount = 0;
            }
        }
    }

    
}