initRunner
(params *startRunnerParams)
| 63 | |
| 64 | // initRunner |
| 65 | func (info *RuntimeInfo) initRunner(params *startRunnerParams) error { |
| 66 | info.RebootWait() |
| 67 | logs.V(5).Infof("runner %s is rebooting", info.RuntimeID) |
| 68 | |
| 69 | info.invokeLock.Lock() |
| 70 | defer info.invokeLock.Unlock() |
| 71 | |
| 72 | if info.State != RuntimeStateClosed { |
| 73 | logs.Errorf("runtime %s current states is %s", info.RuntimeID, info.State) |
| 74 | return fmt.Errorf("duplicate runner") |
| 75 | } |
| 76 | |
| 77 | info.SetState(RuntimeStateCold) |
| 78 | info.runnerConn = params.conn |
| 79 | info.Abnormal = false |
| 80 | return nil |
| 81 | } |
| 82 | |
| 83 | // stopRunner |
| 84 | func (info *RuntimeInfo) stopRunner() { |