00:00
那么接下来我们就看现在已经分配好了,分配好之后咱们还有最后一个过程,最后一个步骤什么呀。咱们的小D是不是得?告诉老大,诶诶,我之前管家告诉我这几个,这几个给你谁谁谁用啊对不对,小弟是不是跑过来告诉他提供slot。然后老大才会怎么样把task发过去啊。啊,就这么一个,接下来就是这么一个过程啊,那我直接看这了啊。嗯,哪在哪一行。啊,我已经标上了,对吧,在这这边是不是有一个请求。Slot。对吧。告诉谁啊?告诉task manager啥意思啊,我不是分配完了吗?我这个管家通知每个小弟我已经分好了,诶一号小弟你这个两个槽给谁用,二号小弟你这几个草给谁用啊,这边就做这个事儿啊,就做个事儿,呃,我这边写一下啊。
01:10
呃,分配完之后啊,通知小弟啊TM啊。通知TM提供草给老大。给job给GM对吧,我都用缩写啊。啊。那就是这个方法,点点进来网关对吧,找实现是不是task可以Q这是不是小D啊,来我们看小D这个方法。他干什么事啊?你看。小弟,是不是咱们这边打印日志是不是通知到啊,接收到请求啊,分配后的请求是不是。是不是管家已经分配完了呀,啊就这里那这一块呢。判断一下是否连接上,如果加了一个非没连接上就走,这对吧,抛一些异常,如那后面正常的应该哪里啊。
02:08
来到了这里。同学们。是又来一个分配啊。他名字起的没有那么直白,好吧,没那么直白,这个叫他名字叫分配草,这个是小弟啊,小弟接收到通知,然后他自己来分配草,这边我们看看他做了什么事啊,呃,那前面呢。已分配的槽是什么,对吧?哎,那是不是在这里啊。做了一个槽的分配。是吧,做了一个朝的分配,那么后面呢。就没有什么重要的东西呢,也就是在这里这个方法。管家告诉你分配结果,你自己是不得安排手底下的人列个队啊。是不是这么一个过程啊啊。那么接下来呢,我们看。
03:02
再点。是不是找这个。实现只有一个对吧。好在这里面呢,又封了一封装了一层啊,封装一层那没事咱们再点啊,这这块内容不多了啊,这块内容不多了,那么接下来我们看看。呃,该怎么样呢?我找找啊,还是得找找。那咱们刚才看的这个分配对吧?呃,这里面呃提供不在这里,那这里面做了一些啥事啊,就是呃分配。咱们是什么情况呢?是不是resource manager里面的。Slot manager已经分配好,告诉谁啊,Task is对吧?诶,他已经告诉你啊,我已经分好了,那么之后比如说他告诉他我要俩,他是不是等于什么。
04:09
他自己内部是不得安排安排呀。内部是不得安排安排,就手底下的人,他是不是安排一下对吧?啊,这边就做这个事儿啊,根据上面的命令去做一个安排啊。那这一块难怪找不到对吧,也没有什么太重要的逻辑了,就是一些分配操作啊,那咱们回去。啊,不看这里了啊,看这个就没意义了。咱们写一个注释啊,回来回来回来回来,那就在这对吧。我们说根据RM的。的什么的指令啊的命令对吧,怎么分配slot。分配自己的lo,自己是指谁啊?Task就小弟啊,那分配了完之后啊,我们。
05:09
哎,不不不是这一行,不是这一行还要再外面一层对吧。你看这是不是还是这个方法啊,我们到最外层去啊,在这里啊。我们刚才是不是从这追进去了,它也好多层对吧?啊,那我们到最二层这里啊。就是接收到这请求啊,哎,然后下来根据这个命令分配自己的槽好了再往下走。这边是不是注册一个。新的job和创建一个服务对吧?啊,这个咱们就不用去,这个其实是什么呢?是跟job manager做一个连接啊做一个连接,那再往后看咱们这边有一个。是吧?来咱们这边写一下。
06:03
是不是像?Job manager提供slot。还记得这一步吗?通用提交流程是不是有这一步啊?Offer to manager啊这个就是。听到指令,那么前面你都分配完了,分配完之后中间这一块跟老大做一个连接对吧?啊,连接完之后判断连接上了之后向老大提供对吧?啊就像小弟跑过去老大跟前说,哎,老大我来了啊,我按照要求啊,带了什么什么对吧。好,那我们瞅一眼。它这里面是不是又调用了这个internal什么什么,哎。好。那我们接着就看这个呗。点看这个方法。
07:01
是不是向老大提供槽啊,对吧?啊,那这边也没呃,也没什么太重要的了啊,这边呢,前面这一块呃,咱们不用过多去看了,就一些对象ID获取啊啊还有一些槽的便利啊,还有等等它最终呢,它封装好之后。调用的方法在这,这个方法是什么。通过一个远程调用向老大提供了一个槽,那么老大收到他提供的槽是不是可以开始?开始啥呀?开始分发任务了吧,对吧,分发任务让给他们执行啊。呃,这个往里看的话,应该也没啥了啊,也没啥了,抽页嘛,Offer slo。你看这里面。最终调用的是什么?Slot pool,也就是说实际老大里面干活是不是还有一个东西叫这个sloter pool提供。
08:06
提供槽之后他做什么对吧,那这里面咱们还要看吗。啊,咱们瞅一眼就好了。找他这个。你看又一层啊,如果大家要追的话,就是呃,它的一个深入的过程,再往里点。然后这边还有对吧?啊,那这边呢,呃,咱们就了解到分配啊,提供这个槽就够了啊就够了。
我来说两句