《鴻蒙智能互聯(lián)設(shè)備開發(fā)（微課版）》 課件 6.3.2 驅(qū)動(dòng)消息機(jī)制開發(fā)

6.3.2驅(qū)動(dòng)消息機(jī)制開發(fā)通過本節(jié)學(xué)習(xí)，您可以：了解驅(qū)動(dòng)消息機(jī)制開發(fā)驅(qū)動(dòng)消息機(jī)制開發(fā)驅(qū)動(dòng)消息機(jī)制的開發(fā)步驟：1.修改服務(wù)策略policy字段將驅(qū)動(dòng)配置信息中服務(wù)策略policy字段設(shè)置為2。

device_test::Device{

policy=2;

...

}2.配置驅(qū)動(dòng)信息中的服務(wù)設(shè)備節(jié)點(diǎn)權(quán)限配置驅(qū)動(dòng)信息中的服務(wù)設(shè)備節(jié)點(diǎn)權(quán)限（permission字段）是框架給驅(qū)動(dòng)創(chuàng)建設(shè)備節(jié)點(diǎn)的權(quán)限，默認(rèn)是0666，驅(qū)動(dòng)開發(fā)者根據(jù)驅(qū)動(dòng)的實(shí)際使用場(chǎng)景配置驅(qū)動(dòng)設(shè)備節(jié)點(diǎn)的權(quán)限。驅(qū)動(dòng)消息機(jī)制開發(fā)3.實(shí)現(xiàn)Dispatch方法在服務(wù)實(shí)現(xiàn)過程中，實(shí)現(xiàn)服務(wù)基類成員IDeviceIoService中的Dispatch方法。

//Dispatch是用來處理用戶態(tài)發(fā)下來的消息

int32_tTestDriverDispatch(structHdfDeviceIoClient*device,intcmdCode,structHdfSBuf*data,structHdfSBuf*reply){

HDF_LOGE("testdriverliteAdispatch");

returnHDF_SUCCESS;

}

int32_tTestDriverBind(structHdfDeviceObject*device){

HDF_LOGE("testforliteostestdriverAOpen!");

if(device==NULL){

HDF_LOGE("testforliteostestdriverAOpenfailed!");

returnHDF_FAILURE;

}

static

structITestDriverServicetestDriverA={

.ioService.Dispatch=TestDriverDispatch,

.ServiceA=TestDriverServiceA,

.ServiceB=TestDriverServiceB,

};

device->service=(structIDeviceIoService*)(&testDriverA);

returnHDF_SUCCESS;}驅(qū)動(dòng)消息機(jī)制開發(fā)4.定義cmd類型驅(qū)動(dòng)定義消息處理函數(shù)中的cmd類型。5.獲取服務(wù)接口并發(fā)送消息用戶態(tài)獲取服務(wù)接口并發(fā)送消息到驅(qū)動(dòng)。#defineTEST_WRITE_READ1//讀寫操作碼1

intSendMsg(const

char*testMsg)

{

if(testMsg==NULL){

HDF_LOGE("testmsgisnull");

returnHDF_FAILURE;

}

structHdfIoService*serv=HdfIoServiceBind("test_driver");

if(serv==NULL){

HDF_LOGE("failtogetservice");

returnHDF_FAILURE;}驅(qū)動(dòng)消息機(jī)制開發(fā)

structHdfSBuf*data=HdfSBufObtainDefaultSize();

if(data==NULL){HDF_LOGE("failtoobtainsbufdata");

returnHDF_FAILURE;

}

structHdfSBuf*reply=HdfSBufObtainDefaultSize();

if(reply==NULL){HDF_LOGE("failtoobtainsbufreply");

ret=HDF_DEV_ERR_NO_MEMORY;

gotoout;

}

if(!HdfSbufWriteString(data,testMsg)){HDF_LOGE("failtowritesbuf");

ret=HDF_FAILURE;

gotoout;

}

intret=serv->dispatcher->Dispatch(&serv->object,TEST_WRITE_READ,data,reply);

if(ret!=HDF_SUCCESS){HDF_LOGE("failtosendservicecall");

gotoout;

}

out:

HdfSBufRecycle(data);

HdfSBufRecycle(reply);

HdfIoServiceRecycle(serv);

returnret;}驅(qū)動(dòng)消息機(jī)制開發(fā)6.用戶態(tài)接收驅(qū)動(dòng)上報(bào)的消息用戶態(tài)編寫驅(qū)動(dòng)上報(bào)消息的處理函數(shù)。

static

intOnDevEventReceived(void*priv,uint32_tid,structHdfSBuf*data)

{

OsalTimespectime;

OsalGetTime(&time);

HDF_LOGE("%sreceivedeventat%llu.%llu",(char*)priv,time.sec,time.usec);

const

char*string=HdfSbufReadString(data);

if(string==NULL){

HDF_LOGE("failtoreadstringineventdata");

returnHDF_FAILURE;

}

HDF_LOGE("%s:deveventreceived:%d%s",(char*)priv,id,string);

returnHDF_SUCCESS;}驅(qū)動(dòng)消息機(jī)制開發(fā)用戶態(tài)注冊(cè)接收驅(qū)動(dòng)上報(bào)消息的操作方法。

intRegisterListen()

{

structHdfIoService*serv=HdfIoServiceBind("test_driver");

if(serv==NULL){

HDF_LOGE("failtogetservice");

returnHDF_FAILURE;

}

static

structHdfDevEventlistenerlistener={

.callBack=OnDevEventReceived,

.priv="Service0"

};

if(HdfDeviceRegisterEventListener(serv,&listener)!=0){

HDF_LOGE("failtoregistereventlistener");

returnHDF_FAILURE;

}

......

HdfDeviceUnregisterEventListener(serv,&listener);

HdfIoServiceRecycle(serv);

returnHDF_SUCCESS;

}驅(qū)動(dòng)消息機(jī)制開發(fā)驅(qū)動(dòng)上報(bào)事件。

int32_tTestDriverDispatch(structHdf