self->low_latency = DEFAULT_LOW_LATENCY;
self->try_audioclient3 = DEFAULT_AUDIOCLIENT3;
self->event_handle = CreateEvent (NULL, FALSE, FALSE, NULL);
+ self->client_needs_restart = FALSE;
CoInitialize (NULL);
}
gint16 *dst = NULL;
guint pending = length;
+ GST_OBJECT_LOCK (self);
+ if (self->client_needs_restart) {
+ hr = IAudioClient_Start (self->client);
+ HR_FAILED_AND (hr, IAudioClient::Start, length = 0; goto beach);
+ self->client_needs_restart = FALSE;
+ }
+ GST_OBJECT_UNLOCK (self);
+
while (pending > 0) {
guint can_frames, have_frames, n_frames, write_len;
GstWasapiSink *self = GST_WASAPI_SINK (asink);
HRESULT hr;
+ GST_INFO_OBJECT (self, "reset called");
+
if (!self->client)
return;
+ GST_OBJECT_LOCK (self);
hr = IAudioClient_Stop (self->client);
- HR_FAILED_RET (hr, IAudioClient::Stop,);
+ HR_FAILED_AND (hr, IAudioClient::Stop,);
hr = IAudioClient_Reset (self->client);
- HR_FAILED_RET (hr, IAudioClient::Reset,);
+ HR_FAILED_AND (hr, IAudioClient::Reset,);
+
+ self->client_needs_restart = TRUE;
+ GST_OBJECT_UNLOCK (self);
}
IAudioRenderClient *render_client;
HANDLE event_handle;
HANDLE thread_priority_handle;
+ /* Client was reset, so it needs to be started again */
+ gboolean client_needs_restart;
/* Actual size of the allocated buffer */
guint buffer_frame_count;
self->low_latency = DEFAULT_LOW_LATENCY;
self->try_audioclient3 = DEFAULT_AUDIOCLIENT3;
self->event_handle = CreateEvent (NULL, FALSE, FALSE, NULL);
+ self->client_needs_restart = FALSE;
CoInitialize (NULL);
}
guint wanted = length;
DWORD flags;
+ GST_OBJECT_LOCK (self);
+ if (self->client_needs_restart) {
+ hr = IAudioClient_Start (self->client);
+ HR_FAILED_AND (hr, IAudioClient::Start, length = 0; goto beach);
+ self->client_needs_restart = FALSE;
+ }
+ GST_OBJECT_UNLOCK (self);
+
while (wanted > 0) {
guint have_frames, n_frames, want_frames, read_len;
if (!self->client)
return;
+ GST_OBJECT_LOCK (self);
hr = IAudioClient_Stop (self->client);
HR_FAILED_RET (hr, IAudioClock::Stop,);
hr = IAudioClient_Reset (self->client);
HR_FAILED_RET (hr, IAudioClock::Reset,);
+
+ self->client_needs_restart = TRUE;
+ GST_OBJECT_UNLOCK (self);
}
static GstClockTime
IAudioCaptureClient *capture_client;
HANDLE event_handle;
HANDLE thread_priority_handle;
+ /* Client was reset, so it needs to be started again */
+ gboolean client_needs_restart;
/* Actual size of the allocated buffer */
guint buffer_frame_count;