Android Binder機(jī)制學(xué)習(xí)總結(jié)(三)-ServiceManager部分
掃描二維碼
隨時(shí)隨地手機(jī)看文章
接上篇的內(nèi)容,分析下ServiceManager的實(shí)現(xiàn)。
??????? ServiceManager的實(shí)現(xiàn)位于:
??????? 4.2:/frameworks/base/cmds/servicemanager/
??????? 4.3:frameworks/native/cmds/servicemanager/
ServiceManager的啟動(dòng) ? ? ? ? ServiceManager的的啟動(dòng)由init進(jìn)程根據(jù)init.rc文件的配置執(zhí)行,從時(shí)間順序上來(lái)說(shuō),ServiceManager的啟動(dòng)優(yōu)先于Zygote進(jìn)程
service?servicemanager?/system/bin/servicemanager ????class?core????????????//core類(lèi)服務(wù) ????user?system???????????//用戶(hù)名 ????group?system??????????//用戶(hù)組 ????critical??????????????//重要service,?如果4分鐘內(nèi)crush4次以上,則重啟系統(tǒng)并進(jìn)入recovery ????onrestart?restart?zygote??????????//servicemanager重啟以后,自動(dòng)重啟zygote ????onrestart?restart?media???????????//同上 ????onrestart?restart?surfaceflinger??//同上 ????onrestart?restart?drm?????????????//同上
? ? ? ? ServiceManager是一個(gè)可執(zhí)行文件,所以,我們從main函數(shù)看起(frameworks/base/cmds/servicemanager/servicemanager.c):
int?main(int?argc,?char?**argv) { ????struct?binder_state?*bs; ????void?*svcmgr?=?BINDER_SERVICE_MANAGER; ????bs?=?binder_open(128*1024); ????if?(binder_become_context_manager(bs))?{ ????????ALOGE("cannot?become?context?manager?(%s)n",?strerror(errno)); ????????return?-1; ????} ????svcmgr_handle?=?svcmgr; ????binder_loop(bs,?svcmgr_handler);//svcmgr_handle為具體的請(qǐng)求處理邏輯 ????return?0; }
? ? ? ? 簡(jiǎn)單來(lái)說(shuō),ServiceManager的啟動(dòng)分為三個(gè)步驟: 打開(kāi)dev/binder,并創(chuàng)建binder緩沖區(qū)注冊(cè)當(dāng)前進(jìn)程為上下文管理者(ServiceManager)進(jìn)入處理循環(huán),等待Service/Client的請(qǐng)求 步驟一 ? ? ? ? 步驟一,由binder_open函數(shù)實(shí)現(xiàn)(frameworks/base/cmds/servicemanager/binder.c):
struct?binder_state?*binder_open(unsigned?mapsize) { ????struct?binder_state?*bs; ????bs?=?malloc(sizeof(*bs)); ????if?(!bs)?{ ????????errno?=?ENOMEM; ????????return?0; ????} ????bs->fd?=?open("/dev/binder",?O_RDWR);//上一節(jié)講過(guò),這里會(huì)轉(zhuǎn)入內(nèi)核態(tài),執(zhí)行binder_open,創(chuàng)建binder_proc ????if?(bs->fd?<?0)?{ ????????fprintf(stderr,"binder:?cannot?open?device?(%s)n", ????????????????strerror(errno)); ????????goto?fail_open; ????} ????bs->mapsize?=?mapsize;//mapsize?=?128KB ????bs->mapped?=?mmap(NULL,?mapsize,?PROT_READ,?MAP_PRIVATE,?bs->fd,?0);//上一節(jié)講過(guò),這里會(huì)轉(zhuǎn)入內(nèi)核態(tài),執(zhí)行binder_mmap ????????????????????????????????????????????????????????????????????????//在內(nèi)核態(tài)創(chuàng)建相同size的緩沖區(qū),并分配第一個(gè)物理頁(yè)面,計(jì)算內(nèi)核緩沖區(qū)地址和用戶(hù)緩沖區(qū)地址的偏移量 ????if?(bs->mapped?==?MAP_FAILED)?{ ????????fprintf(stderr,"binder:?cannot?map?device?(%s)n", ????????????????strerror(errno)); ????????goto?fail_map; ????} ????????/*?TODO:?check?version?*/ ????return?bs; fail_map: ????close(bs->fd); fail_open: ????free(bs); ????return?0; }
? ? ? ? 如果上一節(jié)binder driver部分的內(nèi)容有比較好的理解的話,這邊的代碼應(yīng)該比較好理解的,順便看看binder_state的實(shí)現(xiàn):
struct?binder_state { ????int?fd; ????void?*mapped; ????unsigned?mapsize; };
步驟二 ? ? ? ? 步驟二,由binder_become_context_manager函數(shù)實(shí)現(xiàn):
int?binder_become_context_manager(struct?binder_state?*bs) { ????return?ioctl(bs->fd,?BINDER_SET_CONTEXT_MGR,?0); }
? ? ? ? 灰常簡(jiǎn)單的實(shí)現(xiàn),有木有? 讓我們來(lái)回憶一下,上一節(jié)的內(nèi)容,ioctl的調(diào)用會(huì)轉(zhuǎn)入到binder driver的binder_ioctl函數(shù)來(lái)處理BINDER_SET_CONTEXT_MGR:
????????case?BINDER_SET_CONTEXT_MGR: if?(binder_context_mgr_node?!=?NULL)?{ printk(KERN_ERR?"binder:?BINDER_SET_CONTEXT_MGR?already?setn"); ret?=?-EBUSY; goto?err; } ret?=?security_binder_set_context_mgr(proc->tsk); if?(ret?<?0) goto?err; if?(binder_context_mgr_uid?!=?-1)?{ if?(binder_context_mgr_uid?!=?current->cred->euid)?{ printk(KERN_ERR?"binder:?BINDER_SET_" ???????"CONTEXT_MGR?bad?uid?%d?!=?%dn", ???????current->cred->euid, ???????binder_context_mgr_uid); ret?=?-EPERM; goto?err; } }?else binder_context_mgr_uid?=?current->cred->euid; binder_context_mgr_node?=?binder_new_node(proc,?NULL,?NULL);//binder_context_mgr_node->proc?=?servicemanager if?(binder_context_mgr_node?==?NULL)?{ ret?=?-ENOMEM; goto?err; } binder_context_mgr_node->local_weak_refs++; binder_context_mgr_node->local_strong_refs++; binder_context_mgr_node->has_strong_ref?=?1; binder_context_mgr_node->has_weak_ref?=?1; break;
? ? ? ? 忽略安全檢查等代碼,上面的代碼就是設(shè)定了全局變量binder_context_mgr_node,并增加引用計(jì)數(shù)。 步驟三 ? ? ? ? 處理循環(huán)的實(shí)現(xiàn)在binder_loop函數(shù)中:
void?binder_loop(struct?binder_state?*bs,?binder_handler?func) { ????int?res; ????struct?binder_write_read?bwr; ????unsigned?readbuf[32]; ????bwr.write_size?=?0; ????bwr.write_consumed?=?0; ????bwr.write_buffer?=?0; ???? ????readbuf[0]?=?BC_ENTER_LOOPER; ????binder_write(bs,?readbuf,?sizeof(unsigned));//binder?driver會(huì)通過(guò)binder_thread_write函數(shù)處理BC_ENTER_LOOPER指令 ????for?(;;)?{ ????????bwr.read_size?=?sizeof(readbuf); ????????bwr.read_consumed?=?0; ????????bwr.read_buffer?=?(unsigned)?readbuf; ????????res?=?ioctl(bs->fd,?BINDER_WRITE_READ,?&bwr);//讀取client/service的請(qǐng)求 ????????if?(res?<?0)?{ ????????????ALOGE("binder_loop:?ioctl?failed?(%s)n",?strerror(errno)); ????????????break; ????????} ????????res?=?binder_parse(bs,?0,?readbuf,?bwr.read_consumed,?func);//處理請(qǐng)求 ????????if?(res?==?0)?{ ????????????ALOGE("binder_loop:?unexpected?reply?!n"); ????????????break; ????????} ????????if?(res?<?0)?{ ????????????ALOGE("binder_loop:?io?error?%d?%sn",?res,?strerror(errno)); ????????????break; ????????} ????} }
ServiceManager客戶(hù)端代理 ? ? ? ? ServiceManager運(yùn)行在自己的進(jìn)程中,為了向Client/Service進(jìn)程提供服務(wù),ServiceManager為自己準(zhǔn)備了客戶(hù)端代理,方便Client/Service調(diào)用。 IServiceManager和BpServiceManager ? ? ? ? IServiceManager是ServiceManager在native層的接口(framework/native/include/binder/IServiceManager.h):
class?IServiceManager?:?public?IInterface { public: ????DECLARE_META_INTERFACE(ServiceManager); ????/** ?????*?Retrieve?an?existing?service,?blocking?for?a?few?seconds ?????*?if?it?doesn't?yet?exist. ?????*/ ????virtual?spgetService(?const?String16&?name)?const?=?0; ????/** ?????*?Retrieve?an?existing?service,?non-blocking. ?????*/ ????virtual?spcheckService(?const?String16&?name)?const?=?0; ????/** ?????*?Register?a?service. ?????*/ ????virtual?status_t????????????addService(?const?String16&?name, ????????????????????????????????????????????const?sp&?service, ????????????????????????????????????????????bool?allowIsolated?=?false)?=?0; ????/** ?????*?Return?list?of?all?existing?services. ?????*/ ????virtual?VectorlistServices()?=?0; ????enum?{ ????????GET_SERVICE_TRANSACTION?=?IBinder::FIRST_CALL_TRANSACTION, ????????CHECK_SERVICE_TRANSACTION, ????????ADD_SERVICE_TRANSACTION, ????????LIST_SERVICES_TRANSACTION, ????}; };
? ? ? ? 從接口中,我們看到SeviceManager提供了4個(gè)功能: getService,同checkServicecheckService,供Client獲取Service的binderaddService, 供Service注冊(cè)binderlistService,用于枚舉所有已經(jīng)注冊(cè)的binder ? ? ? ? 而B(niǎo)pServiceManager是IServiceManager的一個(gè)子類(lèi),提供了IServiceManager的實(shí)現(xiàn)(frameworks/native/libs/binder/IServiceManager.cpp):
class?BpServiceManager?:?public?BpInterface{ public: ????BpServiceManager(const?sp&?impl) ????????:?BpInterface(impl) ????{ ????} ????virtual?spgetService(const?String16&?name)?const ????{ ??????????......?//實(shí)現(xiàn)啥的,我們后面再看 ????} ????virtual?spcheckService(?const?String16&?name)?const ????{ ??????????...... ????} ????virtual?status_t?addService(const?String16&?name,?const?sp&?service, ????????????bool?allowIsolated) ????{ ??????????...... ????} ????virtual?VectorlistServices() ????{ ??????????...... ????} };
? ? ? ? 前綴Bp可以理解為Binder Proxy,即BpServiceManager實(shí)際上是ServiceManager在客戶(hù)進(jìn)程中的一個(gè)代理,所以BpServiceManager并不負(fù)責(zé)實(shí)現(xiàn)真正的功能,而是通過(guò)Binder通信發(fā)送請(qǐng)求到前面啟動(dòng)的ServiceManager進(jìn)程。上一節(jié)中我們講到過(guò),Binder通信的前提是客戶(hù)端進(jìn)程需要有BpBinder,那么BpBinder從何而來(lái)呢? defaultServiceManager ? ? ? ? 作為一個(gè)特殊的“Service”,Android系統(tǒng)為ServiceManager準(zhǔn)備了“快捷方式”,這個(gè)快捷方式就是defaultServiceManager(frameworks/native/libs/binder/IServiceManager.cpp):
spdefaultServiceManager() { ????if?(gDefaultServiceManager?!=?NULL)?return?gDefaultServiceManager;//單例模式 ???? ????{ ????????AutoMutex?_l(gDefaultServiceManagerLock); ????????if?(gDefaultServiceManager?==?NULL)?{ ????????????gDefaultServiceManager?=?interface_cast( ????????????????ProcessState::self()->getContextObject(NULL)); ????????} ????} ???? ????return?gDefaultServiceManager; }
? ? ? ? 這里可以把defaultServiceManager分解為三個(gè)步驟: ProcessState::self()ProcessState->getContextObject(NULL)interface_cast