50 static int get_line(JournalImporter *imp, char **line, size_t *size) {  in get_line()  argument
106         *line = imp->buf + imp->offset;  in get_line()
213 static int process_special_field(JournalImporter *imp, char *line) {  in process_special_field()  argument
218         assert(line);  in process_special_field()
220         value = startswith(line, "__CURSOR=");  in process_special_field()
225         value = startswith(line, "__REALTIME_TIMESTAMP=");  in process_special_field()
242         value = startswith(line, "__MONOTONIC_TIMESTAMP=");  in process_special_field()
260         value = startswith(line, "_BOOT_ID=");  in process_special_field()
271         value = startswith(line, "__");  in process_special_field()
286                 char *line, *sep;  in journal_importer_process_data()  local
291                 r = get_line(imp, &line, &n);  in journal_importer_process_data()
299                 assert(line[n-1] == '\n');  in journal_importer_process_data()
311                 sep = memchr(line, '=', n);  in journal_importer_process_data()
316                         if (!journal_field_valid(line, sep - line, true)) {  in journal_importer_process_data()
319                                 t = strndupa_safe(line, sep - line);  in journal_importer_process_data()
326                         line[n] = '\0';  in journal_importer_process_data()
327                         r = process_special_field(imp, line);  in journal_importer_process_data()
331                         r = iovw_put(&imp->iovw, line, n);  in journal_importer_process_data()
335                         if (!journal_field_valid(line, n - 1, true)) {  in journal_importer_process_data()
338                                 t = strndupa_safe(line, n - 1);  in journal_importer_process_data()
346                         line[n-1] = '=';  in journal_importer_process_data()
354                 log_trace("Received: %.*s (%s)", (int) n, line, sep ? "text" : "binary");  in journal_importer_process_data()