input_stream: non-blocking I/O

Add GMutex, GCond attributes which will be used by callers to
conditionally wait on the stream.

Remove the (now-useless) plugin method buffer(), wait on GCond
instead.  Lock the input_stream before each method call.  Do the same
with the playlist plugins.

1 files changed, 7 insertions, 3 deletions

diff --git a/src/playlist_plugin.h b/src/playlist_plugin.h
index d7d7c7769..a27f651c0 100644
--- a/src/playlist_plugin.h
+++ b/src/playlist_plugin.h
@@ -20,6 +20,8 @@
 #ifndef MPD_PLAYLIST_PLUGIN_H
 #define MPD_PLAYLIST_PLUGIN_H
 
+#include <glib.h>
+
 #include <stdbool.h>
 #include <stddef.h>
 
@@ -64,7 +66,8 @@ struct playlist_plugin {
 	 * Opens the playlist on the specified URI.  This URI has
 	 * either matched one of the schemes or one of the suffixes.
 	 */
-	struct playlist_provider *(*open_uri)(const char *uri);
+	struct playlist_provider *(*open_uri)(const char *uri,
+					      GMutex *mutex, GCond *cond);
 
 	/**
 	 * Opens the playlist in the specified input stream.  It has
@@ -110,9 +113,10 @@ playlist_plugin_finish(const struct playlist_plugin *plugin)
 }
 
 static inline struct playlist_provider *
-playlist_plugin_open_uri(const struct playlist_plugin *plugin, const char *uri)
+playlist_plugin_open_uri(const struct playlist_plugin *plugin, const char *uri,
+			 GMutex *mutex, GCond *cond)
 {
-	return plugin->open_uri(uri);
+	return plugin->open_uri(uri, mutex, cond);
 }
 
 static inline struct playlist_provider *