2 files changed, 211 insertions, 0 deletions
diff --git a/src/com/android/loganalysis/item/ServiceInfoItem.java b/src/com/android/loganalysis/item/ServiceInfoItem.java
new file mode 100644
index 0000000..62a89f5
--- /dev/null
+++ b/src/com/android/loganalysis/item/ServiceInfoItem.java
@@ -0,0 +1,99 @@
+/*
+ * Copyright (C) 2016 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.
+ */
+
+package com.android.loganalysis.item;
+
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/**
+ * An {@link IItem} used to store service info logged in dmesg
+ */
+public class ServiceInfoItem extends GenericItem {
+
+    /** Constant for JSON output */
+    public static final String SERVICE_NAME = "SERVICE_NAME";
+    /** Constant for JSON output */
+    public static final String SERVICE_START_TIME = "SERVICE_START_TIME";
+    /** Constant for JSON output */
+    public static final String SERVICE_END_TIME = "SERVICE_END_TIME";
+    /** Constant for JSON output */
+    public static final String SERVICE_DURATION = "SERVICE_DURATION";
+
+    private static final Set<String> ATTRIBUTES = new HashSet<String>(Arrays.asList(
+            SERVICE_NAME, SERVICE_START_TIME, SERVICE_END_TIME));
+
+    /**
+     * The constructor for {@link ServiceInfoItem}.
+     */
+    public ServiceInfoItem() {
+        super(ATTRIBUTES);
+    }
+
+    /**
+     * Get the name of the service
+     */
+    public String getServiceName() {
+        return (String) getAttribute(SERVICE_NAME);
+    }
+
+    /**
+     * Set the name of the service
+     */
+    public void setServiceName(String serviceName) {
+        setAttribute(SERVICE_NAME, serviceName);
+    }
+
+    /**
+     * Get the start time in msecs
+     */
+    public Long getStartTime() {
+        return (Long) getAttribute(SERVICE_START_TIME);
+    }
+
+    /**
+     * Set the start time in msecs
+     */
+    public void setStartTime(Long startTime) {
+        setAttribute(SERVICE_START_TIME, startTime);
+    }
+
+    /**
+     * Get the end time in msecs
+     */
+    public Long getEndTime() {
+        return (Long) getAttribute(SERVICE_END_TIME);
+    }
+
+    /**
+     * Set the end time in msecs
+     */
+    public void setEndTime(Long endTime) {
+        setAttribute(SERVICE_END_TIME, endTime);
+    }
+
+    /**
+     * Get the service duration in msecs If the start or end time is not present then return -1
+     */
+    public Long getServiceDuration() {
+        if (null != getAttribute(SERVICE_END_TIME) && null != getAttribute(SERVICE_START_TIME)) {
+            return getEndTime() - getStartTime();
+        }
+        return -1L;
+    }
+
+}
diff --git a/src/com/android/loganalysis/parser/DmesgParser.java b/src/com/android/loganalysis/parser/DmesgParser.java
new file mode 100644
index 0000000..51fb2e2
--- /dev/null
+++ b/src/com/android/loganalysis/parser/DmesgParser.java
@@ -0,0 +1,112 @@
+/*
+ * Copyright (C) 2016 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.
+ */
+
+package com.android.loganalysis.parser;
+
+import com.android.loganalysis.item.IItem;
+import com.android.loganalysis.item.ServiceInfoItem;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+
+/**
+ * Parse the dmesg logs. </p>
+ */
+public class DmesgParser implements IParser {
+
+    private static final String SERVICENAME = "SERVICENAME";
+    private static final String TIMESTAMP = "TIMESTAMP";
+    // Matches: [ 14.822691] init:
+    private static final String SERVICE_PREFIX = String.format("^\\[\\s+(?<%s>.*)\\] init:\\s+",
+            TIMESTAMP);
+    // Matches: starting service 'ueventd'...
+    private static final String START_SERVICE_SUFFIX = String.format("starting service "
+            + "\\'(?<%s>.*)\\'...", SERVICENAME);
+    // Matches: Service 'ueventd' (pid 439) exited with status 0
+    private static final String EXIT_SERVICE_SUFFIX = String.format("Service \\'(?<%s>.*)\\'\\s+"
+            + "\\((?<PID>.*)\\) exited with status 0", SERVICENAME);
+
+    private static final Pattern START_SERVICE = Pattern.compile(
+            String.format("%s%s", SERVICE_PREFIX, START_SERVICE_SUFFIX));
+    private static final Pattern EXIT_SERVICE = Pattern.compile(
+            String.format("%s%s", SERVICE_PREFIX, EXIT_SERVICE_SUFFIX));
+
+    private Map<String, ServiceInfoItem> mServiceInfoItems = new HashMap<String, ServiceInfoItem>();
+
+    @Override
+    public IItem parse(List<String> lines) {
+        throw new UnsupportedOperationException("Method has not been implemented in lieu"
+                + " of others");
+    }
+
+    /**
+     * Parse init services start time and end time from dmesg logs and store the duration it took to
+     * complete the service if the end time stamp is available.
+     *
+     * @param input dmesg logs
+     * @return list of ServiceInfoItems which contains service start and end time
+     * @throws IOException
+     */
+    public List<ServiceInfoItem> parseServiceInfo(BufferedReader input)
+            throws IOException {
+        String line;
+        while ((line = input.readLine()) != null) {
+            Matcher match = null;
+            if ((match = matches(START_SERVICE, line)) != null) {
+                ServiceInfoItem serviceItem = new ServiceInfoItem();
+                serviceItem.setServiceName(match.group(SERVICENAME));
+                serviceItem.setStartTime((long) (Double.parseDouble(
+                        match.group(TIMESTAMP)) * 1000));
+                getServiceInfoItems().put(match.group(SERVICENAME), serviceItem);
+            } else if ((match = matches(EXIT_SERVICE, line)) != null) {
+                if (getServiceInfoItems().containsKey(match.group(SERVICENAME))) {
+                    ServiceInfoItem serviceItem = getServiceInfoItems().get(
+                            match.group(SERVICENAME));
+                    serviceItem.setEndTime((long) (Double.parseDouble(
+                            match.group(TIMESTAMP)) * 1000));
+                }
+            }
+        }
+        return new ArrayList<ServiceInfoItem>(getServiceInfoItems().values());
+    }
+
+    /**
+     * Checks whether {@code line} matches the given {@link Pattern}.
+     *
+     * @return The resulting {@link Matcher} obtained by matching the {@code line} against
+     *         {@code pattern}, or null if the {@code line} does not match.
+     */
+    private static Matcher matches(Pattern pattern, String line) {
+        Matcher ret = pattern.matcher(line);
+        return ret.matches() ? ret : null;
+    }
+
+    public Map<String, ServiceInfoItem> getServiceInfoItems() {
+        return mServiceInfoItems;
+    }
+
+    public void setServiceInfoItems(Map<String, ServiceInfoItem> serviceInfoItems) {
+        this.mServiceInfoItems = serviceInfoItems;
+    }
+
+}