Revision 6046dca9 src/Ganeti/JQScheduler.hs

b/src/Ganeti/JQScheduler.hs
44 44 
import Ganeti.Constants as C
45 45 
import Ganeti.JQueue as JQ
46 46 
import Ganeti.Logging
47 
import Ganeti.Objects (ConfigData)
47 48 
import Ganeti.Path
48 49 
import Ganeti.Types
49 50 
import Ganeti.Utils
......
66 67 

  		





  67
  68
  
    
data JQStatus = JQStatus


  		





  68
  69
  
    
  { jqJobs :: IORef Queue


  		





  
  70
  
    
  , jqConfig :: IORef (Result ConfigData)


  		





  69
  71
  
    
  }


  		





  70
  72
  
    

  		





  71
  73
  
    

  		





  72
  
  
    
emptyJQStatus :: IO JQStatus


  		





  73
  
  
    
emptyJQStatus = do


  		





  74
  
  
    
  jqJ <- newIORef Queue {qEnqueued=[], qRunning=[]}


  		





  75
  
  
    
  return JQStatus { jqJobs=jqJ }


  		





  
  74
  
    
emptyJQStatus :: IORef (Result ConfigData) -> IO JQStatus


  		





  
  75
  
    
emptyJQStatus config = do


  		





  
  76
  
    
  jqJ <- newIORef Queue { qEnqueued = [], qRunning = []}


  		





  
  77
  
    
  return JQStatus { jqJobs = jqJ, jqConfig = config }


  		





  76
  78
  
    

  		





  77
  79
  
    
-- | Apply a function on the running jobs.


  		





  78
  80
  
    
onRunningJobs :: ([JobWithStat] -> [JobWithStat]) -> Queue -> Queue


  		












Also available in:
  Unified diff