const char *session_name, const char *hostname,
const char *base_path, int session_live_timer,
unsigned int snapshot, uint64_t sessiond_session_id,
- const lttng_uuid sessiond_uuid, const uint64_t *current_chunk_id,
+ const lttng_uuid& sessiond_uuid, const uint64_t *current_chunk_id,
time_t creation_time, bool session_name_contains_creation_time,
struct lttcomm_relayd_create_session_reply_2_11 *reply,
char *output_path)
msg->live_timer = htobe32(session_live_timer);
msg->snapshot = !!snapshot;
- lttng_uuid_copy(msg->sessiond_uuid, sessiond_uuid);
+ std::copy(sessiond_uuid.begin(), sessiond_uuid.end(), msg->sessiond_uuid);
msg->session_id = htobe64(sessiond_session_id);
msg->session_name_contains_creation_time = session_name_contains_creation_time;
if (current_chunk_id) {
const char *session_name, const char *hostname,
const char *base_path, int session_live_timer,
unsigned int snapshot, uint64_t sessiond_session_id,
- const lttng_uuid sessiond_uuid,
+ const lttng_uuid& sessiond_uuid,
const uint64_t *current_chunk_id,
time_t creation_time, bool session_name_contains_creation_time,
char *output_path)
unsigned int i;
struct lttng_dynamic_buffer payload;
struct lttcomm_relayd_generic_reply reply = {};
- const struct lttcomm_relayd_rotate_streams msg = {
- .stream_count = htobe32((uint32_t) stream_count),
- .new_chunk_id = (typeof(msg.new_chunk_id)) {
- .is_set = !!new_chunk_id,
- .value = htobe64(new_chunk_id ? *new_chunk_id : 0),
- },
- };
+ struct lttcomm_relayd_rotate_streams msg;
char new_chunk_id_buf[MAX_INT_DEC_LEN(*new_chunk_id)] = {};
const char *new_chunk_id_str;
+ msg.stream_count = htobe32((uint32_t) stream_count);
+ msg.new_chunk_id = (typeof(msg.new_chunk_id)){
+ .is_set = !!new_chunk_id,
+ .value = htobe64(new_chunk_id ? *new_chunk_id : 0),
+ };
+
if (!relayd_supports_chunks(sock)) {
DBG("Refusing to rotate remote streams: relayd does not support chunks");
return 0;