server/sources/pyrorql.py
changeset 6946 e350771c23a3
parent 6945 28bf94d062a9
child 6957 ffda12be2e9f
equal deleted inserted replaced
6945:28bf94d062a9 6946:e350771c23a3
   109           'help': 'Pyro name server\'s group where the repository will be \
   109           'help': 'Pyro name server\'s group where the repository will be \
   110 registered. If not set, default to the value from all_in_one.conf.',
   110 registered. If not set, default to the value from all_in_one.conf.',
   111           'group': 'pyro-source', 'level': 2,
   111           'group': 'pyro-source', 'level': 2,
   112           }),
   112           }),
   113         ('synchronization-interval',
   113         ('synchronization-interval',
   114          {'type' : 'int',
   114          {'type' : 'time',
   115           'default': 5*60,
   115           'default': '5min',
   116           'help': 'interval between synchronization with the external \
   116           'help': 'interval between synchronization with the external \
   117 repository (default to 5 minutes).',
   117 repository (default to 5 minutes).',
   118           'group': 'pyro-source', 'level': 2,
   118           'group': 'pyro-source', 'level': 2,
   119           }),
   119           }),
   120 
   120 
   170 
   170 
   171     def init(self, activated, session=None):
   171     def init(self, activated, session=None):
   172         """method called by the repository once ready to handle request"""
   172         """method called by the repository once ready to handle request"""
   173         self.load_mapping(session)
   173         self.load_mapping(session)
   174         if activated:
   174         if activated:
   175             interval = int(self.config.get('synchronization-interval', 5*60))
   175             interval = self.config['synchronization-interval']
   176             self.repo.looping_task(interval, self.synchronize)
   176             self.repo.looping_task(interval, self.synchronize)
   177             self.repo.looping_task(self._query_cache.ttl.seconds/10,
   177             self.repo.looping_task(self._query_cache.ttl.seconds/10,
   178                                    self._query_cache.clear_expired)
   178                                    self._query_cache.clear_expired)
   179 
   179 
   180     def load_mapping(self, session=None):
   180     def load_mapping(self, session=None):