Skip to content
Snippets Groups Projects
Commit 2e197877 authored by jkerdreu's avatar jkerdreu
Browse files

- split helpers vs aiohelpers

- async module imported by default right now !! 

git-svn-id: https://redmine.imt-atlantique.fr/svn/xaal/code/Python/branches/0.7@2822 b32b6428-25c9-4566-ad07-03861ab6144f
parent b591eb55
No related branches found
No related tags found
No related merge requests found
......@@ -6,6 +6,7 @@
from . import tools
from . import config
from . import bindings
from . import aiohelpers as helpers
from .core import Timer
......
from . helpers import *
from decorator import decorator
import asyncio
import logging
@decorator
def spawn(func,*args,**kwargs):
return asyncio.get_event_loop().run_in_executor(None,func,*args,**kwargs)
def static_vars(**kwargs_):
def decorate(func):
for k in kwargs_:
setattr(func, k, kwargs_[k])
return func
return decorate
def run_async_package(pkg_name,pkg_setup,console_log = True,file_log=False):
if console_log:
set_console_title(pkg_name)
setup_console_logger()
if file_log:
setup_file_logger(pkg_name)
from .aioengine import AsyncEngine
eng = AsyncEngine()
eng.start()
logger = logging.getLogger(pkg_name)
logger.info('starting xaal package: %s'% pkg_name )
result = pkg_setup(eng)
if result != True:
logger.critical("something goes wrong with package: %s" % pkg_name)
try:
eng.run()
except KeyboardInterrupt:
eng.shutdown()
logger.info("Exit")
......@@ -10,7 +10,7 @@ import time
import coloredlogs
from decorator import decorator
from . import config,Engine
from . import config
def singleton(class_):
instances = {}
......@@ -56,7 +56,6 @@ def setup_file_logger(name,level=config.log_level,filename = None):
#
# Default arguments console_log and file_log are (and should) never be used.
# ---------------------------------------------------------------------------
def run_package(pkg_name,pkg_setup,console_log = True,file_log=False):
if console_log:
set_console_title(pkg_name)
......@@ -66,6 +65,7 @@ def run_package(pkg_name,pkg_setup,console_log = True,file_log=False):
logger = logging.getLogger(pkg_name)
logger.info('starting xaal package: %s'% pkg_name )
from .engine import Engine
eng = Engine()
result = pkg_setup(eng)
......@@ -77,23 +77,4 @@ def run_package(pkg_name,pkg_setup,console_log = True,file_log=False):
eng.shutdown()
logger.info("exit")
def run_async_package(pkg_name,pkg_setup,console_log = True,file_log=False):
if console_log:
set_console_title(pkg_name)
setup_console_logger()
if file_log:
setup_file_logger(pkg_name)
from .aioengine import AsyncEngine
eng = AsyncEngine()
eng.start()
logger = logging.getLogger(pkg_name)
logger.info('starting xaal package: %s'% pkg_name )
result = pkg_setup(eng)
if result != True:
logger.critical("something goes wrong with package: %s" % pkg_name)
try:
eng.run()
except KeyboardInterrupt:
eng.shutdown()
logger.info("Exit")
__all__ = ['singleton','timeit','set_console_title','setup_console_logger','setup_file_logger','run_package']
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment