X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Frelayd%2Frelayd.c;h=ce46c9c54504645b9ff74827eea4151b41405fda;hb=af6c30b5397b3b0542e70140d8aac10cf8c79556;hp=1f427e0e25cb8e1d2e502760294918be10a5172d;hpb=7d2f74525fbda4dcc744f33ea26c911545b5df13;p=lttng-tools.git diff --git a/src/common/relayd/relayd.c b/src/common/relayd/relayd.c index 1f427e0e2..ce46c9c54 100644 --- a/src/common/relayd/relayd.c +++ b/src/common/relayd/relayd.c @@ -184,10 +184,12 @@ int relayd_create_session(struct lttcomm_relayd_sock *rsock, uint64_t *session_i case 2: case 3: ret = relayd_create_session_2_1(rsock, session_id); + break; case 4: default: ret = relayd_create_session_2_4(rsock, session_id, session_name, hostname, session_live_timer, snapshot); + break; } if (ret < 0) { @@ -689,7 +691,7 @@ error: int relayd_end_data_pending(struct lttcomm_relayd_sock *rsock, uint64_t id, unsigned int *is_data_inflight) { - int ret; + int ret, recv_ret; struct lttcomm_relayd_end_data_pending msg; struct lttcomm_relayd_generic_reply reply; @@ -712,15 +714,15 @@ int relayd_end_data_pending(struct lttcomm_relayd_sock *rsock, uint64_t id, goto error; } - reply.ret_code = be32toh(reply.ret_code); - if (reply.ret_code < 0) { - ret = reply.ret_code; + recv_ret = be32toh(reply.ret_code); + if (recv_ret < 0) { + ret = recv_ret; goto error; } - *is_data_inflight = reply.ret_code; + *is_data_inflight = recv_ret; - DBG("Relayd end data pending is data inflight: %d", reply.ret_code); + DBG("Relayd end data pending is data inflight: %d", recv_ret); return 0;