defaultServiceManager()調(diào)用addService添加服務(wù)的執(zhí)行流程:---------------------------------------
1缭保、
defaultServiceManager()->addService(
String16("media.player"), newMediaPlayerService());
因?yàn)閐efaultServiceManager()返回ServiceManager的代理BpServiceManager饭玲,所以這里調(diào)用BpServiceManager的addService函數(shù)。
2秩霍、addService函數(shù)中分析
將調(diào)用,
status_t err =
remote()->transact(ADD_SERVICE_TRANSACTION, data, &reply);
因?yàn)閞emote()函數(shù)是BpServiceManager基類BpRefBase的函數(shù)蚁阳,它返回mRemote铃绒,這個(gè)值我們知道保存了一個(gè)BpBinder對(duì)象,所以將調(diào)用BpBinder的transact函數(shù)螺捐。
3匿垄、在BpBinder::transact函數(shù)中
status_t BpBinder::transact(
uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags)
有如下實(shí)現(xiàn),
status_t status = IPCThreadState::self()->transact(
mHandle, code, data, reply, flags);
因此它又將調(diào)用IPCThreadState的transact函數(shù)归粉。
4椿疗、在IPCThreadState的transact函數(shù)中,
status_t IPCThreadState::transact(int32_t
handle,
uint32_tcode, const Parcel& data,
Parcel*reply, uint32_t flags)
將先掉用
err = writeTransactionData(BC_TRANSACTION, flags, handle, code, data,NULL);
發(fā)送數(shù)據(jù)糠悼,然后使用届榄,
err = waitForResponse(reply);
等待處理的結(jié)果,最后將處理結(jié)果err和reply分別通過返回值和參數(shù)返回倔喂。
5铝条、在函數(shù)IPCThreadState::writeTransactionData中,將數(shù)據(jù)封裝到mOut變量中席噩。
6班缰、在函數(shù)IPCThreadState::waitForResponse中,
起一個(gè)循環(huán)悼枢,首先調(diào)用talkWithDriver將mOut寫給低層Binder,然后通過mIn將結(jié)果傳出埠忘。
其次使用switch判斷傳出的消息,最后執(zhí)行IPCThreadState::executeCommand對(duì)各種消息進(jìn)行處理。
7莹妒、函數(shù)IPCThreadState::executeCommand名船,注意其中的幾個(gè)消息的處理,
case BR_TRANSACTION:處理中
if (tr.target.ptr) {
spb((BBinder*)tr.cookie);
const status_t error =b->transact(tr.code, buffer, &reply, tr.flags);
if (error < NO_ERROR)reply.setError(error);
}
調(diào)用了BBinder對(duì)象b旨怠,這個(gè)對(duì)象就是BnServiceManager中的那個(gè)渠驼。
case BR_DEAD_BINDER:
{
BpBinder *proxy = (BpBinder*)mIn.readInt32();
proxy->sendObituary();
mOut.writeInt32(BC_DEAD_BINDER_DONE);
mOut.writeInt32((int32_t)proxy);
} break;
收到Binder發(fā)來Service死掉的消息,由BpBinder進(jìn)行處理鉴腻。
case BR_SPAWN_LOOPER:
mProcess->spawnPooledThread(false);
break;
收到驅(qū)動(dòng)的指示迷扇,創(chuàng)建一個(gè)新線程,用于和Binder通信爽哎。
8蜓席、函數(shù)IPCThreadState::talkWithDriver
通過ioctl和Binder驅(qū)動(dòng)進(jìn)行消息傳遞。
if (ioctl(mProcess->mDriverFD,
BINDER_WRITE_READ, &bwr) >= 0)
err = NO_ERROR;
else
err = -errno;
9倦青、
使用函數(shù)ProcessState::startThreadPool在進(jìn)程中開一個(gè)線程。
void ProcessState::startThreadPool()
{
AutoMutex _l(mLock);
if (!mThreadPoolStarted) {
mThreadPoolStarted = true;
spawnPooledThread(true);
}
}
調(diào)用spawnPooledThread(true)創(chuàng)建一個(gè)線程盹舞。注意产镐,isMain是true.
線程的名稱用
int32_t s = android_atomic_add(1, &mThreadPoolSeq);
char buf[32];
sprintf(buf, "Binder Thread #%d", s);
指定。
可以看出踢步,和Binder相關(guān)的線程都是有ProcessState啟動(dòng)的癣亚,而每個(gè)進(jìn)程和Binder通訊時(shí),只有一個(gè)ProcessState获印,但可能會(huì)有多個(gè)Binder Thread述雾。
10、使用函數(shù)IPCThreadState::self()->joinThreadPool()將創(chuàng)建的線程添加到線程池兼丰。
在其內(nèi)部調(diào)用
mOut.writeInt32(isMain ? BC_ENTER_LOOPER : BC_REGISTER_LOOPER);
其實(shí)也是啟動(dòng)一個(gè)線程玻孟。
11、以上都是由代理BpServiceManager傳遞的鳍征,BnServiceManager并未顯示創(chuàng)建黍翎,但肯定是有的。有個(gè)和它一樣的功能由系統(tǒng)創(chuàng)建艳丛,在文件service_manager.c的main中進(jìn)行了創(chuàng)建匣掸,它直接和Binder打交道。
12氮双、
MediaPlayerService的Client端實(shí)現(xiàn)碰酝。
通過函數(shù)IMediaDeathNotifier::getMediaPlayerService()獲得MediaPlayerService的BpMediaPlayerService。
首先通過binder =
sm->getService(String16("media.player"));得到系統(tǒng)的BpBinder,然后利用
sMediaPlayerService =
interface_cast(binder);
生成系統(tǒng)的BpMediaPlayerService戴差,得到服務(wù)的代理送爸。
mso-h????-