SmartDeviceClient/SmartProtocolStack/SegmentReceiver.cs

using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;


namespace GPRSWeb.SmartDeviceClient.SmartProtocolStack
{
        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 + ")");
                                        }
                                }
                        } finally {
                                if (udpListener != null) { udpListener.Close(); }
                        }
                }
        }


}

---