SmartDeviceClient/SmartProtocolStack/StackInterface.cs

using System;
using System.Collections;
using GPRSWeb.SmartDeviceClient.SmartProtocolStack.RemoteHost;

namespace GPRSWeb.SmartDeviceClient.SmartProtocolStack {
        public class StackInterface {
                protected IncomingMessageQueue receivedMessages;
                public IncomingMessageQueue ReceivedMessages {
                        get { return receivedMessages; }
                        set {receivedMessages = value; }
                }
                public OutgoingMessageQueue MessagesToSend {
                        get { return messagesToSend; }
                        set { messagesToSend = value; }
                }
                protected OutgoingMessageQueue messagesToSend;

                internal SegmentReceiver segmentReceiver;

                public StackSettings Settings {
                        get { return settings; }
                }
                internal StackSettings settings;

                protected Hashtable remoteHostList;

                internal IPMapper ipMappings;

                internal ConnectionResetDelegate connectionReset;

                internal MessageLogger msgLog;

                public StackInterface(GlobalSettings globalSettings, ConnectionResetDelegate connectionReset) {
                        this.msgLog = msgLog;
                        this.connectionReset = connectionReset;
                        this.settings = globalSettings.stackSettings;

                        msgLog.Log("Initialising GPRSWeb Smart Protocol Stack (Version {0}, Build {1})", System.Reflection.Assembly.GetExecutingAssembly().GetName().Version.ToString(2), System.Reflection.Assembly.GetExecutingAssembly().GetName().Version.Build);
                        settings = new StackSettings();
                        messagesToSend = new OutgoingMessageQueue(this);
                        receivedMessages = new IncomingMessageQueue(this);
                        remoteHostList = new Hashtable();
                        segmentReceiver = new SegmentReceiver(this);
                        ipMappings = new IPMapper(this);
                        AddDefaultRemoteHostTEMP();
                }


                public void ResetConnection() {
                        msgLog.Log("Reseting Protocol Stack ...");

                        Stop();
                        receivedMessages.ResetConnection();
                        foreach (DictionaryEntry de in remoteHostList) {
                                ((RemoteHostComms)de.Value).ResetConnection();
                        }
                        Start();
                        msgLog.Log("... Protocol Stack Reset");
                }

                public void Start() {
                        msgLog.Log("Starting Protocol Stack ...");
                        messagesToSend.Start();
                        foreach (DictionaryEntry de in remoteHostList) {
                                ((RemoteHostComms)de.Value).Start();
                        }
                        segmentReceiver.Start();
                        msgLog.Log("... Protocol Stack Started");
                }


                internal void AddRemoteHost(RemoteHostComms remoteHost) {
                        remoteHostList.Add(remoteHost.RemoteDeviceID, remoteHost);
                }

                internal RemoteHostComms GetRemoteHostByID(ushort remoteID) {
                        RemoteHostComms result = (RemoteHostComms)remoteHostList[remoteID];
                        if (result == null) {
                                throw new ApplicationException("Unable to find remote host communiation object for device " + remoteID);
                        }
                        return result;
                }

                private void AddDefaultRemoteHostTEMP() {
                        if (settings.MyDeviceID == 0 /* SERVER */) {
                                msgLog.LogTodo(" Find a better way of adding remote host clients");
                                AddRemoteHost(new RemoteHostComms(this, 1));
                                //AddRemoteHost(new RemoteHostComms(this, 2)); // if we're the server, add lots of clients
                        } else {
                                AddRemoteHost(new RemoteHostComms(this, 0)); // else we're a client, so just add the server
                        }
                }
        }
}

---