diff options
author | Lennart Poettering <lennart@poettering.net> | 2004-06-15 15:18:33 +0000 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2004-06-15 15:18:33 +0000 |
commit | 78f386ad45dc046d673fca5441dff188a7297059 (patch) | |
tree | 9ffa89fb46457318184e0531bb0e68d3817ceb4d /src/sinkinput.c | |
parent | 98f41f1e70e66dcfc4c457ae47bffb07ed83947f (diff) |
more work
git-svn-id: file:///home/lennart/svn/public/pulseaudio/trunk@17 fefdeb5f-60dc-0310-8127-8f9354f1896f
Diffstat (limited to 'src/sinkinput.c')
-rw-r--r-- | src/sinkinput.c | 82 |
1 files changed, 82 insertions, 0 deletions
diff --git a/src/sinkinput.c b/src/sinkinput.c new file mode 100644 index 00000000..6bc841ac --- /dev/null +++ b/src/sinkinput.c @@ -0,0 +1,82 @@ +#include <assert.h> +#include <stdlib.h> +#include <string.h> + +#include "inputstream.h" + +struct input_stream* input_stream_new(struct sink *s, struct sample_spec *spec, const char *name) { + struct input_stream *i; + int r; + assert(s && spec); + + i = malloc(sizeof(struct input_stream)); + assert(i); + i->name = name ? strdup(name) : NULL; + i->sink = s; + i->spec = *spec; + + i->kill = NULL; + i->kill_userdata = NULL; + i->notify = NULL; + i->notify_userdata = NULL; + + i->memblockq = memblockq_new(bytes_per_second(spec)/2, sample_size(spec), (size_t) -1); + assert(i->memblockq); + + assert(s->core); + r = idxset_put(s->core->input_streams, i, &i->index); + assert(r == 0 && i->index != IDXSET_INVALID); + r = idxset_put(s->input_streams, i, NULL); + assert(r == 0); + + return i; +} + +void input_stream_free(struct input_stream* i) { + assert(i); + + memblockq_free(i->memblockq); + + assert(i->sink && i->sink->core); + idxset_remove_by_data(i->sink->core->input_streams, i, NULL); + idxset_remove_by_data(i->sink->input_streams, i, NULL); + + free(i->name); + free(i); +} + +void input_stream_notify_sink(struct input_stream *i) { + assert(i); + + if (!memblockq_is_readable(i->memblockq)) + return; + + sink_notify(i->sink); +} + +void input_stream_set_kill_callback(struct input_stream *i, void (*kill)(struct input_stream*i, void *userdata), void *userdata) { + assert(i && kill); + i->kill = kill; + i->kill_userdata = userdata; +} + + +void input_stream_kill(struct input_stream*i) { + assert(i); + + if (i->kill) + i->kill(i, i->kill_userdata); +} + +void input_stream_set_notify_callback(struct input_stream *i, void (*notify)(struct input_stream*i, void *userdata), void *userdata) { + assert(i && notify); + + i->notify = notify; + i->notify_userdata = userdata; +} + +void input_stream_notify(struct input_stream *i) { + assert(i); + if (i->notify) + i->notify(i, i->notify_userdata); +} |