/* * 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.server.am; import android.app.IInstrumentationWatcher; import android.content.ComponentName; import android.os.Bundle; import android.os.Process; import android.os.RemoteException; import android.util.Slog; import java.util.ArrayList; public class InstrumentationReporter { static final boolean DEBUG = false; static final String TAG = ActivityManagerDebugConfig.TAG_AM; static final int REPORT_TYPE_STATUS = 0; static final int REPORT_TYPE_FINISHED = 1; final Object mLock = new Object(); ArrayList mPendingReports; Thread mThread; final class MyThread extends Thread { public MyThread() { super("InstrumentationReporter"); if (DEBUG) Slog.d(TAG, "Starting InstrumentationReporter: " + this); } @Override public void run() { Process.setThreadPriority(Process.THREAD_PRIORITY_DEFAULT); boolean waited = false; while (true) { ArrayList reports; synchronized (mLock) { reports = mPendingReports; mPendingReports = null; if (reports == null || reports.isEmpty()) { if (!waited) { // Sleep for a little bit, to avoid thrashing through threads. try { mLock.wait(10000); // 10 seconds } catch (InterruptedException e) { } waited = true; continue; } else { mThread = null; if (DEBUG) Slog.d(TAG, "Exiting InstrumentationReporter: " + this); return; } } } waited = false; for (int i=0; i