fix quicClient
This commit is contained in:
parent
1d19f727d3
commit
b0172444c6
@ -265,6 +265,7 @@ actor SDLContextActor {
|
|||||||
|
|
||||||
defer {
|
defer {
|
||||||
quicClient.stop()
|
quicClient.stop()
|
||||||
|
SDLLogger.log("[SDLContext] quicClient: stop")
|
||||||
}
|
}
|
||||||
|
|
||||||
// 这里必须等待quic的协商完成
|
// 这里必须等待quic的协商完成
|
||||||
@ -509,7 +510,7 @@ actor SDLContextActor {
|
|||||||
self.udpHoleV6 = nil
|
self.udpHoleV6 = nil
|
||||||
self.udpHoleV6LocalAddress = nil
|
self.udpHoleV6LocalAddress = nil
|
||||||
|
|
||||||
await self.quicClient?.stop()
|
self.quicClient?.stop()
|
||||||
self.quicClient = nil
|
self.quicClient = nil
|
||||||
|
|
||||||
await self.dnsClient?.stop()
|
await self.dnsClient?.stop()
|
||||||
@ -630,7 +631,7 @@ actor SDLContextActor {
|
|||||||
|
|
||||||
// 开启新的任务
|
// 开启新的任务
|
||||||
self.readTask = Task.detached(priority: .high) {
|
self.readTask = Task.detached(priority: .high) {
|
||||||
while true {
|
repeat {
|
||||||
if Task.isCancelled {
|
if Task.isCancelled {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -641,7 +642,7 @@ actor SDLContextActor {
|
|||||||
await self.dealTunPacket(packet: ipPacket)
|
await self.dealTunPacket(packet: ipPacket)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
} while true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user