aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Net/UdpSocket.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Emby.Server.Implementations/Net/UdpSocket.cs')
-rw-r--r--Emby.Server.Implementations/Net/UdpSocket.cs255
1 files changed, 255 insertions, 0 deletions
diff --git a/Emby.Server.Implementations/Net/UdpSocket.cs b/Emby.Server.Implementations/Net/UdpSocket.cs
new file mode 100644
index 000000000..58e4d6f89
--- /dev/null
+++ b/Emby.Server.Implementations/Net/UdpSocket.cs
@@ -0,0 +1,255 @@
+using System;
+using System.Net;
+using System.Net.Sockets;
+using System.Threading;
+using System.Threading.Tasks;
+using Emby.Server.Implementations.Networking;
+using MediaBrowser.Model.Net;
+
+namespace Emby.Server.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.
+
+ public sealed class UdpSocket : DisposableManagedObjectBase, ISocket
+ {
+ private Socket _Socket;
+ private int _LocalPort;
+
+ public Socket Socket
+ {
+ get { return _Socket; }
+ }
+
+ private readonly SocketAsyncEventArgs _receiveSocketAsyncEventArgs = new SocketAsyncEventArgs()
+ {
+ SocketFlags = SocketFlags.None
+ };
+
+ private readonly SocketAsyncEventArgs _sendSocketAsyncEventArgs = new SocketAsyncEventArgs()
+ {
+ SocketFlags = SocketFlags.None
+ };
+
+ private TaskCompletionSource<SocketReceiveResult> _currentReceiveTaskCompletionSource;
+ private TaskCompletionSource<int> _currentSendTaskCompletionSource;
+
+ public UdpSocket(Socket socket, int localPort, IPAddress ip)
+ {
+ if (socket == null) throw new ArgumentNullException("socket");
+
+ _Socket = socket;
+ _LocalPort = localPort;
+ LocalIPAddress = NetworkManager.ToIpAddressInfo(ip);
+
+ _Socket.Bind(new IPEndPoint(ip, _LocalPort));
+
+ InitReceiveSocketAsyncEventArgs();
+ }
+
+ private void InitReceiveSocketAsyncEventArgs()
+ {
+ var receiveBuffer = new byte[8192];
+ _receiveSocketAsyncEventArgs.SetBuffer(receiveBuffer, 0, receiveBuffer.Length);
+ _receiveSocketAsyncEventArgs.Completed += _receiveSocketAsyncEventArgs_Completed;
+
+ var sendBuffer = new byte[8192];
+ _sendSocketAsyncEventArgs.SetBuffer(sendBuffer, 0, sendBuffer.Length);
+ _sendSocketAsyncEventArgs.Completed += _sendSocketAsyncEventArgs_Completed;
+ }
+
+ private void _receiveSocketAsyncEventArgs_Completed(object sender, SocketAsyncEventArgs e)
+ {
+ var tcs = _currentReceiveTaskCompletionSource;
+ if (tcs != null)
+ {
+ _currentReceiveTaskCompletionSource = null;
+
+ if (e.SocketError == SocketError.Success)
+ {
+ tcs.TrySetResult(new SocketReceiveResult
+ {
+ Buffer = e.Buffer,
+ ReceivedBytes = e.BytesTransferred,
+ RemoteEndPoint = ToIpEndPointInfo(e.RemoteEndPoint as IPEndPoint),
+ LocalIPAddress = LocalIPAddress
+ });
+ }
+ else
+ {
+ tcs.TrySetException(new Exception("SocketError: " + e.SocketError));
+ }
+ }
+ }
+
+ private void _sendSocketAsyncEventArgs_Completed(object sender, SocketAsyncEventArgs e)
+ {
+ var tcs = _currentSendTaskCompletionSource;
+ if (tcs != null)
+ {
+ _currentSendTaskCompletionSource = null;
+
+ if (e.SocketError == SocketError.Success)
+ {
+ tcs.TrySetResult(e.BytesTransferred);
+ }
+ else
+ {
+ tcs.TrySetException(new Exception("SocketError: " + e.SocketError));
+ }
+ }
+ }
+
+ public UdpSocket(Socket socket, IpEndPointInfo endPoint)
+ {
+ if (socket == null) throw new ArgumentNullException("socket");
+
+ _Socket = socket;
+ _Socket.Connect(NetworkManager.ToIPEndPoint(endPoint));
+
+ InitReceiveSocketAsyncEventArgs();
+ }
+
+ public IpAddressInfo LocalIPAddress
+ {
+ get;
+ private set;
+ }
+
+ public IAsyncResult BeginReceive(byte[] buffer, int offset, int count, AsyncCallback callback)
+ {
+ EndPoint receivedFromEndPoint = new IPEndPoint(IPAddress.Any, 0);
+
+ return _Socket.BeginReceiveFrom(buffer, offset, count, SocketFlags.None, ref receivedFromEndPoint, callback, buffer);
+ }
+
+ public int Receive(byte[] buffer, int offset, int count)
+ {
+ return _Socket.Receive(buffer, 0, buffer.Length, SocketFlags.None);
+ }
+
+ public SocketReceiveResult EndReceive(IAsyncResult result)
+ {
+ IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
+ EndPoint remoteEndPoint = (EndPoint)sender;
+
+ var receivedBytes = _Socket.EndReceiveFrom(result, ref remoteEndPoint);
+
+ var buffer = (byte[]) result.AsyncState;
+
+ return new SocketReceiveResult
+ {
+ ReceivedBytes = receivedBytes,
+ RemoteEndPoint = ToIpEndPointInfo((IPEndPoint)remoteEndPoint),
+ Buffer = buffer,
+ LocalIPAddress = LocalIPAddress
+ };
+ }
+
+ public Task<SocketReceiveResult> ReceiveAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
+ {
+ var taskCompletion = new TaskCompletionSource<SocketReceiveResult>();
+
+ Action<IAsyncResult> callback = callbackResult =>
+ {
+ try
+ {
+ taskCompletion.TrySetResult(EndReceive(callbackResult));
+ }
+ catch (Exception ex)
+ {
+ taskCompletion.TrySetException(ex);
+ }
+ };
+
+ var result = BeginReceive(buffer, offset, count, new AsyncCallback(callback));
+
+ if (result.CompletedSynchronously)
+ {
+ callback(result);
+ }
+
+ cancellationToken.Register(() => taskCompletion.TrySetCanceled());
+
+ return taskCompletion.Task;
+ }
+
+ public Task<SocketReceiveResult> ReceiveAsync(CancellationToken cancellationToken)
+ {
+ var buffer = new byte[8192];
+
+ return ReceiveAsync(buffer, 0, buffer.Length, cancellationToken);
+ }
+
+ public Task SendToAsync(byte[] buffer, int offset, int size, IpEndPointInfo endPoint, CancellationToken cancellationToken)
+ {
+ var taskCompletion = new TaskCompletionSource<int>();
+
+ Action<IAsyncResult> callback = callbackResult =>
+ {
+ try
+ {
+ taskCompletion.TrySetResult(EndSendTo(callbackResult));
+ }
+ catch (Exception ex)
+ {
+ taskCompletion.TrySetException(ex);
+ }
+ };
+
+ var result = BeginSendTo(buffer, offset, size, endPoint, new AsyncCallback(callback), null);
+
+ if (result.CompletedSynchronously)
+ {
+ callback(result);
+ }
+
+ cancellationToken.Register(() => taskCompletion.TrySetCanceled());
+
+ return taskCompletion.Task;
+ }
+
+ public IAsyncResult BeginSendTo(byte[] buffer, int offset, int size, IpEndPointInfo endPoint, AsyncCallback callback, object state)
+ {
+ var ipEndPoint = NetworkManager.ToIPEndPoint(endPoint);
+
+ return _Socket.BeginSendTo(buffer, offset, size, SocketFlags.None, ipEndPoint, callback, state);
+ }
+
+ public int EndSendTo(IAsyncResult result)
+ {
+ return _Socket.EndSendTo(result);
+ }
+
+ protected override void Dispose(bool disposing)
+ {
+ if (disposing)
+ {
+ var socket = _Socket;
+ if (socket != null)
+ socket.Dispose();
+
+ var tcs = _currentReceiveTaskCompletionSource;
+ if (tcs != null)
+ {
+ tcs.TrySetCanceled();
+ }
+ var sendTcs = _currentSendTaskCompletionSource;
+ if (sendTcs != null)
+ {
+ sendTcs.TrySetCanceled();
+ }
+ }
+ }
+
+ private static IpEndPointInfo ToIpEndPointInfo(IPEndPoint endpoint)
+ {
+ if (endpoint == null)
+ {
+ return null;
+ }
+
+ return NetworkManager.ToIpEndPointInfo(endpoint);
+ }
+ }
+}