diff options
Diffstat (limited to 'src/Network/WireGuard/UdpListener.hs')
| -rw-r--r-- | src/Network/WireGuard/UdpListener.hs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/Network/WireGuard/UdpListener.hs b/src/Network/WireGuard/UdpListener.hs index 77b8ae0..93369f4 100644 --- a/src/Network/WireGuard/UdpListener.hs +++ b/src/Network/WireGuard/UdpListener.hs @@ -46,11 +46,11 @@ handlePort bindPort readUdpChan writeUdpChan = retryWithBackoff $ handleRead :: Socket -> PacketQueue UdpPacket -> IO () handleRead sock readUdpChan = forever $ do packet <- recvFrom sock udpReadBufferLength - void $ atomically $ tryPushPacketQueue readUdpChan packet + pushPacketQueue readUdpChan packet handleWrite :: Socket -> PacketQueue UdpPacket -> IO () handleWrite sock writeUdpChan = forever $ do - (packet, dest) <- atomically $ popPacketQueue writeUdpChan + (packet, dest) <- popPacketQueue writeUdpChan void $ sendTo sock packet dest waitNewVar :: Eq a => a -> TVar a -> STM a |