private void HandleMenuStartServer(object sender, RoutedEventArgs e)
 {
     serverState = ServerState.RUNNING;
     serverMiniCheckers.UpdateMenuState(serverState);
     updateRequestResponse("Server started");
     Debug.WriteLine("Server Starting");
 }

 public HttpResponseMessage GetServerState(ServerState serverState)
 {
     var httpResponseMessage = new HttpResponseMessage();
     httpResponseMessage.StatusCode = HttpStatusCode.OK;
     httpResponseMessage.Content = new StringContent((string)serverState["Hello"], System.Text.Encoding.UTF8, "text/plain");
     return httpResponseMessage;
 }

        static void Main(string[] args)
        {
            var serviceLocator = new ServiceLocator(CreateDIContainer());

            var baseurl = new Uri("http://localhost:1000/");

            var serverState = new ServerState();
            serverState["Hello"] = "World";

            var config = new HttpConfiguration();
            config.CreateInstance = (type, context, request) => serviceLocator.GetInstance(type);
            config.RequestHandlers = (handlers, se, od) => handlers.Add(new ServerStateOperationHandler(serverState));
            config.ResponseHandlers = (handlers, se, od) => {
                handlers.Add(new LoggingOperationHandler(new Logger()));
                handlers.Add(new CompressionHandler());
            };

            config.Formatters.Insert(0, new JsonMediaTypeFormatter());

            HttpServiceHost host = new HttpServiceHost(typeof(FooService), config, baseurl);
            host.Open();

            Console.WriteLine("Host open.  Hit enter to exit...");
            Console.WriteLine("Use a web browser and go to " + baseurl + " or do it right and get fiddler!");

            Console.Read();

            host.Close();
        }

 public void Initialize()
 {
     _state = ServerState.LOADING;
     CreateRemotingObjects();
     _residentOpenSAGEReadyMutex = new Mutex(true, OpenSAGERemoteSettings.ResidentOpenSAGEReadyMutexName);
     _state = ServerState.READY;
 }

        private void RaisePacketHandled(int id, IPacket packet, ServerState? state)
        {
            if (DebugPackets)
                PacketsReceived.Add(packet);

            if (OnPacketHandled != null)
                OnPacketHandled(id, packet, state);
        }

 internal WebSocketServiceHostManager(Logger logger)
 {
     _logger = logger;
       _keepClean = true;
       _serviceHosts = new Dictionary<string, WebSocketServiceHost> ();
       _state = ServerState.READY;
       _sync = new object ();
 }

 public void ListenForConnections()
 {
     state = ServerState.RUNNING;
     connectionListenerThread = new Thread(new ThreadStart(ConnectionListenerHandler));
     connectionListenerThread.Start();
     //eventCheckerThread = new Thread(new ThreadStart(CheckForEvents));
     //eventCheckerThread.Start();
 }

 private void HandleMenuStopServer(object sender, RoutedEventArgs e)
 {
     serverState = ServerState.STOPPED;
     serverMiniCheckers.UpdateMenuState(serverState);
     
     updateRequestResponse("Server stopped");
     Debug.WriteLine("Server Stopping");
 }

        public ServerOld(int id, string dataDir)
        {
            _id = id;
            _dataDir = dataDir;

            _peers = new List<Peer>();
            _random = new Random(id ^ (int)DateTime.Now.Ticks);
            _state = ServerState.Stopped;
        }

        protected void stepDown(IConsensus model, int term)
        {
            if (_state == ServerState.Leader || _state == ServerState.Candidate)
                _state = ServerState.Follower;

            _persistedState.UpdateState(term, null);
            if (isElectionTimeout(model))
                updateElectionAlarm(model);
        }

		private void HandleServerStatusChange(ServerState currentState)
		{
			//suport for calls from other threads
			if (InvokeRequired)
			{
				Invoke((MethodInvoker) (() => HandleServerStatusChange(currentState)));
			}
			else
			{
				switch (currentState)
				{
					case ServerState.Starting:
						btnStartStop.Enabled = false;
						btnRestart.Enabled = false;
						btnStartStop.Text = Locale.Tr("Starting...");

						break;
					case ServerState.Running:

						if (ProcessHandler.Server.IsLocal)
						{
							btnStartStop.Text = Locale.Tr("Stop");
							metroToolTip.SetToolTip(btnStartStop, "Stop the server");
						}
						else
						{
							metroToolTip.SetToolTip(btnStartStop, "Disconnect from the server");
							btnStartStop.Text = Locale.Tr("Disconnect");
						}

						btnStartStop.Enabled = true;
						btnRestart.Enabled = true;
						btnStartStop.Text = Locale.Tr("Stop");
						break;
					case ServerState.Stopping:
						btnStartStop.Enabled = false;
						btnRestart.Enabled = false;
						btnStartStop.Text = Locale.Tr("Stopping...");

						break;
					case ServerState.Stopped:
						btnStartStop.Enabled = true;
						btnRestart.Enabled = false;
						if (ProcessHandler.Server.IsLocal)
						{
							btnStartStop.Text = Locale.Tr("Start");
							metroToolTip.SetToolTip(btnStartStop, "Start the server");
						}
						else
						{
							btnStartStop.Text = Locale.Tr("Connect");
							metroToolTip.SetToolTip(btnStartStop, "Connect to the server");
						}
						break;
				}
			}
		}

        protected override void HandleAsync(Packet packet)
        {
            _state = _state ?? (ServerState) State;

            foreach (var endPoint in _state.Users.GetAllExcept(packet.Address))
            {
                LogManager.Debug("Packet from {0} redirected to {1}", packet.UserName, endPoint);
                _state.Client.Send(packet, endPoint);
            }
        }

 void ChangeState(ServerState newState)
 {
     Debug.Log("Change State: " + serverState + " >> " + newState);
     if (serverState == newState) {
         return;
     }
     ExitState();
     serverState = newState;
     EnterState();
 }

        /// <summary>
        /// Initializes a new instance of the <see cref="ServerEnteredErrorStateException"/> class
        /// with the specified error state.
        /// </summary>
        /// <param name="status">The error state entered by the server.</param>
        /// <exception cref="ArgumentNullException">If <paramref name="status"/> is <see langword="null"/>.</exception>
        public ServerEnteredErrorStateException(ServerState status)
            : base(string.Format("The server entered an error state: '{0}'", status))
        {
            if (status == null)
                throw new ArgumentNullException("status");

            _state.Status = status.Name;
#if !NET35
            SerializeObjectState += (ex, args) => args.AddSerializedState(_state);
#endif
        }

        public void UpdateServerState(FeedbackLevel workload, int peerCount, ServerState state)
        {
            if (!this.IsRegistered)
            {
                return;
            }

            var contract = new UpdateServerEvent { LoadIndex = (byte)workload, PeerCount = peerCount, State = (int)state };
            var eventData = new EventData((byte)ServerEventCode.UpdateServer, contract);
            this.SendEvent(eventData, new SendParameters());
        }

        internal WebSocketSessionManager(Logger logger)
        {
            _logger = logger;
              _forSweep = new object ();
              _keepClean = true;
              _sessions = new Dictionary<string, IWebSocketSession> ();
              _state = ServerState.Ready;
              _sync = new object ();

              setSweepTimer (60000);
        }

        public Server(int genSeed)
        {
            this.genSeed = genSeed;
            serverName = "Test server";
            maxPlayers = 4;
            players = new Dictionary<IPAddress, ServerPlayer>();
            port = 19283;
            state = ServerState.Lobby;

            Start();
        }

 /// <summary>
 /// The NetworkServer will be instantiated once in the DDD Server.
 /// External applications such as agents and custom GUIs should ignore this class.
 /// </summary>
 /// <param name="port"></param>
 /// <param name="dist"></param>
 public NetworkServer(int port, ref SimulationEventDistributor dist)
 {
     server = null;
     state = ServerState.STOPPING;
     eventDist = dist;
     m_serverIP = null;
     this.port = port;
     connectionListenerThread = null;
     //eventCheckerThread = null;
     clientHandlers = new List<NetworkServerConnectionHandler>();
     clientHandlersLock = new object();
     //clientCount = 0;
 }

 public Server()
 {
     Rooms = new Dictionary<MobMap, MapRoom>();
     InsertAllRooms();
     DisplayUp = zUpload = 0;
     DisplayDown = Download = 0;
     NextId = 1;
     ClientMutex = new Mutex();
     Socket = null;
     State = ServerState.Stopped;
     AcceptClientsThread = new Thread(new ThreadStart(AcceptClients));
     AcceptClientsThread.IsBackground = true;
 }

        internal WebSocketSessionManager(Logger logger)
        {
            _logger = logger;

              _clean = true;
              _forSweep = new object ();
              _sessions = new Dictionary<string, IWebSocketSession> ();
              _state = ServerState.Ready;
              _sync = ((ICollection) _sessions).SyncRoot;
              _waitTime = TimeSpan.FromSeconds (1);

              setSweepTimer (60000);
        }