Upstream oodles of Chrome for Android code into Chromium.

chrome/android/java_staging/src/org/chromium/chrome/browser/historyreport/HistoryReportJniBridge.java

+// Copyright 2015 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+package org.chromium.chrome.browser.historyreport;
+
+import android.text.TextUtils;
+
+import org.chromium.base.CalledByNative;
+import org.chromium.base.JNINamespace;
+import org.chromium.base.Log;
+import org.chromium.base.ThreadUtils;
+import org.chromium.base.VisibleForTesting;
+
+import java.io.PrintWriter;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+/**
+ * Bridge class for calls between Java and C++.
+ */
+@JNINamespace("history_report")
+public class HistoryReportJniBridge implements SearchJniBridge {
+    private static final String TAG = Log.makeTag("historyreport");
+
+    private long mNativeHistoryReportJniBridge;
+    private DataChangeObserver mDataChangeObserver;
+    private final AtomicBoolean mStarted = new AtomicBoolean();
+
+    @Override
+    public boolean init(DataChangeObserver observer) {
+        assert mDataChangeObserver == null || mDataChangeObserver == observer;
+        if (observer == null) return false;
+        if (mNativeHistoryReportJniBridge != 0) return true;
+        mDataChangeObserver = observer;
+        ThreadUtils.runOnUiThreadBlocking(new Runnable() {
+            @Override
+            public void run() {
+                mNativeHistoryReportJniBridge = nativeInit();
+            }
+        });
+        if (mNativeHistoryReportJniBridge == 0) {
+            Log.w(TAG, "JNI bridge initialization unsuccessful.");
+            return false;
+        }
+
+        Log.d(TAG, "JNI bridge initialization successful.");
+        mStarted.set(true);
+        return true;
+    }
+
+    private boolean isInitialized() {
+        return mNativeHistoryReportJniBridge != 0 && mDataChangeObserver != null && mStarted.get();
+    }
+
+    @VisibleForTesting
+    @Override
+    public boolean isStartedForTest() {
+        return mStarted.get();
+    }
+
+    @Override
+    public DeltaFileEntry[] query(long lastSeqNo, int limit) {
+        if (!isInitialized()) {
+            Log.w(TAG, "query when JNI bridge not initialized");
+            return new DeltaFileEntry[0];
+        }
+        Log.d(TAG, "query %d %d", lastSeqNo, limit);
+        DeltaFileEntry[] result = nativeQuery(mNativeHistoryReportJniBridge, lastSeqNo, limit);
+        Log.d(TAG, "query result: %s", TextUtils.join("\n", result));
+        return result;
+    }
+
+    @Override
+    public long trimDeltaFile(long seqNoLowerBound) {
+        if (!isInitialized()) {
+            Log.w(TAG, "trimDeltaFile when JNI bridge not initialized");
+            return -1;
+        }
+        Log.d(TAG, "trimDeltaFile %d", seqNoLowerBound);
+        return nativeTrimDeltaFile(mNativeHistoryReportJniBridge, seqNoLowerBound);
+    }
+
+    @Override
+    public UsageReport[] getUsageReportsBatch(int batchSize) {
+        if (!isInitialized()) {
+            Log.w(TAG, "getUsageReportsBatch when JNI bridge not initialized");
+            return new UsageReport[0];
+        }
+        Log.d(TAG, "getUsageReportsBatch %d", batchSize);
+        return nativeGetUsageReportsBatch(mNativeHistoryReportJniBridge, batchSize);
+    }
+
+    @Override
+    public void removeUsageReports(UsageReport[] reports) {
+        if (!isInitialized()) {
+            Log.w(TAG, "removeUsageReports when JNI bridge not initialized");
+            return;
+        }
+        String[] reportIds = new String[reports.length];
+        for (int i = 0; i < reports.length; ++i) {
+            reportIds[i] = reports[i].reportId;
+        }
+        Log.d(TAG, "removeUsageReports %s", TextUtils.join(",", reportIds));
+        nativeRemoveUsageReports(mNativeHistoryReportJniBridge, reportIds);
+    }
+
+    @Override
+    public boolean addHistoricVisitsToUsageReportsBuffer() {
+        if (!isInitialized()) return false;
+        return nativeAddHistoricVisitsToUsageReportsBuffer(mNativeHistoryReportJniBridge);
+    }
+
+    @Override
+    public void dump(PrintWriter writer) {
+        writer.append("\nHistoryReportJniBridge [").append("started: " + mStarted.get())
+                .append(", initialized: " + isInitialized());
+        if (isInitialized()) {
+            writer.append(", " + nativeDump(mNativeHistoryReportJniBridge));
+        }
+        writer.append("]");
+    }
+
+    @CalledByNative
+    private static DeltaFileEntry[] createDeltaFileEntriesArray(int size) {
+        return new DeltaFileEntry[size];
+    }
+
+    @CalledByNative
+    private static void setDeltaFileEntry(DeltaFileEntry[] entries, int position, long seqNo,
+            String type, String id, String url, int score, String title, String indexedUrl) {
+        entries[position] = new DeltaFileEntry(seqNo, type, id, url, score, title, indexedUrl);
+    }
+
+    @CalledByNative
+    private static UsageReport[] createUsageReportsArray(int size) {
+        return new UsageReport[size];
+    }
+
+    @CalledByNative
+    private static void setUsageReport(UsageReport[] reports, int position, String reportId,
+            String pageId, long timestampMs, boolean typedVisit) {
+        reports[position] = new UsageReport(reportId, pageId, timestampMs, typedVisit);
+    }
+
+    @CalledByNative
+    private void onDataChanged() {
+        Log.d(TAG, "onDataChanged");
+        mDataChangeObserver.onDataChanged();
+    }
+
+    @CalledByNative
+    private void onDataCleared() {
+        Log.d(TAG, "onDataCleared");
+        mDataChangeObserver.onDataCleared();
+    }
+
+    @CalledByNative
+    private void startReportingTask() {
+        Log.d(TAG, "startReportingTask");
+        mDataChangeObserver.startReportingTask();
+    }
+
+    @CalledByNative
+    private void stopReportingTask() {
+        Log.d(TAG, "stopReportingTask");
+        mDataChangeObserver.stopReportingTask();
+    }
+
+    private native long nativeInit();
+    private native long nativeTrimDeltaFile(long nativeHistoryReportJniBridge,
+            long seqNoLowerBound);
+    private native DeltaFileEntry[] nativeQuery(long nativeHistoryReportJniBridge, long lastSeqNo,
+            int limit);
+    private native UsageReport[] nativeGetUsageReportsBatch(long nativeHistoryReportJniBridge,
+            int batchSize);
+    private native void nativeRemoveUsageReports(long nativeHistoryReportJniBridge,
+            String[] reportIds);
+    private native boolean nativeAddHistoricVisitsToUsageReportsBuffer(
+            long nativeHistoryReportJniBridge);
+    private native String nativeDump(long nativeHistoryReportJniBridge);
+}