1 > "? @A "B @C "D "E FG "H "I "J KL MN FO KP KQR ST UV WXY Z[ K\ M]^_` >a b c de fg Kh Sij fk Fl mn &c Fo Fpq -cr &s Mtuv 2sw Ux fy z{ |}~ f  K K F " " " " " " " m F @   F S U  S F  F   f  f "  _  _ _  _ " _  m  @   y y  yd ~s  F   "               F      @ = F F  F  F  F   F F   F     InnerClassesserventLphex/servent/Servent;messageService!Lphex/msghandling/MessageService;securityService#Lphex/security/PhexSecurityManager; headerBuffer[B connectedHostLphex/host/Host; connection Lphex/net/connection/Connection; headersReadLphex/http/HTTPHeaderGroup; headersSend)(Lphex/servent/Servent;Lphex/host/Host;)VCodeLineNumberTableLocalVariableTablethis"Lphex/connection/ConnectionEngine;processIncomingData()Vexp"Lphex/msg/InvalidMessageException;headerLphex/msg/MsgHeader;bodyttlIhopsmessageLphex/msg/Message;Ljava/io/IOException;Ljava/lang/Exception; Exceptions readHeader()Lphex/msg/MsgHeader;hexBodyLjava/lang/String;lengthinitHostHandshakevMsg'Lphex/msg/vendor/MessagesSupportedVMsg;capVMsg"Lphex/msg/vendor/CapabilitiesVMsg;initializeIncomingWith06handshakeHandler,Lphex/connection/handshake/HandshakeHandler; myResponse+Lphex/connection/handshake/HandshakeStatus;httpHeaderString inResponseinitializeOutgoingWith06greeting requestLine requestBufferLjava/lang/StringBuffer;handshakeHeaders requestStrhandshakeResponsemyResponseHeadersconfigureConnectionType9(Lphex/http/HTTPHeaderGroup;Lphex/http/HTTPHeaderGroup;)V myHeadersSendtheirHeadersRead myUPHeaderLphex/http/HTTPHeader; theirUPHeaderhandleXTryHeaders(Lphex/http/HTTPHeaderGroup;)Vheaders hostAddresses[Lphex/http/HTTPHeader;handleXTryHosts([Lphex/http/HTTPHeader;Z)VprioritySaddress!Lphex/common/address/DestAddress;accessLphex/security/AccessType; ipAddressLphex/common/address/IpAddress;3Lphex/common/address/MalformedDestAddressException;hostAddressStr tokenizerLjava/util/StringTokenizer;ixtryHostAdressesisUltrapeerListZ hostContainer Lphex/host/CaughtHostsContainer;configureRemoteHostaddiportipremoteIPversionFe!Ljava/lang/NumberFormatException;maxTTLBdegreepostHandshakeConfigurationsendStringToHost(Ljava/lang/String;)Vstrbytes SourceFileConnectionEngine.java    ! "# $ %&' () * +, -,TTL or hops below 0. /01 234 56java/lang/Integer 7&Hops larger then maxNetworkTTL 89 :;Unknown message type phex/msg/InvalidMessageExceptionjava/lang/StringBuilderInvalid message: <= >? @? phex/connection/ConnectionEngineA BC D EFjava/io/IOException GC HIJ KL MN Ojava/lang/ExceptionException occured: 9 PQ)phex/connection/ConnectionClosedException Connection closed by remote host2Negative body size. Disconnecting the remote host. R3 STU VW <X - Body too big. Header:  Body(256KB): BY.Packet too big. Disconnecting the remote host.Z [\ ]^ _` aI    7  bL Mc def g` h` ij kl m3 n, op qIr st uvw xyz {| }T - Connect headers: ~ ? GY + )phex/connection/handshake/HandshakeStatus    GNUTELLA/0.6 & < ? 89Connection not accepted:  - Response Code: ''. - Response Message: ' - Response Headers: Host rejected connection:  LNegotiate0_6Handshake   ? <0.6java/lang/StringBuffer  < +phex/connection/ConnectionRejectedException*Gnutella 0.6 connection rejected. Status:  -  X-Ultrapeer  9 IX-Try  X-Try-Ultrapeers java/util/StringTokenizer ?,  I ? ?     &  I 1phex/common/address/MalformedDestAddressException User-Agent 9 Listen-IP X-My-Address   Remote-IP phex/common/address/IpAddress   lX-Query-Routing  java/lang/NumberFormatExceptionX-Ultrapeer-Query-Routing X-Dynamic-Querying   X-Max-TTL  9X-Degree  Accept-Encodingdeflate Content-Encoding  Vendor-Message   - Send:  ISO8859-1    java/lang/Object#phex/connection/ConnectionConstants"phex/connection/ConnectionEngine$1phex/servent/ServentgetMessageService#()Lphex/msghandling/MessageService;getSecurityService%()Lphex/security/PhexSecurityManager;phex/host/Host getConnection"()Lphex/net/connection/Connection;phex/msg/MsgHeader getDataLength()Iphex/msg/MessageProcessorreadMessageBody%(Lphex/net/connection/Connection;I)[BincReceivedCountgetTTL()B getHopsTakenphex/msghandling/MessageService dropMessage;(Lphex/msg/MsgHeader;[BLjava/lang/String;Lphex/host/Host;)Vphex/prefs/core/MessagePrefs MaxNetworkTTLLphex/prefs/api/Setting;phex/prefs/api/Settingget()Ljava/lang/Object;intValuesetTTL(B)VcreateMessageFromBodyM(Lphex/msg/MsgHeader;[BLphex/security/PhexSecurityManager;)Lphex/msg/Message;append-(Ljava/lang/String;)Ljava/lang/StringBuilder; getMessage()Ljava/lang/String;toStringphex/common/log/NLoggerwarn;(Ljava/lang/Class;Ljava/lang/Object;Ljava/lang/Throwable;)VcountHopdispatchMessage%(Lphex/msg/Message;Lphex/host/Host;)Vdebug isConnected()Zphex/host/HostStatusERRORLphex/host/HostStatus; setStatus+(Lphex/host/HostStatus;Ljava/lang/String;)V disconnectparseMessageHeader8(Lphex/net/connection/Connection;[B)Lphex/msg/MsgHeader; MaxLength isWarnEnabled(Ljava/lang/Class;)Zphex/utils/HexConverter toHexString([B)Ljava/lang/String;-(Ljava/lang/Object;)Ljava/lang/StringBuilder;&(Ljava/lang/Class;Ljava/lang/Object;)Vjava/lang/SystemcurrentTimeMillis()JsetArrivalTime(J)V setFromHost(Lphex/host/Host;)V isIncomming CONNECTED(Lphex/host/HostStatus;)VgetHostService()Lphex/host/HostManager;phex/host/HostManageraddIncomingHostaddConnectedHostgetHostAddress#()Lphex/common/address/DestAddress; sendUdpPing$(Lphex/common/address/DestAddress;)VTTL byteValuepingHost(Lphex/host/Host;B)VisVendorMessageSupported%phex/msg/vendor/MessagesSupportedVMsggetMyMsgSupported)()Lphex/msg/vendor/MessagesSupportedVMsg;queueMessageToSend(Lphex/msg/Message;)V phex/msg/vendor/CapabilitiesVMsggetMyCapabilitiesVMsg$()Lphex/msg/vendor/CapabilitiesVMsg;phex/http/HTTPProcessorparseHTTPHeaders=(Lphex/net/connection/Connection;)Lphex/http/HTTPHeaderGroup;isDebugEnabledphex/http/HTTPHeaderGroupbuildHTTPHeaderString*phex/connection/handshake/HandshakeHandlercreateHandshakeHandlerT(Lphex/servent/Servent;Lphex/host/Host;)Lphex/connection/handshake/HandshakeHandler;createHandshakeResponseY(Lphex/connection/handshake/HandshakeStatus;Z)Lphex/connection/handshake/HandshakeStatus;getResponseHeaders()Lphex/http/HTTPHeaderGroup; getStatusCode(I)Ljava/lang/StringBuilder;getStatusMessageparseHandshakeResponseM(Lphex/net/connection/Connection;)Lphex/connection/handshake/HandshakeStatus;replaceHeaders CONNECTINGphex/utils/Localizer getString&(Ljava/lang/String;)Ljava/lang/String;getGnutellaNetwork()Lphex/common/GnutellaNetwork;phex/common/GnutellaNetworkgetNetworkGreeting(C)Ljava/lang/StringBuilder;(I)V,(Ljava/lang/String;)Ljava/lang/StringBuffer;createOutgoingHandshakeHeaders getHeader*(Ljava/lang/String;)Lphex/http/HTTPHeader;setConnectionTypephex/http/HTTPHeader booleanValue getHeaders+(Ljava/lang/String;)[Lphex/http/HTTPHeader;getCaughtHostsContainer"()Lphex/host/CaughtHostsContainer;getValue'(Ljava/lang/String;Ljava/lang/String;)V hasMoreTokens nextTokenjava/lang/Stringtrim#phex/net/repres/PresentationManager getInstance'()Lphex/net/repres/PresentationManager;createHostAddress6(Ljava/lang/String;I)Lphex/common/address/DestAddress;!phex/security/PhexSecurityManagercontrolHostAddressAccess=(Lphex/common/address/DestAddress;)Lphex/security/AccessType;#$SwitchMap$phex$security$AccessType[Iphex/security/AccessTypeordinalphex/common/address/DestAddress getIpAddress!()Lphex/common/address/IpAddress; isSiteLocalIPphex/host/CaughtHostsContainer addCaughtHost%(Lphex/common/address/DestAddress;S)V setVendor phex/common/address/AddressUtils parsePort(Ljava/lang/String;)IsetPortparseIP(Ljava/lang/String;)[B([B)VC(Lphex/common/address/IpAddress;I)Lphex/common/address/DestAddress;updateLocalAddressjava/lang/Float parseFloat(Ljava/lang/String;)FsetQueryRoutingSupported(Z)VsetUPQueryRoutingSupported floatValue()FsetDynamicQuerySupportedgetByteHeaderValue(Ljava/lang/String;B)B setMaxTTLgetIntHeaderValue(Ljava/lang/String;I)IsetUltrapeerDegreeisHeaderValueContaining'(Ljava/lang/String;Ljava/lang/String;)ZactivateInputInflationactivateOutputDeflationequals(Ljava/lang/Object;)ZsetVendorMessageSupportedgetBytesphex/io/buffer/ByteBufferwrap([B)Lphex/io/buffer/ByteBuffer;phex/net/connection/Connectionwrite(Lphex/io/buffer/ByteBuffer;)Vflush!" }'**+*+*+*,*, \] ^_`a&b '''i* * L* + M*+>+6*+,**+,*+d+,*:*+,*\6:*+,Y !*"#&+$**%L"++'*(*)+*+*,+L"++#*(*)+.+*,&YY/+.!0&#-&gl mp r%s+u4wCyF|W~fiy !#$,6DK\ 1 %+^)$Ei&%* * 1L+ 2Y34+ = &Y506P"7=* 8 N-9:"Y*:;+:<!=&Y>0+?@+*A+> #-=FPV4P0V* |&*B *C*D**E*FG**E*FH*F4**FI*F*EL*F**FI*F*E+*JK*B*L*M*L*N**OP**QRS*TUL*+VWM*,V-IIJIv !-4<AFIQY^ceoy  &N** XF"Y)"Y*:Z*F[!\**F]**^L+_Y*F`aM*,bE*Yc,def,gh!i,b[N*-i*hi,dȟ-&YYj,def,g!0* k:"Y|"Y*:ldem!\"Y*:ngm!\"Y*:ob[!\dȟ/&YYpdefg!0*FbqZ  :#B'N)_+g.01246:<>@=BdGoIMN4NZ_I&# *rst+*uvLY+/wxh!MyYdzN-,{W**^:|:-[{W-h{W*E-}:*i* k:*bF"Y{"Y*:ldem!\"Y*:ngm!\"Y*:o*F[!\dȟad*~YYdefg!~YYdeg!**F]a:b: *E q*Ycdefgh!i [: * i*hidȟ/~YYjdefg!!SWY8ZB[H_Ub\dfemfshyikmnprty{(}O{p 8BU\y  D &  d+N,:-*C-!*)** *B #*2:=EHPX[c4dd d]Uy#+M, *,+M, *, " ## >>*L:6+Y+2:w:ʶ:*:  .:   >:hEZ  !3;ER] RU]J  !Eg"3|#$%&'( )*++M,*,*B7+M, +M,!*ON,6 -+M,-,N-!Y-::*+M,,F% *N+M,,F% *N+M,,F% *N+>*+6*-   '+26>GLT[ _"g#k%u&'+,01386;<@ACHFKLPQSXV[]_ab>,G -u.  g"/01230123012345 67 Z+, *,+ *,N-- *"imo3s:wAyQ{Y}*ZZ ZA&89:"Y*:+!\+¶M* ,Ķ* Ʊ '29 :::';&<= "