class IterativeTimeoutJob extends JobImpl
Manages timeout scenarios for specific peer queries during iterative search operations. Unlike overall search timeouts, this handles individual peer response timeouts while allowing the broader iterative search to continue with other peers.
Coordinates with IterativeSearchJob to mark peers as failed when they don't respond within the expected time window. The decision whether a timeout actually occurred is delegated to the parent search job's failure detection logic.
Ensures robust iterative search behavior by handling unresponsive peers without disrupting the overall search progress.
| Constructor and Description |
|---|
IterativeTimeoutJob(RouterContext ctx,
Hash peer,
IterativeSearchJob job) |
| Modifier and Type | Method and Description |
|---|---|
String |
getName()
Descriptive name of the task
|
void |
runJob()
Actually perform the task.
|
dropped, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toStringpublic IterativeTimeoutJob(RouterContext ctx, Hash peer, IterativeSearchJob job)