tmp2

Author: SomberNight

electrum/interface.py

@@ -307,8 +307,8 @@ async def write(self, message):
         self._sbuffer += framed_message
         self._sbuffer_has_data_evt.set()
         self._maybe_consume_sbuffer()
-        if not self._sbuffer:
-            self._sbuffer_has_data_evt.clear()
+        if isinstance(self.session, NotificationSession):
+            self.session.maybe_log(f"heyheyhey. write. {self._sbuffer=}")
 
     def _maybe_consume_sbuffer(self):
         if not self._can_send.is_set() or self.is_closing():
@@ -351,6 +351,8 @@ def _maybe_consume_sbuffer(self):
         self._asyncio_transport.write(buf2)
         self._last_send = time.monotonic()
         del self._sbuffer[:p_idx]
+        if not self._sbuffer:
+            self._sbuffer_has_data_evt.clear()
 
     async def _poll_sbuffer(self):
         while True:
@@ -505,7 +507,7 @@ def __init__(self, *, network: 'Network', server: ServerAddr):
         self.fee_estimates_eta = {}  # type: Dict[int, int]
 
         # Dump network messages (only for this interface).  Set at runtime from the console.
-        self.debug = False
+        self.debug = True
 
         self.taskgroup = OldTaskGroup()
 

tests/regtest/regtest.sh

@@ -152,12 +152,12 @@ if [[ $1 == "breach" ]]; then
 fi
 
 
-if [[ $1 == "backup" ]]; then
+if [[ $1 == "backup" ]]; then  #
     wait_for_balance alice 1
     echo "alice opens channel"
     bob_node=$($bob nodeid)
     channel1=$($alice open_channel $bob_node 0.15 --password='')
-    new_blocks 1  # cannot open multiple chans with same node in same block
+    new_blocks 1  # cannot open multiple chans with same node in same block  # TODO double-check this works well
     $alice setconfig use_recoverable_channels False
     channel2=$($alice open_channel $bob_node 0.15 --password='')
     new_blocks 3