skynet源码阅读系列03skynetcontextnew

　　上一节看了skynetstart（）的一部分代码，那部分代码主要做了下面几件事。如果当前进程收到SIGHUP信号，则调用handlehup函数，将SIG设为1检查配置文件内的deamon配置，这个配置对应一个文件路径，文件内的记录进程的pid号，防止重复启动skynet进程，第一次启动将自动将进程号写入文件。重定向了文件描述符，把文件描述符0，1，2重定向到了devnull，相当于当前进程忽略了标准输入，标准输出，标准错误。初始化了HARBOR的值，HARBOR的值为配置文件内harbor配置的值左移24位。初始化了一个handlestorage结构体，结构体内包含一个harbor成员，其中限定了harbor最高为0xff，也就是（28）1，所以harbor的取值在1255之间，之后再左移24位，和HARBOR保持一致。初始化了一个全局消息队列，全局消息队列里的每一个元素都是一个子消息队列，其中子消息队列的元素内包含具体的消息。初始化了一个modules结构体M，结构体内包含一个path成员，保存着配置文件内的cpath配置，一个skynetmodule类型的数组m，数组长度为32。初始化了定时器模块，暂时不细节功能实现，但是我们知道模块里定时器的时间单位是1100秒。初始化了socket模块，暂时不细节，不影响我们捋顺框架。把配置文件的profile配置保存在GNODE中。
　　以上就是skynetstart（）前半段代码做的一些事了。
　　今天的内容主要梳理了一下skynetcontextnew这个函数都做了什么。
　　接着skynetstart（）的内容看：structskynetcontextctxskynetcontextnew（configlogservice，configlogger）；if（ctxNULL）｛fprintf（stderr，Cantlaunchsservice，configlogservice）；exit（1）；｝
　　可以看到，这段代码无非是尝试去创建一个skynetcontext结构体。
　　如果创建失败了，整个进程就退出了。
　　下面我们看看skynetcontextnew（）函数。structskynetcontextskynetcontextnew（constcharname，constcharparam）｛structskynetmodulemodskynetmodulequery（name）；if（modNULL）returnNULL；voidinstskynetmoduleinstancecreate（mod）；if（instNULL）returnNULL；structskynetcontextctxskynetmalloc（sizeof（ctx））；CHECKCALLINGINIT（ctx）ctxmodmod；ctxinstanceinst；ATOMINIT（ctxref，2）；ctxcbNULL；ctxcbudNULL；ctxsessionid0；ATOMINIT（ctxlogfile，（uintptrt）NULL）；ctxinitfalse；ctxendlessfalse；ctxcpucost0；ctxcpustart0；ctxmessagecount0；ctxprofileGNODE。profile；Shouldsetto0firsttoavoidskynethandleretireallgetanuninitializedhandlectxhandle0；ctxhandleskynethandleregister（ctx）；structmessagequeuequeuectxqueueskynetmqcreate（ctxhandle）；initfunctionmaybeusectxhandle，soitmustinitatlastcontextinc（）；CHECKCALLINGBEGIN（ctx）intrskynetmoduleinstanceinit（mod，inst，ctx，param）；CHECKCALLINGEND（ctx）if（r0）｛structskynetcontextretskynetcontextrelease（ctx）；if（ret）｛ctxinittrue；｝skynetglobalmqpush（queue）；if（ret）｛skyneterror（ret，LAUNCHss，name，param？param：）；｝returnret；｝else｛skyneterror（ctx，FAILEDlaunchs，name）；uint32thandlectxhandle；skynetcontextrelease（ctx）；skynethandleretire（handle）；structdroptd｛handle｝；skynetmqrelease（queue，dropmessage，d）；returnNULL；｝｝
　　好长
　　不急，我们一点点看。structskynetmodulemodskynetmodulequery（name）；if（modNULL）returnNULL；
　　查询name表示的模块，如果没查到，就returnNULLstructskynetmoduleskynetmodulequery（constcharname）｛structskynetmoduleresultquery（name）；if（result）returnresult；SPINLOCK（M）resultquery（name）；doublecheckif（resultNULLMcountMAXMODULETYPE）｛intindexMcount；voiddltryopen（M，name）；if（dl）｛Mm〔index〕。namename；Mm〔index〕。moduledl；if（opensym（Mm〔index〕）0）｛Mm〔index〕。nameskynetstrdup（name）；Mcount；resultMm〔index〕；｝｝｝SPINUNLOCK（M）returnresult；｝
　　skynetmodulequery：调用query（）查找，查到了直接返回。staticstructskynetmodulequery（constcharname）｛inti；for（i0；iMcount；i）｛if（strcmp（Mm〔i〕。name，name）0）｛returnMm〔i〕；｝｝returnNULL；｝
　　从之前初始化好的modulesM结构体内的数组中查找，如果在数组内返回。
　　如果不在数组内，skynetmodulequery（）将尝试打开name文件。staticvoidtryopen（structmodulesm，constcharname）｛constcharl；constcharpathmpath；sizetpathsizestrlen（path）；sizetnamesizestrlen（name）；intszpathsizenamesize；searchpathvoiddlNULL；chartmp〔sz〕；do｛memset（tmp，0，sz）；while（path；）path；if（path）break；lstrchr（path，；）；if（lNULL）lpathstrlen（path）；intlenlpath；inti；for（i0；path〔i〕！？ilen；i）｛tmp〔i〕path〔i〕；｝memcpy（tmpi，name，namesize）；if（path〔i〕？）｛strncpy（tmpinamesize，pathi1，leni1）；｝else｛fprintf（stderr，InvalidCservicepath）；exit（1）；｝dldlopen（tmp，RTLDNOWRTLDGLOBAL）；pathl；｝while（dlNULL）；if（dlNULL）｛fprintf（stderr，tryopensfailed：s，name，dlerror（））；｝returndl；｝
　　我们可以看到tryopen（）函数一直从path（对应配置文件的cpath）中的路径进行尝试，并将？替换为name，也就是传入的文件名，尝试打开文件，如果dl不为NULL，则说明找到了该文件，跳出循环之后还没找到则不在cpath里。
　　不能理解上面的话可以看这里：
　　一般我们在配置文件配填cpath的配置是这样的root。cpathroot。。cservice？。so；。。root。。xxx？。so
　　这段config的lua代码会在main函数内被执行一次，所以cpath的值将变成。cservice？。so；。xxx？。so，假如我们的namelog
　　tryopen（）就是把cpath里的？替换成log，再以；为分隔符分割，得到。cservicelog。so，。xxxlog。so。
　　然后再传入dlopen（），尝试打开动态链接库。intindexMcount；voiddltryopen（M，name）；if（dl）｛Mm〔index〕。namename；Mm〔index〕。moduledl；if（opensym（Mm〔index〕）0）｛Mm〔index〕。nameskynetstrdup（name）；Mcount；resultMm〔index〕；｝｝
　　我们再回到skynetmodulequery（），正常打开之后把相关的信息保存在modulesM，Mm，skynetmodule类型的数组里。structskynetmodule｛constcharname；voidmodule；skynetdlcreatecreate；skynetdlinitinit；skynetdlreleaserelease；skynetdlsignalsignal；｝；name：文件名module：dlopen打开的链接库句柄create：name文件内的｛s｝create，name函数指针。init：name文件内的｛s｝init，name函数指针。release：name文件内的｛s｝release，name函数指针。signal：name文件内的｛s｝signal，name函数指针。
　　所以我们写C服务时应包含create，init，release，signal四个函数，这四个函数的函数名应加上文件名作为前缀。
　　小结一下就是skynetmodulequery（）函数会从M中查找对应的skynetmodule结构体对象，如果找到了直接返回，没找到就从配置文件里cpath路径找对应的文件，如果找到了加载到内存中，并保存到M里，下次就不用重复打开了，返回对象。
　　画了个简单的图可以参考下：
　　下面我们继续回到skynetcontextnew（）里。voidinstskynetmoduleinstancecreate（mod）；if（instNULL）returnNULL；voidskynetmoduleinstancecreate（structskynetmodulem）｛if（mcreate）｛returnmcreate（）；｝else｛return（void）（intptrt）（0）；｝｝
　　返回这个c模块里相应的create函数返回值，否则返回（void）（intptrt）（0）。structskynetcontextctxskynetmalloc（sizeof（ctx））；CHECKCALLINGINIT（ctx）structskynetcontext｛voidinstance；structskynetmodulemod；voidcbud；skynetcbcb；structmessagequeuequeue；ATOMPOINTERlogfile；uint64tcpucost；inmicrosecuint64tcpustart；inmicroseccharresult〔32〕；uint32thandle；intsessionid；ATOMINTref；intmessagecount；boolinit；boolendless；boolprofile；CHECKCALLINGDECL｝；defineCHECKCALLINGINIT（ctx）
　　创建了一个skynetcontext结构体ctx。ctxmodmod；ctxinstanceinst；ATOMINIT（ctxref，2）；ctxcbNULL；ctxcbudNULL；ctxsessionid0；ATOMINIT（ctxlogfile，（uintptrt）NULL）；ctxinitfalse；ctxendlessfalse；ctxcpucost0；ctxcpustart0；ctxmessagecount0；ctxprofileGNODE。profile；
　　初始化了一些信息。Shouldsetto0firsttoavoidskynethandleretireallgetanuninitializedhandlectxhandle0；ctxhandleskynethandleregister（ctx）；uint32tskynethandleregister（structskynetcontextctx）｛structhandlestoragesH；rwlockwlock（slock）；for（；；）｛inti；uint32thandleshandleindex；for（i0；isslotsize；i，handle）｛if（handleHANDLEMASK）｛0isreservedhandle1；｝inthashhandle（sslotsize1）；if（sslot〔hash〕NULL）｛sslot〔hash〕ctx；shandleindexhandle1；rwlockwunlock（slock）；handlesharbor；returnhandle；｝｝assert（（sslotsize21）HANDLEMASK）；structskynetcontextnewslotskynetmalloc（sslotsize2sizeof（structskynetcontext））；memset（newslot，0，sslotsize2sizeof（structskynetcontext））；for（i0；isslotsize；i）｛inthashskynetcontexthandle（sslot〔i〕）（sslotsize21）；assert（newslot〔hash〕NULL）；newslot〔hash〕sslot〔i〕；｝skynetfree（sslot）；sslotnewslot；sslotsize2；｝｝
　　之前在skynethandle。c中声明过一个handlestorageH，其中包括harbor，现在用到了其中的handleindex，slotsize，slot；
　　slot的类型为skynetcontext，ctx为skynetcontext，之前为slot申请了slotsize个skynetcontext大小的内存，所以slot内可以放slotsize个指针。
　　skynethandleregister（）实现了以下功能，从slot中找到一个位置存ctx，其中位置0是保留的，如果找到了，直接返回，则下次找的时候从当前位置的下一个位置找，handleindex存的是下次开始找的位置。
　　如果没找到，则申请别原来多一倍的空间啊，再把所有的元素重新hash，重新保存到newslot里，释放原来的空间，最外层for循环再执行一次，这次肯定就能有位置放了。
　　其实通过handle就可以找到ctx的下标了，hashhandle（sslotsize1）handlesharbor；returnhandle；
　　最后返回handle，注意这里的structmessagequeuequeuectxqueueskynetmqcreate（ctxhandle）；initfunctionmaybeusectxhandle，soitmustinitatlastcontextinc（）；structmessagequeueskynetmqcreate（uint32thandle）｛structmessagequeueqskynetmalloc（sizeof（q））；qhandlehandle；qcapDEFAULTQUEUESIZE；qhead0；qtail0；SPININIT（q）Whenthequeueiscreate（alwaysbetweenservicecreateandserviceinit），setinglobalflagtoavoidpushittoglobalqueue。Iftheserviceinitsuccess，skynetcontextnewwillcallskynetmqpushtopushittoglobalqueue。qinglobalMQINGLOBAL；qrelease0；qoverload0；qoverloadthresholdMQOVERLOAD；qqueueskynetmalloc（sizeof（structskynetmessage）qcap）；qnextNULL；returnq；｝
　　创建一个消息队列，初始化handle：处理这个消息的handlecap：消息队列的capcity容量head，tail：头尾指针inglobal：是否在全局消息队列里release：是否析构了overload：是否过载overloadthreshold：过载阈值queue：当前消息队列中消息指针next：全局消息队列中下一个消息队列的指针contextinc（）；staticvoidcontextinc（）｛ATOMFINC（GNODE。total）；｝
　　初始化GNODE。total，原子类型。CHECKCALLINGBEGIN（ctx）intrskynetmoduleinstanceinit（mod，inst，ctx，param）；CHECKCALLINGEND（ctx）intskynetmoduleinstanceinit（structskynetmodulem，voidinst，structskynetcontextctx，constcharparm）｛returnminit（inst，ctx，parm）；｝
　　这里调用c模块的init函数，这里的话也就是loggerinit。intloggerinit（structloggerinst，structskynetcontextctx，constcharparm）｛constcharrskynetcommand（ctx，STARTTIME，NULL）；inststarttimestrtoul（r，NULL，10）；if（parm）｛insthandlefopen（parm，a）；if（insthandleNULL）｛return1；｝instfilenameskynetmalloc（strlen（parm）1）；strcpy（instfilename，parm）；instclose1；｝else｛insthandlestdout；｝if（insthandle）｛skynetcallback（ctx，inst，loggercb）；return0；｝return1；｝
　　我们可以看到，如果parm存在，也就是configlogger存在，对应配置文件的logger字段，如果存在，则追加输出到文件内，否则输出到stdout。if（r0）｛structskynetcontextretskynetcontextrelease（ctx）；if（ret）｛ctxinittrue；｝skynetglobalmqpush（queue）；if（ret）｛skyneterror（ret，LAUNCHss，name，param？param：）；｝returnret；｝else｛skyneterror（ctx，FAILEDlaunchs，name）；uint32thandlectxhandle；skynetcontextrelease（ctx）；skynethandleretire（handle）；structdroptd｛handle｝；skynetmqrelease（queue，dropmessage，d）；returnNULL；｝
　　如果初始化成功，则将消息队列push到全局消息队列，否则进行析构操作。