Source code for obci.acquisition.saver_control_peer
#!/usr/bin/python
# -*- coding: utf-8 -*-
import time
from obci.control.peer.configured_client import ConfiguredClient
from obci.acquisition import acquisition_helper
from obci.configs import settings
from obci.mx_legacy.multiplexer_constants import peers
from obci.utils.openbci_logging import log_crash
[docs]class SaverControl(ConfiguredClient):
@log_crash
def __init__(self, addresses):
super(SaverControl, self).__init__(addresses=addresses, type=peers.CLIENT)
self.sleep_time_s = int(self.get_param('acquisition_time_s'))
self.logger.info(''.join(['[', str(self.config.peer_id), '] INITIALIZED!', str(self.sleep_time_s)]))
self.ready()
[docs] def run(self):
time.sleep(self.sleep_time_s)
self.logger.info(''.join(['[', str(self.config.peer_id), '] SEND CONTROL!']))
self.logger.info("T-before: " + repr(time.time()))
acquisition_helper.finish_saving()
self.logger.info("T-after: " + repr(time.time()))
if __name__ == '__main__':
SaverControl(settings.MULTIPLEXER_ADDRESSES).run()