irrad_control/irrad_interpreter.py
def store_data(self, server):
        """Method which appends current data to table files. If tables are longer then self._max_buf_len,
        flush the buffer to hard drive"""

        self.raw_table[server].append(self.raw_data[server])
        self.beam_table[server].append(self.beam_data[server])

        # If the stage scanned, append data
        if self._store_fluence_data:
            self.fluence_table[server].append(self.fluence_data[server])
            self._store_fluence_data = False

        if self._store_temp_data:
            self.temp_table[server].append(self.temp_data[server])
            self._store_temp_data = False

        # Flush data to hard drive in fixed interval
        if self._last_data_flush is None or time.time() - self._last_data_flush >= self._data_flush_interval:
            self._last_data_flush = time.time()
            logging.debug("Flushing data to hard disk...")
            self.output_table.flush()
Method which appends current data to table files. If tables are longer then self._max_buf_len,
        flush the buffer to hard drive
Method which appends current data to table files. If tables are longer then self._max_buf_len,
flush the buffer to hard drive
Method which appends current data to table files . If tables are longer then self . _max_buf_len flush the buffer to hard drive
def store_data(self, server):
        self.raw_table[server].append(self.raw_data[server])
        self.beam_table[server].append(self.beam_data[server])
        if self._store_fluence_data:
            self.fluence_table[server].append(self.fluence_data[server])
            self._store_fluence_data = False
        if self._store_temp_data:
            self.temp_table[server].append(self.temp_data[server])
            self._store_temp_data = False
        if self._last_data_flush is None or time.time() - self._last_data_flush >= self._data_flush_interval:
            self._last_data_flush = time.time()
            logging.debug("Flushing data to hard disk...")
            self.output_table.flush()
def store_data ( self , server ) : self . raw_table [ server ] . append ( self . raw_data [ server ] ) self . beam_table [ server ] . append ( self . beam_data [ server ] ) if self . _store_fluence_data : self . fluence_table [ server ] . append ( self . fluence_data [ server ] ) self . _store_fluence_data = False if self . _store_temp_data : self . temp_table [ server ] . append ( self . temp_data [ server ] ) self . _store_temp_data = False if self . _last_data_flush is None or time . time ( ) - self . _last_data_flush >= self . _data_flush_interval : self . _last_data_flush = time . time ( ) logging . debug ( "Flushing data to hard disk..." ) self . output_table . flush ( )
Method which appends current data to table files.
Method which appends current data to table files .
"""Method which appends current data to table files. If tables are longer then self._max_buf_len,
        flush the buffer to hard drive""" # If the stage scanned, append data # Flush data to hard drive in fixed interval
self
server