Changes project wide with this check-in.
MudCompiler: No longer works. Needs to be re-wrote to support the new Alpha 2.0 engine MudDesigenr: Removed most of the forms since we are not working on it. Only form left is Project Manager, which will be removed shortly as well. MudGame: No longer runs. All of the source code was removed due to MudEngine Alpha 2.0 source changing drastically. MudEngine: Alpha 2.0 source code finally checked-in. It contains the full re-build of the engine. A lot of new abstract classes have been added.
This commit is contained in:
parent
5be2f9bf5b
commit
a365256d53
48 changed files with 2254 additions and 2021 deletions
116
MudEngine/Communication/OldServer.cs
Normal file
116
MudEngine/Communication/OldServer.cs
Normal file
|
@ -0,0 +1,116 @@
|
|||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Net;
|
||||
using System.Net.Sockets;
|
||||
using System.Threading;
|
||||
using System.Text;
|
||||
|
||||
using MudEngine.Core;
|
||||
|
||||
namespace MudEngine.Communication
|
||||
{
|
||||
public class OldServer
|
||||
{
|
||||
/*
|
||||
public OldServer()
|
||||
{
|
||||
stage = 0;
|
||||
port = 0;
|
||||
server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||||
}
|
||||
~OldServer()
|
||||
{
|
||||
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;
|
||||
*/
|
||||
}
|
||||
}
|
Loading…
Add table
Add a link
Reference in a new issue