Revision c33549ef

b/lib/constants.py
619 619 
JOB_QUEUE_DRAIN_FILE = QUEUE_DIR + "/drain"
620 620 
JOB_QUEUE_SIZE_HARD_LIMIT = 5000
621 621 
JOB_QUEUE_SIZE_SOFT_LIMIT = JOB_QUEUE_SIZE_HARD_LIMIT * 0.8
622 
JOB_QUEUE_DIRS = [QUEUE_DIR, JOB_QUEUE_ARCHIVE_DIR]
623 
JOB_QUEUE_DIRS_MODE = 0700
622 624 

  		





  623
  625
  
    
JOB_ID_TEMPLATE = r"\d+"


  		





  624
  626
  
    

  		












  

    
      b/lib/jstore.py
    
  






  21
  21
  
    

  		





  22
  22
  
    
"""Module implementing the job queue handling."""


  		





  23
  23
  
    

  		





  24
  
  
    
import os


  		





  25
  24
  
    
import errno


  		





  26
  25
  
    

  		





  27
  26
  
    
from ganeti import constants


  		





  ......




  79
  78
  
    
           locking mode.


  		





  80
  79
  
    

  		





  81
  80
  
    
  """


  		





  82
  
  
    
  # Make sure our directories exists


  		





  83
  
  
    
  for path in (constants.QUEUE_DIR, constants.JOB_QUEUE_ARCHIVE_DIR):


  		





  84
  
  
    
    try:


  		





  85
  
  
    
      os.mkdir(path, 0700)


  		





  86
  
  
    
    except OSError, err:


  		





  87
  
  
    
      if err.errno not in (errno.EEXIST, ):


  		





  88
  
  
    
        raise


  		





  
  81
  
    
  dirs = [(d, constants.JOB_QUEUE_DIRS_MODE) for d in constants.JOB_QUEUE_DIRS]


  		





  
  82
  
    
  utils.EnsureDirs(dirs)


  		





  89
  83
  
    

  		





  90
  84
  
    
  # Lock queue


  		





  91
  85
  
    
  queue_lock = utils.FileLock.Open(constants.JOB_QUEUE_LOCK_FILE)


  		












Also available in:
  Unified diff