From d4d838c8bbe6d537055f9ae91436c8c8c7e76e09 Mon Sep 17 00:00:00 2001
From: Max Kellermann <max@duempel.org>
Date: Sun, 18 Sep 2011 11:51:18 +0200
Subject: output/roar: move code to roar_cancel_locked() and others

Wrap the locking code.
---
 src/output/roar_output_plugin.c | 94 ++++++++++++++++++++++++-----------------
 1 file changed, 55 insertions(+), 39 deletions(-)

(limited to 'src/output/roar_output_plugin.c')

diff --git a/src/output/roar_output_plugin.c b/src/output/roar_output_plugin.c
index 2d1cb09c7..c43b5ac34 100644
--- a/src/output/roar_output_plugin.c
+++ b/src/output/roar_output_plugin.c
@@ -55,39 +55,49 @@ roar_output_quark(void)
 	return g_quark_from_static_string("roar_output");
 }
 
+static int
+roar_output_get_volume_locked(struct roar *roar)
+{
+	if (roar->vss == NULL || !roar->alive)
+		return 0;
+
+	float l, r;
+	int error;
+	roar_vs_volume_get(roar->vss, &l, &r, &error);
+	return (l + r) * 50;
+}
+
 int
 roar_output_get_volume(struct roar *roar)
 {
 	g_mutex_lock(roar->lock);
-	if (roar->vss && roar->alive) {
-		float l, r;
-		int error;
-		roar_vs_volume_get(roar->vss, &l, &r, &error);
-		g_mutex_unlock(roar->lock);
-		return (l + r) * 50;
-	} else {
-		g_mutex_unlock(roar->lock);
-		return 0;
-	}
+	int volume = roar_output_get_volume_locked(roar);
+	g_mutex_unlock(roar->lock);
+	return volume;
+}
+
+static bool
+roar_output_set_volume_locked(struct roar *roar, unsigned volume)
+{
+	assert(volume <= 100);
+
+	if (roar->vss == NULL || !roar->alive)
+		return false;
+
+	int error;
+	float level = volume / 100.0;
+
+	roar_vs_volume_mono(roar->vss, level, &error);
+	return true;
 }
 
 bool
 roar_output_set_volume(struct roar *roar, unsigned volume)
 {
 	g_mutex_lock(roar->lock);
-	if (roar->vss && roar->alive) {
-		assert(volume <= 100);
-
-		int error;
-		float level = volume / 100.0;
-
-		roar_vs_volume_mono(roar->vss, level, &error);
-		g_mutex_unlock(roar->lock);
-		return true;
-	} else {
-		g_mutex_unlock(roar->lock);
-		return false;
-	}
+	bool success = roar_output_set_volume_locked(roar, volume);
+	g_mutex_unlock(roar->lock);
+	return success;
 }
 
 static void
@@ -206,28 +216,34 @@ roar_close(void *data)
 	g_mutex_unlock(self->lock);
 }
 
+static void
+roar_cancel_locked(struct roar *self)
+{
+	if (self->vss == NULL)
+		return;
+
+	roar_vs_t *vss = self->vss;
+	self->vss = NULL;
+	roar_vs_close(vss, ROAR_VS_TRUE, &(self->err));
+	self->alive = false;
+
+	vss = roar_vs_new_from_con(&(self->con), &(self->err));
+	if (vss == NULL)
+		return;
+
+	roar_vs_stream(vss, &(self->info), ROAR_DIR_PLAY, &(self->err));
+	roar_vs_role(vss, self->role, &(self->err));
+	self->vss = vss;
+	self->alive = true;
+}
+
 static void
 roar_cancel(void *data)
 {
 	roar_t * self = data;
 
 	g_mutex_lock(self->lock);
-	if (self->vss != NULL)
-	{
-		roar_vs_t *vss = self->vss;
-		self->vss = NULL;
-		roar_vs_close(vss, ROAR_VS_TRUE, &(self->err));
-		self->alive = false;
-
-		vss = roar_vs_new_from_con(&(self->con), &(self->err));
-		if (vss)
-		{
-			roar_vs_stream(vss, &(self->info), ROAR_DIR_PLAY, &(self->err));
-			roar_vs_role(vss, self->role, &(self->err));
-			self->vss = vss;
-			self->alive = true;
-		}
-	}
+	roar_cancel_locked(self);
 	g_mutex_unlock(self->lock);
 }
 
-- 
cgit v1.2.3