OBS/obs-studio
OBS/obs-studio
1
0
Fork 0
mirror of https://github.com/obsproject/obs-studio.git synced 2024-07-04 10:33:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

mac-virtualcam: Reduce excessive polling for new sample buffers

Browse source
This commit is contained in:
jcm 2023-12-27 22:30:53 -07:00 committed by Lain
parent 7abbfb1c82
commit 354150a992
1 changed files with 30 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
plugins/mac-virtualcam/src/camera-extension/OBSCameraDeviceSource.swift
View file

@ -23,7 +23,8 @@ class OBSCameraDeviceSource: NSObject, CMIOExtensionDeviceSource {
private var _streamingCounter: UInt32 = 0
private var _streamingSinkCounter: UInt32 = 0
private var _timer: DispatchSourceTimer?
private var _placeholderTimer: DispatchSourceTimer?
private var _consumeBufferTimer: DispatchSourceTimer?
private let _timerQueue = DispatchQueue(
label: "timerQueue",
@ -137,15 +138,15 @@ class OBSCameraDeviceSource: NSObject, CMIOExtensionDeviceSource {
_streamingCounter += 1
_timer = DispatchSource.makeTimerSource(flags: .strict, queue: _timerQueue)
_placeholderTimer = DispatchSource.makeTimerSource(flags: .strict, queue: _timerQueue)
_timer!.schedule(
_placeholderTimer!.schedule(
deadline: .now(),
repeating: 1.0 / Double(OBSCameraFrameRate),
leeway: .seconds(0)
)
_timer!.setEventHandler {
_placeholderTimer!.setEventHandler {
if self.sinkStarted {
return
}
@ -217,9 +218,9 @@ class OBSCameraDeviceSource: NSObject, CMIOExtensionDeviceSource {
}
}
}
_timer!.setCancelHandler {}
_placeholderTimer!.setCancelHandler {}
_timer!.resume()
_placeholderTimer!.resume()
}
func stopStreaming() {
@ -228,9 +229,9 @@ class OBSCameraDeviceSource: NSObject, CMIOExtensionDeviceSource {
} else {
_streamingCounter = 0
if let timer = _timer {
if let timer = _placeholderTimer {
timer.cancel()
_timer = nil
_placeholderTimer = nil
}
}
}
@ -267,22 +268,41 @@ class OBSCameraDeviceSource: NSObject, CMIOExtensionDeviceSource {
self._streamSink.stream.notifyScheduledOutputChanged(output)
}
self.consumeBuffer(client)
}
}
func startStreamingSink(client: CMIOExtensionClient) {
_streamingSinkCounter += 1
self.sinkStarted = true
consumeBuffer(client)
_consumeBufferTimer = DispatchSource.makeTimerSource(flags: .strict, queue: _timerQueue)
_consumeBufferTimer!.schedule(
deadline: .now(),
repeating: 1.0 / (Double(OBSCameraFrameRate) * 3.0),
leeway: .seconds(0)
)
_consumeBufferTimer!.setEventHandler {
self.consumeBuffer(client)
}
_consumeBufferTimer!.setCancelHandler {}
_consumeBufferTimer!.resume()
}
func stopStreamingSink() {
self.sinkStarted = false
if _streamingCounter > 1 {
_streamingSinkCounter -= 1
} else {
_streamingSinkCounter = 0
if let timer = _consumeBufferTimer {
timer.cancel()
_consumeBufferTimer = nil
}
}
}
}