diff options
| -rw-r--r-- | src/til_stream.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/til_stream.c b/src/til_stream.c index aeab4b7..a16c3af 100644 --- a/src/til_stream.c +++ b/src/til_stream.c @@ -281,6 +281,8 @@ int til_stream_tap(til_stream_t *stream, const void *owner, const void *owner_fo pipe->next = stream->pipe_buckets[bucket]; stream->pipe_buckets[bucket] = pipe; + *(tap->ptr) = pipe->driving_tap->elems; + pthread_mutex_unlock(&stream->mutex); return 0; } |