4%com/hazelcast/nio/tcp/TcpIpConnectionjava/lang/Objectcom/hazelcast/nio/ConnectionTcpIpConnection.javachannel+Lcom/hazelcast/internal/networking/Channel;endpointManager,Lcom/hazelcast/nio/tcp/TcpIpEndpointManager;alive+Ljava/util/concurrent/atomic/AtomicBoolean;bindingloggerLcom/hazelcast/logging/ILogger; connectionIdI ioServiceLcom/hazelcast/nio/IOService;endPointLcom/hazelcast/nio/Address; errorHandler3Lcom/hazelcast/nio/tcp/TcpIpConnectionErrorHandler;type"Lcom/hazelcast/nio/ConnectionType;lifecycleListener/Lcom/hazelcast/nio/ConnectionLifecycleListener; closeCauseLjava/lang/Throwable; closeReasonLjava/lang/String;(Lcom/hazelcast/nio/tcp/TcpIpEndpointManager;Lcom/hazelcast/nio/ConnectionLifecycleListener;ILcom/hazelcast/internal/networking/Channel;)V()V !# $)java/util/concurrent/atomic/AtomicBoolean&(Z)V !( ') + '$  . com/hazelcast/nio/ConnectionType0NONE 2 13  5  7 9  ;*com/hazelcast/nio/tcp/TcpIpEndpointManager=getNetworkingService'()Lcom/hazelcast/nio/NetworkingService; ?@ >A#com/hazelcast/nio/NetworkingServiceC getIoService()Lcom/hazelcast/nio/IOService; EF DG  Icom/hazelcast/nio/IOServiceKgetLoggingService(()Lcom/hazelcast/logging/LoggingService; MN LO$com/hazelcast/logging/LoggingServiceQ getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; ST RU  W  Y)com/hazelcast/internal/networking/Channel[ attributeMap&()Ljava/util/concurrent/ConcurrentMap; ]^ \_"java/util/concurrent/ConcurrentMapaput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; cd bethis'Lcom/hazelcast/nio/tcp/TcpIpConnection; getChannel-()Lcom/hazelcast/internal/networking/Channel;getType$()Lcom/hazelcast/nio/ConnectionType;setType%(Lcom/hazelcast/nio/ConnectionType;)VMEMBER o 1pjava/lang/StringBuilderr s$+Initialized new cluster connection between uappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; wx sylocalSocketAddress()Ljava/net/SocketAddress; {| \}-(Ljava/lang/Object;)Ljava/lang/StringBuilder; w s and remoteSocketAddress | \toString()Ljava/lang/String; scom/hazelcast/logging/ILoggerinfo(Ljava/lang/String;)V getConnectionType()I&Lcom/hazelcast/internal/metrics/Probe;ordinal 1tgetEndpointManager.()Lcom/hazelcast/nio/tcp/TcpIpEndpointManager;getInetAddress()Ljava/net/InetAddress;socket()Ljava/net/Socket; \java/net/Socket getPort getRemoteSocketAddress()Ljava/net/InetSocketAddress;java/net/InetSocketAddressisAlive()Zget 'lastWriteTimeMillis()J \lastReadTimeMillis \ getEndPoint()Lcom/hazelcast/nio/Address;   setEndPoint(Lcom/hazelcast/nio/Address;)VsetErrorHandler6(Lcom/hazelcast/nio/tcp/TcpIpConnectionErrorHandler;)V  getConnectionIdisClient 1write4(Lcom/hazelcast/internal/networking/OutboundFrame;)Z \isFinestEnabled ,Connection is closed, won't write packet -> finest frame1Lcom/hazelcast/internal/networking/OutboundFrame;hashCode isClientMode \java/lang/BooleanvalueOf(Z)Ljava/lang/Boolean; java/lang/Integer(I)Ljava/lang/Integer; hash([Ljava/lang/Object;)I equals(Ljava/lang/Object;)ZgetClass()Ljava/lang/Class; '(Ljava/lang/Object;Ljava/lang/Object;)Z objLjava/lang/Object;otherclose*(Ljava/lang/String;Ljava/lang/Throwable;)Vjava/lang/Exception compareAndSet(ZZ)Z '    logClose #  # \warning(Ljava/lang/Throwable;)V  -com/hazelcast/nio/ConnectionLifecycleListeneronConnectionClose7(Lcom/hazelcast/nio/Connection;Ljava/lang/Throwable;Z)V     onDisconnect3(Lcom/hazelcast/nio/Address;Ljava/lang/Throwable;)V   L1com/hazelcast/nio/tcp/TcpIpConnectionErrorHandleronError  eLjava/lang/Exception;reasoncause setBindingresolveLogLevelOnClose()Ljava/util/logging/Level;   isLoggable(Ljava/util/logging/Level;)Z  !java/util/logging/Level#  closed. Reason: &java/lang/String(java/lang/Class*getName , +-[/java/lang/Throwable1 getMessage 3 24]6Socket explicitly closed8FINESTLjava/util/logging/Level; :; $< $>logC(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V @A Bjava/io/EOFExceptionD'java/nio/channels/CancelledKeyExceptionF.(Ljava/util/logging/Level;Ljava/lang/String;)V @H IlogLevelmessageisActive M LN REST_CLIENT P 1QMEMCACHE_CLIENT S 1TFINE V; $WINFO Y; $ZWARNING \; $] getCloseCause()Ljava/lang/Throwable;getCloseReasonConnection[id=b(I)Ljava/lang/StringBuilder; wd se, g->i , qualifier=kgetEndpointQualifier,()Lcom/hazelcast/instance/EndpointQualifier; mn >o , endpoint=q, alive=s, type=ujava/util/Arraysw xyvalues[Ljava/lang/Object; >ab%()Lcom/hazelcast/nio/EndpointManager; CodeLineNumberTableLocalVariableTable StackMapTableRuntimeVisibleAnnotations SourceFile!     BBBB !"i*%*'Y*,*'Y-/*46*8*+:*,<*+BHJ**JPVX*Z`*fW2 T:=I"U'V,W1X>YRZX[h\4ighi iii ij/*Z_ ghkl/*6d ghmnM*64*+6+q8*XsYtvz*Z~z*Z @"i j mno+pGoLrMghMZ*6L++  1C vwgh /*:{ gh7 *Z  gh7 *Z  gh7 *Z  gh2*, gh4 *Z  gh4 *Z  gh/* gh>*+ gh>*+ gh/*8 ghe*6L++4+ę 1@ gh9*Z+*X*XsYtͶz+' 79gh9K!Y*ZSY*8S !ghS*++*++M*Z,Z *8,8*,  6@*  GR SghS4h`*,*,*+**ZN*X-*<* *J*,,* *,$'  Y ,: $'(2>LW_*( `gh` `4 */  gh#*L*X+"sYt*%z'zM*sYt,z*zMT*8sYt,z*.z0z*5z7zMsYt,z9zM=+?*X+,*C;**E *G*X+,J*X+,*C$7); >+2KR ghK;+L K*JO=**E *G*6R *6UX[^  +?CG Kgh_`/* gha_** *5*F)!"$ ghysYtcz*8fhz*Z~jz*Zlz*:prz*tz*,vz*67z*+B,x* ygh/*z4 {| W*+**+}@8~A/*2 gh