diff options
| author | Luke <luke.pulverenti@gmail.com> | 2017-05-24 15:40:25 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-05-24 15:40:25 -0400 |
| commit | ff19fd971c3dadd716cb49366691b830d41cea26 (patch) | |
| tree | d12fde3dd5178579e71e2f268602ad642ffaebe7 /RSSDP | |
| parent | 57bce7daf3777be0ab83833d140c3bb1b13766a8 (diff) | |
| parent | 71f7fc4e116f32a20c63ddbb17844a81283a6ba4 (diff) | |
Merge pull request #2658 from MediaBrowser/dev
Dev
Diffstat (limited to 'RSSDP')
| -rw-r--r-- | RSSDP/SsdpCommunicationsServer.cs | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/RSSDP/SsdpCommunicationsServer.cs b/RSSDP/SsdpCommunicationsServer.cs index e9dc4c54f..91004b76f 100644 --- a/RSSDP/SsdpCommunicationsServer.cs +++ b/RSSDP/SsdpCommunicationsServer.cs @@ -177,7 +177,7 @@ namespace Rssdp.Infrastructure { try { - await socket.SendWithLockAsync(messageData, messageData.Length, destination, cancellationToken).ConfigureAwait(false); + await socket.SendToAsync(messageData, 0, messageData.Length, destination, cancellationToken).ConfigureAwait(false); } catch (ObjectDisposedException) { @@ -392,11 +392,13 @@ namespace Rssdp.Infrastructure var t = Task.Run(async () => { var cancelled = false; + var receiveBuffer = new byte[8192]; + while (!cancelled) { try { - var result = await socket.ReceiveAsync(CancellationToken.None).ConfigureAwait(false); + var result = await socket.ReceiveAsync(receiveBuffer, 0, receiveBuffer.Length, CancellationToken.None).ConfigureAwait(false); if (result.ReceivedBytes > 0) { |
