Remove redundant imports and unused binds in various modules

Author: tmcgilchrist

packages/distributed-process-client-server/src/Control/Distributed/Process/ManagedProcess.hs

@@ -651,7 +651,6 @@ module Control.Distributed.Process.ManagedProcess
 import Control.Distributed.Process hiding (call, Message)
 import Control.Distributed.Process.ManagedProcess.Client
 import Control.Distributed.Process.ManagedProcess.Server
-import qualified Control.Distributed.Process.ManagedProcess.Server.Restricted as R
 import qualified Control.Distributed.Process.ManagedProcess.Server.Priority as P hiding (reject)
 import qualified Control.Distributed.Process.ManagedProcess.Internal.GenProcess as Gen
 import Control.Distributed.Process.ManagedProcess.Internal.GenProcess

packages/distributed-process-client-server/src/Control/Distributed/Process/ManagedProcess/Server/Gen.hs

@@ -97,7 +97,6 @@ import qualified Control.Distributed.Process.ManagedProcess.Internal.GenProcess
  , modifyState
  , setUserTimeout
  , setProcessState
- , GenProcess
  , peek
  , push
  , enqueue

packages/distributed-process-client-server/src/Control/Distributed/Process/ManagedProcess/Timer.hs

@@ -67,7 +67,6 @@ import Control.Distributed.Process.Extras.Timer
 import Data.Binary (Binary)
 import Data.Maybe (isJust, fromJust)
 import Data.Typeable (Typeable)
-import GHC.Conc (registerDelay)
 import GHC.Generics
 
 --------------------------------------------------------------------------------

packages/distributed-process-extras/src/Control/Distributed/Process/Extras/Internal/Containers/MultiMap.hs

@@ -21,13 +21,11 @@ module Control.Distributed.Process.Extras.Internal.Containers.MultiMap
 
 import qualified Data.Foldable as Foldable
 import Data.Foldable (Foldable)
-
 import Data.Hashable
 import Data.HashMap.Strict (HashMap)
 import qualified Data.HashMap.Strict as Map
 import Data.HashSet (HashSet)
 import qualified Data.HashSet as Set
-import Data.Foldable (Foldable(foldr))
 import Prelude hiding (lookup, filter, pred)
 
 -- | Class of things that can be inserted in a map or

packages/distributed-process-extras/tests/TestQueues.hs

@@ -9,7 +9,7 @@ import qualified Control.Distributed.Process.Extras.Internal.Queue.PriorityQ as
 import Data.Function (on)
 import Data.List ( sortBy )
 import Test.Tasty (TestTree, testGroup, defaultMain)
-import Test.Tasty.HUnit (Assertion, assertEqual, assertBool, testCase)
+import Test.Tasty.HUnit (assertEqual, assertBool, testCase)
 import Test.Tasty.QuickCheck (testProperty)
 
 import Prelude

packages/distributed-process-extras/tests/TestTimer.hs

@@ -19,7 +19,7 @@ import Control.Distributed.Process.Extras.Timer
 import Control.Distributed.Process.SysTest.Utils
 
 import Test.Tasty (TestTree, testGroup, defaultMain)
-import Test.Tasty.HUnit (Assertion, assertEqual, assertBool, testCase)
+import Test.Tasty.HUnit (testCase)
 import Network.Transport.TCP
 import qualified Network.Transport as NT
 

packages/distributed-process-simplelocalnet/tests/Main.hs

@@ -2,17 +2,17 @@
 
 import Control.Concurrent (forkIO, threadDelay)
 import qualified Control.Concurrent.MVar as MVar
-import Control.Distributed.Process (NodeId, Process, liftIO)
 import Control.Distributed.Process.Node (initRemoteTable)
 import Control.Distributed.Process.Backend.SimpleLocalnet
 import Control.Monad (forM_)
+import Control.Monad.IO.Class (liftIO)
 import qualified Data.List as List
 import Test.Tasty (TestTree, defaultMain, testGroup)
 import Test.Tasty.HUnit (assertEqual, testCase)
 
 main :: IO ()
-main = defaultMain 
-     $ testGroup "Test suite" 
+main = defaultMain
+     $ testGroup "Test suite"
      [ testDiscoverNodes
      ]
 
@@ -24,7 +24,7 @@ testDiscoverNodes = testCase "discover nodes" $ do
     backend <- initializeBackend "127.0.0.1" port initRemoteTable
     _ <- forkIO $ startSlave backend
     threadDelay 100000
-  
+
   -- initialize master node
   discoveredNodesSlot <- MVar.newEmptyMVar
   backend <- initializeBackend "127.0.0.1" "10004" initRemoteTable
@@ -33,12 +33,12 @@ testDiscoverNodes = testCase "discover nodes" $ do
     liftIO $ MVar.putMVar discoveredNodesSlot nds
 
   discoveredNodes <- (List.sort . List.nub) <$> MVar.readMVar discoveredNodesSlot
-  assertEqual "Discovered nodes" 
+  assertEqual "Discovered nodes"
               [ "nid://127.0.0.1:10000:0"
               , "nid://127.0.0.1:10001:0"
               , "nid://127.0.0.1:10002:0"
               , "nid://127.0.0.1:10003:0"
-              ] 
+              ]
               (map show discoveredNodes)
 
 

packages/distributed-process-supervisor/src/Control/Distributed/Process/Supervisor/Management.hs

@@ -52,7 +52,6 @@ import Control.Distributed.Process.Supervisor.Types
   , SupervisorPid
   )
 import Data.Binary
-import Data.Foldable (mapM_)
 import Data.Hashable (Hashable(..))
 import Control.Distributed.Process.Extras.Internal.Containers.MultiMap (MultiMap)
 import qualified Control.Distributed.Process.Extras.Internal.Containers.MultiMap as Map

packages/network-transport-inmemory/tests/TestInMemory.hs

@@ -4,7 +4,6 @@ import Network.Transport.Tests
 import Network.Transport.Tests.Auxiliary (runTests)
 import Network.Transport.InMemory
 import Network.Transport
-import Control.Applicative ((<$>))
 
 main :: IO ()
 main = do

packages/network-transport-tcp/src/Network/Transport/TCP.hs

@@ -71,7 +71,6 @@ import Network.Transport.Internal
   ( prependLength
   , mapIOException
   , tryIO
-  , tryToEnum
   , void
   , timeoutMaybe
   , asyncWhenCancelled
@@ -130,7 +129,6 @@ import Control.Concurrent.MVar
   )
 import Control.Concurrent.Async (async, wait)
 import Control.Category ((>>>))
-import Control.Applicative ((<$>))
 import Control.Monad (when, unless, join, mplus, (<=<))
 import Control.Exception
   ( IOException
@@ -151,10 +149,10 @@ import Control.Exception
   )
 import Data.IORef (IORef, newIORef, writeIORef, readIORef, writeIORef)
 import Data.ByteString (ByteString)
-import qualified Data.ByteString as BS (concat, length, null)
+import qualified Data.ByteString as BS (concat, null)
 import qualified Data.ByteString.Char8 as BSC (pack, unpack)
 import Data.Bits (shiftL, (.|.))
-import Data.Maybe (isJust, isNothing, fromJust)
+import Data.Maybe (isJust, isNothing)
 import Data.Word (Word32)
 import Data.Set (Set)
 import qualified Data.Set as Set
@@ -168,7 +166,6 @@ import qualified Data.Set as Set
   )
 import Data.Map (Map)
 import qualified Data.Map as Map (empty)
-import Data.Traversable (traverse)
 import Data.Accessor (Accessor, accessor, (^.), (^=), (^:))
 import qualified Data.Accessor.Container as DAC (mapMaybe)
 import Data.Foldable (forM_, mapM_)
@@ -821,8 +818,6 @@ apiConnect transport ourEndPoint theirAddress _reliability hints =
           { send  = apiSend  (ourEndPoint, theirEndPoint) connId connAlive
           , close = apiClose (ourEndPoint, theirEndPoint) connId connAlive
           }
-  where
-  params = transportParams transport
 
 -- | Close a connection
 apiClose :: EndPointPair -> LightweightConnectionId -> IORef Bool -> IO ()
@@ -1025,7 +1020,7 @@ handleConnectionRequest transport socketClosed (sock, sockAddr) = handle handleE
     handleConnectionRequestV0 :: (N.Socket, N.SockAddr) -> IO (Maybe (IO ()))
     handleConnectionRequestV0 (sock, sockAddr) = do
       -- Get the OS-determined host and port.
-      (numericHost, resolvedHost, actualPort) <-
+      (numericHost, resolvedHost, _actualPort) <-
         resolveSockAddr sockAddr >>=
           maybe (throwIO (userError "handleConnectionRequest: invalid socket address")) return
       -- The peer must send our identifier and their address promptly, if a
@@ -1304,7 +1299,7 @@ handleIncomingMessages params (ourEndPoint, theirEndPoint) =
 
     -- Close the socket (if we don't have any outgoing connections)
     closeSocket :: N.Socket -> LightweightConnectionId -> IO Bool
-    closeSocket sock lastReceivedId = do
+    closeSocket _sock lastReceivedId = do
       mAct <- modifyMVar theirState $ \st -> do
         case st of
           RemoteEndPointInvalid _ ->
@@ -1388,8 +1383,8 @@ handleIncomingMessages params (ourEndPoint, theirEndPoint) =
               "handleIncomingMessages:closeSocket (closed)"
       case mAct of
         Nothing -> return False
-        Just act -> do
-          runScheduledAction (ourEndPoint, theirEndPoint) act
+        Just act' -> do
+          runScheduledAction (ourEndPoint, theirEndPoint) act'
           return True
 
     -- Read a message and output it on the endPoint's channel. By rights we
@@ -2013,7 +2008,7 @@ schedule theirEndPoint act = do
 -- However, it will then wait until @p@ is executed (by this call to
 -- 'runScheduledAction' or by another).
 runScheduledAction :: EndPointPair -> Action a -> IO a
-runScheduledAction (ourEndPoint, theirEndPoint) mvar = do
+runScheduledAction (_ourEndPoint, theirEndPoint) mvar = do
     join $ readChan (remoteScheduled theirEndPoint)
     ma <- readMVar mvar
     case ma of