Revision b336e6fa snf-pithos-backend/pithos/backends/util.py

b/snf-pithos-backend/pithos/backends/util.py
47 47 
                 queue_exchange=None, free_versioning=True,
48 48 
                 quotaholder_enabled=True,
49 49 
                 quotaholder_url=None, quotaholder_token=None,
50 
                 quotaholder_client_poolsize=None,
50 51 
                 block_params=None):
51 52 
        super(PithosBackendPool, self).__init__(size=size)
52 53 
        self.db_module = db_module
......
61 62 
        self.quotaholder_enabled = quotaholder_enabled
62 63 
        self.quotaholder_url = quotaholder_url
63 64 
        self.quotaholder_token = quotaholder_token
65 
        self.quotaholder_client_poolsize = quotaholder_client_poolsize
64 66 
        self.free_versioning = free_versioning
65 67 

  		





  66
  68
  
    
    def _pool_create(self):


  		





  67
  
  
    
        backend = connect_backend(db_module=self.db_module,


  		





  68
  
  
    
                                  db_connection=self.db_connection,


  		





  69
  
  
    
                                  block_module=self.block_module,


  		





  70
  
  
    
                                  block_path=self.block_path,


  		





  71
  
  
    
                                  block_umask=self.block_umask,


  		





  72
  
  
    
                                  queue_module=self.queue_module,


  		





  73
  
  
    
                                  block_params=self.block_params,


  		





  74
  
  
    
                                  queue_hosts=self.queue_hosts,


  		





  75
  
  
    
                                  queue_exchange=self.queue_exchange,


  		





  76
  
  
    
                                  quotaholder_enabled=self.quotaholder_enabled,


  		





  77
  
  
    
                                  quotaholder_url=self.quotaholder_url,


  		





  78
  
  
    
                                  quotaholder_token=self.quotaholder_token,


  		





  79
  
  
    
                                  free_versioning=self.free_versioning)


  		





  
  69
  
    
        backend = connect_backend(


  		





  
  70
  
    
                db_module=self.db_module,


  		





  
  71
  
    
                db_connection=self.db_connection,


  		





  
  72
  
    
                block_module=self.block_module,


  		





  
  73
  
    
                block_path=self.block_path,


  		





  
  74
  
    
                block_umask=self.block_umask,


  		





  
  75
  
    
                queue_module=self.queue_module,


  		





  
  76
  
    
                block_params=self.block_params,


  		





  
  77
  
    
                queue_hosts=self.queue_hosts,


  		





  
  78
  
    
                queue_exchange=self.queue_exchange,


  		





  
  79
  
    
                quotaholder_enabled=self.quotaholder_enabled,


  		





  
  80
  
    
                quotaholder_url=self.quotaholder_url,


  		





  
  81
  
    
                quotaholder_token=self.quotaholder_token,


  		





  
  82
  
    
                quotaholder_client_poolsize=self.quotaholder_client_poolsize,


  		





  
  83
  
    
                free_versioning=self.free_versioning)


  		





  80
  84
  
    

  		





  81
  85
  
    
        backend._real_close = backend.close


  		





  82
  86
  
    
        backend.close = instancemethod(_pooled_backend_close, backend,


  		












Also available in:
  Unified diff