linux內(nèi)核completion實(shí)現(xiàn)分析

《linux內(nèi)核completion實(shí)現(xiàn)分析》由會(huì)員上傳分享，免費(fèi)在線閱讀，更多相關(guān)內(nèi)容在行業(yè)資料-天天文庫。

1、Linux內(nèi)核completion實(shí)現(xiàn)分析completion結(jié)構(gòu)及初始化#define__WAITQUEUE_INITIALIZER(name,tsk){.private=tsk,.func=default_wake_function,.task_list={NULL,NULL}}#defineDECLARE_WAITQUEUE(name,tsk)wait_queue_tname=__WAITQUEUE_INITIALIZER(name,tsk)struct__wait_queue{unsignedintflags;#defineWQ_FLAG_EXCLUSIVE0x01vo

2、id*private;wait_queue_func_tfunc;structlist_headtask_list;};structcompletion{unsignedintdone;wait_queue_head_twait;};靜態(tài)初始化直接使用DECLARE_COMPLETION#defineDECLARE_COMPLETION(work)structcompletionwork=COMPLETION_INITIALIZER(work)#defineCOMPLETION_INITIALIZER(work){0,__WAIT_QUEUE_HEAD_INITIALIZER((w

3、ork).wait)}staticinlinevoidinit_completion(structcompletion*x){x->done=0;init_waitqueue_head(&x->wait);}#defineINIT_COMPLETION(x)((x).done=0)動(dòng)態(tài)創(chuàng)建structcompletionmy_completion;init_completion(&my_completion);completion實(shí)現(xiàn)分析completion實(shí)現(xiàn)主要依靠spinlock、系統(tǒng)調(diào)度schedule、wait_queue，還有一個(gè)標(biāo)志位done。一個(gè)completion通常

4、是一個(gè)單次設(shè)備，也就是說，他在使用一次后會(huì)被丟棄。但是如果仔細(xì)處理也可以被重復(fù)使用。如果沒有使用completion_all，則我們可以重復(fù)使用一個(gè)completion結(jié)構(gòu)，只要那個(gè)將要觸發(fā)的事件是明確而不含糊的，就不會(huì)有問題。但是如果使用了completion_all，則必須在重復(fù)使用前重新初始化，可以使用宏INIT_COMPLETION完成，此宏把done置零。因?yàn)樵赾ompletion_all中done被賦值成UINT_MAX/2，所有在喚醒所有進(jìn)程后done也不太可能變成0，為方便下次使用，必須重新初始化。Completion常用函數(shù)：voidfastcall__schedwa

5、it_for_completion(structcompletion*x);unsignedlongfastcall__schedwait_for_completion_timeout(structcompletion*x,unsignedlongtimeout);voidfastcallcomplete(structcompletion*x);voidfastcallcomplete_all(structcompletion*x);completion例子：#include#include#include

6、nel.h>/*printk*/#include/*currentandeverything*/#include/*forcompletion*/#include/*forchardev*/staticintcompletion_major=0;ssize_tcompletion_read(structfile*filp,char__user*buf,size_tcount,loff_t*pos);ssize_tcompletion_write(structfile*filp,char__us

7、er*buf,size_tcount,loff_t*pos);DECLARE_COMPLETION(my_completion);ssize_tcompletion_read(structfile*filp,char__user*buf,size_tcount,loff_t*pos){printk(KERN_ALERT"%s,process%i(%s)goingtosleep",__FUNCTION__,current->pid,curre