aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Udp/UdpServer.cs
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2017-03-26 15:00:35 -0400
committerLuke Pulverenti <luke.pulverenti@gmail.com>2017-03-26 15:00:35 -0400
commitcaaa906604c759e6899ebf6be6f5ac4f9845db84 (patch)
tree6b7be01aed32a0c861f125ff361a1e36a61d0bed /Emby.Server.Implementations/Udp/UdpServer.cs
parent240000f965f5cb7df1c8c46245c5a93a9007c8f8 (diff)
update socket methods
Diffstat (limited to 'Emby.Server.Implementations/Udp/UdpServer.cs')
-rw-r--r--Emby.Server.Implementations/Udp/UdpServer.cs26
1 files changed, 11 insertions, 15 deletions
diff --git a/Emby.Server.Implementations/Udp/UdpServer.cs b/Emby.Server.Implementations/Udp/UdpServer.cs
index bb303d8fa..21ef3cab6 100644
--- a/Emby.Server.Implementations/Udp/UdpServer.cs
+++ b/Emby.Server.Implementations/Udp/UdpServer.cs
@@ -204,19 +204,6 @@ namespace Emby.Server.Implementations.Udp
}
/// <summary>
- /// Stops this instance.
- /// </summary>
- public void Stop()
- {
- _isDisposed = true;
-
- if (_udpClient != null)
- {
- _udpClient.Dispose();
- }
- }
-
- /// <summary>
/// Releases unmanaged and - optionally - managed resources.
/// </summary>
/// <param name="dispose"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param>
@@ -224,7 +211,12 @@ namespace Emby.Server.Implementations.Udp
{
if (dispose)
{
- Stop();
+ _isDisposed = true;
+
+ if (_udpClient != null)
+ {
+ _udpClient.Dispose();
+ }
}
}
@@ -247,10 +239,14 @@ namespace Emby.Server.Implementations.Udp
try
{
- await _udpClient.SendAsync(bytes, bytes.Length, remoteEndPoint, CancellationToken.None).ConfigureAwait(false);
+ await _udpClient.SendWithLockAsync(bytes, bytes.Length, remoteEndPoint, CancellationToken.None).ConfigureAwait(false);
_logger.Info("Udp message sent to {0}", remoteEndPoint);
}
+ catch (OperationCanceledException)
+ {
+
+ }
catch (Exception ex)
{
_logger.ErrorException("Error sending message to {0}", ex, remoteEndPoint);