Add an assertion in wait_selector() / wait_epoll()

Making sure the ready event matches what we're waiting on.

diff --git a/psycopg/psycopg/waiting.py b/psycopg/psycopg/waiting.py
index 59bbd6559bc409fdd1aa2332f08492fc582cf7da..b75dbe5b598de93a14a22c18bc82435d9fae2746 100644 (file)
--- a/psycopg/psycopg/waiting.py
+++ b/psycopg/psycopg/waiting.py
@@ -59,6 +59,7 @@ def wait_selector(
             sel.unregister(fileno)
             # note: this line should require a cast, but mypy doesn't complain
             ready: Ready = rlist[0][1]
+            assert s & ready
             s = gen.send(ready)
 
     except StopIteration as ex:
@@ -237,6 +238,7 @@ def wait_epoll(
                 ready = Ready.R
             if ev & ~select.EPOLLIN:
                 ready |= Ready.W
+            assert s & ready
             s = gen.send(ready)
             evmask = poll_evmasks[s]
             epoll.modify(fileno, evmask)