(self, dst_curs)
Send copy buffer to target queue.
Send copy buffer to target queue.
Send copy buffer to target queue .
def flush_events(self, dst_curs):
        """Send copy buffer to target queue.
        """
        if len(self.ev_buf) == 0:
            return
        flds = ['ev_time', 'ev_type', 'ev_data', 'ev_extra1',
                'ev_extra2', 'ev_extra3', 'ev_extra4']
        st = self._worker_state
        if st.keep_event_ids:
            flds.append('ev_id')
        bulk_insert_events(dst_curs, self.ev_buf, flds, st.target_queue)
        self.ev_buf = []
def flush_events ( self , dst_curs ) : if len ( self . ev_buf ) == 0 : return flds = [ 'ev_time' , 'ev_type' , 'ev_data' , 'ev_extra1' , 'ev_extra2' , 'ev_extra3' , 'ev_extra4' ] st = self . _worker_state if st . keep_event_ids : flds . append ( 'ev_id' ) bulk_insert_events ( dst_curs , self . ev_buf , flds , st . target_queue ) self . ev_buf = [ ]