xref: /frameworks/base/cmds/incident_helper/src/parsers/EventLogTagsParser.cpp

/*
 * Copyright (C) 2017 The Android Open Source Project
 *
 * 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.
 */
#define LOG_TAG "incident_helper"

#include <android/util/ProtoOutputStream.h>

#include "frameworks/base/core/proto/android/util/event_log_tags.proto.h"
#include "ih_util.h"
#include "EventLogTagsParser.h"

status_t
EventLogTagsParser::Parse(const int in, const int out) const
{
    Reader reader(in);
    string line;

    ProtoOutputStream proto;

    // parse line by line
    while (reader.readLine(&line)) {
        if (line.empty()) continue;
        string debug = line;
        string tagNumber = behead(&line, ' ');
        string tagName = behead(&line, ' ');
        if (tagNumber == "" || tagName == "") {
            fprintf(stderr, "Bad line, expect at least two parts: %s[%s, %s]\n",
                debug.c_str(), tagNumber.c_str(), tagName.c_str());
            continue;
        }

        uint64_t token = proto.start(EventLogTagMapProto::EVENT_LOG_TAGS);
        proto.write(EventLogTag::TAG_NUMBER, toInt(tagNumber));
        proto.write(EventLogTag::TAG_NAME, tagName);

        record_t valueDescriptors = parseRecord(line, PARENTHESES_DELIMITER);
        for (size_t i = 0; i < valueDescriptors.size(); i++) {
            record_t valueDescriptor = parseRecord(valueDescriptors[i], PIPE_DELIMITER);
            if (valueDescriptor.size() != 2 && valueDescriptor.size() != 3) {
                // If the parts doesn't contains pipe, then skips it.
                continue;
            }
            uint64_t descriptorToken = proto.start(EventLogTag::VALUE_DESCRIPTORS);
            proto.write(EventLogTag::ValueDescriptor::NAME, valueDescriptor[0]);
            proto.write(EventLogTag::ValueDescriptor::TYPE, toInt(valueDescriptor[1]));
            if (valueDescriptor.size() == 3) {
                char c = valueDescriptor[2][0];
                int unit = 0;
                if (c < '0' || c > '9') {
                    unit = (int) c;
                } else {
                    unit = toInt(valueDescriptor[2]);
                }
                proto.write(EventLogTag::ValueDescriptor::UNIT, unit);
            }
            proto.end(descriptorToken);
        }
        proto.end(token);
    }

    if (!reader.ok(&line)) {
        fprintf(stderr, "Bad read from fd %d: %s\n", in, line.c_str());
        return -1;
    }

    if (!proto.flush(out)) {
        fprintf(stderr, "[%s]Error writing proto back\n", this->name.string());
        return -1;
    }
    fprintf(stderr, "[%s]Proto size: %zu bytes\n", this->name.string(), proto.size());
    return NO_ERROR;
}