(self, args)
Replication init.
Replication init.
Replication init .
def __init__(self, args):
        """Replication init."""
        CascadedWorker.__init__(self, 'londiste3', 'db', args)

        self.table_list = []
        self.table_map = {}

        self.copy_thread = 0
        self.set_name = self.queue_name
        self.used_plugins = {}

        self.parallel_copies = self.cf.getint('parallel_copies', 1)
        if self.parallel_copies < 1:
            raise Exception('Bad value for parallel_copies: %d' % self.parallel_copies)

        self.consumer_filter = None

        load_handler_modules(self.cf)
def __init__ ( self , args ) : CascadedWorker . __init__ ( self , 'londiste3' , 'db' , args ) self . table_list = [ ] self . table_map = { } self . copy_thread = 0 self . set_name = self . queue_name self . used_plugins = { } self . parallel_copies = self . cf . getint ( 'parallel_copies' , 1 ) if self . parallel_copies < 1 : raise Exception ( 'Bad value for parallel_copies: %d' % self . parallel_copies ) self . consumer_filter = None load_handler_modules ( self . cf )