From e6cae9bcc37db47bc94aafcaabcd3c1418a11bef Mon Sep 17 00:00:00 2001
From: Jack Robison <jackrobison@lbry.io>
Date: Mon, 15 Jun 2020 10:22:30 -0400
Subject: [PATCH] remove mempool wakeup event, lower refresh delay

---
 lbry/wallet/server/mempool.py | 13 +++----------
 lbry/wallet/server/session.py |  1 -
 2 files changed, 3 insertions(+), 11 deletions(-)

diff --git a/lbry/wallet/server/mempool.py b/lbry/wallet/server/mempool.py
index 40311bd20..fd045ced7 100644
--- a/lbry/wallet/server/mempool.py
+++ b/lbry/wallet/server/mempool.py
@@ -104,7 +104,7 @@ class MemPool:
        hashXs: hashX   -> set of all hashes of txs touching the hashX
     """
 
-    def __init__(self, coin, api, refresh_secs=5.0, log_status_secs=120.0):
+    def __init__(self, coin, api, refresh_secs=1.0, log_status_secs=120.0):
         assert isinstance(api, MemPoolAPI)
         self.coin = coin
         self.api = api
@@ -230,16 +230,9 @@ class MemPool:
             synchronized_event.set()
             synchronized_event.clear()
             await self.api.on_mempool(touched, height)
-            timed_out = False
-            try:
-                # we wait up to `refresh_secs` but go early if a broadcast happens (which triggers wakeup event)
-                await asyncio.wait_for(self.wakeup.wait(), timeout=self.refresh_secs)
-            except asyncio.TimeoutError:
-                timed_out = True
-            finally:
-                self.wakeup.clear()
-            duration = time.perf_counter() - start - (0 if not timed_out else self.refresh_secs)
+            duration = time.perf_counter() - start
             self.mempool_process_time_metric.observe(duration)
+            await asyncio.sleep(self.refresh_secs)
 
     async def _process_mempool(self, all_hashes):
         # Re-sync with the new set of hashes
diff --git a/lbry/wallet/server/session.py b/lbry/wallet/server/session.py
index 3e6bfb771..6eb514335 100644
--- a/lbry/wallet/server/session.py
+++ b/lbry/wallet/server/session.py
@@ -602,7 +602,6 @@ class SessionManager:
 
     async def broadcast_transaction(self, raw_tx):
         hex_hash = await self.daemon.broadcast_transaction(raw_tx)
-        self.mempool.wakeup.set()
         self.txs_sent += 1
         return hex_hash