Android/frameworks_base
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge "profcollectd: register callback to wait until ETM is ready." am: 0a57fb2b79 am: e615db8246 am: 5dcb003f12 am: 14f9d4834c

Browse Source 
Original change: https://android-review.googlesource.com/c/platform/frameworks/base/+/1972401

Change-Id: If0c25470de33b92b8a509f6e2ebe96a7793bbf33
This commit is contained in:
Yabin Cui
2022-02-09 19:09:52 +00:00
committed by Automerger Merge Worker
parent 4ff2a4e611 14f9d4834c
commit c1e5aea101
1 changed files with 23 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
services/profcollect/src/com/android/server/profcollect/ProfcollectForwardingService.java
View File

@@ -60,6 +60,12 @@ public final class ProfcollectForwardingService extends SystemService {
private static ProfcollectForwardingService sSelfService;
private final Handler mHandler = new ProfcollectdHandler(IoThread.getHandler().getLooper());
private IProviderStatusCallback mProviderStatusCallback = new IProviderStatusCallback.Stub() {
public void onProviderReady() {
mHandler.sendEmptyMessage(ProfcollectdHandler.MESSAGE_REGISTER_SCHEDULERS);
}
};
public ProfcollectForwardingService(Context context) {
super(context);
@@ -93,13 +99,23 @@ public final class ProfcollectForwardingService extends SystemService {
}
BackgroundThread.get().getThreadHandler().post(() -> {
if (serviceHasSupportedTraceProvider()) {
registerObservers();
ProfcollectBGJobService.schedule(getContext());
registerProviderStatusCallback();
}
});
}
}
private void registerProviderStatusCallback() {
if (mIProfcollect == null) {
return;
}
try {
mIProfcollect.registerProviderStatusCallback(mProviderStatusCallback);
} catch (RemoteException e) {
Log.e(LOG_TAG, e.getMessage());
}
}
private boolean serviceHasSupportedTraceProvider() {
if (mIProfcollect == null) {
return false;
@@ -141,6 +157,7 @@ public final class ProfcollectForwardingService extends SystemService {
}
public static final int MESSAGE_BINDER_CONNECT = 0;
public static final int MESSAGE_REGISTER_SCHEDULERS = 1;
@Override
public void handleMessage(android.os.Message message) {
@@ -148,6 +165,10 @@ public final class ProfcollectForwardingService extends SystemService {
case MESSAGE_BINDER_CONNECT:
connectNativeService();
break;
case MESSAGE_REGISTER_SCHEDULERS:
registerObservers();
ProfcollectBGJobService.schedule(getContext());
break;
default:
throw new AssertionError("Unknown message: " + message);
}