projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Relay rotate pending command
[lttng-tools.git]
/
src
/
bin
/
lttng-relayd
/
main.c
diff --git
a/src/bin/lttng-relayd/main.c
b/src/bin/lttng-relayd/main.c
index 45b7de8c657f9b43a426057fc07f7a299689dc75..f68ecdfbcbfe6ab9248c8603676a6a811e59d9aa 100644
(file)
--- a/
src/bin/lttng-relayd/main.c
+++ b/
src/bin/lttng-relayd/main.c
@@
-2803,7
+2803,7
@@
int relay_rotate_pending(struct lttcomm_relayd_hdr *recv_hdr,
{
struct relay_session *session = conn->session;
struct lttcomm_relayd_rotate_pending msg;
{
struct relay_session *session = conn->session;
struct lttcomm_relayd_rotate_pending msg;
- struct lttcomm_relayd_
generic
_reply reply;
+ struct lttcomm_relayd_
rotate_pending
_reply reply;
struct lttng_ht_iter iter;
struct relay_stream *stream;
int ret = 0;
struct lttng_ht_iter iter;
struct relay_stream *stream;
int ret = 0;
@@
-2883,7
+2883,8
@@
int relay_rotate_pending(struct lttcomm_relayd_hdr *recv_hdr,
send_reply:
rcu_read_unlock();
memset(&reply, 0, sizeof(reply));
send_reply:
rcu_read_unlock();
memset(&reply, 0, sizeof(reply));
- reply.ret_code = htobe32(rotate_pending ? 1 : 0);
+ reply.generic.ret_code = htobe32((uint32_t) LTTNG_OK);
+ reply.is_pending = (uint8_t) !!rotate_pending;
network_ret = conn->sock->ops->sendmsg(conn->sock, &reply,
sizeof(reply), 0);
if (network_ret < (ssize_t) sizeof(reply)) {
network_ret = conn->sock->ops->sendmsg(conn->sock, &reply,
sizeof(reply), 0);
if (network_ret < (ssize_t) sizeof(reply)) {
This page took
0.024129 seconds
and
4
git commands to generate.