(self, src_db, batch_id, ev_list, dst_db)
Content dispatcher.
Content dispatcher.
Content dispatcher .
def process_remote_batch(self, src_db, batch_id, ev_list, dst_db):
        """Content dispatcher."""

        # add events to per-table caches
        tables = {}
        for ev in ev_list:
            tbl = ev.extra1
            if not tbl in tables:
                tables[tbl] = TableCache(tbl)
            cache = tables[tbl]
            cache.add_event(ev)

        # then process them
        for tbl, cache in tables.items():
            cache.finish()
            self.process_one_table(dst_db, tbl, cache)
def process_remote_batch ( self , src_db , batch_id , ev_list , dst_db ) : # add events to per-table caches tables = { } for ev in ev_list : tbl = ev . extra1 if not tbl in tables : tables [ tbl ] = TableCache ( tbl ) cache = tables [ tbl ] cache . add_event ( ev ) # then process them for tbl , cache in tables . items ( ) : cache . finish ( ) self . process_one_table ( dst_db , tbl , cache )