(code int, message string)
| 539 | } |
| 540 | |
| 541 | func (m *Manager) forceFinalizeAll(code int, message string) { |
| 542 | m.invStateMux.Lock() |
| 543 | uids := make([]string, 0, len(m.invState)) |
| 544 | for uid := range m.invState { |
| 545 | uids = append(uids, uid) |
| 546 | } |
| 547 | m.invStateMux.Unlock() |
| 548 | |
| 549 | for _, uid := range uids { |
| 550 | m.respUID(uid, code, "%s", message) |
| 551 | } |
| 552 | } |
| 553 | |
| 554 | // markCancelled performs the same bookkeeping as tryFinalize (tombstone + |
| 555 | // scheduler.complete + remove from invState) but does NOT emit anything to |
no test coverage detected