1                      ! ! ! !    , , ,   *                   I              V   V V !" !# $% &'( &) * + V, - V. / 0 1 23 4 4 56 78 9: ;<= u>? 4@ ABC DE |F  G H IJ K L MN OP Q RS TU IVD WX Y Z [ \  ] ^B_` ^ab c d e fg hi  j k lmn o op qr st uv wx yz {| } ~      A       0                               serventLphex/servent/Servent; msgRouting!Lphex/msghandling/MessageRouting;messageSubscribersLjava/util/Map; SignaturepLjava/util/Map;Lphex/msghandling/MessageSubscriber<+Lphex/msg/Message;>;>; pongFactoryLphex/msg/PongFactory;sharedFilesServiceLphex/share/SharedFilesService;hostMgrLphex/host/HostManager;securityService#Lphex/security/PhexSecurityManager;pingMsgInCounter(Lphex/statistic/SimpleStatisticProvider;pongMsgInCounterqueryMsgInCounterqueryHitMsgInCounterpushMsgInCounterdropedMsgInCountertotalInMsgCounteruptimeStatsProvider"Lphex/statistic/StatisticProvider;$assertionsDisabledZP(Lphex/servent/Servent;Lphex/msghandling/MessageRouting;Lphex/msg/PongFactory;)VCodeLineNumberTableLocalVariableTablethis$Lphex/msghandling/MessageDispatcher; initStats%(Lphex/statistic/StatisticsManager;)VstatsMgr"Lphex/statistic/StatisticsManager;addMessageSubscriber8(Ljava/lang/Class;Lphex/msghandling/MessageSubscriber;)Vlist(Lphex/msghandling/MessageSubscriberList;clazzLjava/lang/Class; subscriber$Lphex/msghandling/MessageSubscriber;registeredSubscriberLocalVariableTypeTable-Lphex/msghandling/MessageSubscriberList;Ljava/lang/Class;)Lphex/msghandling/MessageSubscriber;X(Ljava/lang/Class;Lphex/msghandling/MessageSubscriber;)VremoveMessageSubscriberdispatchToSubscribers%(Lphex/msg/Message;Lphex/host/Host;)VmessageLphex/msg/Message; sourceHostLphex/host/Host;messageSubscriber Exceptions handlePing%(Lphex/msg/PingMsg;Lphex/host/Host;)VpingMsgLphex/msg/PingMsg;headerLphex/msg/MsgHeader; respondToPingha!Lphex/common/address/DestAddress;pongLphex/msg/PongMsg;iIleafs[Lphex/host/Host;pMsgi$Ljava/util/Iterator;ttlBhopsnewTTLavgDailyUptimeshareFileCount shareFileSize orginAddressipLphex/common/address/IpAddress;guidLphex/msg/GUID;pongsLjava/util/List;$Ljava/util/List; handlePong%(Lphex/msg/PongMsg;Lphex/host/Host;)VisNew connectedPortpongPortconnectedAddress connectedIPpongMsg pongAddressaccessLphex/security/AccessType; hopsTaken handleQuery&(Lphex/msg/QueryMsg;Lphex/host/Host;)Vexp"Lphex/msg/InvalidMessageException;msgLphex/msg/QueryMsg; resultFiles(Ljava/util/List;respondToQuery7(Lphex/msg/MsgHeader;Ljava/util/List;Lphex/host/Host;)V shareFileLphex/share/ShareFile;recordLphex/msg/QueryResponseRecord; newHeader resultCountrecords[Lphex/msg/QueryResponseRecord;recPos hostAddress serventGuidresponseLphex/msg/QueryResponseMsg;O(Lphex/msg/MsgHeader;Ljava/util/List;Lphex/host/Host;)VhandleQueryResponse.(Lphex/msg/QueryResponseMsg;Lphex/host/Host;)VqueryResponseMsg respServentId queryAddresshandleRouteTableUpdate1(Lphex/msg/RouteTableUpdateMsg;Lphex/host/Host;)VLphex/msg/RouteTableUpdateMsg;qrTableLphex/common/QueryRoutingTable;handleVendorMessage.(Lphex/msg/vendor/VendorMsg;Lphex/host/Host;)V vendorMsgLphex/msg/vendor/VendorMsg;handleMessagesSupportedVMsg:(Lphex/msg/vendor/MessagesSupportedVMsg;Lphex/host/Host;)Vpprmsg&Lphex/msg/vendor/PushProxyRequestVMsg; localAddresstcpConnectBack'Lphex/msg/vendor/MessagesSupportedVMsg; isFirewalledhandleCapabilitiesVMsg5(Lphex/msg/vendor/CapabilitiesVMsg;Lphex/host/Host;)V"Lphex/msg/vendor/CapabilitiesVMsg;handleTCPConnectBackVMsg7(Lphex/msg/vendor/TCPConnectBackVMsg;Lphex/host/Host;)V$Lphex/msg/vendor/TCPConnectBackVMsg;portaddress redirectMsghosts sentCount handleTCPConnectBackRedirectVMsg?(Lphex/msg/vendor/TCPConnectBackRedirectVMsg;Lphex/host/Host;)V,Lphex/msg/vendor/TCPConnectBackRedirectVMsg;connectBackRunnerLjava/lang/Runnable;handlePushProxyRequestVMsg9(Lphex/msg/vendor/PushProxyRequestVMsg;Lphex/host/Host;)Vpprvmsg requestGUIDppavmsg.Lphex/msg/vendor/PushProxyAcknowledgementVMsg;"handlePushProxyAcknowledgementVMsgA(Lphex/msg/vendor/PushProxyAcknowledgementVMsg;Lphex/host/Host;)VhandleHopsFlowVMsg1(Lphex/msg/vendor/HopsFlowVMsg;Lphex/host/Host;)V hopsFlowVMsgLphex/msg/vendor/HopsFlowVMsg; hopsFlowValuehandlePushRequest,(Lphex/msg/PushRequestMsg;Lphex/host/Host;)VLphex/msg/PushRequestMsg; dropMessage7(Lphex/msg/Message;Ljava/lang/String;Lphex/host/Host;)VreasonLjava/lang/String;;(Lphex/msg/MsgHeader;[BLjava/lang/String;Lphex/host/Host;)Vbody[B access$000<(Lphex/msghandling/MessageDispatcher;)Lphex/servent/Servent;x0()V SourceFileMessageDispatcher.java  java/util/HashMap     PingMsgInProvider &phex/statistic/SimpleStatisticProvider PongMsgInProvider QueryMsgInProvider QueryHitMsgInProvider PushMsgInProvider DropedMsgInProvider TotalMsgInProvider  DailyUptimeProvider   "phex/msghandling/MessageDispatcherjava/lang/StringBuilderAdding MessageSubscriber   for type   "phex/msghandling/MessageSubscriber &phex/msghandling/MessageSubscriberList  Removing MessageSubscriber    ) Received Ping:   -    Dropping already seen ping  61         java/lang/Integer                phex/msg/PongMsg   Received Pong:      [IP access strongly denied. ![ "# $ % &' (% )' * + ,#Received Query: - .Drop already seen query /#Drop query from leaf with hops > 2.0 123 java/lang/Boolean 4 56 7Drop index query. () phex/msg/InvalidMessageException 8 ]9 : efphex/msg/MsgHeader ; <=   java/lang/AssertionErrorphex/msg/QueryResponseRecordphex/share/ShareFile >? @phex/msg/QueryResponseMsgA B2 CDE FG HI  J K LM(My query response should never reach me.Message id equals servent id. NMServent id is empty. O PQ R SQRP not supported from host. TUphex/common/QueryRoutingTable VW XY ZInvalid QRT update message.Received VendorMsg: [%phex/msg/vendor/MessagesSupportedVMsg "phex/msg/vendor/TCPConnectBackVMsg *phex/msg/vendor/TCPConnectBackRedirectVMsg $phex/msg/vendor/PushProxyRequestVMsg ,phex/msg/vendor/PushProxyAcknowledgementVMsg phex/msg/vendor/HopsFlowVMsg  phex/msg/vendor/CapabilitiesVMsg  \] ^ _ ` aLimeWire bc d e f  g hi&phex/common/address/DefaultDestAddress j k l m n o$phex/msghandling/MessageDispatcher$1 InnerClasses pq rTCPConnectBackJob st)Local address has no IP to use for PPAck. u v wx yl z {|} ~ phex/upload/PushWorker   Dropping message:  from:  Header: [] - Message: [ ].  ] - Body: [   java/lang/Objectphex/servent/ServentgetHostService()Lphex/host/HostManager;getSharedFilesService!()Lphex/share/SharedFilesService;getSecurityService%()Lphex/security/PhexSecurityManager; phex/statistic/StatisticsManagergetStatisticProvider6(Ljava/lang/String;)Lphex/statistic/StatisticProvider;append-(Ljava/lang/String;)Ljava/lang/StringBuilder;-(Ljava/lang/Object;)Ljava/lang/StringBuilder;toString()Ljava/lang/String;phex/common/log/NLoggerdebug&(Ljava/lang/Class;Ljava/lang/Object;)V java/util/Mapget&(Ljava/lang/Object;)Ljava/lang/Object;put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; addSubscriber'(Lphex/msghandling/MessageSubscriber;)VK(Lphex/msghandling/MessageSubscriber;Lphex/msghandling/MessageSubscriber;)VremoveSubscriberremovegetClass()Ljava/lang/Class; onMessageisDebugEnabled(Ljava/lang/Class;)Zphex/msg/PingMsggetDebugString getHeader()Lphex/msg/MsgHeader; increment(I)VgetMsgID()Lphex/msg/GUID;phex/msghandling/MessageRoutingcheckAndAddToPingRoutingTable"(Lphex/msg/GUID;Lphex/host/Host;)ZgetTTL()B getHopsTakenphex/host/HostManagerareIncommingSlotsAdvertised()ZgetNetworkHostsContainer#()Lphex/host/NetworkHostsContainer;phex/host/NetworkHostsContainergetLeafConnections()[Lphex/host/Host;phex/host/HostgetHostAddress#()Lphex/common/address/DestAddress;phex/msg/PongFactorycreateOtherLeafsOutgoingPongF(Lphex/msg/GUID;BBLphex/common/address/DestAddress;)Lphex/msg/PongMsg;queueMessageToSend(Lphex/msg/Message;)V phex/statistic/StatisticProvidergetValue()Ljava/lang/Object;intValue()Iphex/share/SharedFilesService getFileCountgetTotalFileSizeInKbgetLocalAddress isUltrapeercreateMyOutgoingPongI(Lphex/msg/GUID;Lphex/common/address/DestAddress;BIIZI)Lphex/msg/PongMsg;phex/common/address/DestAddress getIpAddress!()Lphex/common/address/IpAddress;getMessageService#()Lphex/msghandling/MessageService;phex/msghandling/MessageServicegetCachedPongs()Ljava/util/List;java/util/Listiterator()Ljava/util/Iterator;java/util/IteratorhasNextnextgetPongAddressphex/common/address/IpAddressequals"(Lphex/common/address/IpAddress;)ZcreateFromCachePongY(Lphex/msg/GUID;BLphex/msg/PongMsg;Lphex/security/PhexSecurityManager;)Lphex/msg/PongMsg;phex/common/HorizonTracker getInstance()Lphex/common/HorizonTracker; trackPong(Lphex/msg/PongMsg;)V!phex/security/PhexSecurityManagercontrolHostAddressAccess=(Lphex/common/address/DestAddress;)Lphex/security/AccessType;phex/security/AccessTypeACCESS_STRONGLY_DENIEDACCESS_GRANTED catchHosts(Lphex/msg/PongMsg;)ZaddPongToCache()J setFileCount(J)VgetFileSizeInKBsetTotalFileSizegetPortsetPortroutePongMessagephex/msg/QueryMsgcheckAndAddToQueryRoutingTableisUltrapeerLeafConnectionphex/prefs/core/MessagePrefsDropIndexQueriesLphex/prefs/api/Setting;phex/prefs/api/Setting booleanValuegetSearchStringjava/lang/String(Ljava/lang/Object;)Z getMessage%(Lphex/msg/QueryMsg;)Ljava/util/List;size(Lphex/msg/GUID;BBBI)VsubList(II)Ljava/util/List;createFromShareFile6(Lphex/share/ShareFile;)Lphex/msg/QueryResponseRecord;getServentGuidphex/prefs/core/BandwidthPrefsMaxUploadBandwidth floatValue()Fjava/lang/Mathround(F)IgetPushProxies$()[Lphex/common/address/DestAddress;isUploadLimitReached(Lphex/msg/MsgHeader;Lphex/msg/GUID;Lphex/common/address/DestAddress;I[Lphex/msg/QueryResponseRecord;[Lphex/common/address/DestAddress;ZZ)VgetRemoteServentID phex/msg/GUID EMPTY_GUIDgetDestAddressrouteQueryResponse.(Lphex/msg/QueryResponseMsg;Lphex/host/Host;)ZisQueryRoutingSupportedisUPQueryRoutingSupportedgetLastReceivedRoutingTable!()Lphex/common/QueryRoutingTable;setLastReceivedRoutingTable"(Lphex/common/QueryRoutingTable;)VupdateRouteTable!(Lphex/msg/RouteTableUpdateMsg;)VtriggerQueryRoutingTableUpdatephex/msg/vendor/VendorMsgsetSupportedVMsgs*(Lphex/msg/vendor/MessagesSupportedVMsg;)VisLeafUltrapeerConnectionisPushProxySupported(Lphex/msg/GUID;)V getVendorindexOf(Ljava/lang/String;)I setVersionisTCPRedirectAllowedisTCPConnectBackSupportedincNumberOfTCPRedirectsSentsetCapabilitiesVMsgs%(Lphex/msg/vendor/CapabilitiesVMsg;)V getHostName(Ljava/lang/String;I)V$(Lphex/common/address/DestAddress;)VgetUltrapeerConnections!isTCPConnectBackRedirectSupported getAddressH(Lphex/msghandling/MessageDispatcher;Lphex/common/address/DestAddress;)Vphex/common/Environment()Lphex/common/Environment;executeOnThreadPool)(Ljava/lang/Runnable;Ljava/lang/String;)Vwarn3(Lphex/common/address/DestAddress;Lphex/msg/GUID;)VaddToPushRoutingTable"(Lphex/msg/GUID;Lphex/host/Host;)VsetPushProxyAddress getHopsValuesetHopsFlowLimit(B)Vphex/msg/PushRequestMsggetRequestAddress getClientGUIDgetUploadService()Lphex/upload/UploadManager;7(Lphex/msg/PushRequestMsg;Lphex/upload/UploadManager;)VroutePushMessage(Lphex/msg/PushRequestMsg;)Zinfophex/msg/Message toDebugString incDropCount getDataLengthphex/utils/HexConverter toHexString([BII)Ljava/lang/String;java/lang/ClassdesiredAssertionStatus      7**+*,*-*Y*+ *+ *+ & cd efgh&i.j6k*7777f*+*+*+*+*+*+*+*+& q su'w4yA{N}[effn !Y"#$,%&$+%'(*+)*N-*+,+W--,-,,-,Y-,.:*++W. "04@CJRU`m4` nnn 0>! "*` #n$n%0>!%&'N !Y"/$,%&$+%'(*+)*N-,-,,0*+1W"07?BM*NNN 0! " N$N%0!%&()j*+2)*N-+,3**+,- . /|01` 4. !Y"5$+6$7$+89$'(*:+8N*-;,< *+=,>*+,?& 4<APXY_*``23`,-A4561F+8N-@6-A6`* BGA* CD:6*2E:*-;F: , G`66`6*HIJ6* K6* L6 *-;*M *NO: , G,E:  P:  -;: *QR:S:T<UV: WPX,* * YG  $%1 = H R ci oz"%&')+,-/*1-3B5E6R78c9: @/;<=2=>*?:C@AFF23F,-A45 ;BC5DCzECF<G<H< z9: nI8 eJK YLM MNO" MNPQR  4. !Y"Z$+[$7$+\9$'(*:]+^+WN* -_:` *+a,>b* +c6*Q+d+\A6Q,E:P:-PX4,+ef,+ghi6-i6   j+\@ *+kWn= >4B<CCEHFRGZJbKcOkQuRzTX[]^_abefginprp uS T<U< HV8?WKX:,-HY8RZ[h\C]^ 4. !Y"l$+m$7$+n9$'(*:+nN*-;,o *+p,>,q-A *+r,>stuvw+xy *+z,>*+,{:*+},>* +~: *-,|Vv w4{<}APXYhp> _`ab,-A45cO" cdef Y+;+A`:,6,W,6 Y:6,S:  T# U:  :S*M: *: Y  tIn* C**: - GJ (3;QX[yygh ijc*@A 45cO,-k5 l<Xmn[o<Sp8 JqM rs " cdtuv*:+N+:* *+,>-; *+,> *+,>+:* _:` *+a,>b*+,{:*+},>-@*+,W:*+},>~||z "*+7?@KSTZem u v~/39578;\ _` _`ws,- 45xMZ^y8eSZ[z{Y*:,, *+,>,N-YN,--+,q *Q :*+,>5KN|>@ADEH$I(M0N5R:SAXK^N[P]X_4P_`YY*|Y,-$5}~M 4. !Y"$+$7$+9$'(+*+,r+*+,_+*+,L+*+,9+*+,&+*+,+ *+,^c d4g;iDjGkNmWnZoaqjrmstu}vwyz{}~ ,-.,+*>,A,:,3Y*:,, ,G@*Q3,™,*M:Yi:,G*Qı6  &6JPVnwH6 w 8a,-  H,+ű  a,-/ }+>,E:iY:Y:* C:665-,22̙2G˱> '2>AR[^isv|\ D8;<}}a},-x< r82K>?>A<<y+NY*-:Ѷұ4a,-8 H,q*MN-P  ӸԱ+ն;:Y-:,G*,ױ. !"+7=G>HHH,-88+M7c*+ض; ,+ٶڱ   ,-[ +>,ܱ *   ,-Cd*:* +ݶ_N-` *+a,>*+޶-bY+*W+@*Q+W2 !#"$%5'<)L+M.W0c2*ddad,-PZ[h !Y"$,$$-%' 43 !Y"$+9$$+$$'(-*:6"8+:[>_?g@*hha+hh,-l !Y"$-$$%' 45 !Y"$+9$$,+$$'(*:D#F,H^LcMkN4ll45lll,-/*M * M