(delete bool)
| 174 | } |
| 175 | |
| 176 | func (e *engineImpl) reportAndDesireAsync(delete bool) error { |
| 177 | node, err := e.nod.Get() |
| 178 | if err != nil { |
| 179 | return errors.Trace(err) |
| 180 | } |
| 181 | if err := e.recycleIfNeed(node); err != nil { |
| 182 | e.log.Error("failed to recycle", log.Error(err)) |
| 183 | } |
| 184 | if err := e.reportAndApply(true, delete, node.Desire); err != nil { |
| 185 | return errors.Trace(err) |
| 186 | } |
| 187 | if err := e.reportAndApply(false, delete, node.Desire); err != nil { |
| 188 | return errors.Trace(err) |
| 189 | } |
| 190 | return nil |
| 191 | } |
| 192 | |
| 193 | func (e *engineImpl) recycleIfNeed(node *specv1.Node) error { |
| 194 | report := node.Report |
no test coverage detected