DecoderInternal: wake up the player thread in _flush_chunk()

Merge duplicate code.

2 files changed, 2 insertions, 4 deletions

diff --git a/src/DecoderAPI.cxx b/src/DecoderAPI.cxx
index aaa8bb17f..fbe4d98c0 100644
--- a/src/DecoderAPI.cxx
+++ b/src/DecoderAPI.cxx
@@ -312,7 +312,6 @@ do_send_tag(Decoder &decoder, const Tag &tag)
 		/* there is a partial chunk - flush it, we want the
 		   tag in a new chunk */
 		decoder_flush_chunk(decoder);
-		decoder.dc.client_cond.signal();
 	}
 
 	assert(decoder.chunk == nullptr);
@@ -422,7 +421,6 @@ decoder_data(Decoder &decoder,
 		if (dest.IsNull()) {
 			/* the chunk is full, flush it */
 			decoder_flush_chunk(decoder);
-			dc.client_cond.signal();
 			continue;
 		}
 
@@ -442,7 +440,6 @@ decoder_data(Decoder &decoder,
 		if (full) {
 			/* the chunk is full, flush it */
 			decoder_flush_chunk(decoder);
-			dc.client_cond.signal();
 		}
 
 		data = (const uint8_t *)data + nbytes;
@@ -535,7 +532,6 @@ decoder_replay_gain(Decoder &decoder,
 			   replay gain values affect the following
 			   samples */
 			decoder_flush_chunk(decoder);
-			decoder.dc.client_cond.signal();
 		}
 	} else
 		decoder.replay_gain_serial = 0;
diff --git a/src/DecoderInternal.cxx b/src/DecoderInternal.cxx
index 92fa7c451..25d9c3f05 100644
--- a/src/DecoderInternal.cxx
+++ b/src/DecoderInternal.cxx
@@ -100,4 +100,6 @@ decoder_flush_chunk(Decoder &decoder)
 		dc.pipe->Push(decoder.chunk);
 
 	decoder.chunk = nullptr;
+
+	dc.client_cond.signal();
 }