(dest ...any)
| 554 | } |
| 555 | defer func() { |
| 556 | recoverClientPanic(&err) |
| 557 | if err != nil && isTerminalSessionIdleWaitError(err) { |
| 558 | err = nil |
| 559 | } |
| 560 | }() |
| 561 | |
| 562 | payload, err := json.Marshal(wire.WorkerWaitSessionIdlePayload{ |
| 563 | WorkerControlMetadata: wire.WorkerControlMetadata{ |
| 564 | WorkerID: e.workerID, |
| 565 | OwnerEpoch: e.ownerEpoch, |
| 566 | CPInstanceID: e.cpInstanceID, |
| 567 | }, |
| 568 | }) |
| 569 | if err != nil { |
| 570 | return err |
| 571 | } |
| 572 | |
| 573 | ctx, cancel := context.WithTimeout(context.Background(), queryCloseWaitTimeout) |
| 574 | defer cancel() |
| 575 | if e.ctx != nil { |
| 576 | go func() { |
| 577 | select { |
| 578 | case <-e.ctx.Done(): |
| 579 | cancel() |
| 580 | case <-ctx.Done(): |
nothing calls this directly
no test coverage detected