use outside ctx to make control
#559
Conversation
Codecov Report
@@ Coverage Diff @@
## master #559 +/- ##
=======================================
Coverage 19.18% 19.18%
=======================================
Files 28 28
Lines 1496 1496
=======================================
Hits 287 287
Misses 1170 1170
Partials 39 39 |
|
设计的过程是 leadershipLeader 和 leadershipFollower可以来回切换； @pwzgorilla 建议可以独立的context来做graceful机制 另外， 之所以以前没有把signal handler加上的原因是考虑到swan作为long running任务来运行， 手动shutdown的机会基本不存在； 另外如果想通过信号来做graceful的shutdown， 我理解重头戏是比如scheduler内部状态的graceful， events的graceful， 有很多工作需要做。 |
|
|
||
| setupLogger(conf.LogLevel) | ||
| setupLogger(conf.LogLevel) |
There was a problem hiding this comment.
use tabs instead of white space
|
@cmingxu 我这样改是发现 src/cmd/manager_cmd:46 行的context.TODO() 没有做控制，从而导致src/manager/manager.go:180行的ctx.Done()无法执行到。而且148，152，156，160行任何一个goroutine出错推出，都没有显示的去退出其他goroutine，而只是在程序最后结束时调用了os.Exit(1)来清理(这样因该也是可行的）。所以才想到用一个全局的context来控制。当然也可以不用这样做，在172行调用stopFunc()也可以退出其他goroutine. |
|
@pwzgorilla 我对从外面传入ctx没有意见； 改动时候开多个manager试几次 |
|
要多做测试，有必要需要把每个函数的行为定义写在comments里面。目前的代码逻辑还是比较复杂的。需要简化逻辑。 |
| go func() { | ||
| manager.criticalErrorChan <- eventbus.Start(stopCtx) | ||
| errC <- eventbus.Start(stopCtx) |
There was a problem hiding this comment.
这里我有一个小疑问 如果这四个里面都用一个 stopCtx 一旦外面 cancel 是否四个都能收到消息
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| err = store.InitZkStore(managerConf.ZkPath) | ||
| err = store.InitZkStore(cfg.ZkPath) | ||
| if err != nil { | ||
| logrus.Fatalln(err) |
| go func() { | ||
| manager.criticalErrorChan <- eventbus.Start(stopCtx) | ||
| errC <- eventbus.Start(stopCtx) |
|
PR需要拆一下，把精华抽取出来force push一下。 |
|
need rebase |
No description provided.