aboutsummaryrefslogtreecommitdiff
path: root/Emby.Common.Implementations/Net/UdpSocket.cs
diff options
context:
space:
mode:
authorLuke <luke.pulverenti@gmail.com>2017-03-08 02:24:30 -0500
committerGitHub <noreply@github.com>2017-03-08 02:24:30 -0500
commit23010f2980381a4b56e05620d4604cafc0e00043 (patch)
tree418b4ad6964c84d17ff9c33fa88b0e1a8bcacd34 /Emby.Common.Implementations/Net/UdpSocket.cs
parent0ac0a09c806112ce82dcd23f43c7df9ff8b5531d (diff)
parent314b84ae9ef5a692144b0a3a178ddcbd393c9fb9 (diff)
Merge pull request #2516 from MediaBrowser/beta
Beta
Diffstat (limited to 'Emby.Common.Implementations/Net/UdpSocket.cs')
-rw-r--r--Emby.Common.Implementations/Net/UdpSocket.cs16
1 files changed, 10 insertions, 6 deletions
diff --git a/Emby.Common.Implementations/Net/UdpSocket.cs b/Emby.Common.Implementations/Net/UdpSocket.cs
index e4b0c7d6dc..8e2a1da6f6 100644
--- a/Emby.Common.Implementations/Net/UdpSocket.cs
+++ b/Emby.Common.Implementations/Net/UdpSocket.cs
@@ -14,7 +14,7 @@ namespace Emby.Common.Implementations.Net
// THIS IS A LINKED FILE - SHARED AMONGST MULTIPLE PLATFORMS
// Be careful to check any changes compile and work for all platform projects it is shared in.
- internal sealed class UdpSocket : DisposableManagedObjectBase, IUdpSocket
+ internal sealed class UdpSocket : DisposableManagedObjectBase, ISocket
{
#region Fields
@@ -23,8 +23,6 @@ namespace Emby.Common.Implementations.Net
private int _LocalPort;
#endregion
- #region Constructors
-
public UdpSocket(Socket socket, int localPort, IPAddress ip)
{
if (socket == null) throw new ArgumentNullException("socket");
@@ -36,7 +34,13 @@ namespace Emby.Common.Implementations.Net
_Socket.Bind(new IPEndPoint(ip, _LocalPort));
}
- #endregion
+ public UdpSocket(Socket socket, IpEndPointInfo endPoint)
+ {
+ if (socket == null) throw new ArgumentNullException("socket");
+
+ _Socket = socket;
+ _Socket.Connect(NetworkManager.ToIPEndPoint(endPoint));
+ }
public IpAddressInfo LocalIPAddress
{
@@ -44,9 +48,9 @@ namespace Emby.Common.Implementations.Net
private set;
}
- #region IUdpSocket Members
+ #region ISocket Members
- public Task<SocketReceiveResult> ReceiveAsync()
+ public Task<SocketReceiveResult> ReceiveAsync(CancellationToken cancellationToken)
{
ThrowIfDisposed();