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)Create a timeout job for an iterative search |
| Modifier and Type | Method and Description |
|---|---|
void | dropped()Called when the job is dropped due to router overload. |
String | getName()Descriptive name of the task |
void | runJob()Actually perform the task. |
getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toStringpublic IterativeTimeoutJob(RouterContext ctx, Hash peer, IterativeSearchJob job)
ctx - the router contextpeer - the peerjob - the parent search jobpublic void dropped()
public String getName()
Jobpublic void runJob()
Job