1 K J J J J J J J J J J J J  J . . А J@YA J J J J ?  ? ? J ? ?  . ? J J  J  P@0p@4@ihostsContainer!Lphex/host/NetworkHostsContainer;messageService!Lphex/msghandling/MessageService;isDynamicQueryStartedZisDynamicQueryStoppedareLeavesQueriedisProbeQuerySent queryTimeoutJqueryStartTimenextProcessTimetimeToWaitPerHopIdesiredResultsreceivedResultsestimatedQueriedHorizon queriedHostsLjava/util/List; Signature"Ljava/util/List;queryLphex/msg/QueryMsg;Y(Lphex/msg/QueryMsg;ILphex/host/NetworkHostsContainer;Lphex/msghandling/MessageService;)VCodeLineNumberTableLocalVariableTablethisLphex/query/DynamicQueryEngine;incrementResultCount(I)VincgetResultCount()I stopQuery()VareEnoughResultsRouted()Z getFromHost()Lphex/host/Host;isQueryFinished currentTime getProgressresultProgresshorizonProgress timeProgress processQuery sentToLeavesprocessStandardQueryiqrtLphex/common/QueryRoutingTable; ultrapeers[Lphex/host/Host;notQueriedHosts hostToQueryLphex/host/Host;maxTTLBdegreettlnewQueryprocessProbeQuery directHitList failedListdirectProbeSizefailedProbeSizetoIdxLocalVariableTypeTableprocessQueryToLeavessendProbeQueryToHosts(Ljava/util/List;B)VhosthostListiteratorLjava/util/Iterator;&Ljava/util/Iterator;&(Ljava/util/List;B)VcalculateEstimatedHorizon(IB)I hostCount calculateTTL(BII)BhostsNeededToQueryhostsconnectionCountresultsPerHostDmissingResultshostsPerConnectionadjustTimeToWaitPerHopratio SourceFileDynamicQueryEngine.java er MN OP cd \[ QR SR TR UR VW Z[ ^[ ][java/util/ArrayList _` t  uv XW YW t r r t  p t  phex/msg/QueryMsg e    r em   p    p   t phex/host/Host phex/query/DynamicQueryEnginejava/lang/Object phex/query/DynamicQueryConstants hasQueryURNs getHeader()Lphex/msg/MsgHeader;phex/msg/MsgHeaderjava/lang/SystemcurrentTimeMillis()Jjava/lang/Mathmax(II)Iminphex/host/NetworkHostsContainergetUltrapeerConnections()[Lphex/host/Host;isConnectionStablejava/util/Listcontains(Ljava/lang/Object;)Z getMaxTTL()BgetUltrapeerDegreeisUPQueryRoutingSupportedgetLastReceivedRoutingTable!()Lphex/common/QueryRoutingTable;phex/common/QueryRoutingTable containsQuery(Lphex/msg/QueryMsg;)Z(Lphex/msg/QueryMsg;B)VqueueMessageToSend(Lphex/msg/Message;)Vadd(ILjava/lang/Object;)VsizesubList(II)Ljava/util/List;phex/msghandling/MessageServicegetLastSentQueryRoutingTablegetLeafConnectionCountforwardQueryToLeaves&(Lphex/msg/QueryMsg;Lphex/host/Host;)V()Ljava/util/Iterator;java/util/IteratorhasNextnext()Ljava/lang/Object;pow(DD)D!JKLMNOPQRSRTRURVWXWYWZ[\[][^[_`abcdefg[**-**+***** * * ` ***Y+=hF #(-4;@EPWZi4[jk[cd[\[[MN[OPlmgC *Y`h  i jk n[opg/*hi jkqrg4*h i jkstg;**hi jkuvg5 *hi  jkwtg@*****@** ah2  (*.<>i@jk.xWypgd**d**ok<*ok=B** a!e* okg6dh&  $37Ti4djk$@z[31{[7-xWT|[}rgI@**$*** >** a* *!*"h> "$#(%5&6,=.A/D2H4i $~RIjkExWrg*#L=N6+.+2$*+2% +2N-*&a-(6-)6**6$-+-,:*-6.Y*/:-0*-1W**2** ha*3hj=@ A BF0I3K6M;BAPIRTSUV[WaXl[y_`bfghklnoif 2[jk [ [yas[lh2drg*#LY+4MY+4N6+T+2,:+2+0+*-,+21W-+21W-+25,666 6*,786!-66*-786** `ha* hfwxy{&}/~>JUXcfq{wi\ /BX[jk``[[X[O[bbtgG*9L+<+*-1.Y*/M*Y*:`*,,;h$4CEi $!dGjk?gR+<N.Y*/:-=6->?:0*1W)6**2DZh* )0<CNQiH)%C [RjkR`RK=dRbKag| >dd@c>d=hi* jk [ [g2 l**o9**d6 A6 o6l66  . B* 2k6    `6 h> #&/5?EGV]`j ip #[V [ 82 ljkll[l[ _T[/=[57[rgW* dP*eDA* FH*l*lH*Y H'kd * d *d h& #&8!G"P$V'i #8Wjk