(self, ev, tick_id, copy_thread, copy_table_name)
return True
Check if table wants this event.
Check if table wants this event.
Check if table wants this event .
def interesting(self, ev, tick_id, copy_thread, copy_table_name):
        """Check if table wants this event."""

        if copy_thread:
            if self.name != copy_table_name:
                return False
            if self.state not in (TABLE_CATCHING_UP, TABLE_DO_SYNC):
                return False
        else:
            if self.state != TABLE_OK:
                return False

        # if no snapshot tracking, then accept always
        if not self.from_snapshot:
            return True

        # uninteresting?
        if self.from_snapshot.contains(ev.txid):
            return False

        # after couple interesting batches there no need to check snapshot
        # as there can be only one partially interesting batch
        if tick_id != self.last_tick:
            self.last_tick = tick_id
            self.ok_batch_count += 1

            # disable batch tracking
            if self.ok_batch_count > 3:
                self.change_snapshot(None)
        return True
def interesting ( self , ev , tick_id , copy_thread , copy_table_name ) : if copy_thread : if self . name != copy_table_name : return False if self . state not in ( TABLE_CATCHING_UP , TABLE_DO_SYNC ) : return False else : if self . state != TABLE_OK : return False # if no snapshot tracking, then accept always if not self . from_snapshot : return True # uninteresting? if self . from_snapshot . contains ( ev . txid ) : return False # after couple interesting batches there no need to check snapshot # as there can be only one partially interesting batch if tick_id != self . last_tick : self . last_tick = tick_id self . ok_batch_count += 1 # disable batch tracking if self . ok_batch_count > 3 : self . change_snapshot ( None ) return True