skynet源码阅读系列04skynetstart收尾

　　上一小节主要是梳理了一下skynetcontextnew（）的功能。
　　skynetcontextnew（）主要功能是创建一个skynetcontext。
　　根据传入的name从配置的cpath路径对应的。so库中查找。
　　我们写的C服务需要包含四个函数，假如name为logger，则这四个函数的函数名分别为loggercreateloggerreleaseloggerinitloggersignal
　　skynetcontext结构体包含以下成员：structskynetcontext｛voidinstance；创建出的服务实例structskynetmodulemod；内存里该C服务句柄voidcbud；skynetcbcb；structmessagequeuequeue；该服务的消息队列ATOMPOINTERlogfile；uint64tcpucost；inmicrosecuint64tcpustart；inmicroseccharresult〔32〕；暂存结果uint32thandle；启动该服务后，服务号intsessionid；ATOMINTref；intmessagecount；boolinit；init之后为falseboolendless；boolprofile；配置文件profile的值CHECKCALLINGDECL｝；
　　上述成员变量没注释的从main看到这里，暂时不清楚是做什么的，往后继续阅读就清楚了。
　　今天我们接着skynetstart（）继续看，完整的函数体在下面。voidskynetstart（structskynetconfigconfig）｛registerSIGHUPforlogfilereopenstructsigactionsa；sa。sahandlerhandlehup；sa。saflagsSARESTART；sigfillset（sa。samask）；sigaction（SIGHUP，sa，NULL）；if（configdaemon）｛if（daemoninit（configdaemon））｛exit（1）；｝｝skynetharborinit（configharbor）；skynethandleinit（configharbor）；skynetmqinit（）；skynetmoduleinit（configmodulepath）；skynettimerinit（）；skynetsocketinit（）；skynetprofileenable（configprofile）；structskynetcontextctxskynetcontextnew（configlogservice，configlogger）；if（ctxNULL）｛fprintf（stderr，Cantlaunchsservice，configlogservice）；exit（1）；｝skynethandlenamehandle（skynetcontexthandle（ctx），logger）；bootstrap（ctx，configbootstrap）；start（configthread）；harborexitmaycallsocketsend，soitshouldexitbeforesocketfreeskynetharborexit（）；skynetsocketfree（）；if（configdaemon）｛daemonexit（configdaemon）；｝｝
　　只剩下下面这点没看了。skynetstart（structskynetconfigconfig）｛。。。skynethandlenamehandle（skynetcontexthandle（ctx），logger）；bootstrap（ctx，configbootstrap）；start（configthread）；harborexitmaycallsocketsend，soitshouldexitbeforesocketfreeskynetharborexit（）；skynetsocketfree（）；if（configdaemon）｛daemonexit（configdaemon）；｝｝
　　skynethandlenamehandle（skynetcontexthandle（ctx），logger）；constcharskynethandlenamehandle（uint32thandle，constcharname）｛rwlockwlock（Hlock）；constcharretinsertname（H，name，handle）；rwlockwunlock（Hlock）；returnret；｝
　　我们可以看到，skynethandlenamehandle（）的功能是insertname（）。
　　看看insertname（）的具体实现：staticconstcharinsertname（structhandlestorages，constcharname，uint32thandle）｛intbegin0；intendsnamecount1；while（beginend）｛intmid（beginend）2；structhandlenamensname〔mid〕；intcstrcmp（nname，name）；if（c0）｛returnNULL；｝if（c0）｛beginmid1；｝else｛endmid1；｝｝charresultskynetstrdup（name）；insertnamebefore（s，result，handle，begin）；returnresult；｝
　　很明显的一个二分查找，判断传入的name是否在Hname里，这是一个指针，指向一块内存，其内存元素的类型为skynetname，定义如下：structhandlename｛charname；uint32thandle；｝；structhandlestorage｛。。。intnamecap；name指向内存块的容量intnamecount；name指向内存块当前已经占用了几个元素，每个元素为一个skynetnamestructhandlenamename；指向一块内存｝；
　　为什么这里可以使用二分查找？
　　我们看下strcmp（）函数的功能
　　百度百科：strcmp函数是stringcompare（字符串比较）的缩写，用于比较两个字符串并根据比较结果返回整数。基本形式为strcmp（str1，str2），若str1str2，则返回零；若str1str2，则返回负数；若str1str2，则返回正数。
　　我们可以依据返回的结果判断，如果为0说明找到了，直接返回，后面的逻辑就不跑了，如果0，说明结果在mid的右边，beginmid1，反之endmid1。
　　既然可以使用了二分查找，那一定要保证数组的有序咯？
　　我们接着往下看，
　　charresultskynetstrdup（name）；将name拷贝了一份，为什么要拷贝，下面解释。
　　insertnamebefore（s，result，handle，begin）；函数原型如下：staticvoidinsertnamebefore（structhandlestorages，charname，uint32thandle，intbefore）｛if（snamecountsnamecap）｛snamecap2；assert（snamecapMAXSLOTSIZE）；structhandlenamenskynetmalloc（snamecapsizeof（structhandlename））；inti；for（i0；ibefore；i）｛n〔i〕sname〔i〕；｝for（ibefore；isnamecount；i）｛n〔i1〕sname〔i〕；｝skynetfree（sname）；snamen；｝else｛inti；for（isnamecount；ibefore；i）｛sname〔i〕sname〔i1〕；｝｝sname〔before〕。namename；sname〔before〕。handlehandle；snamecount；｝
　　首先我们看else分支，此时Hname指向的内存还没放满元素，将从before下标开始到之后一个元素，将数组统一向后挪一个位置，不过都是从末端开始，到before截至。
　　before也就是传入函数的begin，是name将要插入的位置，将下标比begin大的元素往后移，将name插入begin的位置，从而保证了数组的有序。
　　如果if（snamecountsnamecap）如果容量不够了，将容量扩充至原来的两倍，并且有一个MAXSLOTSIZE最大值内存上限，将before之前的元素重新写入内存，之后的元素向后挪一个位置，同时释放掉原内存空间，中间before的位置写入name。
　　注意这里的释放操作，也就是为什么insertname（）里为什么要拷贝一份的原因了。
　　接下来是bootstrap（ctx，configbootstrap）；staticvoidbootstrap（structskynetcontextlogger，constcharcmdline）｛intszstrlen（cmdline）；charname〔sz1〕；charargs〔sz1〕；intargpos；sscanf（cmdline，s，name）；argposstrlen（name）；if（argpossz）｛while（cmdline〔argpos〕）｛argpos；｝strncpy（args，cmdlineargpos，sz）；｝else｛args〔0〕；｝structskynetcontextctxskynetcontextnew（name，args）；if（ctxNULL）｛skyneterror（NULL，Bootstraperror：s，cmdline）；skynetcontextdispatchall（logger）；exit（1）；｝｝
　　我们拿exampleconfig下的配置举例，config下的bootstrap配置如下。bootstrapsnluabootstrapTheserviceforbootstrap
　　bootstrap（）函数体内在调用skynetcontextnew（）之前，主要是把snlua赋值给name，而空格之后的字符串即为args的值。
　　然后再把name，args传入skynetcontextnew（）函数，从snlua。so中查找模块并创建实例。
　　如果失败了，把消息队列里的消息分发完，退出。
　　start（configthread）；staticvoidstart（intthread）｛pthreadtpid〔thread3〕；structmonitormskynetmalloc（sizeof（m））；memset（m，0，sizeof（m））；mcountthread；msleep0；mmskynetmalloc（threadsizeof（structskynetmonitor））；inti；for（i0；ithread；i）｛mm〔i〕skynetmonitornew（）；｝if（pthreadmutexinit（mmutex，NULL））｛fprintf（stderr，Initmutexerror）；exit（1）；｝if（pthreadcondinit（mcond，NULL））｛fprintf（stderr，Initconderror）；exit（1）；｝createthread（pid〔0〕，threadmonitor，m）；createthread（pid〔1〕，threadtimer，m）；createthread（pid〔2〕，threadsocket，m）；staticintweight〔〕｛1，1，1，1，0，0，0，0，1，1，1，1，1，1，1，1，2，2，2，2，2，2，2，2，3，3，3，3，3，3，3，3，｝；structworkerparmwp〔thread〕；for（i0；ithread；i）｛wp〔i〕。mm；wp〔i〕。idi；if（isizeof（weight）sizeof（weight〔0〕））｛wp〔i〕。weightweight〔i〕；｝else｛wp〔i〕。weight0；｝createthread（pid〔i3〕，threadworker，wp〔i〕）；｝for（i0；ithread3；i）｛pthreadjoin（pid〔i〕，NULL）；｝freemonitor（m）；｝
　　声明了一个线程数组，数组大小为configthread3。structmonitor｛intcount；structskynetmonitorm；pthreadcondtcond；pthreadmutextmutex；intsleep；intquit；｝；
　　创建了一个monitor结构体，初始化数据count：configthreadsleep：0m：为每个thread创建了一个skynetmonitorcond：条件变量mutex：互斥锁createthread（pid〔0〕，threadmonitor，m）；createthread（pid〔1〕，threadtimer，m）；createthread（pid〔2〕，threadsocket，m）；
　　创建了三个线程，monitor，timer，socket，这就是声明数组大小为thread3的原因。
　　createthread（）的函数原型如下：staticvoidcreatethread（pthreadtthread，void（startroutine）（void），voidarg）｛if（pthreadcreate（thread，NULL，startroutine，arg））｛fprintf（stderr，Createthreadfailed）；exit（1）；｝｝
　　参数thread：指向线程的指针startroutine：指向函数的指针arg：void指针
　　创建线程，并指明线程运行函数的起始地址，也就是我们传入的函数指针指向的地址，arg将最为参数传递给startroutine函数。staticintweight〔〕｛1，1，1，1，0，0，0，0，1，1，1，1，1，1，1，1，2，2，2，2，2，2，2，2，3，3，3，3，3，3，3，3，｝；structworkerparmwp〔thread〕；for（i0；ithread；i）｛wp〔i〕。mm；wp〔i〕。idi；if（isizeof（weight）sizeof（weight〔0〕））｛wp〔i〕。weightweight〔i〕；｝else｛wp〔i〕。weight0；｝createthread（pid〔i3〕，threadworker，wp〔i〕）；｝for（i0；ithread3；i）｛pthreadjoin（pid〔i〕，NULL）；｝freemonitor（m）；
　　创建剩下的thread个线程，并且传入workerparm结构体作为参数，结构体包含structworkerparm｛structmonitorm；指向skynetmonitor类型的指针intid；intweight；权重，后面有用｝；
　　最后，join，free。
　　start（）的功能就是为整个框架创建好线程，线程数量由config文件的thread参数配置，还包括框架本身需要的3个线程，monitor，timer，socket。
　　继续回到skynetstart（）函数。harborexitmaycallsocketsend，soitshouldexitbeforesocketfreeskynetharborexit（）；skynetsocketfree（）；if（configdaemon）｛daemonexit（configdaemon）；｝
　　最后join调线程之后再把harbor，socket，等相关资源释放掉。
　　skynetstart（）到这里就结束了，是不是很奇怪，是不是感觉还有很多事情没有做（如果有skynet使用经验会有这种感觉），别急，后面我们继续看。