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

Modified IWebSocketServiceHost.cs and WebSocketServiceHostManager.cs

Browse Source
This commit is contained in:
sta 2013-09-18 17:44:14 +09:00
parent 903a5bf46b
commit 403cf2a3f2
5 changed files with 130 additions and 117 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
websocket-sharp/Server/HttpServer.cs
View File

@ -390,7 +390,7 @@ namespace WebSocketSharp.Server
var wsContext = context.AcceptWebSocket ();
IWebSocketServiceHost host;
if (!_serviceHosts.TryGetServiceHost (wsContext.Path, out host))
if (!_serviceHosts.TryGetServiceHostInternally (wsContext.Path, out host))
{
context.Response.StatusCode = (int) HttpStatusCode.NotImplemented;
return false;

8
websocket-sharp/Server/IWebSocketServiceHost.cs
View File

@ -55,6 +55,14 @@ namespace WebSocketSharp.Server
/// </value>
bool KeepClean { get; set; }
/// <summary>
/// Gets the path to the WebSocket service provided by the WebSocket service host.
/// </summary>
/// <value>
/// A <see cref="string"/> that contains an absolute path to the WebSocket service.
/// </value>
string ServicePath { get; }
/// <summary>
/// Gets the manager of the sessions to the WebSocket service host.
/// </summary>

2
websocket-sharp/Server/WebSocketServer.cs
View File

@ -226,7 +226,7 @@ namespace WebSocketSharp.Server
var path = context.Path;
IWebSocketServiceHost host;
if (!_serviceHosts.TryGetServiceHost (path, out host))
if (!_serviceHosts.TryGetServiceHostInternally (path, out host))
{
websocket.Close (HttpStatusCode.NotImplemented);
return;

2
websocket-sharp/Server/WebSocketServiceHost.cs
View File

@ -223,7 +223,7 @@ namespace WebSocketSharp.Server
}
/// <summary>
/// Gets the path to the WebSocket service that the WebSocket service host provides.
/// Gets the path to the WebSocket service provided by the WebSocket service host.
/// </summary>
/// <value>
/// A <see cref="string"/> that contains an absolute path to the WebSocket service.

233
websocket-sharp/Server/WebSocketServiceHostManager.cs
View File

@ -66,44 +66,13 @@ namespace WebSocketSharp.Server
#endregion
#region Internal Properties
internal bool KeepClean {
get {
return _keepClean;
}
set {
lock (_sync)
{
if (_keepClean ^ value)
{
_keepClean = value;
foreach (var host in _serviceHosts.Values)
host.KeepClean = value;
}
}
}
}
internal IEnumerable<IWebSocketServiceHost> ServiceHosts {
get {
lock (_sync)
{
return _serviceHosts.Values.ToList ();
}
}
}
#endregion
#region Public Properties
/// <summary>
/// Gets the connection count to the WebSocket services provided by the WebSocket server.
/// Gets the connection count to the every WebSocket service provided by the WebSocket server.
/// </summary>
/// <value>
/// An <see cref="int"/> that contains the connection count to the WebSocket services.
/// An <see cref="int"/> that contains the connection count to the every WebSocket service.
/// </value>
public int ConnectionCount {
get {
@ -130,6 +99,76 @@ namespace WebSocketSharp.Server
}
}
/// <summary>
/// Gets the WebSocket service host with the specified <paramref name="servicePath"/>.
/// </summary>
/// <value>
/// A <see cref="IWebSocketServiceHost"/> instance that represents the WebSocket service host
/// if it is successfully found; otherwise, <see langword="null"/>.
/// </value>
/// <param name="servicePath">
/// A <see cref="string"/> that contains an absolute path to the WebSocket service managed by
/// the WebSocket service host to get.
/// </param>
public IWebSocketServiceHost this [string servicePath] {
get {
var msg = servicePath.CheckIfValidServicePath ();
if (msg != null)
{
_logger.Error (msg);
return null;
}
IWebSocketServiceHost host;
if (!TryGetServiceHostInternally (servicePath, out host))
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return host;
}
}
/// <summary>
/// Gets a value indicating whether the manager cleans up periodically the every inactive session
/// to the WebSocket services provided by the WebSocket server.
/// </summary>
/// <value>
/// <c>true</c> if the manager cleans up periodically the every inactive session to the WebSocket
/// services; otherwise, <c>false</c>.
/// </value>
public bool KeepClean {
get {
return _keepClean;
}
internal set {
lock (_sync)
{
if (_keepClean ^ value)
{
_keepClean = value;
foreach (var host in _serviceHosts.Values)
host.KeepClean = value;
}
}
}
}
/// <summary>
/// Gets the collection of the WebSocket service hosts managed by the WebSocket server.
/// </summary>
/// <value>
/// An IEnumerable&lt;IWebSocketServiceHost&gt; that contains the collection of the WebSocket
/// service hosts.
/// </value>
public IEnumerable<IWebSocketServiceHost> ServiceHosts {
get {
lock (_sync)
{
return _serviceHosts.Values.ToList ();
}
}
}
/// <summary>
/// Gets the collection of every path to the WebSocket services provided by the WebSocket server.
/// </summary>
@ -152,20 +191,12 @@ namespace WebSocketSharp.Server
private Dictionary<string, Dictionary<string, bool>> broadping (byte [] data)
{
var result = new Dictionary<string, Dictionary<string, bool>> ();
foreach (var service in copy ())
result.Add (service.Key, service.Value.Sessions.BroadpingInternally (data));
foreach (var host in ServiceHosts)
result.Add (host.ServicePath, host.Sessions.BroadpingInternally (data));
return result;
}
private Dictionary<string, IWebSocketServiceHost> copy ()
{
lock (_sync)
{
return new Dictionary<string, IWebSocketServiceHost> (_serviceHosts);
}
}
#endregion
#region Internal Methods
@ -190,7 +221,6 @@ namespace WebSocketSharp.Server
internal bool Remove (string servicePath)
{
servicePath = HttpUtility.UrlDecode (servicePath).TrimEndSlash ();
IWebSocketServiceHost host;
lock (_sync)
{
@ -230,7 +260,7 @@ namespace WebSocketSharp.Server
}
}
internal bool TryGetServiceHost (string servicePath, out IWebSocketServiceHost serviceHost)
internal bool TryGetServiceHostInternally (string servicePath, out IWebSocketServiceHost serviceHost)
{
servicePath = HttpUtility.UrlDecode (servicePath).TrimEndSlash ();
lock (_sync)
@ -306,7 +336,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return false;
@ -339,7 +369,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return false;
@ -412,7 +442,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return null;
@ -450,7 +480,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return null;
@ -479,7 +509,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return;
@ -514,7 +544,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return;
@ -549,7 +579,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return;
@ -558,64 +588,6 @@ namespace WebSocketSharp.Server
host.Sessions.CloseSession (code, reason, id);
}
/// <summary>
/// Gets the connection count to the WebSocket service with the specified <paramref name="servicePath"/>.
/// </summary>
/// <returns>
/// An <see cref="int"/> that contains the connection count if the WebSocket service is successfully
/// found; otherwise, <c>-1</c>.
/// </returns>
/// <param name="servicePath">
/// A <see cref="string"/> that contains an absolute path to the WebSocket service to find.
/// </param>
public int GetConnectionCount (string servicePath)
{
var msg = servicePath.CheckIfValidServicePath ();
if (msg != null)
{
_logger.Error (msg);
return -1;
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return -1;
}
return host.ConnectionCount;
}
/// <summary>
/// Gets the manager of the sessions to the WebSocket service with the specified <paramref name="servicePath"/>.
/// </summary>
/// <returns>
/// A <see cref="WebSocketSessionManager"/> if the WebSocket service is successfully found;
/// otherwise, <see langword="null"/>.
/// </returns>
/// <param name="servicePath">
/// A <see cref="string"/> that contains an absolute path to the WebSocket service to find.
/// </param>
public WebSocketSessionManager GetSessions (string servicePath)
{
var msg = servicePath.CheckIfValidServicePath ();
if (msg != null)
{
_logger.Error (msg);
return null;
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return null;
}
return host.Sessions;
}
/// <summary>
/// Sends a Ping to the client associated with the specified <paramref name="id"/> and
/// <paramref name="servicePath"/>.
@ -640,7 +612,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return false;
@ -676,7 +648,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return false;
@ -711,7 +683,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return false;
@ -746,7 +718,7 @@ namespace WebSocketSharp.Server
}
IWebSocketServiceHost host;
if (!TryGetServiceHost (servicePath, out host))
if (!TryGetServiceHostInternally (servicePath, out host))
{
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return false;
@ -755,6 +727,39 @@ namespace WebSocketSharp.Server
return host.Sessions.SendTo (data, id);
}
/// <summary>
/// Tries to get the WebSocket service host with the specified <paramref name="servicePath"/>.
/// </summary>
/// <returns>
/// <c>true</c> if the WebSocket service host is successfully found; otherwise, <c>false</c>.
/// </returns>
/// <param name="servicePath">
/// A <see cref="string"/> that contains an absolute path to the WebSocket service managed by
/// the WebSocket service host to get.
/// </param>
/// <param name="serviceHost">
/// When this method returns, a <see cref="IWebSocketServiceHost"/> instance that represents
/// the WebSocket service host if it is successfully found; otherwise, <see langword="null"/>.
/// This parameter is passed uninitialized.
/// </param>
public bool TryGetServiceHost (string servicePath, out IWebSocketServiceHost serviceHost)
{
var msg = servicePath.CheckIfValidServicePath ();
if (msg != null)
{
_logger.Error (msg);
serviceHost = null;
return false;
}
var result = TryGetServiceHostInternally (servicePath, out serviceHost);
if (!result)
_logger.Error ("The WebSocket service with the specified path not found.\npath: " + servicePath);
return result;
}
#endregion
}
}