SmartDeviceTestbed/Class1.cs

using System;
using System.Data;
using System.Net;
using System.Net.Sockets;
using System.IO;
using System.Text;

namespace SmartDeviceTestbed
{
        public class Class1
        {
                SegmentReceiver rx = new SegmentReceiver();
                public Class1(ref string s)     {
                        StringWriter strWriter = new StringWriter();
                        StackInterface stackitnf = new StackInterface(strWriter);
                        s = strWriter.GetStringBuilder().ToString();
                }
        }

        class StackInterface {
                public MessageLogger msgLog; 
                public StackInterface(TextWriter writer) {
                        msgLog = new MessageLogger(writer);
                }
        }

        public class MessageLogger {
                private System.IO.TextWriter writer;
                public MessageLogger(System.IO.TextWriter loggerOutput) {
                        writer = loggerOutput;
                }

                public void Log(string s) {
                        writer.WriteLine("    " + s);
                }
                public void Log(string s, params object[] args) {
                        writer.WriteLine("    " + s, args);
                }
                public void LogError(string s) {
                        writer.WriteLine("*** " + s);
                }
                public void LogError(string s, params object[] args) {
                        writer.WriteLine("*** " + s, args);
                }
                public void LogTodo(string s) {
                        writer.WriteLine("### " + s);
                }
                public void LogTodo(string s, params object[] args) {
                        writer.WriteLine("### " + s, args);
                }
                public void LogStartBegin(string deviceStarting) {
                        writer.WriteLine("+++ Starting " + deviceStarting);
                }
                public void LogStartComplete(string deviceStarted) {
                        writer.WriteLine("+++ " + deviceStarted + " Started");
                }
        }

        public class SegmentReceiver {
                Thread processingThread; // does all the work
                //StackInterface thisStack; // the parent stack
                UdpClient udpListener; // theudp socket that listens

                public SegmentReceiver(StackInterface thisStack) {
                        this.thisStack = thisStack;
                }

                public void Start() {
                        thisStack.msgLog.LogStartBegin("Segment Receiver");
                        processingThread = new Thread(new ThreadStart(Listen));
                        processingThread.Start();
                        thisStack.msgLog.LogStartComplete("Segment Receiver");
                }

                private void Listen() { 
                        IPEndPoint currentEndPoint;
                        Segment receivedSegment;
                        int localPortNumber = -1;
                        if (thisStack.settings.MyDeviceID == thisStack.Settings.SERVER_DEVICE_ID) { // we are the server
                                localPortNumber = thisStack.Settings.ServerReceivePortNumber;
                        } else {// we are a client
                                localPortNumber = thisStack.Settings.ClientReceivePortNumber;
                        }
                        // create UDP socket bound to listen on IP address from settings
                        udpListener = new UdpClient(new IPEndPoint(IPAddress.Any, localPortNumber));
                        try {
                                while(true) {/* We want to do as little as possible here so we can run this in a tight loop */
                                        try {
                                                // create end point to hold receieved address
                                                currentEndPoint = new IPEndPoint(IPAddress.Any, localPortNumber);
                                                receivedSegment = new Segment(udpListener.Receive(ref currentEndPoint));
                                                receivedSegment.Headers.TimeReceived = DateTime.Now.ToUniversalTime();
                                                Console.WriteLine("Got segment #{0}", receivedSegment.Headers.SequenceNumber);
                                                thisStack.GetRemoteHostByID(receivedSegment.Headers.SourceDeviceID).AcceptIncomingSegment(receivedSegment);
                                        } catch (Exception ex) {
                                                thisStack.msgLog.LogError("Error in Protocol Stack\n\rUnable to correctly receive segment.\n\rSkipping over and continuting. Details:\n\r(" + ex + ")");
                                        }
                                }
                        } catch (ThreadAbortException) {
                                Console.WriteLine("Segment Receive Listen Thread Aborted");
                        } finally {
                                if (udpListener != null) { udpListener.Close(); }
                        }
                }
        }
}

---