X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fpayload-view.c;h=43ddf3132c774ed414292f7044ccf83b85a4ca04;hp=8c99c56efa5d9d122c8fb6571e887cf3c74469cd;hb=fe489250ce102edf511e99669025934ec9587c63;hpb=dd1bac00c933616842aaf51ad4c4240ccee98838 diff --git a/src/common/payload-view.c b/src/common/payload-view.c index 8c99c56ef..43ddf3132 100644 --- a/src/common/payload-view.c +++ b/src/common/payload-view.c @@ -19,7 +19,7 @@ struct lttng_payload_view lttng_payload_view_from_payload( return (struct lttng_payload_view) { .buffer = lttng_buffer_view_from_dynamic_buffer( &payload->buffer, offset, len), - ._fds = payload->_fds, + ._fd_handles = payload->_fd_handles, }; } @@ -31,9 +31,9 @@ struct lttng_payload_view lttng_payload_view_from_view( return (struct lttng_payload_view) { .buffer = lttng_buffer_view_from_view( &view->buffer, offset, len), - ._fds = view->_fds, - ._iterator.p_fds_position = view->_iterator.p_fds_position ?: - &view->_iterator.fds_position, + ._fd_handles = view->_fd_handles, + ._iterator.p_fd_handles_position = view->_iterator.p_fd_handles_position ?: + &view->_iterator.fd_handles_position, }; } @@ -70,7 +70,7 @@ struct lttng_payload_view lttng_payload_view_init_from_buffer( } LTTNG_HIDDEN -int lttng_payload_view_get_fd_count(struct lttng_payload_view *payload_view) +int lttng_payload_view_get_fd_handle_count(struct lttng_payload_view *payload_view) { int ret; size_t position; @@ -80,43 +80,43 @@ int lttng_payload_view_get_fd_count(struct lttng_payload_view *payload_view) goto end; } - ret = lttng_dynamic_array_get_count(&payload_view->_fds); + ret = lttng_dynamic_pointer_array_get_count(&payload_view->_fd_handles); if (ret < 0) { goto end; } - position = payload_view->_iterator.p_fds_position ? - *payload_view->_iterator.p_fds_position : - payload_view->_iterator.fds_position; + position = payload_view->_iterator.p_fd_handles_position ? + *payload_view->_iterator.p_fd_handles_position : + payload_view->_iterator.fd_handles_position; ret = ret - (int) position; end: return ret; } LTTNG_HIDDEN -int lttng_payload_view_pop_fd(struct lttng_payload_view *view) +struct fd_handle *lttng_payload_view_pop_fd_handle( + struct lttng_payload_view *view) { - int ret = 0; - size_t fd_count; + struct fd_handle *handle = NULL; + size_t fd_handle_count; size_t *pos; if (!view) { - ret = -1; goto end; } - fd_count = lttng_dynamic_array_get_count(&view->_fds); - pos = view->_iterator.p_fds_position ? view->_iterator.p_fds_position : - &view->_iterator.fds_position; - - if (*pos >= fd_count) { - ret = -1; + fd_handle_count = lttng_payload_view_get_fd_handle_count(view); + if (fd_handle_count == 0) { goto end; } - ret = *((int *) lttng_dynamic_array_get_element( - &view->_fds, *pos)); + pos = view->_iterator.p_fd_handles_position ? + view->_iterator.p_fd_handles_position : + &view->_iterator.fd_handles_position; + handle = lttng_dynamic_pointer_array_get_pointer(&view->_fd_handles, + *pos); (*pos)++; + fd_handle_get(handle); end: - return ret; + return handle; }