projects
/
lttng-ust.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Implement capturing payload on event notifiers
[lttng-ust.git]
/
liblttng-ust
/
lttng-ust-comm.c
diff --git
a/liblttng-ust/lttng-ust-comm.c
b/liblttng-ust/lttng-ust-comm.c
index ca51f7575ef4810ae15f8155e3678fbbd6ac842c..de03407b702aa5851f7fc69ae99633f5f08455f4 100644
(file)
--- a/
liblttng-ust/lttng-ust-comm.c
+++ b/
liblttng-ust/lttng-ust-comm.c
@@
-748,6
+748,8
@@
static inline
const char *bytecode_type_str(uint32_t cmd)
{
switch (cmd) {
const char *bytecode_type_str(uint32_t cmd)
{
switch (cmd) {
+ case LTTNG_UST_CAPTURE:
+ return "capture";
case LTTNG_UST_FILTER:
return "filter";
default:
case LTTNG_UST_FILTER:
return "filter";
default:
@@
-775,6
+777,13
@@
int handle_bytecode_recv(struct sock_info *sock_info,
reloc_offset = lum->u.filter.reloc_offset;
seqnum = lum->u.filter.seqnum;
break;
reloc_offset = lum->u.filter.reloc_offset;
seqnum = lum->u.filter.seqnum;
break;
+ case LTTNG_UST_CAPTURE:
+ type = LTTNG_UST_BYTECODE_NODE_TYPE_CAPTURE;
+ data_size = lum->u.capture.data_size;
+ data_size_max = CAPTURE_BYTECODE_MAX_LEN;
+ reloc_offset = lum->u.capture.reloc_offset;
+ seqnum = lum->u.capture.seqnum;
+ break;
default:
abort();
}
default:
abort();
}
@@
-897,6
+906,7
@@
int handle_message(struct sock_info *sock_info,
else
ret = lttng_ust_objd_unref(lum->handle, 1);
break;
else
ret = lttng_ust_objd_unref(lum->handle, 1);
break;
+ case LTTNG_UST_CAPTURE:
case LTTNG_UST_FILTER:
ret = handle_bytecode_recv(sock_info, sock, lum);
if (ret)
case LTTNG_UST_FILTER:
ret = handle_bytecode_recv(sock_info, sock, lum);
if (ret)
This page took
0.022805 seconds
and
4
git commands to generate.