}
HRESULT
- RuntimeClassInitialize (GstWasapi2Client * listener)
+ RuntimeClassInitialize (GstWasapi2Client * listener, gpointer dispatcher)
{
if (!listener)
return E_INVALIDARG;
listener_ = listener;
- findCoreDispatcher ();
+ if (dispatcher) {
+ ComPtr<IInspectable> inspectable =
+ reinterpret_cast<IInspectable*> (dispatcher);
+ HRESULT hr;
+
+ hr = inspectable.As (&dispatcher_);
+ if (gst_wasapi2_result (hr))
+ GST_INFO("Main UI dispatcher is available");
+ }
return S_OK;
}
});
}
- /* Try to find ICoreDispatcher of main UI so that active audio
- * interface on main UI thread */
- void findCoreDispatcher(void)
- {
- HRESULT hr;
- HStringReference hstr_core_app =
- HStringReference(RuntimeClass_Windows_ApplicationModel_Core_CoreApplication);
- ComPtr<ICoreApplication> core_app;
- ComPtr<ICoreApplicationView> core_app_view;
- ComPtr<ICoreWindow> core_window;
-
- hr = GetActivationFactory (hstr_core_app.Get(), &core_app);
- if (!gst_wasapi2_result (hr))
- return;
-
- hr = core_app->GetCurrentView (&core_app_view);
- if (!gst_wasapi2_result (hr))
- return;
-
- hr = core_app_view->get_CoreWindow (&core_window);
- if (!gst_wasapi2_result (hr))
- return;
-
- hr = core_window->get_Dispatcher (&dispatcher_);
- if (!gst_wasapi2_result (hr))
- return;
-
- GST_DEBUG ("Main UI dispatcher is available");
- }
-
template <typename CB>
HRESULT
runOnUIThread (DWORD timeout, CB && cb)
gchar *device_id;
gchar *device_name;
gint device_index;
+ gpointer dispatcher;
IAudioClient3 *audio_client;
IAudioCaptureClient *audio_capture_client;
PROP_DEVICE_INDEX,
PROP_DEVICE_CLASS,
PROP_LOW_LATENCY,
+ PROP_DISPATCHER,
};
#define DEFAULT_DEVICE_INDEX -1
g_param_spec_boolean ("low-latency", "Low latency",
"Optimize all settings for lowest latency. Always safe to enable.",
DEFAULT_LOW_LATENCY, param_flags));
+ g_object_class_install_property (gobject_class, PROP_DISPATCHER,
+ g_param_spec_pointer ("dispatcher", "Dispatcher",
+ "ICoreDispatcher COM object to use", param_flags));
}
static void
case PROP_LOW_LATENCY:
g_value_set_boolean (value, self->low_latency);
break;
+ case PROP_DISPATCHER:
+ g_value_set_pointer (value, self->dispatcher);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
case PROP_LOW_LATENCY:
self->low_latency = g_value_get_boolean (value);
break;
+ case PROP_DISPATCHER:
+ self->dispatcher = g_value_get_pointer (value);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
self->device_class == GST_WASAPI2_CLIENT_DEVICE_CLASS_CAPTURE ? "capture" :
"render", GST_STR_NULL (self->device_id), self->device_index);
- hr = MakeAndInitialize<GstWasapiDeviceActivator> (&activator, self);
+ hr = MakeAndInitialize<GstWasapiDeviceActivator> (&activator,
+ self, self->dispatcher);
if (!gst_wasapi2_result (hr))
goto run_loop;
return TRUE;
}
+static HRESULT
+find_dispatcher (ICoreDispatcher ** dispatcher)
+{
+ HStringReference hstr_core_app =
+ HStringReference(RuntimeClass_Windows_ApplicationModel_Core_CoreApplication);
+ HRESULT hr;
+
+ ComPtr<ICoreApplication> core_app;
+ hr = GetActivationFactory (hstr_core_app.Get(), &core_app);
+ if (!gst_wasapi2_result (hr))
+ return hr;
+
+ ComPtr<ICoreApplicationView> core_app_view;
+ hr = core_app->GetCurrentView (&core_app_view);
+ if (!gst_wasapi2_result (hr))
+ return hr;
+
+ ComPtr<ICoreWindow> core_window;
+ hr = core_app_view->get_CoreWindow (&core_window);
+ if (!gst_wasapi2_result (hr))
+ return hr;
+
+ return core_window->get_Dispatcher (dispatcher);
+}
+
GstWasapi2Client *
gst_wasapi2_client_new (GstWasapi2ClientDeviceClass device_class,
- gboolean low_latency, gint device_index, const gchar * device_id)
+ gboolean low_latency, gint device_index, const gchar * device_id,
+ gpointer dispatcher)
{
GstWasapi2Client *self;
+ ComPtr<ICoreDispatcher> core_dispatcher;
+ /* Multiple COM init is allowed */
+ RoInitializeWrapper init_wrapper (RO_INIT_MULTITHREADED);
+
+ /* If application didn't pass ICoreDispatcher object,
+ * try to get dispatcher object for the current thread */
+ if (!dispatcher) {
+ HRESULT hr;
+
+ hr = find_dispatcher (&core_dispatcher);
+ if (gst_wasapi2_result (hr)) {
+ GST_DEBUG ("UI dispatcher is available");
+ dispatcher = core_dispatcher.Get ();
+ } else {
+ GST_DEBUG ("UI dispatcher is unavailable");
+ }
+ } else {
+ GST_DEBUG ("Use user passed UI dispatcher");
+ }
self = (GstWasapi2Client *) g_object_new (GST_TYPE_WASAPI2_CLIENT,
"device-class", device_class, "low-latency", low_latency,
- "device-index", device_index, "device", device_id, NULL);
+ "device-index", device_index, "device", device_id,
+ "dispatcher", dispatcher, NULL);
+
+ /* Reset explicitly to ensure that it happens before
+ * RoInitializeWrapper dtor is called */
+ core_dispatcher.Reset ();
if (!self->audio_client) {
gst_object_unref (self);
PROP_LOW_LATENCY,
PROP_MUTE,
PROP_VOLUME,
+ PROP_DISPATCHER,
};
struct _GstWasapi2Sink
gboolean low_latency;
gboolean mute;
gdouble volume;
+ gpointer dispatcher;
gboolean mute_changed;
gboolean volume_changed;
GST_PARAM_MUTABLE_PLAYING | G_PARAM_READWRITE |
G_PARAM_STATIC_STRINGS));
+ g_object_class_install_property (gobject_class, PROP_DISPATCHER,
+ g_param_spec_pointer ("dispatcher", "Dispatcher",
+ "ICoreDispatcher COM object to use. In order for application to ask "
+ "permission of audio device, device activation should be running "
+ "on UI thread via ICoreDispatcher",
+ GST_PARAM_MUTABLE_READY | G_PARAM_READWRITE |
+ G_PARAM_STATIC_STRINGS));
+
gst_element_class_add_static_pad_template (element_class, &sink_template);
gst_element_class_set_static_metadata (element_class, "Wasapi2Sink",
"Sink/Audio/Hardware",
case PROP_VOLUME:
gst_wasapi2_sink_set_volume (self, g_value_get_double (value));
break;
+ case PROP_DISPATCHER:
+ self->dispatcher = g_value_get_pointer (value);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
case PROP_VOLUME:
g_value_set_double (value, gst_wasapi2_sink_get_volume (self));
break;
+ case PROP_DISPATCHER:
+ g_value_set_pointer (value, self->dispatcher);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
self->client =
gst_wasapi2_client_new (GST_WASAPI2_CLIENT_DEVICE_CLASS_RENDER,
- self->low_latency, -1, self->device_id);
+ self->low_latency, -1, self->device_id, self->dispatcher);
return ! !self->client;
}
PROP_LOW_LATENCY,
PROP_MUTE,
PROP_VOLUME,
+ PROP_DISPATCHER,
};
struct _GstWasapi2Src
gboolean low_latency;
gboolean mute;
gdouble volume;
+ gpointer dispatcher;
gboolean mute_changed;
gboolean volume_changed;
GST_PARAM_MUTABLE_PLAYING | G_PARAM_READWRITE |
G_PARAM_STATIC_STRINGS));
+ g_object_class_install_property (gobject_class, PROP_DISPATCHER,
+ g_param_spec_pointer ("dispatcher", "Dispatcher",
+ "ICoreDispatcher COM object to use. In order for application to ask "
+ "permission of audio device, device activation should be running "
+ "on UI thread via ICoreDispatcher",
+ GST_PARAM_MUTABLE_READY | G_PARAM_READWRITE |
+ G_PARAM_STATIC_STRINGS));
+
gst_element_class_add_static_pad_template (element_class, &src_template);
gst_element_class_set_static_metadata (element_class, "Wasapi2Src",
"Source/Audio/Hardware",
case PROP_VOLUME:
gst_wasapi2_src_set_volume (self, g_value_get_double (value));
break;
+ case PROP_DISPATCHER:
+ self->dispatcher = g_value_get_pointer (value);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
case PROP_VOLUME:
g_value_set_double (value, gst_wasapi2_src_get_volume (self));
break;
+ case PROP_DISPATCHER:
+ g_value_set_pointer (value, self->dispatcher);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
self->client =
gst_wasapi2_client_new (GST_WASAPI2_CLIENT_DEVICE_CLASS_CAPTURE,
- self->low_latency, -1, self->device_id);
+ self->low_latency, -1, self->device_id, self->dispatcher);
return ! !self->client;
}