Revision 350f0759 src/Ganeti/JQScheduler.hs
b/src/Ganeti/JQScheduler.hs | ||
---|---|---|
99 | 99 |
qdir <- queueDir |
100 | 100 |
let fpath = liveJobFile qdir jid |
101 | 101 |
logDebug $ "Checking if " ++ fpath ++ " changed on disk." |
102 |
changed <- needsReload fstat fpath |
|
102 |
changedResult <- try $ needsReload fstat fpath |
|
103 |
:: IO (Either IOError (Maybe FStat)) |
|
104 |
let changed = either (const $ Just nullFStat) id changedResult |
|
103 | 105 |
case changed of |
104 | 106 |
Nothing -> do |
105 | 107 |
logDebug $ "File " ++ fpath ++ " not changed on disk." |
106 | 108 |
return Nothing |
107 | 109 |
Just fstat' -> do |
108 |
logInfo $ "Rereading " ++ fpath |
|
109 |
readResult <- loadJobFromDisk qdir False jid |
|
110 | 110 |
let jids = show $ fromJobId jid |
111 |
logInfo $ "Rereading job " ++ jids |
|
112 |
readResult <- loadJobFromDisk qdir True jid |
|
111 | 113 |
case readResult of |
112 | 114 |
Bad s -> do |
113 | 115 |
logWarning $ "Failed to read job " ++ jids ++ ": " ++ s |
Also available in: Unified diff