Skip to content

Commit

Permalink
fixup! Refactor existing experiment to adapt Channel Download experim…
Browse files Browse the repository at this point in the history
…ents
  • Loading branch information
ardhipoetra committed Jan 25, 2017
1 parent a43e66e commit 0f860dc
Showing 1 changed file with 7 additions and 12 deletions.
19 changes: 7 additions & 12 deletions gumby/experiments/TriblerDispersyClient.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,26 +42,20 @@ def stop_dispersy(self):
def start_session(self):
from twisted.internet import threads

def _do_start():
logging.error("Starting Tribler Session")

self.session = Session(scfg=self.session_config)

self.session.start()

while not self.session.lm.initComplete:
time.sleep(0.5)

logging.error("Tribler Session started")
def _do_ready(_):
self.annotate("Tribler Session started")

if self.session.get_dispersy():
self._dispersy = self.session.lm.dispersy

return self.session

logging.error("Starting Tribler Session")
self.session_config = self.setup_session_config()
self.session_deferred = threads.deferToThread(_do_start)
self.session = Session(scfg=self.session_config)

self.session_deferred = self.session.start()
self.session_deferred.addCallback(_do_ready)

if self.session_config.get_dispersy():
self.session_deferred.addCallback(self.__start_dispersy)
Expand Down Expand Up @@ -99,6 +93,7 @@ def setup_session_config(self):
config.set_dht_torrent_collecting(False)
config.set_enable_torrent_search(False)
config.set_enable_channel_search(False)
config.set_http_api_enabled(False)
config.set_listen_port(20000 + self.scenario_runner._peernumber)

if self.dispersy_port is None:
Expand Down

0 comments on commit 0f860dc

Please sign in to comment.