近年來,國內(nèi)開源實(shí)現(xiàn)跨越式發(fā)展,并成為企業(yè)提升創(chuàng)新能力、生產(chǎn)力、協(xié)作和透明度的關(guān)鍵。作為 OpenAtom OpenHarmony(以下簡稱“OpenHarmony”)開源項(xiàng)目共建單位之一,深開鴻以成為智能物聯(lián)網(wǎng)操作系統(tǒng)領(lǐng)軍者為戰(zhàn)略目標(biāo),基于 OpenHarmony 聚焦智能物聯(lián)網(wǎng)操作系統(tǒng)(KaihongOS)的技術(shù)研發(fā)與持續(xù)創(chuàng)新。身為深開鴻 OS 內(nèi)核開發(fā)師,我們常年深耕于 OpenHarmony 的內(nèi)核開發(fā),希望通過分享一些工作上的經(jīng)驗(yàn),幫助大家掌握開源知識。OpenHarmony LiteOS-M 內(nèi)核是面向 IoT 領(lǐng)域構(gòu)建的輕量級物聯(lián)網(wǎng)操作系統(tǒng)內(nèi)核,具有小體積、低功耗、高性能的特點(diǎn),其代碼結(jié)構(gòu)簡單,實(shí)現(xiàn)了進(jìn)程、線程、內(nèi)存等管理機(jī)制,提供了常見任務(wù)間 IPC、軟定時器等公共模塊,大幅度降低了嵌入式設(shè)備開發(fā)的難度。目前 OpenHarmony 的事件提供一種任務(wù)間的 IPC,即一個或多個任務(wù)可以通過寫一個或多個不同的事件來觸發(fā)內(nèi)核調(diào)度,讓另一個等待讀取事件的任務(wù)進(jìn)入運(yùn)行狀態(tài),從而實(shí)現(xiàn)任務(wù)間的同步。對于嵌入式開發(fā)工作人員和技術(shù)愛好者來說,深入了解常見任務(wù)間 IPC,有助于學(xué)習(xí)和研發(fā)內(nèi)核。本文將從數(shù)據(jù)結(jié)構(gòu)和算法解析 OpenHarmony 的事件機(jī)制,帶大家深入了解內(nèi)核任務(wù)間 IPC 原理。
關(guān)鍵數(shù)據(jù)結(jié)構(gòu)
在解讀事件的源碼之前,首先了解下事件的關(guān)鍵的數(shù)據(jù)結(jié)構(gòu) PEVENT_CB_S:uwEventID:即標(biāo)記任務(wù)的事件類型,每個bit可以標(biāo)識一個事件,最多支持 31 個事件(第 25bit 保留)。stEventList:即事件控制塊的雙向循環(huán)鏈表,理解這個字段是理解事件的關(guān)鍵。在雙向循環(huán)鏈表中唯一不變的節(jié)點(diǎn)就是頭節(jié)點(diǎn),而這里的 stEventList 就是頭節(jié)點(diǎn)。當(dāng)有任務(wù)等待事件但事件還沒發(fā)生時,任務(wù)會被掛載到等待鏈表中;當(dāng)事件發(fā)生時,系統(tǒng)喚醒等待事件的任務(wù),此時任務(wù)就會被剔出鏈表。typedef struct tagEvent {
UINT32 uwEventID;
LOS_DL_LIST stEventList; /**< Event control block linked list */
}EVENT_CB_S,*PEVENT_CB_S;
事件初始化
下面是事件初始化源碼:LITE_OS_SEC_TEXT_INIT UINT32 LOS_EventInit(PEVENT_CB_S eventCB)
{
if (eventCB == NULL) {
return LOS_ERRNO_EVENT_PTR_NULL;
}
eventCB->uwEventID = 0;
LOS_ListInit(&eventCB->stEventList);
OsHookCall(LOS_HOOK_TYPE_EVENT_INIT, eventCB);
return LOS_OK;
}
PEVENT_CB_S 相當(dāng)于 EVENT_CB_S *, 因此 eventCB 是指針。
說明事件控制塊由任務(wù)自己創(chuàng)建,內(nèi)核事件模塊只負(fù)責(zé)維護(hù)。任務(wù)定義自己的事件控制塊變量,通過 LOS_EventInit 初始化,此時沒有事件發(fā)生,事件鏈表為空。
用圖來表達(dá)就是:
事件寫操作
任務(wù)可以通過 LOS_EventWrite 來寫觸發(fā)一個或多個事件:1處,保存事件使用的或運(yùn)算操作,因此一個或多個任務(wù)可以寫一個或多個事件,寫一次或多次,而且每次為不同的事件,多次寫同一個事件相當(dāng)于只寫了一次;2處,有事件發(fā)生了就該檢查是否有任務(wù)在等待事件,事件鏈表不為空說明有任務(wù)在等待事件;3處,遍歷事件鏈表,喚醒符合條件的任務(wù)。LOS_DL_LIST_ENTRY((&eventCB->stEventList)->pstNext,LosTaskCB,pendList) 前面提到,頭節(jié)點(diǎn)是空節(jié)點(diǎn),第一次遍歷從頭節(jié)點(diǎn)的下一個節(jié)點(diǎn)開始,后續(xù)再依次找出 nextTask,直到回到頭節(jié)點(diǎn);4處,針對事件讀取模式,找到滿足條件的任務(wù)并喚醒該任務(wù);5處,一旦匹配到等待事件的任務(wù),則執(zhí)行任務(wù)調(diào)度,被喚醒的任務(wù)得到執(zhí)行。LITE_OS_SEC_TEXT UINT32 LOS_EventWrite(PEVENT_CB_S eventCB, UINT32 events)
{
...
eventCB->uwEventID |= events; ---1
if (!LOS_ListEmpty(&eventCB->stEventList)) { ---2
for (resumedTask = LOS_DL_LIST_ENTRY((&eventCB->stEventList)->pstNext, LosTaskCB, pendList);
&resumedTask->pendList != (&eventCB->stEventList);) { -------3
nextTask = LOS_DL_LIST_ENTRY(resumedTask->pendList.pstNext, LosTaskCB, pendList);
if (((resumedTask->eventMode & LOS_WAITMODE_OR) && (resumedTask->eventMask & events) != 0) ||
((resumedTask->eventMode & LOS_WAITMODE_AND) &&
((resumedTask->eventMask & eventCB->uwEventID) == resumedTask->eventMask))) {
exitFlag = 1;
OsSchedTaskWake(resumedTask); ---4
}
resumedTask = nextTask;
}
if (exitFlag == 1) {
LOS_IntRestore(intSave);
LOS_Schedule(); ---5
return LOS_OK;
}
}
...
}
寫事件實(shí)際操作如下圖:
事件讀操作
LiteOS 為用戶提供了兩個事件的函數(shù):● LOS_EventPoll():根據(jù)任務(wù)傳入的事件值、掩碼及校驗(yàn)?zāi)J剑祷貪M足條件的事件,任務(wù)可以主動檢查事件是否發(fā)生而不必被掛起;● LOS_EventRead():讀取事件,可以理解為阻塞式讀,如果事件沒有發(fā)生,可以指定等待時間,掛起當(dāng)前任務(wù)。下面是 LOS_EventPoll() 的實(shí)現(xiàn):
1處,如果讀取模式是LOS_WAITMODE_OR,只要有一個事件發(fā)生則讀取成功,返回發(fā)生的那個事件;2處,如果讀取模式LOS_WAITMODE_AND,全部檢查事件發(fā)生才算讀取成功,并返回全部發(fā)生事件;3處,事件讀取成功后事件控制塊中的事件標(biāo)記怎么處理?這里通過LOS_WAITMODE_CLR來決定是否清除事件標(biāo)記。LITE_OS_SEC_TEXT UINT32 LOS_EventPoll(UINT32 *eventID, UINT32 eventMask, UINT32 mode)
{
UINT32 ret = 0;
UINT32 intSave;
if (eventID == NULL) {
return LOS_ERRNO_EVENT_PTR_NULL;
}
intSave = LOS_IntLock();
if (mode & LOS_WAITMODE_OR) {
if ((*eventID & eventMask) != 0) { ---1
ret = *eventID & eventMask;
}
} else {
if ((eventMask != 0) && (eventMask == (*eventID & eventMask))) { ---2
ret = *eventID & eventMask;
}
}
if (ret && (mode & LOS_WAITMODE_CLR)) { ---3
*eventID = *eventID & ~(ret);
}
LOS_IntRestore(intSave);
return ret;
}
可以看出以上實(shí)現(xiàn)了兩種事件的讀取方式:一種是多個事件只要一個發(fā)生就算發(fā)生,另一種是全部事件發(fā)生才算發(fā)生。
下面是 LOS_EventRead():
1處,主動查詢想要的事件是否已經(jīng)發(fā)生;2處,如果事件沒有發(fā)生,就把當(dāng)前任務(wù)掛起到等待事件鏈表中;3處,如果事件沒有發(fā)生,當(dāng)前讀事件的任務(wù)被掛起,讓出 CPU;4處,事件發(fā)生時等待事件的任務(wù)被調(diào)度再次獲得 CPU 恢復(fù)執(zhí)行,讀取事件。LITE_OS_SEC_TEXT UINT32 LOS_EventRead(PEVENT_CB_S eventCB, UINT32 eventMask, UINT32 mode, UINT32 timeOut)
{
...
ret = LOS_EventPoll(&(eventCB->uwEventID), eventMask, mode); ---1
OsHookCall(LOS_HOOK_TYPE_EVENT_READ, eventCB, eventMask, mode, timeOut);
if (ret == 0) {
if (timeOut == 0) {
LOS_IntRestore(intSave);
return ret;
}
if (g_losTaskLock) {
LOS_IntRestore(intSave);
return LOS_ERRNO_EVENT_READ_IN_LOCK;
}
runTsk = g_losTask.runTask;
runTsk->eventMask = eventMask;
runTsk->eventMode = mode;
OsSchedTaskWait(&eventCB->stEventList, timeOut); ---2
LOS_IntRestore(intSave);
LOS_Schedule(); ---3
intSave = LOS_IntLock();
if (runTsk->taskStatus & OS_TASK_STATUS_TIMEOUT) {
runTsk->taskStatus &= ~OS_TASK_STATUS_TIMEOUT;
LOS_IntRestore(intSave);
return LOS_ERRNO_EVENT_READ_TIMEOUT;
}
ret = LOS_EventPoll(&eventCB->uwEventID, eventMask, mode); ---4
}
...
}
事件讀寫整個過程串起來如下圖所示:
事件銷毀操作
做事有始有終,事件消費(fèi)完成剩下的事情是清除事件和等待事件的任務(wù)鏈表。在 LOS_EventClear 中通過使 eventMask=0 來清空事件,在 LOS_EventDestroy 中清空事件鏈表指針。LITE_OS_SEC_TEXT_MINOR UINT32 LOS_EventClear(PEVENT_CB_S eventCB, UINT32 eventMask)
{
...
eventCB->uwEventID &= eventMask;
...
}
LITE_OS_SEC_TEXT_INIT UINT32 LOS_EventDestroy(PEVENT_CB_S eventCB)
{
...
eventCB->stEventList.pstNext = (LOS_DL_LIST *)NULL;
eventCB->stEventList.pstPrev = (LOS_DL_LIST *)NULL;
...
}
小結(jié)
看了上面的描述,相信大家對 OpenHarmony LiteOS-M 內(nèi)核事件的運(yùn)作機(jī)制有了更加深刻的理解,開發(fā)者可以更好地使用事件的 API 來進(jìn)行任務(wù)間的同步操作,也可以進(jìn)一步嘗試修改內(nèi)核事件通知機(jī)制,做出一個更適合自己任務(wù)的IPC機(jī)制。OpenHarmony 生態(tài)建設(shè)離不開每位開發(fā)者的參與,希望有更多的開發(fā)者分享自己開源項(xiàng)目的經(jīng)驗(yàn)和成果,共同為 OpenHarmony 生態(tài)建設(shè)貢獻(xiàn)一份力量。
原文標(biāo)題:OpenHarmony——內(nèi)核對象事件之源碼詳解
文章出處:【微信公眾號:OpenAtom OpenHarmony】歡迎添加關(guān)注!文章轉(zhuǎn)載請注明出處。
-
內(nèi)核
+關(guān)注
關(guān)注
3文章
1382瀏覽量
40430 -
數(shù)據(jù)結(jié)構(gòu)
+關(guān)注
關(guān)注
3文章
573瀏覽量
40233 -
事件機(jī)制
+關(guān)注
關(guān)注
0文章
2瀏覽量
6228 -
OpenHarmony
+關(guān)注
關(guān)注
25文章
3747瀏覽量
16592
原文標(biāo)題:OpenHarmony——內(nèi)核對象事件之源碼詳解
文章出處:【微信號:gh_e4f28cfa3159,微信公眾號:OpenAtom OpenHarmony】歡迎添加關(guān)注!文章轉(zhuǎn)載請注明出處。
發(fā)布評論請先 登錄
相關(guān)推薦
數(shù)據(jù)結(jié)構(gòu)與算法分析(Java版)(pdf)
OpenHarmony——內(nèi)核IPC機(jī)制數(shù)據(jù)結(jié)構(gòu)解析
OpenHarmony——內(nèi)核IPC機(jī)制數(shù)據(jù)結(jié)構(gòu)解析
數(shù)據(jù)結(jié)構(gòu)教程,下載
![<b class='flag-5'>數(shù)據(jù)結(jié)構(gòu)</b>教程,下載](https://file.elecfans.com/web2/M00/48/A1/pYYBAGKhtBOAUJtLAAArvzW_ZHo150.jpg)
數(shù)據(jù)結(jié)構(gòu)與算法習(xí)題
數(shù)據(jù)結(jié)構(gòu)與算法
引入深度遍歷機(jī)制的分布式數(shù)據(jù)結(jié)構(gòu)插值算法
大牛分享平時如何學(xué)習(xí)數(shù)據(jù)結(jié)構(gòu)與算法
JavaScrit數(shù)據(jù)結(jié)構(gòu)與算法(第2版)
算法和數(shù)據(jù)結(jié)構(gòu)基礎(chǔ)知識分享(上)
![<b class='flag-5'>算法</b>和<b class='flag-5'>數(shù)據(jù)結(jié)構(gòu)</b>基礎(chǔ)知識分享(上)](https://file1.elecfans.com/web2/M00/81/FE/wKgZomQuft6AXARDAAd5-xFiiE4310.jpg)
算法和數(shù)據(jù)結(jié)構(gòu)基礎(chǔ)知識分享(中)
![<b class='flag-5'>算法</b>和<b class='flag-5'>數(shù)據(jù)結(jié)構(gòu)</b>基礎(chǔ)知識分享(中)](https://file1.elecfans.com/web2/M00/81/FE/wKgaomQuft6AF5WUAASBBWwYu1g184.jpg)
算法和數(shù)據(jù)結(jié)構(gòu)基礎(chǔ)知識分享(下)
![<b class='flag-5'>算法</b>和<b class='flag-5'>數(shù)據(jù)結(jié)構(gòu)</b>基礎(chǔ)知識分享(下)](https://file1.elecfans.com/web2/M00/81/FE/wKgaomQuft-AYR3bAASEHBYOkXc957.jpg)
評論