diff options
| author | Nicolas Dato <nicolas.dato@gmail.com> | 2025-07-17 20:52:49 -0300 |
|---|---|---|
| committer | Nicolas Dato <nicolas.dato@gmail.com> | 2025-07-18 07:15:02 -0300 |
| commit | b1fcc672448f8403a567cd280c2151eb6d5799cb (patch) | |
| tree | 995ef80358f3c88807d8034b5ad3f78b54301482 /src/tuberia.c | |
| parent | ee208b6f61a4f2f52d6a796acdb0764374d23234 (diff) | |
| download | libtuberia-b1fcc672448f8403a567cd280c2151eb6d5799cb.tar.gz | |
adding documentation
Diffstat (limited to 'src/tuberia.c')
| -rw-r--r-- | src/tuberia.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/tuberia.c b/src/tuberia.c index 0184289..5d5d8a7 100644 --- a/src/tuberia.c +++ b/src/tuberia.c @@ -195,7 +195,7 @@ static void *tube_stage_thread(void *arg) } while (stage->run) { - element = itc_retrive(stage->input, ITC_DEFAULT_TIMEOUT_MS); + element = itc_retrieve(stage->input, ITC_DEFAULT_TIMEOUT_MS); if (element) { element = stage->process(element, stage->opaque); if (element) { @@ -249,7 +249,7 @@ static void *tube_sink_thread(void *arg) } while (sink->run) { - element = itc_retrive(sink->input, ITC_DEFAULT_TIMEOUT_MS); + element = itc_retrieve(sink->input, ITC_DEFAULT_TIMEOUT_MS); if (element) { sink->sink(element, sink->opaque); } @@ -299,13 +299,13 @@ int tube_inject(tube *ctx, int timeout_ms, void *element) return tube_inject_at(ctx, 0, timeout_ms, element); } -void *tube_retrive(tube *ctx, int timeout_ms) +void *tube_retrieve(tube *ctx, int timeout_ms) { if (ctx == NULL || !ctx->nitcs) { return NULL; } - return itc_retrive(ctx->itcs[ctx->nitcs - 1], timeout_ms); + return itc_retrieve(ctx->itcs[ctx->nitcs - 1], timeout_ms); } void tube_stop_and_wait_empty(tube *ctx) |