use lock for token refresh

This commit is contained in:
Artem Kharlamov 2016-03-04 14:35:55 +06:00
parent 9e3ac3d218
commit 7330ee78f4

View File

@ -67,6 +67,7 @@ async def api(params):
query_text = pretty(params) query_text = pretty(params)
secho('[{}] {}'.format(request_id, query_text), fg='cyan') secho('[{}] {}'.format(request_id, query_text), fg='cyan')
async with app.lock:
await refresh_token() await refresh_token()
async with app.lock: async with app.lock:
@ -116,7 +117,6 @@ def main():
handler = app.make_handler() handler = app.make_handler()
f = loop.create_server(handler, '0.0.0.0', 4444) f = loop.create_server(handler, '0.0.0.0', 4444)
srv = loop.run_until_complete(f) srv = loop.run_until_complete(f)
asyncio.ensure_future(refresh_token())
secho('serving on {}:{}'.format(*srv.sockets[0].getsockname()), fg='yellow') secho('serving on {}:{}'.format(*srv.sockets[0].getsockname()), fg='yellow')
loop.run_forever() loop.run_forever()