output/{recorder,shout}: call encoder_read() in a loop

This is necessary for Ogg packets that span more than one page.

NEWS

@@ -2,6 +2,7 @@ ver 0.17.3 (2012/??/??)
 * output:
   - recorder: fix I/O error check
   - shout: fix memory leak in error handler
+  - recorder, shout: support Ogg packets that span more than one page
 
 ver 0.17.2 (2012/09/30)
 * protocol:

src/encoder_plugin.h

@@ -295,6 +295,8 @@ encoder_write(struct encoder *encoder, const void *data, size_t length,
 /**
  * Reads encoded data from the encoder.
  *
+ * Call this repeatedly until no more data is returned.
+ *
  * @param encoder the encoder
  * @param dest the destination buffer to copy to
  * @param length the maximum length of the destination buffer

src/output/recorder_output_plugin.c

@@ -160,6 +160,7 @@ recorder_output_encoder_to_file(struct recorder_output *recorder,
 {
 	assert(recorder->fd >= 0);
 
+	while (true) {
 		/* read from the encoder */
 
 		size_t size = encoder_read(recorder->encoder, recorder->buffer,
@@ -169,8 +170,10 @@ recorder_output_encoder_to_file(struct recorder_output *recorder,
 
 		/* write everything into the file */
 
-	return recorder_write_to_file(recorder, recorder->buffer, size,
+		if (!recorder_write_to_file(recorder, recorder->buffer, size,
-				      error_r);
+					    error_r))
+			return false;
+	}
 }
 
 static bool

src/output/shout_output_plugin.c

@@ -342,6 +342,7 @@ write_page(struct shout_data *sd, GError **error)
 {
 	assert(sd->encoder != NULL);
 
+	while (true) {
 		size_t nbytes = encoder_read(sd->encoder,
 					     sd->buffer, sizeof(sd->buffer));
 		if (nbytes == 0)
@@ -350,6 +351,7 @@ write_page(struct shout_data *sd, GError **error)
 		int err = shout_send(sd->shout_conn, sd->buffer, nbytes);
 		if (!handle_shout_error(sd, err, error))
 			return false;
+	}
 
 	return true;
 }