X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fpayload-view.c;h=4a4edea146385ae0e2198ebfbd5a41a32d7c1c04;hp=8c99c56efa5d9d122c8fb6571e887cf3c74469cd;hb=18eec1c924daf8d63a5f2cc06b1c1fdd9a838c6e;hpb=e368fb4396b9bdb22de16f0c93512c9f6d7ab0b4 diff --git a/src/common/payload-view.c b/src/common/payload-view.c index 8c99c56ef..4a4edea14 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,8 @@ 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( + const struct lttng_payload_view *payload_view) { int ret; size_t position; @@ -80,43 +81,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; }