Commit | Line | Data |
---|---|---|
03c229bf | 1 | BEGIN { |
8482fea6 SK |
2 | FS1 = "|" # Fiels separator, level 1 (record to fields) |
3 | FS2 = ":" # Fiels separator, level 2 (field to subfields) | |
4 | ||
5 | FS = FS1 | |
6 | Kfs = FS2 | |
7 | } | |
8 | ||
9 | function msg_in_parse(msg, line, fields, type) { | |
10 | split(line, fields, FS1) | |
11 | msg["node"] = fields[1] | |
12 | msg["module"] = fields[2] | |
13 | type = fields[3] | |
14 | msg["type"] = type | |
15 | ||
16 | if (type == "data") { | |
17 | msg["key"] = fields[4] | |
18 | msg["val"] = str_tail(str_join(fields, 1, 4, FS1) FS1, line) | |
19 | } else if (type == "error") { | |
20 | msg["line"] = str_tail(str_join(fields, 1, 3, FS1) FS1, line) | |
21 | } else if (type == "alert") { | |
22 | msg["priority"] = fields[4] | |
23 | msg["subject"] = fields[5] | |
24 | msg["body"] = str_tail(str_join(fields, 1, 5, FS1) FS1, line) | |
25 | } else if (type == "log") { | |
26 | msg["location"] = fields[4] | |
27 | msg["level"] = fields[5] | |
28 | msg["msg"] = str_tail(str_join(fields, 1, 5, FS1) FS1, line) | |
29 | } else if (type == "status_bar") { | |
30 | msg["status_bar"] = str_tail(str_join(fields, 1, 3, FS1) FS1, line) | |
31 | } else { | |
32 | msg_out_log_error(\ | |
33 | "msg_in_parse", | |
34 | "Unexpected msg type: " type " in given input line: " line \ | |
35 | ) | |
36 | exit 1 | |
37 | } | |
03c229bf | 38 | } |