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