4 E E E E E E E E E E E E E E E E E   E    E  E    E        E  E E  E E   E 8 E 8          G G  G  G N G G G  G F  E E 8 F    ^ E  8  ! E" F # $ E% E& E' E()* m+, p-./ r+ 01 023 E456 y+ 78 9: 0;<  => ? @A EBC D 0E F 0G H I ,J EKL M NO EPQ R S TU yV W XY Z[ Z\ E]  ^ F_ `a b pc Zd  e fg `h ij 9k pl Xmn op qrs Xt Euvwx y  z{ + p |} InnerClassesInetSocketAddressCache~ AuthCallbackInitConnectionTask#ClientConnectionChannelErrorHandlerTimeoutAuthenticationTaskDEFAULT_SSL_THREAD_COUNTI ConstantValueconnectionIdGen+Ljava/util/concurrent/atomic/AtomicInteger;aliveZloggerLcom/hazelcast/logging/ILogger;connectionTimeoutMillisclientBLcom/hazelcast/client/impl/clientside/HazelcastClientInstanceImpl;executionService1Lcom/hazelcast/client/spi/ClientExecutionService;inetSocketAddressCacheXLcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl$InetSocketAddressCache;activeConnections$Ljava/util/concurrent/ConcurrentMap; SignaturexLjava/util/concurrent/ConcurrentMap;connectionsInProgress|Ljava/util/concurrent/ConcurrentMap;connectionListenersLjava/util/Collection;>Ljava/util/Collection;allowInvokeWhenDisconnected networking5Lcom/hazelcast/internal/networking/nio/NioNetworking; heartbeat6Lcom/hazelcast/client/connection/nio/HeartbeatManager;authenticationTimeoutJconnectionStrategy:Lcom/hazelcast/client/connection/ClientConnectionStrategy; outboundPortsLjava/util/LinkedList;+Ljava/util/LinkedList;labelsLjava/util/Set;#Ljava/util/Set;outboundPortCountfailoverConfigProvidedlastCredentials$Lcom/hazelcast/security/Credentials; principal2Lcom/hazelcast/client/impl/client/ClientPrincipal;clusterPartitionCountLjava/lang/Integer; clusterIdLjava/lang/String;ownerConnectionAddressLcom/hazelcast/nio/Address;currentClusterContext>Lcom/hazelcast/client/impl/clientside/CandidateClusterContext;E(Lcom/hazelcast/client/impl/clientside/HazelcastClientInstanceImpl;)VCodeLineNumberTableLocalVariableTablethisALcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl; networkConfig1Lcom/hazelcast/client/config/ClientNetworkConfig; connTimeout StackMapTablegetOutboundPortsI(Lcom/hazelcast/client/config/ClientNetworkConfig;)Ljava/util/Collection;outboundPortDefinitionsLocalVariableTypeTable+Ljava/util/Collection;*Ljava/util/Collection;^(Lcom/hazelcast/client/config/ClientNetworkConfig;)Ljava/util/Collection; getNetworking7()Lcom/hazelcast/internal/networking/nio/NioNetworking;initNetworkingy(Lcom/hazelcast/client/impl/clientside/HazelcastClientInstanceImpl;)Lcom/hazelcast/internal/networking/nio/NioNetworking; inputThreads outputThreads properties2Lcom/hazelcast/spi/properties/HazelcastProperties; sslConfig Lcom/hazelcast/config/SSLConfig; sslEnabledconfiguredInputThreadsconfiguredOutputThreadsgetConnectionStrategy<()Lcom/hazelcast/client/connection/ClientConnectionStrategy;getActiveConnections()Ljava/util/Collection;P()Ljava/util/Collection;isAlive()Zstart()VstartNetworkingshutdown connectionLcom/hazelcast/nio/Connection; getPrincipal4()Lcom/hazelcast/client/impl/client/ClientPrincipal; setPrincipal5(Lcom/hazelcast/client/impl/client/ClientPrincipal;)VstopNetworkinggetActiveConnection;(Lcom/hazelcast/nio/Address;)Lcom/hazelcast/nio/Connection;target getOrConnectaddress ExceptionsgetOrTriggerConnect<(Lcom/hazelcast/nio/Address;Z)Lcom/hazelcast/nio/Connection;acquiresResources getConnection=(Lcom/hazelcast/nio/Address;ZZ)Lcom/hazelcast/nio/Connection;asOwner6Lcom/hazelcast/client/connection/nio/ClientConnection;, checkAllowed (Lcom/hazelcast/nio/Address;ZZ)Ve6Lcom/hazelcast/client/HazelcastClientOfflineException;3getOwnerConnectionAddress()Lcom/hazelcast/nio/Address;future:Lcom/hazelcast/client/connection/nio/AuthenticationFuture;Ljava/lang/Throwable;<8triggerConnectX(Lcom/hazelcast/nio/Address;Z)Lcom/hazelcast/client/connection/nio/AuthenticationFuture; oldFuturegetOwnerConnection8()Lcom/hazelcast/client/connection/nio/ClientConnection;fireConnectionAddedEvent9(Lcom/hazelcast/client/connection/nio/ClientConnection;)VconnectionListener&Lcom/hazelcast/nio/ConnectionListener;fireConnectionRemovedEventlisteneruseAnyOutboundPortacquireOutboundPort()Iport|bindSocketToPort(Ljava/net/Socket;)V socketAddressLjava/net/SocketAddress;Ljava/io/IOException;i retryCountexsocketLjava/net/Socket;5createSocketConnectionS(Lcom/hazelcast/nio/Address;)Lcom/hazelcast/client/connection/nio/ClientConnection;channelInitializer>Lcom/hazelcast/internal/networking/ChannelInitializerProvider;channel+Lcom/hazelcast/internal/networking/Channel;socketInterceptor%Lcom/hazelcast/nio/SocketInterceptor;Ljava/lang/Exception; remoteAddress socketChannel!Ljava/nio/channels/SocketChannel;honClose!(Lcom/hazelcast/nio/Connection;)VremoveFromActiveConnectionsendpointaddConnectionListener)(Lcom/hazelcast/nio/ConnectionListener;)VgetLastCredentials&()Lcom/hazelcast/security/Credentials;setCandidateClusterContextA(Lcom/hazelcast/client/impl/clientside/CandidateClusterContext;)VcontextbeforeClusterSwitchactiveConnection access$300D(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Jx0 access$400b(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Lcom/hazelcast/logging/ILogger; access$500(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl$InetSocketAddressCache; access$600g(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Ljava/util/concurrent/ConcurrentMap; access$700(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Lcom/hazelcast/client/impl/clientside/HazelcastClientInstanceImpl; access$800D(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Z access$900t(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Lcom/hazelcast/client/spi/ClientExecutionService; access$1000(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Lcom/hazelcast/client/impl/clientside/CandidateClusterContext; access$1102(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;Lcom/hazelcast/security/Credentials;)Lcom/hazelcast/security/Credentials;x1 access$1200U(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Ljava/lang/String; access$1300R(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Ljava/util/Set; access$1400V(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;)Ljava/lang/Integer; access$1500 access$1402i(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;Ljava/lang/Integer;)Ljava/lang/Integer; access$1202g(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;Ljava/lang/String;)Ljava/lang/String; access$1600v(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;Lcom/hazelcast/client/impl/client/ClientPrincipal;)V access$1702y(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/nio/Address; access$1800z(Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl;Lcom/hazelcast/client/connection/nio/ClientConnection;)V access$1900 SourceFile ClientConnectionManagerImpl.java Y XY 56  -)java/util/concurrent/atomic/AtomicInteger Vcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl$InetSocketAddressCache &java/util/concurrent/ConcurrentHashMap)java/util/concurrent/CopyOnWriteArrayList java/util/LinkedList        7com/hazelcast/client/connection/ClientConnectionManager   `java/lang/Integer   %&   ` 4com/hazelcast/client/connection/nio/HeartbeatManager    ( (   +   ?com/hazelcast/client/connection/nio/ClientConnectionManagerImpl3com/hazelcast/internal/networking/nio/NioNetworking;com/hazelcast/internal/networking/nio/NioNetworking$ContextContext     ccom/hazelcast/client/connection/nio/ClientConnectionManagerImpl$ClientConnectionChannelErrorHandler        ( .- ,-  + com/hazelcast/nio/Connection!Hazelcast client is shutting down  7- - /- -   ;? BC ST GHjava/lang/IllegalStateExceptionAddress can not be null 4com/hazelcast/client/connection/nio/ClientConnection +6com/hazelcast/client/HazelcastClientNotActiveException ConnectionManager is not active!  4com/hazelcast/client/HazelcastClientOfflineException VWjava/io/IOException"Owner connection is not available! java/lang/Throwable  8com/hazelcast/client/connection/nio/AuthenticationFuture Rcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl$InitConnectionTask   89$com/hazelcast/nio/ConnectionListener  Y  Y   ` ^+java/net/InetSocketAddress   _`java/lang/StringBuilderCould not bind port[  ]:     k cd    `       djava/lang/Exception   M + Destroying K, but it has end-point set to null -> not removing it from a connection map  Removed connection to endpoint: , connection:  \Y1Destroying a connection, but there is no mapping  ->  in the connection map. 7com/hazelcast/spi/exception/TargetDisconnectedException)Closing since client is switching clusterjava/lang/ObjectAcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl$1Lcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl$AuthCallbackYcom/hazelcast/client/connection/nio/ClientConnectionManagerImpl$TimeoutAuthenticationTask@com/hazelcast/client/impl/clientside/HazelcastClientInstanceImpl/com/hazelcast/client/config/ClientNetworkConfig0com/hazelcast/spi/properties/HazelcastPropertiescom/hazelcast/config/SSLConfigjava/util/Iteratorjava/net/Socketjava/net/SocketAddresscom/hazelcast/nio/Addressjava/nio/channels/SocketChannel*-.*+/ **+01*+23**,45W**67*8Y*+9:**:;*+< ^~`gh&j1l<sGUZhw*m h  F      W    |+=M+>N,-? *     /*1  + M+$*@N--A6,BC6,DC66666FYGYH+'I+JK+LMNY*OPQR,SCTUR"+4:IMSbfryp F_" +!4v"M]fD " #$@"@@%&/*3 '(4 *V  )*+/*W !,-`*W*W*X*:Y   .-6*1Z  !/-^*W*W*V[L+\+]^M,_`*a*b*:c* * d2  /8;?HOV]/ 01^ 2!34/*e 56>*+e 7-6*1f  89`+**+gh^: ;9;*+i<=y>?}*+jN--*+kW    *:@01 A=yBCD*+l+ mYno**+ghp:q*  +047?B 4DD:DDD@+0E !F =yGHX*W rYst *3+u*3+v:*#*x*#yYz{&)wB$%'(*-&4).+/6173:5A6L8M:W<4+IJXX:XDX@  JK K =yLM/*@ ;?:*+jpN--*+k:|pN--q-N-~4}'4}(04}144}2 F GHJK"M&N(P/Q1S4T5U> &0ENO5IP::<:D FQBRSTI *3+YN**+g-:* Y*+--"Z[ ^_+`0aDbFd4II:ID5NO+UO  9QQVWP***pij l   XY0*[M,\,]N-+*3+pq$r's/t Z[000E  2\Y0*[M,\,]N-+*3+wx$y'z/{ ][000E  2^+B *7~    @_`/*7*YL*,M*,,+ìN+-)**-* #*a/   bRcd~*YM+,j*7h=N6V*6Y:+:N*Y-AGHyN!*056AGHJMw}\ efJ-Ig0GaA6ef$Yh`i!^jgkl . m nmom4=ypqMM,N*-* :*1,:*+g*.pY* *:,W* : -N,-yuvJ ':FPV_dlsvw{\ kkl]rs'OtuP&0E_vww Ixyz{ 4l |}n~F  |}=yA *+p   01Y)+M,1*$*Y+**,g+0*Y,+*+9*-*Y,+.  67Lqy 0E 6|A5D *+W    Z[/*  Z* +*+    Z*V[M,\,]pN-Y* * d***+ * * "03:AFMRY "EZZ 2# /*\ /*\ /*\ /*\ /* \ /* \ /* \ /* \ ;*+Z \/*\ /*\ /*\ /*\ ;*+Z\;*+Z\:*+\;*+Z\:*+\E:*+\E:E EENEEGF