ProtocolStack/StackInterface.cs

using System;
using System.Threading;
using System.Collections;


namespace ProtocolStack
{
        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;
                internal StackSettings settings;
                public StackSettings Settings {
                        get { return settings; }
                        set { settings = value; }
                }
                protected Hashtable remoteHostList;

                internal IPMapper ipMappings;

                internal ConnectionResetDelegate connectionReset;

                public StackInterface(ConnectionResetDelegate connectionReset) {
                        Console.WriteLine("\nInitialising GPRSWeb Protocol Stack (Version {0}, Build {1})\n\n", System.Reflection.Assembly.GetExecutingAssembly().GetName().Version.ToString(2), System.Reflection.Assembly.GetExecutingAssembly().GetName().Version.Build);
                        this.connectionReset = connectionReset;
                        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() {
                        Console.WriteLine("Reseting Protocol Stack ...");
                        Stop();
                        receivedMessages.ResetConnection();
                        foreach (DictionaryEntry de in remoteHostList) {
                                ((RemoteHostComms)de.Value).ResetConnection();
                        }
                        Start();
                        Console.WriteLine("... Protocol Stack Reset");
                }

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

                public void Stop() {
                        Console.WriteLine("Stopping Protocol Stack ...");
                        messagesToSend.Stop();
                        foreach (DictionaryEntry de in remoteHostList) {
                                ((RemoteHostComms)de.Value).Stop();
                        }
                        segmentReceiver.Stop();
                        Console.WriteLine("... Protocol Stack Stopped");
                }

                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() {
                        Console.WriteLine("### TODO: Better way of adding clients if we're the server ###");
                        if (settings.MyDeviceID == 0 /* SERVER */) {
                                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
                        }
                }
        }

        
}

---