let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

macos: log health timeout and control requests

Browse Source
This commit is contained in:
Peter Steinberger
2025-12-09 00:00:26 +00:00
parent d9eb320bba
commit 15729e9ea0
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
apps/macos/Sources/Clawdis/ControlChannel.swift
View File

@@ -240,11 +240,15 @@ final class ControlChannel: ObservableObject {
func health(timeout: TimeInterval? = nil) async throws -> Data { func health(timeout: TimeInterval? = nil) async throws -> Data {
try await self.ensureConnected() try await self.ensureConnected()
let start = Date()
self.logger.debug("health probe start timeout=\(timeout?.description ?? "nil", privacy: .public)")
let payload = try await self.request( let payload = try await self.request(
method: "health", method: "health",
params: timeout.map { ["timeoutMs": Int($0 * 1000)] }, params: timeout.map { ["timeoutMs": Int($0 * 1000)] },
timeout: timeout.map { $0 + 1 } // small cushion over server-side timeout timeout: timeout.map { $0 + 1 } // small cushion over server-side timeout
) )
let ms = Int(Date().timeIntervalSince(start) * 1000)
self.logger.debug("health probe ok in \(ms)ms")
return payload return payload
} }
@@ -269,6 +273,7 @@ final class ControlChannel: ObservableObject {
try? await Task.sleep(nanoseconds: UInt64(timeout * 1_000_000_000)) try? await Task.sleep(nanoseconds: UInt64(timeout * 1_000_000_000))
guard let self else { return } guard let self else { return }
if let pending = self.pending.removeValue(forKey: id) { if let pending = self.pending.removeValue(forKey: id) {
self.logger.error("control request \(method) timed out after \(Int(timeout))s")
pending.resume(throwing: ControlChannelError.badResponse("timeout after \(Int(timeout))s")) pending.resume(throwing: ControlChannelError.badResponse("timeout after \(Int(timeout))s"))
} }
} }