Using InsomniaServer to Build a Web-interface for your Application

//All code is copyright � 2007, InsomniaSoftware | Manuel Then, All rights reserved.

using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace InsomniaSoftware.Server
{
    sealed class EndPointListener : IDisposable
    {
        #region Public variables
        public IPEndPoint endPoint
        {
            get
            {
                return (IPEndPoint)socket.LocalEndPoint;
            }
        }
        #endregion

        #region Private variables
        InsomniaServer server;

        bool listening = false;
        Thread listenThread;

        Socket socket = null;
        #endregion


        public EndPointListener(InsomniaServer server, IPEndPoint localEndPoint)
        {
            if (server == null)
                throw new Exception("No server handle passed to the constructor");
            if (localEndPoint == null)
                throw new Exception("No local end point passed to the constructor");
            this.server = server;

            try
            {
                socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp);
                socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.NoDelay, true);
                socket.Bind(localEndPoint);
            }
            catch
            {
                socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.NoDelay, true);
                socket.Bind(localEndPoint);
            }
            socket.Listen(10);
        }

        public void Dispose()
        {
            Stop(500);
            if (socket != null)
            {
                if (socket.Connected)
                    socket.Disconnect(false);
                socket = null;
            }
        }


        public void Start()
        {
            lock (this)
            {
                if (!listening)
                {
                    listening = true;
                    listenThread = new Thread(ListenThread);
                    listenThread.Start();
                }
            }
        }

        public void Stop(int maxWaitTime)
        {
            try
            {
                lock(this)
                    listening = false;
                listenThread.Join(maxWaitTime);
                if (listenThread.ThreadState == ThreadState.Running)
                    listenThread.Abort();
            }
            catch { }
        }


        void ListenThread()
        {
            while (listening)
            {
                try
                {
                    while (socket.Poll(0, SelectMode.SelectRead))
                    {
                        ExtendedSocket listenSocket = ExtendedSocket.FromSocket(socket.Accept());
                        HttpConnection httpConnection = new HttpConnection(server, listenSocket);
                    }
                    Thread.Sleep(20);
                }
                catch { }
            }
        }
    }
}