projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Change backing type of lttng_uuid to std::array
[lttng-tools.git]
/
src
/
bin
/
lttng-sessiond
/
consumer.cpp
diff --git
a/src/bin/lttng-sessiond/consumer.cpp
b/src/bin/lttng-sessiond/consumer.cpp
index bdda3913597a7639150a67473517e92bf31f1180..b87e1d73d2d065ef21ee19c4a015b2c00946c396 100644
(file)
--- a/
src/bin/lttng-sessiond/consumer.cpp
+++ b/
src/bin/lttng-sessiond/consumer.cpp
@@
-924,7
+924,7
@@
void consumer_init_ask_channel_comm_msg(struct lttcomm_consumer_msg *msg,
const char *name,
uint64_t relayd_id,
uint64_t key,
const char *name,
uint64_t relayd_id,
uint64_t key,
-
unsigned char *
uuid,
+
const lttng_uuid&
uuid,
uint32_t chan_id,
uint64_t tracefile_size,
uint64_t tracefile_count,
uint32_t chan_id,
uint64_t tracefile_size,
uint64_t tracefile_count,
@@
-979,7
+979,7
@@
void consumer_init_ask_channel_comm_msg(struct lttcomm_consumer_msg *msg,
msg->u.ask_channel.ust_app_uid = ust_app_uid;
msg->u.ask_channel.blocking_timeout = blocking_timeout;
msg->u.ask_channel.ust_app_uid = ust_app_uid;
msg->u.ask_channel.blocking_timeout = blocking_timeout;
-
memcpy(msg->u.ask_channel.uuid, uuid, sizeof(msg->u.ask_channel.uuid)
);
+
std::copy(uuid.begin(), uuid.end(), msg->u.ask_channel.uuid
);
if (pathname) {
strncpy(msg->u.ask_channel.pathname, pathname,
if (pathname) {
strncpy(msg->u.ask_channel.pathname, pathname,
@@
-1782,7
+1782,7
@@
error_socket:
}
int consumer_init(struct consumer_socket *socket,
}
int consumer_init(struct consumer_socket *socket,
- const lttng_uuid sessiond_uuid)
+ const lttng_uuid
&
sessiond_uuid)
{
int ret;
struct lttcomm_consumer_msg msg = {
{
int ret;
struct lttcomm_consumer_msg msg = {
@@
-1793,7
+1793,7
@@
int consumer_init(struct consumer_socket *socket,
LTTNG_ASSERT(socket);
DBG("Sending consumer initialization command");
LTTNG_ASSERT(socket);
DBG("Sending consumer initialization command");
-
lttng_uuid_copy(msg.u.init.sessiond_uuid,
sessiond_uuid);
+
std::copy(sessiond_uuid.begin(), sessiond_uuid.end(), msg.u.init.
sessiond_uuid);
health_code_update();
ret = consumer_send_msg(socket, &msg);
health_code_update();
ret = consumer_send_msg(socket, &msg);
This page took
0.027726 seconds
and
4
git commands to generate.