From da9b4e317a685f58b44e03a89ef33ea7864c830d Mon Sep 17 00:00:00 2001
From: Jack Robison <jackrobison@lbry.io>
Date: Fri, 8 Feb 2019 16:29:55 -0500
Subject: [PATCH] limit blobs to announce

---
 lbrynet/extras/daemon/storage.py | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/lbrynet/extras/daemon/storage.py b/lbrynet/extras/daemon/storage.py
index af3c3616c..4ba896783 100644
--- a/lbrynet/extras/daemon/storage.py
+++ b/lbrynet/extras/daemon/storage.py
@@ -308,16 +308,18 @@ class SQLiteStorage(SQLiteMixin):
                 r = transaction.execute(
                     "select blob_hash from blob "
                     "where blob_hash is not null and "
-                    "(should_announce=1 or single_announce=1) and next_announce_time<? and status='finished'",
-                    (timestamp,)
+                    "(should_announce=1 or single_announce=1) and next_announce_time<? and status='finished' "
+                    "order by next_announce_time asc limit ?",
+                    (timestamp, int(self.conf.concurrent_blob_announcers * 10))
                 )
             else:
                 r = transaction.execute(
                     "select blob_hash from blob where blob_hash is not null "
-                    "and next_announce_time<? and status='finished'", (timestamp,)
+                    "and next_announce_time<? and status='finished' "
+                    "order by next_announce_time asc limit ?",
+                    (timestamp, int(self.conf.concurrent_blob_announcers * 10))
                 )
-            blobs = [b[0] for b in r.fetchall()]
-            return blobs
+            return [b[0] for b in r.fetchall()]
         return self.db.run(get_and_update)
 
     def delete_blobs_from_db(self, blob_hashes):