isa/mutter
1
0
Fork 0
mirror of https://github.com/brl/mutter.git synced 2025-02-06 08:34:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

thread/impl: Add API to tell whether its realtime scheduled

Browse Source 
Will be used by thread impl's to decide whether they can rely on real
time scheduling or not.

Part-of: <https://gitlab.gnome.org/GNOME/mutter/-/merge_requests/2777>
This commit is contained in:
Jonas Ådahl 2022-10-26 19:33:49 +02:00
parent e92e4fe64d
commit 6da3e9eb69
4 changed files with 33 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/backends/native/meta-thread-impl.c
View File

@ -56,6 +56,8 @@ typedef struct _MetaThreadImplPrivate
GMainContext *thread_context; GMainContext *thread_context;
GSource *impl_source; GSource *impl_source;
GAsyncQueue *task_queue; GAsyncQueue *task_queue;
gboolean is_realtime;
} MetaThreadImplPrivate; } MetaThreadImplPrivate;
struct _MetaThreadTask struct _MetaThreadTask
@ -551,7 +553,8 @@ meta_thread_impl_dispatch (MetaThreadImpl *thread_impl)
} }
void void
meta_thread_impl_run (MetaThreadImpl *thread_impl) meta_thread_impl_run (MetaThreadImpl *thread_impl,
MetaThreadImplRunFlags flags)
{ {
MetaThreadImplPrivate *priv = MetaThreadImplPrivate *priv =
meta_thread_impl_get_instance_private (thread_impl); meta_thread_impl_get_instance_private (thread_impl);
@ -559,7 +562,9 @@ meta_thread_impl_run (MetaThreadImpl *thread_impl)
meta_assert_in_thread_impl (priv->thread); meta_assert_in_thread_impl (priv->thread);
priv->loop = g_main_loop_new (priv->thread_context, FALSE); priv->loop = g_main_loop_new (priv->thread_context, FALSE);
priv->is_realtime = !!(flags & META_THREAD_IMPL_RUN_FLAG_REALTIME);
g_main_loop_run (priv->loop); g_main_loop_run (priv->loop);
priv->is_realtime = FALSE;
} }
void void
@ -572,3 +577,12 @@ meta_thread_impl_queue_task (MetaThreadImpl *thread_impl,
g_async_queue_push (priv->task_queue, task); g_async_queue_push (priv->task_queue, task);
g_main_context_wakeup (priv->thread_context); g_main_context_wakeup (priv->thread_context);
} }
gboolean
meta_thread_impl_is_realtime (MetaThreadImpl *thread_impl)
{
MetaThreadImplPrivate *priv =
meta_thread_impl_get_instance_private (thread_impl);
return priv->is_realtime;
}

12
src/backends/native/meta-thread-impl.h
View File

@ -27,6 +27,12 @@
typedef struct _MetaThread MetaThread; typedef struct _MetaThread MetaThread;
typedef enum _MetaThreadImplRunFlags
{
META_THREAD_IMPL_RUN_FLAG_NONE = 0,
META_THREAD_IMPL_RUN_FLAG_REALTIME = 1 << 0,
} MetaThreadImplRunFlags;
#define META_TYPE_THREAD_IMPL (meta_thread_impl_get_type ()) #define META_TYPE_THREAD_IMPL (meta_thread_impl_get_type ())
META_EXPORT_TEST META_EXPORT_TEST
G_DECLARE_DERIVABLE_TYPE (MetaThreadImpl, meta_thread_impl, G_DECLARE_DERIVABLE_TYPE (MetaThreadImpl, meta_thread_impl,
@ -67,12 +73,16 @@ void meta_thread_impl_queue_task (MetaThreadImpl *thread_impl,
void meta_thread_impl_terminate (MetaThreadImpl *thread_impl); void meta_thread_impl_terminate (MetaThreadImpl *thread_impl);
void meta_thread_impl_run (MetaThreadImpl *thread_impl); void meta_thread_impl_run (MetaThreadImpl *thread_impl,
MetaThreadImplRunFlags flags);
int meta_thread_impl_dispatch (MetaThreadImpl *thread_impl); int meta_thread_impl_dispatch (MetaThreadImpl *thread_impl);
gboolean meta_thread_impl_is_in_impl (MetaThreadImpl *thread_impl); gboolean meta_thread_impl_is_in_impl (MetaThreadImpl *thread_impl);
META_EXPORT_TEST
gboolean meta_thread_impl_is_realtime (MetaThreadImpl *thread_impl);
MetaThreadTask * meta_thread_task_new (MetaThreadTaskFunc func, MetaThreadTask * meta_thread_task_new (MetaThreadTaskFunc func,
gpointer user_data, gpointer user_data,
GDestroyNotify user_data_destroy, GDestroyNotify user_data_destroy,

4
src/backends/native/meta-thread.c
View File

@ -296,6 +296,7 @@ thread_impl_func (gpointer user_data)
MetaThreadPrivate *priv = meta_thread_get_instance_private (thread); MetaThreadPrivate *priv = meta_thread_get_instance_private (thread);
MetaContext *context = meta_backend_get_context (priv->backend); MetaContext *context = meta_backend_get_context (priv->backend);
MetaThreadImpl *impl = priv->impl; MetaThreadImpl *impl = priv->impl;
MetaThreadImplRunFlags run_flags = META_THREAD_IMPL_RUN_FLAG_NONE;
#ifdef HAVE_PROFILER #ifdef HAVE_PROFILER
GMainContext *thread_context = meta_thread_impl_get_main_context (impl); GMainContext *thread_context = meta_thread_impl_get_main_context (impl);
MetaProfiler *profiler = meta_context_get_profiler (context); MetaProfiler *profiler = meta_context_get_profiler (context);
@ -320,10 +321,11 @@ thread_impl_func (gpointer user_data)
else else
{ {
g_message ("Made thread '%s' realtime scheduled", priv->name); g_message ("Made thread '%s' realtime scheduled", priv->name);
run_flags |= META_THREAD_IMPL_RUN_FLAG_REALTIME;
} }
} }
meta_thread_impl_run (impl); meta_thread_impl_run (impl, run_flags);
#ifdef HAVE_PROFILER #ifdef HAVE_PROFILER
meta_profiler_unregister_thread (profiler, thread_context); meta_profiler_unregister_thread (profiler, thread_context);

4
src/tests/native-thread.c
View File

@ -1152,6 +1152,8 @@ assert_realtime (MetaThreadImpl *thread_impl,
g_autoptr (GVariant) priority_variant = NULL; g_autoptr (GVariant) priority_variant = NULL;
uint32_t priority = 0; uint32_t priority = 0;
g_assert_true (meta_thread_impl_is_realtime (thread_impl));
ret = call_rtkit_mock_method ("GetThreadPriority", ret = call_rtkit_mock_method ("GetThreadPriority",
g_variant_new ("(t)", gettid ())); g_variant_new ("(t)", gettid ()));
@ -1199,6 +1201,8 @@ assert_no_realtime (MetaThreadImpl *thread_impl,
g_autoptr (GVariant) priority_variant = NULL; g_autoptr (GVariant) priority_variant = NULL;
uint32_t priority = UINT32_MAX; uint32_t priority = UINT32_MAX;
g_assert_false (meta_thread_impl_is_realtime (thread_impl));
ret = call_rtkit_mock_method ("GetThreadPriority", ret = call_rtkit_mock_method ("GetThreadPriority",
g_variant_new ("(t)", gettid ())); g_variant_new ("(t)", gettid ()));