(self, args, copy_thread = 1)
Initializer.  copy_thread arg shows if the copy process is separate
        from main Playback thread or not.  copy_thread=0 means copying happens
        in same process.
Initializer.  copy_thread arg shows if the copy process is separate
        from main Playback thread or not.  copy_thread=0 means copying happens
        in same process.
Initializer . copy_thread arg shows if the copy process is separate from main Playback thread or not . copy_thread = 0 means copying happens in same process .
def __init__(self, args, copy_thread = 1):
        """Initializer.  copy_thread arg shows if the copy process is separate
        from main Playback thread or not.  copy_thread=0 means copying happens
        in same process.
        """

        Replicator.__init__(self, args)

        if not copy_thread:
            raise Exception("Combined copy not supported")

        if len(self.args) != 3:
            self.log.error("londiste copy requires table name")
            sys.exit(1)
        self.copy_table_name = self.args[2]

        sfx = self.get_copy_suffix(self.copy_table_name)
        self.old_consumer_name = self.consumer_name
        self.pidfile += sfx
        self.consumer_name += sfx
        self.copy_thread = 1
        self.main_worker = False
def __init__ ( self , args , copy_thread = 1 ) : Replicator . __init__ ( self , args ) if not copy_thread : raise Exception ( "Combined copy not supported" ) if len ( self . args ) != 3 : self . log . error ( "londiste copy requires table name" ) sys . exit ( 1 ) self . copy_table_name = self . args [ 2 ] sfx = self . get_copy_suffix ( self . copy_table_name ) self . old_consumer_name = self . consumer_name self . pidfile += sfx self . consumer_name += sfx self . copy_thread = 1 self . main_worker = False