Naanou.LookupService.WorkDispatch
Class QueryWorker

Field Summary
Naanou.LookupService.WorkDispatch.Dispatch dispatch
int iteration
Naanou.Common.Search.SearchPart part
long queueTime
Naanou.LookupService.WorkDispatch.QueryState state

Constructor Summary
QueryWorker(Naanou.Common.Search.SearchQuery query, Naanou.Common.QueryProgressDelegate clientCallback, string clientIdSerial, string requestSerial)

Method Summary
void IWorkItem.Queued()
void IWorkItem.Run(Naanou.Common.WorkPool pool)
void OnFoundSuccessor(Naanou.Common.FindSuccessorResult result, Naanou.Common.BasicAddress address)
void QuerySearchPartWork(Naanou.LookupService.WorkDispatch.Dispatch dispatch, Naanou.Common.Search.SearchPart part, int parts, int iteration)
void Run(Naanou.LookupService.WorkDispatch.Dispatch dispatch)

Methods inherited from class System.Object
Equals, Finalize, GetHashCode, GetType, MemberwiseClone, ToString


Field Detail

dispatch

private Naanou.LookupService.WorkDispatch.Dispatch dispatch


iteration

private int iteration


part

private Naanou.Common.Search.SearchPart part


queueTime

private long queueTime


state

private Naanou.LookupService.WorkDispatch.QueryState state

Constructor Detail

QueryWorker

public QueryWorker(Naanou.Common.Search.SearchQuery query,
                   Naanou.Common.QueryProgressDelegate clientCallback,
                   string clientIdSerial,
                   string requestSerial)

Method Detail

IWorkItem.Queued

private void IWorkItem.Queued()


IWorkItem.Run

private void IWorkItem.Run(Naanou.Common.WorkPool pool)


OnFoundSuccessor

private void OnFoundSuccessor(Naanou.Common.FindSuccessorResult result,
                              Naanou.Common.BasicAddress address)


QuerySearchPartWork

private void QuerySearchPartWork(Naanou.LookupService.WorkDispatch.Dispatch dispatch,
                                 Naanou.Common.Search.SearchPart part,
                                 int parts,
                                 int iteration)


Run

public void Run(Naanou.LookupService.WorkDispatch.Dispatch dispatch)