diff options
Diffstat (limited to '')
| -rw-r--r-- | src/input_internal.c | 24 |
1 files changed, 23 insertions, 1 deletions
diff --git a/src/input_internal.c b/src/input_internal.c index 4d675fc97..92a71856e 100644 --- a/src/input_internal.c +++ b/src/input_internal.c @@ -25,7 +25,7 @@ void input_stream_init(struct input_stream *is, const struct input_plugin *plugin, - const char *uri) + const char *uri, GMutex *mutex, GCond *cond) { assert(is != NULL); assert(plugin != NULL); @@ -33,6 +33,8 @@ input_stream_init(struct input_stream *is, const struct input_plugin *plugin, is->plugin = plugin; is->uri = g_strdup(uri); + is->mutex = mutex; + is->cond = cond; is->ready = false; is->seekable = false; is->size = -1; @@ -49,3 +51,23 @@ input_stream_deinit(struct input_stream *is) g_free(is->uri); g_free(is->mime); } + +void +input_stream_signal_client(struct input_stream *is) +{ + if (is->cond != NULL) + g_cond_broadcast(is->cond); +} + +void +input_stream_set_ready(struct input_stream *is) +{ + g_mutex_lock(is->mutex); + + if (!is->ready) { + is->ready = true; + input_stream_signal_client(is); + } + + g_mutex_unlock(is->mutex); +} |