summaryrefslogtreecommitdiff
path: root/src/til_stream.c
diff options
context:
space:
mode:
authorVito Caputo <vcaputo@pengaru.com>2023-06-08 20:15:45 -0700
committerVito Caputo <vcaputo@pengaru.com>2023-06-08 20:15:45 -0700
commitf5b05390f057b0c7c1a5f99be354692445678e55 (patch)
treef54842b40e5943d9f87d555093cee0671c7f3a73 /src/til_stream.c
parent7b09ed69ad9f454e702b750d529a8dda95de0aec (diff)
til_stream: name pipe-oriented stream api as such
When all the stream encapsulated were pipes/taps, naming was less precise. With module contexts in the process of being registered in the stream, there's a need to distinguish things more. This is a largely mechanical naming change...
Diffstat (limited to 'src/til_stream.c')
-rw-r--r--src/til_stream.c6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/til_stream.c b/src/til_stream.c
index 1eb749b..afc635b 100644
--- a/src/til_stream.c
+++ b/src/til_stream.c
@@ -304,7 +304,7 @@ static int til_stream_fprint_pipe_cb(void *arg, til_stream_pipe_t *pipe, const v
{
FILE *out = arg;
- fprintf(out, "%s/%s: ", pipe->parent_path, pipe->driving_tap->name);
+ fprintf(out, " %s/%s: ", pipe->parent_path, pipe->driving_tap->name);
for (size_t j = 0; j < pipe->driving_tap->n_elems; j++) {
const char *sep = j ? ", " : "";
@@ -420,7 +420,7 @@ static int til_stream_fprint_pipe_cb(void *arg, til_stream_pipe_t *pipe, const v
* to acquire the mutex - but it's also an uncontended lock if that's the case so just take the
* mutex anyways since we're accessing the underlying structure it protects.
*/
-void til_stream_fprint(til_stream_t *stream, FILE *out)
+void til_stream_fprint_pipes(til_stream_t *stream, FILE *out)
{
fprintf(out, "Pipes on stream %p:\n", stream);
(void) til_stream_for_each_pipe(stream, til_stream_fprint_pipe_cb, out);
@@ -429,7 +429,7 @@ void til_stream_fprint(til_stream_t *stream, FILE *out)
/* returns -errno on error (from pipe_cb), 0 otherwise */
-int til_stream_for_each_pipe(til_stream_t *stream, til_stream_iter_func_t pipe_cb, void *cb_context)
+int til_stream_for_each_pipe(til_stream_t *stream, til_stream_pipe_iter_func_t pipe_cb, void *cb_context)
{
assert(stream);
assert(pipe_cb);
© All Rights Reserved