Skip to content

Commit

Permalink
set_verbose() and logz
Browse files Browse the repository at this point in the history
  • Loading branch information
bubbleboy14 committed Apr 25, 2024
1 parent 516ba92 commit 100771e
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 6 deletions.
2 changes: 1 addition & 1 deletion rel/__init__.py
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
from .version import __version__
from .rel import override, supported_methods, initialize, set_sleep, set_turbo, safe_read, read, write, timeout, signal, error, event, dispatch, loop, report, is_running, abort, abort_branch, thread, tick, init, start, stop, buffwrite, EV_PERSIST, EV_READ, EV_SIGNAL, EV_TIMEOUT, EV_WRITE
from .rel import override, supported_methods, initialize, set_verbose, set_sleep, set_turbo, safe_read, read, write, timeout, signal, error, event, dispatch, loop, report, is_running, abort, abort_branch, thread, tick, init, start, stop, buffwrite, EV_PERSIST, EV_READ, EV_SIGNAL, EV_TIMEOUT, EV_WRITE
17 changes: 12 additions & 5 deletions rel/rel.py
Original file line number Diff line number Diff line change
Expand Up @@ -101,8 +101,7 @@ def __init__(self, **kwargs):
}

def _display(text):
if verbose:
print("Registered Event Listener output:", text)
verbose and print("rel:", text)

def __report():
print("=" * 60)
Expand Down Expand Up @@ -166,6 +165,10 @@ def get_registrar(method):
return mapping[method]()
raise ImportError

def set_verbose(isverb):
global verbose
verbose = isverb

def initialize(methods=supported_methods,options=()):
"""
initialize(methods=['epoll','kqueue','poll','select','pyevent'],options=[])
Expand All @@ -177,8 +180,7 @@ def initialize(methods=supported_methods,options=()):
"""
global registrar
global threader
global verbose
verbose = "verbose" in options
set_verbose("verbose" in options)
if "strict" not in options:
for m in supported_methods:
if m not in methods:
Expand Down Expand Up @@ -282,6 +284,7 @@ def tick():
return registrar.tick

def start():
_display("stop")
signal(2, abort)
dispatch()

Expand All @@ -304,14 +307,18 @@ def _bw(fn):
wopts["data"].pop(0)
else:
wopts["data"][0] = wd[sent:]
wopts["data"] or _display("buffwrite send complete")
return wopts["data"]
except OSError:
_display("buffwrite send error!")
wopts["err"]()

def _berr(fn, ecb):
def _ewrap():
wopts = writings[fn]
if "efired" not in wopts:
firstFire = "efired" not in wopts
_display("buffwrite error (%s)"%(firstFire and "first" or "redundant",))
if firstFire:
wopts["efired"] = True
ecb()
return _ewrap
Expand Down

0 comments on commit 100771e

Please sign in to comment.