@@ -9,11 +9,10 @@ import ProjectM36.Server.Config (ServerConfig(..))
99import Control.Monad.IO.Class (liftIO)
1010import Network.Transport.TCP (createTransport, defaultTCPParameters)
1111import Network.Transport (EndPointAddress(..), newEndPoint, address)
12−import Control.Distributed.Process.Node (initRemoteTable, runProcess, newLocalNode)
12+import Control.Distributed.Process.Node (initRemoteTable, runProcess, newLocalNode, initRemoteTable)
1313import Control.Distributed.Process.Extras.Time (Delay(..))
14−import Control.Distributed.Process (Process, register, RemoteTable, getSelfPid)
14+import Control.Distributed.Process (Process, register, getSelfPid)
1515import Control.Distributed.Process.ManagedProcess (defaultProcess, UnhandledMessagePolicy(..), ProcessDefinition(..), handleCall, serve, InitHandler, InitResult(..))
16−import qualified Control.Distributed.Process.Extras.Internal.Types as DIT
1716import Control.Concurrent.MVar (putMVar, MVar)
1817import System.IO (stderr, hPutStrLn)
1918
@@ -62,9 +61,6 @@ initServer (conn, dbname, mAddressMVar, saddress) = do
6261 --traceShowM ("server started on " ++ show saddress)
6362 pure $ InitOk conn Infinity
6463
65−remoteTable :: RemoteTable
66−remoteTable = DIT.__remoteTable initRemoteTable
67−
6864registerDB :: DatabaseName -> Process ()
6965registerDB dbname = do
7066 self <- getSelfPid
@@ -95,7 +91,7 @@ launchServer daemonConfig mAddressMVar = do
9591 case eEndpoint of
9692 Left err -> hPutStrLn stderr ("Failed to create transport: " ++ show err) >> pure False
9793 Right endpoint -> do
98− localTCPNode <- newLocalNode transport remoteTable
94+ localTCPNode <- newLocalNode transport initRemoteTable
9995 --traceShowM ("newLocalNode in Server " ++ show (localNodeId localTCPNode))
10096 runProcess localTCPNode $ do
10197 let testBool = testMode daemonConfig