projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: consumer relayd cleanup on disconnect
[lttng-tools.git]
/
src
/
common
/
relayd
/
relayd.c
diff --git
a/src/common/relayd/relayd.c
b/src/common/relayd/relayd.c
index 785d3dc584bd66d2d825a0df09f9e63d0e49cc02..db476080ec207d505938ddcb9b351cd1b4d10ac7 100644
(file)
--- a/
src/common/relayd/relayd.c
+++ b/
src/common/relayd/relayd.c
@@
-67,6
+67,7
@@
static int send_command(struct lttcomm_sock *sock,
ret = sock->ops->sendmsg(sock, buf, buf_size, flags);
if (ret < 0) {
ret = sock->ops->sendmsg(sock, buf, buf_size, flags);
if (ret < 0) {
+ ret = -errno;
goto error;
}
goto error;
}
@@
-90,6
+91,7
@@
static int recv_reply(struct lttcomm_sock *sock, void *data, size_t size)
ret = sock->ops->recvmsg(sock, data, size, 0);
if (ret < 0) {
ret = sock->ops->recvmsg(sock, data, size, 0);
if (ret < 0) {
+ ret = -errno;
goto error;
}
goto error;
}
@@
-283,6
+285,7
@@
int relayd_send_data_hdr(struct lttcomm_sock *sock,
/* Only send data header. */
ret = sock->ops->sendmsg(sock, hdr, size, 0);
if (ret < 0) {
/* Only send data header. */
ret = sock->ops->sendmsg(sock, hdr, size, 0);
if (ret < 0) {
+ ret = -errno;
goto error;
}
goto error;
}
This page took
0.026271 seconds
and
5
git commands to generate.