()
| 381 | await logger.complete() |
| 382 | |
| 383 | async def _shutdown(): |
| 384 | global _is_shutting_down |
| 385 | _is_shutting_down = True |
| 386 | global peer |
| 387 | logger.debug('Shutting down. Peer {}', peer) |
| 388 | if peer: |
| 389 | logger.info('Destroying peer {}', peer) |
| 390 | await peer.destroy() |
| 391 | else: |
| 392 | logger.info('Peer is None') |
| 393 | # loop.run_until_complete(pc.close()) |
| 394 | # loop.run_until_complete(signaling.close()) |
| 395 | global http_session |
| 396 | await http_session.close() |
| 397 | |
| 398 | @logger.catch |
| 399 | def main(): |