diff options
| author | Luke <luke.pulverenti@gmail.com> | 2017-03-08 02:24:30 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-03-08 02:24:30 -0500 |
| commit | 23010f2980381a4b56e05620d4604cafc0e00043 (patch) | |
| tree | 418b4ad6964c84d17ff9c33fa88b0e1a8bcacd34 /Emby.Common.Implementations/Net/UdpSocket.cs | |
| parent | 0ac0a09c806112ce82dcd23f43c7df9ff8b5531d (diff) | |
| parent | 314b84ae9ef5a692144b0a3a178ddcbd393c9fb9 (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.cs | 16 |
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(); |
