aboutsummaryrefslogtreecommitdiff
path: root/Mono.Nat/NatUtility.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Mono.Nat/NatUtility.cs')
-rw-r--r--Mono.Nat/NatUtility.cs11
1 files changed, 6 insertions, 5 deletions
diff --git a/Mono.Nat/NatUtility.cs b/Mono.Nat/NatUtility.cs
index 1ba12f346..bcbe5d8d0 100644
--- a/Mono.Nat/NatUtility.cs
+++ b/Mono.Nat/NatUtility.cs
@@ -36,7 +36,7 @@ using System.IO;
using System.Net.NetworkInformation;
using System.Threading.Tasks;
using MediaBrowser.Common.Net;
-using MediaBrowser.Controller.Dlna;
+using MediaBrowser.Model.Dlna;
using MediaBrowser.Model.Logging;
namespace Mono.Nat
@@ -109,7 +109,7 @@ namespace Mono.Nat
if (enabledProtocols.Contains(PmpSearcher.Instance.Protocol))
{
- Receive(PmpSearcher.Instance, PmpSearcher.sockets);
+ await Receive(PmpSearcher.Instance, PmpSearcher.sockets).ConfigureAwait(false);
}
foreach (ISearcher s in controllers)
@@ -129,15 +129,16 @@ namespace Mono.Nat
}
}
- static void Receive (ISearcher searcher, List<UdpClient> clients)
+ static async Task Receive (ISearcher searcher, List<UdpClient> clients)
{
- IPEndPoint received = new IPEndPoint(IPAddress.Parse("192.168.0.1"), 5351);
foreach (UdpClient client in clients)
{
if (client.Available > 0)
{
IPAddress localAddress = ((IPEndPoint)client.Client.LocalEndPoint).Address;
- byte[] data = client.Receive(ref received);
+ var result = await client.ReceiveAsync().ConfigureAwait(false);
+ var data = result.Buffer;
+ var received = result.RemoteEndPoint;
searcher.Handle(localAddress, data, received);
}
}