projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add lttng-error.h containing every API err. code
[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 cb115afda0ede578de51c9302b5380f4bd2bf671..3826f0a759bcf8580706a2b64f1fb82d7d0b1d1c 100644
(file)
--- a/
src/bin/lttng-relayd/main.c
+++ b/
src/bin/lttng-relayd/main.c
@@
-977,9
+977,9
@@
end:
free(root_path);
/* send the session id to the client or a negative return code on error */
if (ret < 0) {
free(root_path);
/* send the session id to the client or a negative return code on error */
if (ret < 0) {
- reply.ret_code = htobe32(LTT
COMM_ERR
);
+ reply.ret_code = htobe32(LTT
NG_ERR_UNK
);
} else {
} else {
- reply.ret_code = htobe32(LTT
COMM
_OK);
+ reply.ret_code = htobe32(LTT
NG
_OK);
}
reply.handle = htobe64(stream->stream_handle);
send_ret = cmd->sock->ops->sendmsg(cmd->sock, &reply,
}
reply.handle = htobe64(stream->stream_handle);
send_ret = cmd->sock->ops->sendmsg(cmd->sock, &reply,
@@
-1058,9
+1058,9
@@
end_unlock:
rcu_read_unlock();
if (ret < 0) {
rcu_read_unlock();
if (ret < 0) {
- reply.ret_code = htobe32(LTT
COMM_ERR
);
+ reply.ret_code = htobe32(LTT
NG_ERR_UNK
);
} else {
} else {
- reply.ret_code = htobe32(LTT
COMM
_OK);
+ reply.ret_code = htobe32(LTT
NG
_OK);
}
send_ret = cmd->sock->ops->sendmsg(cmd->sock, &reply,
sizeof(struct lttcomm_relayd_generic_reply), 0);
}
send_ret = cmd->sock->ops->sendmsg(cmd->sock, &reply,
sizeof(struct lttcomm_relayd_generic_reply), 0);
@@
-1081,7
+1081,7
@@
void relay_unknown_command(struct relay_command *cmd)
struct lttcomm_relayd_generic_reply reply;
int ret;
struct lttcomm_relayd_generic_reply reply;
int ret;
- reply.ret_code = htobe32(LTT
COMM_ERR
);
+ reply.ret_code = htobe32(LTT
NG_ERR_UNK
);
ret = cmd->sock->ops->sendmsg(cmd->sock, &reply,
sizeof(struct lttcomm_relayd_generic_reply), 0);
if (ret < 0) {
ret = cmd->sock->ops->sendmsg(cmd->sock, &reply,
sizeof(struct lttcomm_relayd_generic_reply), 0);
if (ret < 0) {
@@
-1097,13
+1097,13
@@
static
int relay_start(struct lttcomm_relayd_hdr *recv_hdr,
struct relay_command *cmd)
{
int relay_start(struct lttcomm_relayd_hdr *recv_hdr,
struct relay_command *cmd)
{
- int ret = htobe32(LTT
COMM
_OK);
+ int ret = htobe32(LTT
NG
_OK);
struct lttcomm_relayd_generic_reply reply;
struct relay_session *session = cmd->session;
if (!session) {
DBG("Trying to start the streaming without a session established");
struct lttcomm_relayd_generic_reply reply;
struct relay_session *session = cmd->session;
if (!session) {
DBG("Trying to start the streaming without a session established");
- ret = htobe32(LTT
COMM_ERR
);
+ ret = htobe32(LTT
NG_ERR_UNK
);
}
reply.ret_code = ret;
}
reply.ret_code = ret;
@@
-1151,7
+1151,7
@@
static
int relay_recv_metadata(struct lttcomm_relayd_hdr *recv_hdr,
struct relay_command *cmd, struct lttng_ht *streams_ht)
{
int relay_recv_metadata(struct lttcomm_relayd_hdr *recv_hdr,
struct relay_command *cmd, struct lttng_ht *streams_ht)
{
- int ret = htobe32(LTT
COMM
_OK);
+ int ret = htobe32(LTT
NG
_OK);
struct relay_session *session = cmd->session;
struct lttcomm_relayd_metadata_payload *metadata_struct;
struct relay_stream *metadata_stream;
struct relay_session *session = cmd->session;
struct lttcomm_relayd_metadata_payload *metadata_struct;
struct relay_stream *metadata_stream;
@@
-1223,7
+1223,7
@@
static
int relay_send_version(struct lttcomm_relayd_hdr *recv_hdr,
struct relay_command *cmd)
{
int relay_send_version(struct lttcomm_relayd_hdr *recv_hdr,
struct relay_command *cmd)
{
- int ret = htobe32(LTT
COMM
_OK);
+ int ret = htobe32(LTT
NG
_OK);
struct lttcomm_relayd_version reply;
struct relay_session *session = NULL;
struct lttcomm_relayd_version reply;
struct relay_session *session = NULL;
This page took
0.026776 seconds
and
5
git commands to generate.