output/Thread: move code to InternalClose()

src/output/Control.hxx

@@ -425,6 +425,11 @@ private:
 	/**
 	 * Runs inside the OutputThread.
 	 */
+	void InternalClose(bool drain) noexcept;
+
+	/**
+	 * Runs inside the OutputThread.
+	 */
 	void InternalCheckClose(bool drain) noexcept;
 
 	/**

src/output/Thread.cxx

@@ -172,16 +172,22 @@ AudioOutputControl::InternalOpen(const AudioFormat in_audio_format,
 }
 
 inline void
-AudioOutputControl::InternalCheckClose(bool drain) noexcept
+AudioOutputControl::InternalClose(bool drain) noexcept
 {
-	if (!IsOpen())
-		return;
+	assert(IsOpen());
 
 	open = false;
 	output->Close(drain);
 	source.Close();
 }
 
+inline void
+AudioOutputControl::InternalCheckClose(bool drain) noexcept
+{
+	if (IsOpen())
+		InternalClose(drain);
+}
+
 /**
  * Wait until the output's delay reaches zero.
  *
@@ -211,7 +217,7 @@ try {
 	FormatError(e, "Failed to filter for output \"%s\" [%s]",
 		    GetName(), output->plugin.name);
 
-	InternalCheckClose(false);
+	InternalClose(false);
 
 	/* don't automatically reopen this device for 10
 	   seconds */
@@ -259,7 +265,7 @@ AudioOutputControl::PlayChunk() noexcept
 		}
 
 		if (nbytes == 0) {
-			InternalCheckClose(false);
+			InternalClose(false);
 
 			/* don't automatically reopen this device for
 			   10 seconds */
@@ -330,9 +336,7 @@ AudioOutputControl::InternalPause() noexcept
 			break;
 
 		if (!output->IteratePause()) {
-			open = false;
-			output->Close(false);
-			source.Close();
+			InternalClose(false);
 			break;
 		}
 	} while (command == Command::NONE);