DevWiki/websocket-sharp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Modify] Polish it

Browse Source
This commit is contained in:
sta 2017-09-24 19:47:52 +09:00
parent 55aabfbcaf
commit 3ef00d0368
1 changed files with 26 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
websocket-sharp/Server/WebSocketSessionManager.cs
View File

@ -1615,31 +1615,42 @@ namespace WebSocketSharp.Server
/// </summary> /// </summary>
public void Sweep () public void Sweep ()
{ {
if (_state != ServerState.Start || _sweeping || Count == 0) if (_sweeping) {
_log.Info ("The sweeping is already in progress.");
return; return;
}
lock (_forSweep) { lock (_forSweep) {
if (_sweeping) {
_log.Info ("The sweeping is already in progress.");
return;
}
_sweeping = true; _sweeping = true;
foreach (var id in InactiveIDs) { }
foreach (var id in InactiveIDs) {
if (_state != ServerState.Start)
break;
lock (_sync) {
if (_state != ServerState.Start) if (_state != ServerState.Start)
break; break;
lock (_sync) { IWebSocketSession session;
IWebSocketSession session; if (_sessions.TryGetValue (id, out session)) {
if (_sessions.TryGetValue (id, out session)) { var state = session.State;
var state = session.State; if (state == WebSocketState.Open)
if (state == WebSocketState.Open) session.Context.WebSocket.Close (CloseStatusCode.Abnormal);
session.Context.WebSocket.Close (CloseStatusCode.ProtocolError); else if (state == WebSocketState.Closing)
else if (state == WebSocketState.Closing) continue;
continue; else
else _sessions.Remove (id);
_sessions.Remove (id);
}
} }
} }
_sweeping = false;
} }
_sweeping = false;
} }
/// <summary> /// <summary>