Skip to content

Commit

Permalink
Log adjustments
Browse files Browse the repository at this point in the history
  • Loading branch information
hiroshihorie committed Sep 6, 2024
1 parent 007678e commit c6bcb46
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 6 deletions.
1 change: 0 additions & 1 deletion Sources/LiveKit/Core/SignalClient.swift
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,6 @@ actor SignalClient: Loggable {
} catch {
await self.cleanUp(withError: error)
}
self.log("Did exit WebSocket message loop...")
}

let connectResponse = try await _connectResponseCompleter.wait()
Expand Down
8 changes: 4 additions & 4 deletions Sources/LiveKit/Support/AsyncCompleter.swift
Original file line number Diff line number Diff line change
Expand Up @@ -147,11 +147,11 @@ class AsyncCompleter<T>: Loggable {
// Already resolved...
if case let .success(value) = result {
// resume(returning:) already called
log("\(label) returning value...")
log("\(label) returning existing value")
return value
} else if case let .failure(error) = result {
// resume(throwing:) already called
log("\(label) throwing error...")
log("\(label) throwing existing error")
throw error
}
}
Expand All @@ -166,7 +166,7 @@ class AsyncCompleter<T>: Loggable {
// Create time-out block
let timeoutBlock = DispatchWorkItem { [weak self] in
guard let self else { return }
self.log("Wait \(entryId) timedOut")
self.log("\(label) id: \(entryId) timed out")
self._lock.sync {
if let entry = self._entries[entryId] {
entry.timeout()
Expand All @@ -182,7 +182,7 @@ class AsyncCompleter<T>: Loggable {
// Store entry
_entries[entryId] = WaitEntry(continuation: continuation, timeoutBlock: timeoutBlock)

log("\(label) waiting \(computedTimeout) with id: \(entryId)")
log("\(label) id: \(entryId) waiting for \(computedTimeout)")
}
}
} onCancel: {
Expand Down
1 change: 0 additions & 1 deletion Sources/LiveKit/Support/AsyncTimer.swift
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,6 @@ class AsyncTimer: Loggable {
$0.isStarted = false
$0.task?.cancel()
}
log(nil, .debug)
}

func cancel() {
Expand Down

0 comments on commit c6bcb46

Please sign in to comment.