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

temporary debug print statements

Browse source
This commit is contained in:
Lex Berezhny 2020-07-20 09:57:52 -04:00
parent e2aae23575
commit 96aea579ac
2 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lbry/cli.py
View file

@ -221,11 +221,14 @@ def main(argv=None):
if args.help: if args.help:
args.start_parser.print_help() args.start_parser.print_help()
elif args.full_node: elif args.full_node:
print('Instantiating FullNode')
service = FullNode(Ledger(conf)) service = FullNode(Ledger(conf))
if conf.console == "advanced": if conf.console == "advanced":
console = AdvancedConsole(service) console = AdvancedConsole(service)
else: else:
print('Instantiating BasicConsole')
console = BasicConsole(service) console = BasicConsole(service)
print('Daemon(service, console).run()')
return Daemon(service, console).run() return Daemon(service, console).run()
else: else:
print('Only `start --full-node` is currently supported.') print('Only `start --full-node` is currently supported.')

7
lbry/service/daemon.py
View file

@ -97,7 +97,9 @@ class Daemon:
pass # Not implemented on Windows pass # Not implemented on Windows
try: try:
print('loop.run_until_complete(self.start())')
loop.run_until_complete(self.start()) loop.run_until_complete(self.start())
print('loop.run_forever()')
loop.run_forever() loop.run_forever()
except (GracefulExit, KeyboardInterrupt, asyncio.CancelledError): except (GracefulExit, KeyboardInterrupt, asyncio.CancelledError):
pass pass
@ -109,10 +111,15 @@ class Daemon:
loop.run_until_complete(loop.shutdown_asyncgens()) loop.run_until_complete(loop.shutdown_asyncgens())
async def start(self): async def start(self):
print('self.console.starting()')
self.console.starting() self.console.starting()
print('await self.runner.setup()')
await self.runner.setup() await self.runner.setup()
print('TCPSite(self.runner, self.conf.api_host, self.conf.api_port)')
site = TCPSite(self.runner, self.conf.api_host, self.conf.api_port) site = TCPSite(self.runner, self.conf.api_host, self.conf.api_port)
print('await site.start()')
await site.start() await site.start()
print('await self.service.start()')
await self.service.start() await self.service.start()
async def stop(self): async def stop(self):