summaryrefslogtreecommitdiffstats
path: root/src/inputstream.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/inputstream.h')
-rw-r--r--src/inputstream.h14
1 files changed, 12 insertions, 2 deletions
diff --git a/src/inputstream.h b/src/inputstream.h
index a258c3d1..544c3318 100644
--- a/src/inputstream.h
+++ b/src/inputstream.h
@@ -18,6 +18,9 @@ struct input_stream {
void (*kill)(struct input_stream* i, void *userdata);
void *kill_userdata;
+
+ void (*notify)(struct input_stream*i, void *userdata);
+ void *notify_userdata;
};
struct input_stream* input_stream_new(struct sink *s, struct sample_spec *spec, const char *name);
@@ -31,10 +34,17 @@ void input_stream_notify_sink(struct input_stream *i);
/* The registrant of the input stream should call this function to set a
* callback function which is called when destruction of the input stream is
* requested */
-void input_stream_set_kill_callback(struct input_stream *c, void (*kill)(struct input_stream*i, void *userdata), void *userdata);
+void input_stream_set_kill_callback(struct input_stream *i, void (*kill)(struct input_stream*i, void *userdata), void *userdata);
/* Code that didn't create the input stream should call this function to
* request destruction of it */
-void input_stream_kill(struct input_stream *c);
+void input_stream_kill(struct input_stream *i);
+
+/* Notify the code that created this input stream that some data has
+ * been removed from the memblockq */
+void input_stream_set_notify_callback(struct input_stream *i, void (*notify)(struct input_stream*i, void *userdata), void *userdata);
+
+void input_stream_notify(struct input_stream *i);
+
#endif