Rooba
/
Quasar
mirror of https://github.com/quasar/Quasar.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed #207

This commit is contained in:
MaxXor 2015-05-26 19:35:28 +02:00
parent 36ac738e43
commit 3e009117af
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
Server/Core/Server.cs
View File

@ -33,6 +33,11 @@ private void OnClientState(Client c, bool connected)
{ {
ClientState(this, c, connected); ClientState(this, c, connected);
} }
if (!connected)
{
c.Disconnect();
_clients.Remove(c);
}
} }
public event ClientReadEventHandler ClientRead; public event ClientReadEventHandler ClientRead;
@ -152,16 +157,16 @@ private void Process(object s, SocketAsyncEventArgs e)
{ {
if (e.SocketError == SocketError.Success) if (e.SocketError == SocketError.Success)
{ {
Client T = new Client(this, e.AcceptSocket, PacketTypes.ToArray()); Client client = new Client(this, e.AcceptSocket, PacketTypes.ToArray());
lock (_clients) lock (_clients)
{ {
_clients.Add(T); _clients.Add(client);
T.ClientState += OnClientState; client.ClientState += OnClientState;
T.ClientRead += OnClientRead; client.ClientRead += OnClientRead;
T.ClientWrite += OnClientWrite; client.ClientWrite += OnClientWrite;
OnClientState(T, true); OnClientState(client, true);
} }
e.AcceptSocket = null; e.AcceptSocket = null;