X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Funix.c;h=623421cadb98642889c56b2a6cbd1f46e7a51ca4;hb=5dbd97426d568a2a05d94614085cb1cdd8527819;hp=2053343256a337fa25e5ab866a0950e488e5b02e;hpb=3545ccee06dde5d357ff4c9811939af1e1c0622e;p=lttng-tools.git diff --git a/src/common/unix.c b/src/common/unix.c index 205334325..623421cad 100644 --- a/src/common/unix.c +++ b/src/common/unix.c @@ -15,9 +15,9 @@ #include #include #include -#include #include +#include #include #include @@ -730,6 +730,8 @@ enum lttng_error_code add_fds_to_payload(struct lttng_dynamic_array *raw_fds, int *raw_fd = (int *) lttng_dynamic_array_get_element( raw_fds, i); + assert(*raw_fd != -1); + handle = fd_handle_create(*raw_fd); if (!handle) { ret_code = LTTNG_ERR_NOMEM; @@ -755,15 +757,19 @@ static ssize_t _lttcomm_recv_payload_fds_unix_sock(int sock, size_t nb_fd, struct lttng_payload *payload, bool blocking) { + int i = 0; enum lttng_error_code add_ret; ssize_t ret; + int default_value = -1; struct lttng_dynamic_array raw_fds; lttng_dynamic_array_init(&raw_fds, sizeof(int), close_raw_fd); - ret = lttng_dynamic_array_set_count(&raw_fds, nb_fd); - if (ret) { - ret = -LTTNG_ERR_NOMEM; - goto end; + + for (i = 0; i < nb_fd; i++) { + if (lttng_dynamic_array_add_element(&raw_fds, &default_value)) { + ret = -LTTNG_ERR_NOMEM; + goto end; + } } if (blocking) {