Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

Disable console autofetcher

Browse source
This commit is contained in:
Jack 2015-12-14 13:14:04 -05:00
parent 75fbedeeac
commit 1abe890067
2 changed files with 47 additions and 47 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

88
lbrynet/lbrynet_console/ControlHandlers.py
View file

@ -2362,52 +2362,52 @@ class StatusFactory(CommandHandlerFactory):
"to remove the file." "to remove the file."
class AutoFetcherStart(CommandHandler): # class AutoFetcherStart(CommandHandler):
def __init__(self, console, autofetcher): # def __init__(self, console, autofetcher):
CommandHandler.__init__(self, console) # CommandHandler.__init__(self, console)
self.autofetcher = autofetcher # self.autofetcher = autofetcher
#
def start(self): # def start(self):
self.autofetcher.start(self.console) # self.autofetcher.start(self.console)
self.finished_deferred.callback(None) # self.finished_deferred.callback(None)
#
#
# class AutoFetcherStop(CommandHandler):
# def __init__(self, console, autofetcher):
# CommandHandler.__init__(self, console)
# self.autofetcher = autofetcher
#
# def start(self):
# self.autofetcher.stop(self.console)
# self.finished_deferred.callback(None)
#
#
# class AutoFetcherStatus(CommandHandler):
# def __init__(self, console, autofetcher):
# CommandHandler.__init__(self, console)
# self.autofetcher = autofetcher
#
# def start(self):
# self.autofetcher.check_if_running(self.console)
# self.finished_deferred.callback(None)
class AutoFetcherStop(CommandHandler): # class AutoFetcherStartFactory(CommandHandlerFactory):
def __init__(self, console, autofetcher): # control_handler_class = AutoFetcherStart
CommandHandler.__init__(self, console) # command = "start-autofetcher"
self.autofetcher = autofetcher # short_help = "Start downloading all lbry files as they are published"
#
def start(self): #
self.autofetcher.stop(self.console) # class AutoFetcherStopFactory(CommandHandlerFactory):
self.finished_deferred.callback(None) # control_handler_class = AutoFetcherStop
# command = "stop-autofetcher"
# short_help = "Stop downloading all lbry files as they are published"
class AutoFetcherStatus(CommandHandler): #
def __init__(self, console, autofetcher): #
CommandHandler.__init__(self, console) # class AutoFetcherStatusFactory(CommandHandlerFactory):
self.autofetcher = autofetcher # control_handler_class = AutoFetcherStatus
# command = "autofetcher-status"
def start(self): # short_help = "Check autofetcher status"
self.autofetcher.check_if_running(self.console)
self.finished_deferred.callback(None)
class AutoFetcherStartFactory(CommandHandlerFactory):
control_handler_class = AutoFetcherStart
command = "start-autofetcher"
short_help = "Start downloading all lbry files as they are published"
class AutoFetcherStopFactory(CommandHandlerFactory):
control_handler_class = AutoFetcherStop
command = "stop-autofetcher"
short_help = "Stop downloading all lbry files as they are published"
class AutoFetcherStatusFactory(CommandHandlerFactory):
control_handler_class = AutoFetcherStatus
command = "autofetcher-status"
short_help = "Check autofetcher status"
class BlockchainStatus(CommandHandler): class BlockchainStatus(CommandHandler):

6
lbrynet/lbrynet_console/LBRYConsole.py
View file

@ -370,9 +370,9 @@ class LBRYConsole():
AddStreamFromHashFactory(self.sd_identifier, self.session), AddStreamFromHashFactory(self.sd_identifier, self.session),
StatusFactory(self, self.session.rate_limiter, self.lbry_file_manager, StatusFactory(self, self.session.rate_limiter, self.lbry_file_manager,
self.session.blob_manager, self.session.wallet if self.wallet_type == 'lbrycrd' else None), self.session.blob_manager, self.session.wallet if self.wallet_type == 'lbrycrd' else None),
AutoFetcherStartFactory(self.autofetcher), # AutoFetcherStartFactory(self.autofetcher),
AutoFetcherStopFactory(self.autofetcher), # AutoFetcherStopFactory(self.autofetcher),
AutoFetcherStatusFactory(self.autofetcher), # AutoFetcherStatusFactory(self.autofetcher),
ImmediateAnnounceAllBlobsFactory(self.session.blob_manager) ImmediateAnnounceAllBlobsFactory(self.session.blob_manager)
] ]
self.add_control_handlers(handlers) self.add_control_handlers(handlers)