projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Cleanup unused health state reference
[lttng-tools.git]
/
src
/
bin
/
lttng-sessiond
/
ust-consumer.c
diff --git
a/src/bin/lttng-sessiond/ust-consumer.c
b/src/bin/lttng-sessiond/ust-consumer.c
index ea9c8570353501ec86cb8ef7335a593bd7cf7ccb..f108e99bd0b1379bd751432bee5276394d97b054 100644
(file)
--- a/
src/bin/lttng-sessiond/ust-consumer.c
+++ b/
src/bin/lttng-sessiond/ust-consumer.c
@@
-57,14
+57,14
@@
static int send_channel(struct consumer_socket *sock,
uchan->name,
uchan->streams.count);
uchan->name,
uchan->streams.count);
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
fd = uchan->obj->shm_fd;
ret = consumer_send_fds(sock, &fd, 1);
fd = uchan->obj->shm_fd;
ret = consumer_send_fds(sock, &fd, 1);
@@
-72,7
+72,7
@@
static int send_channel(struct consumer_socket *sock,
goto error;
}
goto error;
}
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
error:
return ret;
error:
return ret;
@@
-114,7
+114,7
@@
static int send_channel_stream(struct consumer_socket *sock,
pathname,
usess->id);
pathname,
usess->id);
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
/* Send stream and file descriptor */
fds[0] = stream->obj->shm_fd;
/* Send stream and file descriptor */
fds[0] = stream->obj->shm_fd;
@@
-124,7
+124,7
@@
static int send_channel_stream(struct consumer_socket *sock,
goto error;
}
goto error;
}
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
error:
return ret;
error:
return ret;
@@
-230,14
+230,14
@@
static int send_metadata(struct consumer_socket *sock,
DEFAULT_METADATA_NAME,
1);
DEFAULT_METADATA_NAME,
1);
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
/* Sending metadata shared memory fd */
fd = usess->metadata->obj->shm_fd;
/* Sending metadata shared memory fd */
fd = usess->metadata->obj->shm_fd;
@@
-246,7
+246,7
@@
static int send_metadata(struct consumer_socket *sock,
goto error;
}
goto error;
}
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
/* Get correct path name destination */
if (consumer->type == CONSUMER_DST_LOCAL) {
/* Get correct path name destination */
if (consumer->type == CONSUMER_DST_LOCAL) {
@@
-293,7
+293,7
@@
static int send_metadata(struct consumer_socket *sock,
pathname,
usess->id);
pathname,
usess->id);
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
/* Send stream and file descriptor */
fds[0] = usess->metadata->stream_obj->shm_fd;
/* Send stream and file descriptor */
fds[0] = usess->metadata->stream_obj->shm_fd;
@@
-303,7
+303,7
@@
static int send_metadata(struct consumer_socket *sock,
goto error;
}
goto error;
}
- health_code_update(
&health_thread_cmd
);
+ health_code_update();
error:
return ret;
error:
return ret;
This page took
0.024985 seconds
and
4
git commands to generate.