Revision 9d049fb4 src/Ganeti/Query/Server.hs
b/src/Ganeti/Query/Server.hs | ||
---|---|---|
57 | 57 |
import Ganeti.Luxi |
58 | 58 |
import qualified Ganeti.Query.Language as Qlang |
59 | 59 |
import qualified Ganeti.Query.Cluster as QCluster |
60 |
import Ganeti.Path (queueDir, jobQueueLockFile, defaultLuxiSocket)
|
|
60 |
import Ganeti.Path (queueDir, jobQueueLockFile, defaultMasterSocket)
|
|
61 | 61 |
import Ganeti.Query.Query |
62 | 62 |
import Ganeti.Query.Filter (makeSimpleFilter) |
63 | 63 |
import Ganeti.Types |
... | ... | |
210 | 210 |
case write_result of |
211 | 211 |
Bad s -> return . Bad . GenericError $ s |
212 | 212 |
Ok () -> do |
213 |
socketpath <- defaultLuxiSocket
|
|
213 |
socketpath <- defaultMasterSocket
|
|
214 | 214 |
client <- getClient socketpath |
215 | 215 |
pickupResult <- callMethod (PickupJob jid) client |
216 | 216 |
closeClient client |
... | ... | |
244 | 244 |
succeeded = map snd $ filter (isOk . fst) annotated_results |
245 | 245 |
when (any isBad write_results) . logWarning |
246 | 246 |
$ "Writing some jobs failed " ++ show annotated_results |
247 |
socketpath <- defaultLuxiSocket
|
|
247 |
socketpath <- defaultMasterSocket
|
|
248 | 248 |
client <- getClient socketpath |
249 | 249 |
pickupResults <- mapM (flip callMethod client . PickupJob) |
250 | 250 |
succeeded |
Also available in: Unified diff