diff options
Diffstat (limited to 'fluent-bit/src/multiline/flb_ml_parser_java.c')
| -rw-r--r-- | fluent-bit/src/multiline/flb_ml_parser_java.c | 143 |
1 files changed, 143 insertions, 0 deletions
diff --git a/fluent-bit/src/multiline/flb_ml_parser_java.c b/fluent-bit/src/multiline/flb_ml_parser_java.c new file mode 100644 index 000000000..4df5a00f7 --- /dev/null +++ b/fluent-bit/src/multiline/flb_ml_parser_java.c @@ -0,0 +1,143 @@ +/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ + +/* Fluent Bit + * ========== + * Copyright (C) 2015-2022 The Fluent Bit Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include <fluent-bit/flb_info.h> +#include <fluent-bit/multiline/flb_ml.h> +#include <fluent-bit/multiline/flb_ml_rule.h> +#include <fluent-bit/multiline/flb_ml_parser.h> + +#define rule flb_ml_rule_create + +static void rule_error(struct flb_ml_parser *ml_parser) +{ + int id; + + id = mk_list_size(&ml_parser->regex_rules); + flb_error("[multiline: java] rule #%i could not be created", id); + flb_ml_parser_destroy(ml_parser); +} + +/* Java mode */ +struct flb_ml_parser *flb_ml_parser_java(struct flb_config *config, char *key) +{ + int ret; + struct flb_ml_parser *mlp; + + mlp = flb_ml_parser_create(config, /* Fluent Bit context */ + "java", /* name */ + FLB_ML_REGEX, /* type */ + NULL, /* match_str */ + FLB_FALSE, /* negate */ + FLB_ML_FLUSH_TIMEOUT, /* flush_ms */ + key, /* key_content */ + NULL, /* key_group */ + NULL, /* key_pattern */ + NULL, /* parser ctx */ + NULL); /* parser name */ + + if (!mlp) { + flb_error("[multiline] could not create 'java mode'"); + return NULL; + } + + ret = rule(mlp, + "start_state, java_start_exception", + "/(.)(?:Exception|Error|Throwable|V8 errors stack trace)[:\\r\\n]/", + "java_after_exception", NULL); + if (ret != 0) { + rule_error(mlp); + return NULL; + } + + ret = rule(mlp, + "java_after_exception", + "/^[\\t ]*nested exception is:[\\t ]*/", + "java_start_exception", NULL); + if (ret != 0) { + rule_error(mlp); + return NULL; + } + + ret = rule(mlp, + "java_after_exception", + "/^[\\r\\n]*$/", + "java_after_exception", NULL); + if (ret != 0) { + rule_error(mlp); + return NULL; + } + + ret = rule(mlp, + "java_after_exception, java", + "/^[\\t ]+(?:eval )?at /", + "java", NULL); + if (ret != 0) { + rule_error(mlp); + return NULL; + } + + ret = rule(mlp, + "java_after_exception, java", + /* C# nested exception */ + "/^[\\t ]+--- End of inner exception stack trace ---$/", + "java", NULL); + if (ret != 0) { + rule_error(mlp); + return NULL; + } + + ret = rule(mlp, + "java_after_exception, java", + /* C# exception from async code */ + "/^--- End of stack trace from previous (?x:" + ")location where exception was thrown ---$/", + "java", NULL); + if (ret != 0) { + rule_error(mlp); + return NULL; + } + + ret = rule(mlp, + "java_after_exception, java", + "/^[\\t ]*(?:Caused by|Suppressed):/", + "java_after_exception", NULL); + if (ret != 0) { + rule_error(mlp); + return NULL; + } + + ret = rule(mlp, + "java_after_exception, java", + "/^[\\t ]*... \\d+ (?:more|common frames omitted)/", + "java", NULL); + if (ret != 0) { + rule_error(mlp); + return NULL; + } + + /* Map the rules (mandatory for regex rules) */ + ret = flb_ml_parser_init(mlp); + if (ret != 0) { + flb_error("[multiline: java] error on mapping rules"); + flb_ml_parser_destroy(mlp); + return NULL; + } + + return mlp; +} |