anlicheng/swiftlib_sdlan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add error support

Browse Source
This commit is contained in:
anlicheng 2025-08-02 23:37:25 +08:00
parent 7af3b235e7
commit 3e96169690
4 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
Sources/Punchnet/SDLError.swift Normal file
View File

@ -0,0 +1,11 @@
//
// SDLError.swift
// sdlan
//
// Created by 安礼成 on 2025/8/2.
//
enum SDLError: Error {
case socketClosed
case socketError
}

6
Sources/Punchnet/SDLNoticeClient.swift
View File

@ -47,6 +47,12 @@ actor SDLNoticeClient {
func start() async throws { func start() async throws {
try await self.asyncChannel.executeThenClose { inbound, outbound in try await self.asyncChannel.executeThenClose { inbound, outbound in
try await withThrowingTaskGroup(of: Void.self) { group in try await withThrowingTaskGroup(of: Void.self) { group in
group.addTask {
try await self.asyncChannel.channel.closeFuture.get()
NSLog("[UDPHole] channel closed")
throw SDLError.socketClosed
}
group.addTask { group.addTask {
for try await message in self.writeStream { for try await message in self.writeStream {
let buf = self.asyncChannel.channel.allocator.buffer(bytes: message) let buf = self.asyncChannel.channel.allocator.buffer(bytes: message)

3
Sources/Punchnet/SDLSuperClient.swift
View File

@ -9,6 +9,8 @@ import Foundation
import NIOCore import NIOCore
import NIOPosix import NIOPosix
// --MARK: 和SuperNode的客户端 // --MARK: 和SuperNode的客户端
actor SDLSuperClient { actor SDLSuperClient {
private let group = MultiThreadedEventLoopGroup(numberOfThreads: 1) private let group = MultiThreadedEventLoopGroup(numberOfThreads: 1)
@ -63,6 +65,7 @@ actor SDLSuperClient {
group.addTask { group.addTask {
try await self.asyncChannel.channel.closeFuture.get() try await self.asyncChannel.channel.closeFuture.get()
NSLog("[SDLSuperClient] socket closed") NSLog("[SDLSuperClient] socket closed")
throw SDLError.socketClosed
} }
group.addTask { group.addTask {

2
Sources/Punchnet/SDLUDPHole.swift
View File

@ -60,6 +60,7 @@ actor SDLUDPHole {
group.addTask { group.addTask {
try await self.asyncChannel.channel.closeFuture.get() try await self.asyncChannel.channel.closeFuture.get()
NSLog("[UDPHole] channel closed") NSLog("[UDPHole] channel closed")
throw SDLError.socketClosed
} }
group.addTask { group.addTask {
@ -83,6 +84,7 @@ actor SDLUDPHole {
} }
} catch let err { } catch let err {
SDLLogger.log("[SDLUDPHole] decode message, get error: \(err)", level: .debug) SDLLogger.log("[SDLUDPHole] decode message, get error: \(err)", level: .debug)
throw err
} }
} }
} }