{-# language BangPatterns #-}
{-# language DataKinds #-}
{-# language MagicHash #-}
module Socket.Stream.Uninterruptible.Addr
( send
, receiveExactly
, receiveOnce
, receiveBetween
) where
import Data.Bytes.Types (UnmanagedBytes(..))
import Data.Primitive.Addr (Addr)
import GHC.Exts (proxy#)
import Socket.Stream (Connection,ReceiveException,SendException)
import Socket (Interruptibility(Uninterruptible))
import qualified Socket.Stream.Uninterruptible.Addr.Send as Send
import qualified Socket.Stream.Uninterruptible.Addr.Receive as Receive
send ::
Connection
-> Addr
-> Int
-> IO (Either (SendException 'Uninterruptible) ())
{-# inline send #-}
send !conn !addr !len = Send.send proxy# conn (UnmanagedBytes addr len)
receiveExactly ::
Connection
-> Addr
-> Int
-> IO (Either (ReceiveException 'Uninterruptible) ())
{-# inline receiveExactly #-}
receiveExactly !conn !addr !len =
Receive.receiveExactly proxy# conn (UnmanagedBytes addr len)
receiveOnce ::
Connection
-> Addr
-> Int
-> IO (Either (ReceiveException 'Uninterruptible) Int)
{-# inline receiveOnce #-}
receiveOnce conn addr len =
Receive.receiveOnce proxy# conn (UnmanagedBytes addr len)
receiveBetween ::
Connection
-> Addr
-> Int
-> Int
-> IO (Either (ReceiveException 'Uninterruptible) Int)
{-# inline receiveBetween #-}
receiveBetween conn addr minLen maxLen =
Receive.receiveBetween proxy# conn (UnmanagedBytes addr maxLen) minLen