From a728fd5408f303a0415b07412c9735c0ac269066 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Fri, 22 May 2026 17:19:05 +0800 Subject: [PATCH] fix udpHole --- Tun/UDPHole/SDLUDPHoleHandler.swift | 15 +-------------- 1 file changed, 1 insertion(+), 14 deletions(-) diff --git a/Tun/UDPHole/SDLUDPHoleHandler.swift b/Tun/UDPHole/SDLUDPHoleHandler.swift index c3ce320..0d138d2 100644 --- a/Tun/UDPHole/SDLUDPHoleHandler.swift +++ b/Tun/UDPHole/SDLUDPHoleHandler.swift @@ -1,7 +1,7 @@ // // SDLUDPHoleHandler.swift // punchnet -// +// 上游的SDLUDPHole是基于actor实现的,串行实现的逻辑已经保证了SDLUDPHoleHandler的内部的一致性 // Created by 安礼成 on 2026/5/22. // import Foundation @@ -23,9 +23,6 @@ final class SDLUDPHoleHandler: ChannelInboundHandler { public let messageStream: AsyncThrowingStream private let messageContinuation: AsyncThrowingStream.Continuation - private let locker = NSLock() - private var isStopped: Bool = false - // 启动函数 init() throws { let (stream, continuation) = AsyncThrowingStream.makeStream(of: SDLHoleDatagram.self, bufferingPolicy: .bufferingNewest(2048)) @@ -102,16 +99,6 @@ final class SDLUDPHoleHandler: ChannelInboundHandler { } func stop() { - locker.lock() - defer { - locker.unlock() - } - - guard !self.isStopped else { - return - } - self.isStopped = true - self.messageContinuation.finish() let channel = self.channel self.channel = nil