1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
------------------------------------------------------------------------
--- Implementation of a worker client to analyze a module
---
--- @author Heiko Hoffmann, Michael Hanus
--- @version March 2013
------------------------------------------------------------------------
module AnalysisWorker(main) where
import IO(Handle,hClose,hFlush,hWaitForInput,hPutStrLn,hGetLine)
import ReadShowTerm(readQTerm)
import Socket(connectToSocket)
import System(getArgs,setEnviron)
import Configuration(debugMessage,waitTime,getDefaultPath)
import Registry(lookupRegAnaWorker)
import ServerFunctions(WorkerMessage(..))
main :: IO ()
main = do
args <- getArgs
if length args /= 2
then error "Analysis worker program started with illegal arguments"
else do
let port = readQTerm (args!!1)
debugMessage 2 ("start analysis worker on port " ++ show port)
getDefaultPath >>= setEnviron "CURRYPATH"
handle <- connectToSocket (head args) port
worker handle
-- communication loop
worker :: Handle -> IO ()
worker handle = do
gotInput <- hWaitForInput handle waitTime
if gotInput
then do
input <- hGetLine handle
debugMessage 3 ("input: "++input)
case readQTerm input of
Task ananame moduleName -> do
debugMessage 1 ("Start task: "++ananame++" for "++moduleName)
-- Run the analysis worker for the given analysis and module:
(lookupRegAnaWorker ananame) [moduleName]
debugMessage 1 ("Finished task: "++ananame++" for "++moduleName)
debugMessage 3 ("Output: "++input)
hPutStrLn handle input
hFlush handle
worker handle
ChangePath path -> do
setEnviron "CURRYPATH" path
worker handle
StopWorker -> do
debugMessage 2 "Stop worker"
hClose handle
done
else done
|
