{-# LINE 1 "System/FileLock/Internal/Flock.hsc" #-}
{-# LANGUAGE InterruptibleFFI #-}

module System.FileLock.Internal.Flock

{-# LINE 7 "System/FileLock/Internal/Flock.hsc" #-}
  (Lock, lock, tryLock, unlock) where



import Control.Applicative
import Control.Concurrent (yield)
import qualified Control.Exception as E
import Data.Bits
import Foreign.C.Error
import Foreign.C.Types
import System.Posix.Files
import System.Posix.IO
  ( openFd, closeFd, defaultFileFlags, OpenMode(..)

{-# LINE 23 "System/FileLock/Internal/Flock.hsc" #-}
  , setFdOption, FdOption(..)

{-# LINE 25 "System/FileLock/Internal/Flock.hsc" #-}
  )
import System.Posix.Types
import Prelude

type Lock = Fd

lock :: FilePath -> Bool -> IO Lock
lock path exclusive = do
  fd <- open path
  (`E.onException` closeFd fd) $ do
    True <- flock fd exclusive True
    return fd

tryLock :: FilePath -> Bool -> IO (Maybe Lock)
tryLock path exclusive = do
  fd <- open path
  (`E.onException` closeFd fd) $ do
    success <- flock fd exclusive False
    if success
      then return $ Just $ fd
      else Nothing <$ closeFd fd

unlock :: Lock -> IO ()
unlock fd = closeFd fd

open :: FilePath -> IO Fd
open path = do

{-# LINE 56 "System/FileLock/Internal/Flock.hsc" #-}
  fd <- openFd path WriteOnly (Just stdFileMode) defaultFileFlags
  setFdOption fd CloseOnExec True
    -- Ideally, we would open the file descriptor with CLOEXEC enabled, but this
    -- is not available in unix < 2.9.
    -- So we set CLOEXEC after opening the file descriptor.  This
    -- may seem like a race condition at first. However, since the lock is always
    -- taken after CLOEXEC is set, the worst that can happen is that a child
    -- process inherits the open FD in an unlocked state. While non-ideal from a
    -- performance standpoint, it doesn't introduce any locking bugs.

{-# LINE 66 "System/FileLock/Internal/Flock.hsc" #-}
  return fd

flock :: Fd -> Bool -> Bool -> IO Bool
flock (Fd fd) exclusive block = do
  r <- c_flock fd $ modeOp .|. blockOp
  if r == 0
    then return True -- success
    else do
      errno <- getErrno
      case () of
        _ | errno == eWOULDBLOCK
            -> return False -- already taken
          | errno == eINTR -> do
              -- If InterruptibleFFI interrupted the syscall with EINTR,
              -- we need to give the accompanying Haskell exception a chance to bubble.
              -- See also https://gitlab.haskell.org/ghc/ghc/issues/8684#note_142404.
              E.interruptible yield
              flock (Fd fd) exclusive block
          | otherwise -> throwErrno "flock"
  where
    modeOp = case exclusive of
      False -> 1
{-# LINE 88 "System/FileLock/Internal/Flock.hsc" #-}
      True -> 2
{-# LINE 89 "System/FileLock/Internal/Flock.hsc" #-}
    blockOp = case block of
      True -> 0
      False -> 4
{-# LINE 92 "System/FileLock/Internal/Flock.hsc" #-}

-- `interruptible` so that async exceptions like `timeout` can stop it
-- when used in blocking mode (without `LOCK_NB`).
foreign import ccall interruptible "flock"
  c_flock :: CInt -> CInt -> IO CInt


{-# LINE 99 "System/FileLock/Internal/Flock.hsc" #-}