diff options
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) |