#include <stdint.h>
#include <lttng/urcu/pointer.h>
+#include <urcu/rculist.h>
#include <lttng/ust-endian.h>
#include <lttng/ust-events.h>
#include "ust-events-internal.h"
return diff;
}
-uint64_t lttng_bytecode_filter_interpret_false(void *filter_data,
- const char *filter_stack_data)
+int lttng_bytecode_interpret_error(struct lttng_ust_bytecode_runtime *bytecode_runtime,
+ const char *stack_data,
+ void *ctx)
{
- return LTTNG_INTERPRETER_DISCARD;
-}
-
-uint64_t lttng_bytecode_capture_interpret_false(void *capture_data,
- const char *capture_stack_data,
- struct lttng_interpreter_output *output)
-{
- return LTTNG_INTERPRETER_DISCARD;
+ return LTTNG_UST_BYTECODE_INTERPRETER_ERROR;
}
#ifdef INTERPRETER_USE_SWITCH
return -EINVAL;
}
- return LTTNG_INTERPRETER_RECORD_FLAG;
+ return 0;
}
/*
- * For `output` equal to NULL:
- * Return 0 (discard), or raise the 0x1 flag (log event).
- * Currently, other flags are kept for future extensions and have no
- * effect.
- * For `output` not equal to NULL:
- * Return 0 on success, negative error value on error.
+ * Return LTTNG_UST_BYTECODE_INTERPRETER_OK on success.
+ * Return LTTNG_UST_BYTECODE_INTERPRETER_ERROR on error.
+ *
+ * For FILTER bytecode: expect a struct lttng_ust_bytecode_filter_ctx *
+ * as @ctx argument.
+ * For CAPTURE bytecode: expect a struct lttng_interpreter_output *
+ * as @ctx argument.
*/
-static
-uint64_t bytecode_interpret(void *interpreter_data,
+int lttng_bytecode_interpret(struct lttng_ust_bytecode_runtime *ust_bytecode,
const char *interpreter_stack_data,
- struct lttng_interpreter_output *output)
+ void *caller_ctx)
{
- struct bytecode_runtime *bytecode = interpreter_data;
- struct lttng_ust_ctx *ctx = lttng_ust_rcu_dereference(*bytecode->p.priv->pctx);
+ struct bytecode_runtime *bytecode = caa_container_of(ust_bytecode, struct bytecode_runtime, p);
+ struct lttng_ust_ctx *ctx = lttng_ust_rcu_dereference(*ust_bytecode->pctx);
void *pc, *next_pc, *start_pc;
- int ret = -EINVAL;
- uint64_t retval = 0;
+ int ret = -EINVAL, retval = 0;
struct estack _stack;
struct estack *stack = &_stack;
register int64_t ax = 0, bx = 0;
goto end;
OP(BYTECODE_OP_RETURN):
- /* LTTNG_INTERPRETER_DISCARD or LTTNG_INTERPRETER_RECORD_FLAG */
+ /* LTTNG_UST_BYTECODE_INTERPRETER_ERROR or LTTNG_UST_BYTECODE_INTERPRETER_OK */
/* Handle dynamic typing. */
switch (estack_ax_t) {
case REG_S64:
case REG_DOUBLE:
case REG_STRING:
case REG_PTR:
- if (!output) {
+ if (ust_bytecode->type != LTTNG_UST_BYTECODE_TYPE_CAPTURE) {
ret = -EINVAL;
goto end;
}
goto end;
OP(BYTECODE_OP_RETURN_S64):
- /* LTTNG_INTERPRETER_DISCARD or LTTNG_INTERPRETER_RECORD_FLAG */
+ /* LTTNG_UST_BYTECODE_INTERPRETER_ERROR or LTTNG_UST_BYTECODE_INTERPRETER_OK */
retval = !!estack_ax_v;
ret = 0;
goto end;
JUMP_TO(BYTECODE_OP_CAST_DOUBLE_TO_S64);
case REG_U64:
estack_ax_t = REG_S64;
- next_pc += sizeof(struct cast_op);
+ next_pc += sizeof(struct cast_op); /* Fall-through */
case REG_STRING: /* Fall-through */
case REG_STAR_GLOB_STRING:
ret = -EINVAL;
END_OP
end:
- /* Return _DISCARD on error. */
+ /* No need to prepare output if an error occurred. */
if (ret)
- return LTTNG_INTERPRETER_DISCARD;
+ return LTTNG_UST_BYTECODE_INTERPRETER_ERROR;
- if (output) {
- return lttng_bytecode_interpret_format_output(estack_ax(stack, top),
- output);
+ /* Prepare output. */
+ switch (ust_bytecode->type) {
+ case LTTNG_UST_BYTECODE_TYPE_FILTER:
+ {
+ struct lttng_ust_bytecode_filter_ctx *filter_ctx =
+ (struct lttng_ust_bytecode_filter_ctx *) caller_ctx;
+ if (retval)
+ filter_ctx->result = LTTNG_UST_BYTECODE_FILTER_ACCEPT;
+ else
+ filter_ctx->result = LTTNG_UST_BYTECODE_FILTER_REJECT;
+ break;
}
-
- return retval;
-}
-
-uint64_t lttng_bytecode_filter_interpret(void *filter_data,
- const char *filter_stack_data)
-{
- return bytecode_interpret(filter_data, filter_stack_data, NULL);
+ case LTTNG_UST_BYTECODE_TYPE_CAPTURE:
+ ret = lttng_bytecode_interpret_format_output(estack_ax(stack, top),
+ (struct lttng_interpreter_output *) caller_ctx);
+ break;
+ default:
+ ret = -EINVAL;
+ break;
+ }
+ if (ret)
+ return LTTNG_UST_BYTECODE_INTERPRETER_ERROR;
+ else
+ return LTTNG_UST_BYTECODE_INTERPRETER_OK;
}
-uint64_t lttng_bytecode_capture_interpret(void *capture_data,
- const char *capture_stack_data,
- struct lttng_interpreter_output *output)
+/*
+ * Return LTTNG_UST_EVENT_FILTER_ACCEPT or LTTNG_UST_EVENT_FILTER_REJECT.
+ */
+int lttng_ust_interpret_event_filter(struct lttng_ust_event_common *event,
+ const char *interpreter_stack_data,
+ void *event_filter_ctx)
{
- return bytecode_interpret(capture_data, capture_stack_data,
- (struct lttng_interpreter_output *) output);
+ struct lttng_ust_bytecode_runtime *filter_bc_runtime;
+ struct cds_list_head *filter_bytecode_runtime_head = &event->priv->filter_bytecode_runtime_head;
+ struct lttng_ust_bytecode_filter_ctx bytecode_filter_ctx;
+ bool filter_record = false;
+
+ cds_list_for_each_entry_rcu(filter_bc_runtime, filter_bytecode_runtime_head, node) {
+ if (caa_likely(filter_bc_runtime->interpreter_func(filter_bc_runtime,
+ interpreter_stack_data, &bytecode_filter_ctx) == LTTNG_UST_BYTECODE_INTERPRETER_OK)) {
+ if (caa_unlikely(bytecode_filter_ctx.result == LTTNG_UST_BYTECODE_FILTER_ACCEPT)) {
+ filter_record = true;
+ break;
+ }
+ }
+ }
+ if (filter_record)
+ return LTTNG_UST_EVENT_FILTER_ACCEPT;
+ else
+ return LTTNG_UST_EVENT_FILTER_REJECT;
}
#undef START_OP
projects / lttng-ust.git / blobdiff