summaryrefslogtreecommitdiffstats
path: root/src/inputstream.c
diff options
context:
space:
mode:
authorLennart Poettering <lennart@poettering.net>2004-06-15 15:18:33 +0000
committerLennart Poettering <lennart@poettering.net>2004-06-15 15:18:33 +0000
commit78f386ad45dc046d673fca5441dff188a7297059 (patch)
tree9ffa89fb46457318184e0531bb0e68d3817ceb4d /src/inputstream.c
parent98f41f1e70e66dcfc4c457ae47bffb07ed83947f (diff)
more work
git-svn-id: file:///home/lennart/svn/public/pulseaudio/trunk@17 fefdeb5f-60dc-0310-8127-8f9354f1896f
Diffstat (limited to 'src/inputstream.c')
-rw-r--r--src/inputstream.c82
1 files changed, 0 insertions, 82 deletions
diff --git a/src/inputstream.c b/src/inputstream.c
deleted file mode 100644
index 6bc841ac..00000000
--- a/src/inputstream.c
+++ /dev/null
@@ -1,82 +0,0 @@
-#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);
-}