()
| 519 | } |
| 520 | |
| 521 | func (dd *msgpipelineDelivery) close() { |
| 522 | dd.checkRunner.close() |
| 523 | |
| 524 | if dd.globalModifiersState != nil { |
| 525 | if err := dd.globalModifiersState.Close(); err != nil { |
| 526 | dd.log.Error("failed to close global modifiers state", err) |
| 527 | } |
| 528 | } |
| 529 | if dd.sourceModifiersState != nil { |
| 530 | if err := dd.sourceModifiersState.Close(); err != nil { |
| 531 | dd.log.Error("failed to close source modifiers state", err) |
| 532 | } |
| 533 | } |
| 534 | for _, modifiers := range dd.rcptModifiersState { |
| 535 | if err := modifiers.Close(); err != nil { |
| 536 | dd.log.Error("failed to close rcpt modifiers state", err) |
| 537 | } |
| 538 | } |
| 539 | } |
| 540 | |
| 541 | func (dd *msgpipelineDelivery) Abort(ctx context.Context) error { |
| 542 | dd.close() |
no test coverage detected