start boosting manager if ready only -reduce startup load-

Tribler/Policies/BoostingManager.py

@@ -25,8 +25,10 @@
 from Tribler.Core.TorrentChecker.session import MAX_TRACKER_MULTI_SCRAPE
 from Tribler.Core.TorrentDef import TorrentDef
 from Tribler.Core.Utilities import utilities
+from Tribler.Core.exceptions import TriblerException
 from Tribler.Core.simpledefs import DLSTATUS_SEEDING, NTFY_INSERT, NTFY_SCRAPE, NTFY_TORRENTS, NTFY_UPDATE
 from Tribler.Main.Utility.GuiDBTuples import Torrent
+from Tribler.Main.Utility.GuiDBHandler import startWorker
 from Tribler.Main.globals import DefaultDownloadStartupConfig
 from Tribler.Main.vwxGUI.GuiUtility import GUIUtility
 from Tribler.Main.vwxGUI.SearchGridManager import ChannelManager
@@ -36,6 +38,7 @@
 from Tribler.dispersy.taskmanager import TaskManager
 from Tribler.dispersy.util import call_on_reactor_thread
 
+
 from Tribler.Main.vwxGUI.SearchGridManager import ChannelManager as cm
 
 logger = logging.getLogger(__name__)
@@ -730,6 +733,7 @@ class BoostingSource(object):
     def __init__(self, session, tqueue, source, interval, max_torrents, callback):
         self.session = session
         self.session.lm.threadpool = tqueue
+        self.channelcast_db = session.lm.channelcast_db
 
         self.torrents = {}
         self.source = source
@@ -749,10 +753,27 @@ def __init__(self, session, tqueue, source, interval, max_torrents, callback):
         if not self.gui_util.registered:
             self.gui_util.register()
 
-
     def kill_tasks(self):
         self.session.lm.threadpool.cancel_pending_task(self.source)
 
+    def _load_if_ready(self, source):
+
+        nr_channels = self.channelcast_db.getNrChannels()
+        nr_connections = 0
+
+        for community in self.session.lm.dispersy.get_communities():
+            from Tribler.community.search.community import SearchCommunity
+            if isinstance(community, SearchCommunity):
+                nr_connections = community.get_nr_connections()
+
+        # condition example
+        if nr_channels > 100 and nr_connections > 5:
+            fun = self._load
+        else:
+            fun = self._load_if_ready
+
+        self.session.lm.threadpool.add_task(lambda src=source: fun(src), 15, task_name=str(self.source)+"_load")
+
     def _load(self, source):
         pass
 
@@ -771,14 +792,11 @@ def __init__(self, session, tqueue, dispersy_cid, interval, max_torrents, callba
         self.channel_id = None
 
         self.channel = None
-
-        self.channelcast_db = self.session.lm.channelcast_db
-
         self.community = None
         self.database_updated = True
 
         self.session.add_observer(self._on_database_updated, NTFY_TORRENTS, [NTFY_INSERT, NTFY_UPDATE])
-        self.session.lm.threadpool.add_task(lambda cid=dispersy_cid: self._load(cid), 0, task_name=self.source)
+        self.session.lm.threadpool.add_task(lambda cid=dispersy_cid: self._load_if_ready(cid), 0, task_name=str(self.source)+"_load")
 
         self.unavail_torrent = {}
 
@@ -790,7 +808,6 @@ def _load(self, dispersy_cid):
         dispersy = self.session.get_dispersy_instance()
 
         @call_on_reactor_thread
-
         def join_community():
             try:
                 self.community = dispersy.get_community(dispersy_cid, True)
@@ -831,10 +848,10 @@ def get_channel_id():
             self.ready = True
         except Exception,ex:
             logger.info("Channel %s was not ready, waits for next interval (%d chn)", hexlify(self.source), len(dispersy.get_communities()))
-            self.session.lm.threadpool.add_task(lambda cid=self.source: self._load(cid), 10, task_name=self.source)
+            self.session.lm.threadpool.add_task(lambda cid=dispersy_cid: self._load_if_ready(cid), 0, task_name=str(self.source)+"_load")
 
     def _check_tor(self):
-        from Tribler.Main.Utility.GuiDBHandler import startWorker
+
         def doGui(delayedResult):
             # wait here
             requesttype = delayedResult.get(timeout=70)
@@ -924,7 +941,7 @@ def __init__(self, session, tqueue, rss_feed, interval, max_torrents, callback):
 
         self.feed_handle = None
 
-        self.session.lm.threadpool.add_task(lambda feed=rss_feed: self._load(feed), 0, task_name=str(self.source)+"_load")
+        self.session.lm.threadpool.add_task(lambda feed=rss_feed: self._load_if_ready(feed), 0, task_name=str(self.source)+"_load")
 
         self.title = ""
         self.description = ""
@@ -1037,8 +1054,7 @@ class DirectorySource(BoostingSource):
 
     def __init__(self, session, tqueue, directory, interval, max_torrents, callback):
         BoostingSource.__init__(self, session, tqueue, directory, interval, max_torrents, callback)
-
-        self._load(directory)
+        self._load_if_ready(directory)
 
     def _load(self, directory):
         if os.path.isdir(directory):