更新节点配置变更
(task *pb.NodeTask)
| 129 | |
| 130 | // 更新节点配置变更 |
| 131 | func (this *Node) execConfigChangedTask(task *pb.NodeTask) error { |
| 132 | if task.ServerId > 0 { |
| 133 | return this.syncServerConfig(task.ServerId) |
| 134 | } |
| 135 | if !task.IsPrimary { |
| 136 | // 我们等等主节点配置准备完毕 |
| 137 | time.Sleep(2 * time.Second) |
| 138 | } |
| 139 | return this.syncConfig(task.Version) |
| 140 | } |
| 141 | |
| 142 | // 节点程序版本号变更 |
| 143 | func (this *Node) execNodeVersionChangedTask() error { |
no test coverage detected