mirror of
https://github.com/Grasscutters/mitmproxy.git
synced 2024-12-02 12:01:17 +00:00
[sans-io] clientplayback: don't catch cancellederror
This commit is contained in:
parent
b5f59a1297
commit
5bf07b2176
@ -106,17 +106,14 @@ class ClientPlayback:
|
|||||||
self.playback_task.cancel()
|
self.playback_task.cancel()
|
||||||
|
|
||||||
async def playback(self):
|
async def playback(self):
|
||||||
try:
|
while True:
|
||||||
while True:
|
self.inflight = await self.queue.get()
|
||||||
self.inflight = await self.queue.get()
|
try:
|
||||||
try:
|
h = ReplayHandler(self.inflight, self.options)
|
||||||
h = ReplayHandler(self.inflight, self.options)
|
await h.replay()
|
||||||
await h.replay()
|
except Exception:
|
||||||
except Exception:
|
ctx.log(f"Client replay has crashed!\n{traceback.format_exc()}", "error")
|
||||||
ctx.log(f"Client replay has crashed!\n{traceback.format_exc()}", "error")
|
self.inflight = None
|
||||||
self.inflight = None
|
|
||||||
except asyncio.CancelledError:
|
|
||||||
return
|
|
||||||
|
|
||||||
def check(self, f: flow.Flow) -> typing.Optional[str]:
|
def check(self, f: flow.Flow) -> typing.Optional[str]:
|
||||||
if f.live:
|
if f.live:
|
||||||
|
Loading…
Reference in New Issue
Block a user