projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Use non-blocking recvmsg() for data/ctrl connections of lttng-relayd
[lttng-tools.git]
/
src
/
bin
/
lttng-relayd
/
stream.c
diff --git
a/src/bin/lttng-relayd/stream.c
b/src/bin/lttng-relayd/stream.c
index 5ed37c58ec1d2c0956b550ac837bac314d1e33a0..709b3b1f5e7af9d135a24b0b3d67a957f6f3fcbe 100644
(file)
--- a/
src/bin/lttng-relayd/stream.c
+++ b/
src/bin/lttng-relayd/stream.c
@@
-361,6
+361,7
@@
void try_stream_close(struct relay_stream *stream)
* a packet. Since those are sent in that order, we take
* care of consumerd crashes.
*/
* a packet. Since those are sent in that order, we take
* care of consumerd crashes.
*/
+ DBG("relay_index_close_partial_fd");
relay_index_close_partial_fd(stream);
/*
* Use the highest net_seq_num we currently have pending
relay_index_close_partial_fd(stream);
/*
* Use the highest net_seq_num we currently have pending
@@
-368,6
+369,7
@@
void try_stream_close(struct relay_stream *stream)
* at -1ULL if we cannot find any index.
*/
stream->last_net_seq_num = relay_index_find_last(stream);
* at -1ULL if we cannot find any index.
*/
stream->last_net_seq_num = relay_index_find_last(stream);
+ DBG("Updating stream->last_net_seq_num to %" PRIu64, stream->last_net_seq_num);
/* Fall-through into the next check. */
}
/* Fall-through into the next check. */
}
This page took
0.022835 seconds
and
4
git commands to generate.