From 78f386ad45dc046d673fca5441dff188a7297059 Mon Sep 17 00:00:00 2001 From: Lennart Poettering Date: Tue, 15 Jun 2004 15:18:33 +0000 Subject: more work git-svn-id: file:///home/lennart/svn/public/pulseaudio/trunk@17 fefdeb5f-60dc-0310-8127-8f9354f1896f --- src/inputstream.c | 82 ------------------------------------------------------- 1 file changed, 82 deletions(-) delete mode 100644 src/inputstream.c (limited to 'src/inputstream.c') 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 -#include -#include - -#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); -} -- cgit