Add retry in daemon
This commit is contained in:
parent
f031c68f88
commit
47ea5db7c6
1 changed files with 10 additions and 1 deletions
|
@ -4,6 +4,7 @@ import json
|
||||||
import sys
|
import sys
|
||||||
import os
|
import os
|
||||||
import importlib
|
import importlib
|
||||||
|
import itertools
|
||||||
import traceback
|
import traceback
|
||||||
|
|
||||||
|
|
||||||
|
@ -113,8 +114,16 @@ class Pyprland:
|
||||||
|
|
||||||
async def run_daemon():
|
async def run_daemon():
|
||||||
manager = Pyprland()
|
manager = Pyprland()
|
||||||
|
err_count = itertools.count()
|
||||||
manager.server = await asyncio.start_unix_server(manager.read_command, CONTROL)
|
manager.server = await asyncio.start_unix_server(manager.read_command, CONTROL)
|
||||||
events_reader, events_writer = await get_event_stream()
|
try:
|
||||||
|
events_reader, events_writer = await get_event_stream()
|
||||||
|
except Exception as e:
|
||||||
|
print("Failed to get event stream: %s" % e)
|
||||||
|
if next(err_count) > 10:
|
||||||
|
raise
|
||||||
|
await asyncio.sleep(1)
|
||||||
|
|
||||||
manager.event_reader = events_reader
|
manager.event_reader = events_reader
|
||||||
|
|
||||||
try:
|
try:
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue