MTK PerfService (2) - PerfService的落地
API讲完了之后，我们来看看如何落地。我们先从java层说起。
PerfServiceWrapper
PerfServiceWrapper调用例
我们上面曾经看到过WebView中调用PerfService的例子：
sPerfService = new PerfServiceWrapper(null);
if (sPerfService != null) {
int minCPU = 2;
if (maxFreq < 1100000)
minCPU = 4;
sPerfHandle = sPerfService.userReg(minCPU, maxFreq);
if (sPerfHandle != -1) {
sPerfService.userEnableTimeoutMs(sPerfHandle, 500);
Handler handler = new Handler();
handler.postDelayed(new Runnable() {
@Override
public void run() {
sPerfService.userUnreg(sPerfHandle);
}
}, 600);
}
}我们来看看userReg是如何调用的：
public int userReg(int scn_core, int scn_freq) {
int handle = -1;
//log("[userReg] - "+scn_core+", "+scn_freq);
try {
init();
int pid = nativeGetPid();
int tid = nativeGetTid();
if (sService != null)
handle = sService.userReg(scn_core, scn_freq, pid, tid);
} catch (RemoteException e) {
loge("ERR: RemoteException in userReg:" + e);
}
//log("[userReg] - handle:"+handle);
return handle;
}再来看看init是如何做的，通过Context.MTK_PERF_SERVICE来提供服务。
private void init() {
if (inited == 0) {
IBinder b = ServiceManager.checkService(Context.MTK_PERF_SERVICE);
if (b != null) {
sService = IPerfService.Stub.asInterface(b);
if (sService != null)
inited = 1;
else
log("ERR: getService() sService is still null..");
}
}
}PerfServiceImpl
我们再看服务中是如何实现的，在/frameworks/base/services/core/java/com/mediatek/perfservice/PerfServiceImpl.java中：
public int userReg(int scn_core, int scn_freq, int pid, int tid) {
//log("userReg");
return perfServiceMgr.userReg(scn_core, scn_freq, pid, tid);
}具体的实现在PerfServiceMgr中，
public int userGetCapability(int cmd) {
return nativePerfUserGetCapability(cmd);
}PerfService的落地还是靠JNI：
static int
android_server_PerfUserScnReg(JNIEnv *env, jobject thiz,
jint scn_core, jint scn_freq, jint pid, jint tid)
{
#if defined(MTK_PERFSERVICE_SUPPORT)
if (!inited)
init();
if (perfUserScnReg) {
return perfUserScnReg(scn_core, scn_freq, pid, tid);
}
ALOGE("perfUserScnReg bypassed!");
#endif
return -1;
}com_mediatek_perfservice_PerfServiceManager.cpp
最终，终于落地在我们熟悉的Native API上了。定义于frameworks/base/services/core/jni/com_mediatek_perfservice_PerfServiceManager.cpp
#define LIB_FULL_NAME "libperfservice.so"
static void init()
{
#if defined(MTK_PERFSERVICE_SUPPORT)
void *handle, *func;
// only enter once
inited = true;
handle = dlopen(LIB_FULL_NAME, RTLD_NOW);
if (handle == NULL) {
ALOGE("Can't load library: %s", dlerror());
return;
}
...
func = dlsym(handle, "perfUserScnReg");
perfUserScnReg = reinterpret_cast<user_reg>(func);
if (perfUserScnReg == NULL) {
ALOGE("perfUserScnReg error: %s", dlerror());
perfUserScnReg = NULL;
dlclose(handle);
return;
}超时的处理
超时并不是在libperfservice.so中实现的，直接在java层就搞定了：
public void userEnableTimeout(int handle, int timeout) {
mHandler.stopCheckUserTimer(handle);
nativePerfUserScnEnable(handle);
Message msg = mHandler.obtainMessage();
msg.what = PerfServiceThreadHandler.MESSAGE_USER_ENABLE_TIMEOUT;
msg.arg1 = handle;
msg.arg2 = timeout;
msg.sendToTarget();
}
public void userEnableTimeoutMs(int handle, int timeout_ms) {
mHandler.stopCheckUserTimer(handle);
nativePerfUserScnEnable(handle);
Message msg = mHandler.obtainMessage();
msg.what = PerfServiceThreadHandler.MESSAGE_USER_ENABLE_TIMEOUT_MS;
msg.arg1 = handle;
msg.arg2 = timeout_ms;
msg.sendToTarget();
}Native API的调用方式
请注意，com_mediatek_perfservice_PerfServiceManager.cpp是调用libperfservice.so，而我们使用libperfservicenative.so.
所以我们也要做一些事情才可以调用
函数原型定义
我们先把可能用到的Native API的原型定义一下，这些函数方便后面调用。
static int (*perfUserScnReg)(int, int) = nullptr;
static int (*perfUserScnRegBigLittle)(int, int, int, int) = nullptr;
static void (*perfUserScnUnreg)(int) = nullptr;
static int (*perfUserGetCapability)(int) = nullptr;
static int (*perfUserRegScn)(void) = nullptr;
static void (*perfUserRegScnConfig)(int, int, int, int, int, int) = nullptr;
static void (*perfUserUnregScn)(int) = nullptr;
static void (*perfUserScnEnable)(int) = nullptr;
static void (*perfUserScnDisable)(int) = nullptr;
static void (*perfUserScnEnableTimeout)(int, int) = nullptr;
static void (*perfUserScnEnableTimeoutMs)(int, int) = nullptr;然后再用typedef定义一些类型吧：
typedef int (*user_reg)(int, int);
typedef int (*user_reg_big_little)(int, int, int, int);
typedef void (*user_unreg)(int);
typedef int (*user_get_capability)(int);
typedef int (*user_reg_scn)(void);
typedef void (*user_reg_scn_config)(int, int, int, int, int, int);
typedef void (*user_unreg_scn)(int);
typedef void (*user_enable)(int);
typedef void (*user_disable)(int);
typedef void (*user_enable_timeout)(int, int);
typedef void (*user_enable_timeout_ms)(int, int);引入libperfservicenative.so
#define PERF_SERVICE_NATIVE_LIB "libperfservicenative.so"
void *handle, *func;
handle = dlopen(PERF_SERVICE_NATIVE_LIB, RTLD_NOW);
if (handle == nullptr) {
ALOGE("Can't load library: %s", dlerror());
return;
}加载符号
func = dlsym(handle, "PerfServiceNative_userReg");
perfUserScnReg = reinterpret_cast<user_reg>(func);
if (perfUserScnReg == nullptr) {
ALOGE("perfUserScnReg error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userRegBigLittle");
perfUserScnRegBigLittle = reinterpret_cast<user_reg_big_little>(func);
if (perfUserScnRegBigLittle == nullptr) {
ALOGE("perfUserScnRegBigLittle error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userUnreg");
perfUserScnUnreg = reinterpret_cast<user_unreg>(func);
if (perfUserScnUnreg == nullptr) {
ALOGE("perfUserScnUnreg error: %s", dlerror());
dlclose(handle);
return;
}
...终于可以调用了
下面终于可以正式干活了：
老的API，开8个核!
int handle;
init();
handle = perfUserScnReg(4,0);
perfUserScnEnable(handle);
//Do job!
perfUserScnDisable(handle);
perfUserScnUnreg(handle);新的API：
int handle2;
handle2 = perfUserRegScn();
perfUserRegScnConfig(handle2,CMD_SET_CPU_CORE_MIN,4,0,0,0);
perfUserRegScnConfig(handle2,CMD_SET_CPU_FREQ_MIN,1469000,0,0,0);
perfUserRegScnConfig(handle2,CMD_SET_CPU_FREQ_MAX,1469000,0,0,0);
perfUserScnEnable(handle2);
//Do job!
perfUserScnDisable(handle2);
perfUserUnregScn(handle2);Native调用的完整例子
Android.mk
LOCAL_PATH := $(call my-dir)
include $(CLEAR_VARS)
LOCAL_SHARED_LIBRARIES += libdl liblog
LOCAL_C_INCLUDES += $(MTK_PATH_SOURCE)/hardware/perfservice/perfservicenative/
LOCAL_SRC_FILES := native_perf.cc
LOCAL_MODULE := nativeperf
include $(BUILD_EXECUTABLE)native_perf.cc
#include <dlfcn.h>
#include <android/log.h>
#include "PerfServiceNative.h"
#define PERF_SERVICE_NATIVE_LIB "libperfservicenative.so"
#define ALOGE(...) __android_log_print(ANDROID_LOG_ERROR,"TestPerfNative",__VA_ARGS__)
static int (*perfUserScnReg)(int, int) = nullptr;
static int (*perfUserScnRegBigLittle)(int, int, int, int) = nullptr;
static void (*perfUserScnUnreg)(int) = nullptr;
static int (*perfUserGetCapability)(int) = nullptr;
static int (*perfUserRegScn)(void) = nullptr;
static void (*perfUserRegScnConfig)(int, int, int, int, int, int) = nullptr;
static void (*perfUserUnregScn)(int) = nullptr;
static void (*perfUserScnEnable)(int) = nullptr;
static void (*perfUserScnDisable)(int) = nullptr;
static void (*perfUserScnEnableTimeout)(int, int) = nullptr;
static void (*perfUserScnEnableTimeoutMs)(int, int) = nullptr;
typedef int (*user_reg)(int, int);
typedef int (*user_reg_big_little)(int, int, int, int);
typedef void (*user_unreg)(int);
typedef int (*user_get_capability)(int);
typedef int (*user_reg_scn)(void);
typedef void (*user_reg_scn_config)(int, int, int, int, int, int);
typedef void (*user_unreg_scn)(int);
typedef void (*user_enable)(int);
typedef void (*user_disable)(int);
typedef void (*user_enable_timeout)(int, int);
typedef void (*user_enable_timeout_ms)(int, int);
static void init()
{
void *handle, *func;
handle = dlopen(PERF_SERVICE_NATIVE_LIB, RTLD_NOW);
if (handle == nullptr) {
ALOGE("Can't load library: %s", dlerror());
return;
}
func = dlsym(handle, "PerfServiceNative_userReg");
perfUserScnReg = reinterpret_cast<user_reg>(func);
if (perfUserScnReg == nullptr) {
ALOGE("perfUserScnReg error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userRegBigLittle");
perfUserScnRegBigLittle = reinterpret_cast<user_reg_big_little>(func);
if (perfUserScnRegBigLittle == nullptr) {
ALOGE("perfUserScnRegBigLittle error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userUnreg");
perfUserScnUnreg = reinterpret_cast<user_unreg>(func);
if (perfUserScnUnreg == nullptr) {
ALOGE("perfUserScnUnreg error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userGetCapability");
perfUserGetCapability = reinterpret_cast<user_get_capability>(func);
if (perfUserGetCapability == nullptr) {
ALOGE("perfUserGetCapability error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userRegScn");
perfUserRegScn = reinterpret_cast<user_reg_scn>(func);
if (perfUserRegScn == nullptr) {
ALOGE("perfUserRegScn error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userRegScnConfig");
perfUserRegScnConfig = reinterpret_cast<user_reg_scn_config>(func);
if (perfUserRegScnConfig == nullptr) {
ALOGE("perfUserRegScnConfig error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userUnregScn");
perfUserUnregScn = reinterpret_cast<user_unreg_scn>(func);
if (perfUserUnregScn == nullptr) {
ALOGE("perfUserUnregScn error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userEnable");
perfUserScnEnable = reinterpret_cast<user_enable>(func);
if (perfUserScnEnable == nullptr) {
ALOGE("perfUserScnEnable error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userDisable");
perfUserScnDisable = reinterpret_cast<user_disable>(func);
if (perfUserScnDisable == nullptr) {
ALOGE("perfUserScnDisable error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userEnableTimeout");
perfUserScnEnableTimeout = reinterpret_cast<user_enable_timeout>(func);
if (perfUserScnEnableTimeout == nullptr) {
ALOGE("perfUserScnEnableTimeout error: %s", dlerror());
dlclose(handle);
return;
}
func = dlsym(handle, "PerfServiceNative_userEnableTimeoutMs");
perfUserScnEnableTimeoutMs = reinterpret_cast<user_enable_timeout_ms>(func);
if (perfUserScnEnableTimeoutMs == nullptr) {
ALOGE("perfUserScnEnableTimeoutMs error: %s", dlerror());
dlclose(handle);
return;
}
};
int main()
{
int handle;
init();
handle = perfUserScnReg(4,0);
perfUserScnEnable(handle);
//Do job!
perfUserScnDisable(handle);
perfUserScnUnreg(handle);
int handle2;
handle2 = perfUserRegScn();
perfUserRegScnConfig(handle2,CMD_SET_CPU_CORE_MIN,4,0,0,0);
perfUserRegScnConfig(handle2,CMD_SET_CPU_FREQ_MIN,1469000,0,0,0);
perfUserRegScnConfig(handle2,CMD_SET_CPU_FREQ_MAX,1469000,0,0,0);
perfUserScnEnable(handle2);
//Do job!
perfUserScnDisable(handle2);
perfUserUnregScn(handle2);
}