zydronium/muddesigner
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Removed old engine classes. Needs to be done prior to checking-in the new engine classes re-wrote from ground up.

Browse source
This commit is contained in:
Scionwest_cp 2011-10-01 22:09:33 -07:00
parent 5a39a7995e
commit 5be2f9bf5b
39 changed files with 201 additions and 3300 deletions
Download patch file Download diff file Expand all files Collapse all files

115
MudEngine/Communication/Server.cs
View file

@ -1,115 +0,0 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using MudEngine.GameObjects.Characters;
using MudEngine.GameManagement;
namespace MudEngine.Networking
{
public class Server
{
public Server()
{
stage = 0;
port = 0;
server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
}
~Server()
{
stage = 0;
port = 0;
}
public Boolean Initialize(Int32 p, ref BaseCharacter[] pbs)
{
if (stage != 0)
return false;
if (p <= 0)
return false;
port = p;
players = pbs;
clientThreads = new Thread[players.Length];
stage++;
return true;
}
public Boolean Start()
{
try
{
if (stage != 1)
return false;
IPEndPoint ipep = new IPEndPoint(IPAddress.Any, port);
server.Bind(ipep);
server.Listen(10);
stage++;
serverThread = new Thread(ServerThread);
serverThread.Start();
}
catch (Exception)
{
return false;
}
return true;
}
public void EndServer()
{
stage = 0;
serverThread.Abort();
server.Close();
}
private void ServerThread()
{
while (stage == 2)
{
Int32 sub = -1;
do
{
for (Int32 i = 0; i < players.Length; i++)
{
if (!players[i].IsActive)
{
sub = i;
break;
}
}
} while (sub < 0);
players[sub].client = server.Accept();
players[sub].IsActive = true;
players[sub].IsControlled = true;
clientThreads[sub] = new Thread(ReceiveThread);
clientThreads[sub].Start((object)sub);
}
}
private void ReceiveThread(object obj)
{
Int32 sub = (Int32)obj;
players[sub].Initialize();
while (stage == 2 && players[sub].IsActive)
{
players[sub].Receive(players[sub].ReadInput());
}
}
public void Disconnect(Int32 sub)
{
if (sub > 0 && sub < players.Length)
{
clientThreads[sub].Abort();
if (players[sub].IsActive)
players[sub].Disconnect();
}
}
private Thread serverThread;
private Socket server;
private Int32 stage;
private Int32 port;
BaseCharacter[] players;
private Thread[] clientThreads;
}
}