mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-01 22:58:50 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

module-rt{kit}: replace get_default_int with the new property helper

Browse source
This commit is contained in:
Peter Hutterer 2021-10-12 13:19:12 +10:00 • committed by Wim Taymans
parent 1d8d7e90ce
commit 56bc3508c4
2 changed files with 8 additions and 50 deletions
Download patch file Download diff file Expand all files Collapse all files

29
src/modules/module-rt.c
View file

@ -143,27 +143,6 @@ static int set_rlimit(struct impl *impl)
return res; return res;
} }
static int get_default_int(struct pw_properties *properties, const char *name, int def)
{
const char *str;
int val;
bool set_default = true;
if ((str = pw_properties_get(properties, name)) != NULL) {
if (spa_atoi32(str, &val, 10))
set_default = false;
else
pw_log_warn("invalid integer value '%s' of property %s, using default (%d) instead", str, name, def);
}
if (set_default) {
val = def;
pw_properties_setf(properties, name, "%d", val);
}
return val;
}
static struct spa_thread *impl_create(void *data, static struct spa_thread *impl_create(void *data,
const struct spa_dict *props, const struct spa_dict *props,
void *(*start)(void*), void *arg) void *(*start)(void*), void *arg)
@ -267,12 +246,12 @@ int pipewire__module_init(struct pw_impl_module *module, const char *args)
goto error; goto error;
} }
nice_level = get_default_int(props, "nice.level", DEFAULT_NICE_LEVEL); nice_level = pw_properties_get_int32(props, "nice.level", DEFAULT_NICE_LEVEL);
set_nice(impl, nice_level); set_nice(impl, nice_level);
impl->rt_prio = get_default_int(props, "rt.prio", DEFAULT_RT_PRIO); impl->rt_prio = pw_properties_get_int32(props, "rt.prio", DEFAULT_RT_PRIO);
impl->rt_time_soft = get_default_int(props, "rt.time.soft", DEFAULT_RT_TIME_SOFT); impl->rt_time_soft = pw_properties_get_int32(props, "rt.time.soft", DEFAULT_RT_TIME_SOFT);
impl->rt_time_hard = get_default_int(props, "rt.time.hard", DEFAULT_RT_TIME_HARD); impl->rt_time_hard = pw_properties_get_int32(props, "rt.time.hard", DEFAULT_RT_TIME_HARD);
set_rlimit(impl); set_rlimit(impl);

29
src/modules/module-rtkit.c
View file

@ -497,27 +497,6 @@ static int set_rlimit(struct impl *impl)
return res; return res;
} }
static int get_default_int(struct pw_properties *properties, const char *name, int def)
{
int val;
const char *str;
bool set_default = true;
if ((str = pw_properties_get(properties, name)) != NULL) {
if (spa_atoi32(str, &val, 10))
set_default = false;
else
pw_log_warn("invalid integer value '%s' of property %s, using default (%d) instead", str, name, def);
}
if (set_default) {
val = def;
pw_properties_setf(properties, name, "%d", val);
}
return val;
}
static struct thread *find_thread_by_pt(struct impl *impl, pthread_t pt) static struct thread *find_thread_by_pt(struct impl *impl, pthread_t pt)
{ {
struct thread *t; struct thread *t;
@ -718,13 +697,13 @@ int pipewire__module_init(struct pw_impl_module *module, const char *args)
pw_log_warn("could not get system bus: %m"); pw_log_warn("could not get system bus: %m");
goto error; goto error;
} }
impl->nice_level = get_default_int(impl->props, "nice.level", DEFAULT_NICE_LEVEL); impl->nice_level = pw_properties_get_int32(impl->props, "nice.level", DEFAULT_NICE_LEVEL);
set_nice(impl, impl->nice_level); set_nice(impl, impl->nice_level);
impl->rt_prio = get_default_int(impl->props, "rt.prio", DEFAULT_RT_PRIO); impl->rt_prio = pw_properties_get_int32(impl->props, "rt.prio", DEFAULT_RT_PRIO);
impl->rt_time_soft = get_default_int(impl->props, "rt.time.soft", DEFAULT_RT_TIME_SOFT); impl->rt_time_soft = pw_properties_get_int32(impl->props, "rt.time.soft", DEFAULT_RT_TIME_SOFT);
impl->rt_time_hard = get_default_int(impl->props, "rt.time.hard", DEFAULT_RT_TIME_HARD); impl->rt_time_hard = pw_properties_get_int32(impl->props, "rt.time.hard", DEFAULT_RT_TIME_HARD);
set_rlimit(impl); set_rlimit(impl);