mirror of
https://github.com/BOSWatch/BW3-Core.git
synced 2026-03-21 20:24:51 +01:00
Merge branch 'develop' into patch-1
This commit is contained in:
commit
bd25ff75e8
|
|
@ -48,6 +48,11 @@ class LineInInput(InputBase):
|
||||||
if not lineInProc.isRunning:
|
if not lineInProc.isRunning:
|
||||||
logging.warning("asla was down - try to restart")
|
logging.warning("asla was down - try to restart")
|
||||||
lineInProc.start()
|
lineInProc.start()
|
||||||
|
|
||||||
|
if lineInProc.isRunning:
|
||||||
|
logging.info("rtl_fm is back up - restarting multimon...")
|
||||||
|
mmProc.setStdin(lineInProc.stdout)
|
||||||
|
mmProc.start()
|
||||||
elif not mmProc.isRunning:
|
elif not mmProc.isRunning:
|
||||||
logging.warning("multimon was down - try to restart")
|
logging.warning("multimon was down - try to restart")
|
||||||
mmProc.start()
|
mmProc.start()
|
||||||
|
|
|
||||||
|
|
@ -47,6 +47,11 @@ class PulseAudioInput(InputBase):
|
||||||
if not PulseAudioProc.isRunning:
|
if not PulseAudioProc.isRunning:
|
||||||
logging.warning("PulseAudio was down - try to restart")
|
logging.warning("PulseAudio was down - try to restart")
|
||||||
PulseAudioProc.start()
|
PulseAudioProc.start()
|
||||||
|
|
||||||
|
if PulseAudioProc.isRunning:
|
||||||
|
logging.info("rtl_fm is back up - restarting multimon...")
|
||||||
|
mmProc.setStdin(PulseAudioProc.stdout)
|
||||||
|
mmProc.start()
|
||||||
elif not mmProc.isRunning:
|
elif not mmProc.isRunning:
|
||||||
logging.warning("multimon was down - try to restart")
|
logging.warning("multimon was down - try to restart")
|
||||||
mmProc.start()
|
mmProc.start()
|
||||||
|
|
|
||||||
|
|
@ -72,7 +72,7 @@ class BoswatchPlugin(PluginBase):
|
||||||
|
|
||||||
loop = asyncio.get_event_loop()
|
loop = asyncio.get_event_loop()
|
||||||
|
|
||||||
future = asyncio.ensure_future(self.asyncRequests(urls))
|
future = asyncio.ensure_future(self._asyncRequests(urls))
|
||||||
loop.run_until_complete(future)
|
loop.run_until_complete(future)
|
||||||
|
|
||||||
async def _asyncRequests(self, urls):
|
async def _asyncRequests(self, urls):
|
||||||
|
|
|
||||||
|
|
@ -8,6 +8,7 @@ mkdocs
|
||||||
# for develope only
|
# for develope only
|
||||||
pytest
|
pytest
|
||||||
pytest-cov
|
pytest-cov
|
||||||
|
flake8==4.0.1
|
||||||
pytest-flake8
|
pytest-flake8
|
||||||
pytest-flakes
|
pytest-flakes
|
||||||
pytest-randomly
|
pytest-randomly
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue