goto error;
}
+ if (msg.size == 0) {
+ goto skip_payload;
+ }
+
/* Reserve space for the payload. */
ret = lttng_dynamic_buffer_set_size(&channel->reception_payload.buffer,
channel->reception_payload.buffer.size + msg.size);
goto error;
}
+skip_payload:
/* Receive message fds. */
if (msg.fds != 0) {
ret = lttcomm_recv_payload_fds_unix_sock(channel->socket,
goto end;
}
- sock_path = (char *) zmalloc(LTTNG_PATH_MAX);
+ sock_path = calloc<char>(LTTNG_PATH_MAX);
if (!sock_path) {
goto end;
}
- channel = (lttng_notification_channel *) zmalloc(sizeof(struct lttng_notification_channel));
+ channel = zmalloc<lttng_notification_channel>();
if (!channel) {
goto end;
}
goto end;
}
- pending_notification = (struct pending_notification *) zmalloc(sizeof(*pending_notification));
+ pending_notification = zmalloc<struct pending_notification>();
if (!pending_notification) {
ret = -1;
goto end;
goto end;
}
- pending_notification = (struct pending_notification *) zmalloc(sizeof(*pending_notification));
+ pending_notification = zmalloc<struct pending_notification>();
if (!pending_notification) {
ret = -1;
goto error;