From 100771eca1232d8fe986f7a29575d84979dc40c9 Mon Sep 17 00:00:00 2001
From: bubbleboy14 <mario.balibrera@gmail.com>
Date: Thu, 25 Apr 2024 15:18:45 -0700
Subject: [PATCH] set_verbose() and logz

---
 rel/__init__.py |  2 +-
 rel/rel.py      | 17 ++++++++++++-----
 2 files changed, 13 insertions(+), 6 deletions(-)

diff --git a/rel/__init__.py b/rel/__init__.py
index ba86715..1b40099 100644
--- a/rel/__init__.py
+++ b/rel/__init__.py
@@ -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
diff --git a/rel/rel.py b/rel/rel.py
index fa95ea5..01a3558 100644
--- a/rel/rel.py
+++ b/rel/rel.py
@@ -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)
@@ -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=[])
@@ -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:
@@ -282,6 +284,7 @@ def tick():
     return registrar.tick
 
 def start():
+    _display("stop")
     signal(2, abort)
     dispatch()
 
@@ -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