节点程序版本号变更
()
| 141 | |
| 142 | // 节点程序版本号变更 |
| 143 | func (this *Node) execNodeVersionChangedTask() error { |
| 144 | if !sharedUpgradeManager.IsInstalling() { |
| 145 | goman.New(func() { |
| 146 | sharedUpgradeManager.Start() |
| 147 | }) |
| 148 | } |
| 149 | return nil |
| 150 | } |
| 151 | |
| 152 | // 节点级别变更 |
| 153 | func (this *Node) execNodeLevelChangedTask(rpcClient *rpc.RPCClient) error { |
no test coverage detected