.w       !  " #$  % & ' ( ) *+  , -. / 0 1 2 ;3 45 `6 7 8 9:;< %= >? @ AB C D E FG /H I /B J K -L M N -OP %QR -S ;T -U V WX Y Z -[ \ ] ^ _ ` a b c d Ve fg fhi Rj k lm On o p q rs t ruv w x -y z{ -|} r~ e e e e k kQ   o o  A o   A - y  yB V   y o  o A e     y2   n   V p R  A  -     -     o r o  k o `   B O l l O  k A A -           - A  y o  y       -      B B      l O e O  O O   O ` O O   ;   -  `  A A r    /        !" o# r$%& ' ( O)* + O,- o. o/ o0 o12 3 4 p5 6 7 ;8 ;B k9 : ; < = > ?@ lAB lC D lEF { lGHI J OK  LM N O P Q lR S Tp U V /W /X Y TVZ [ \  ]^_` a lb c pd ef g lhi jk olmnopqrstuvwxyz{|}~  LOGGER_NAMELjava/lang/String; ConstantValuerole_*Loracle/ias/cache/groupv2/DistributorRole; clientEps_Ljava/util/Vector;distributorEps_distributorsTable_Ljava/util/Hashtable;distributorIDTable_ listeners_$[Loracle/ias/cache/groupv2/Listener;isInitialized_ZcoordinatorEp_-Loracle/ias/cache/groupv2/EndPointConnection;distributorLock_Ljava/lang/Object;parent_&Loracle/ias/cache/groupv2/GroupMember; clientsTable_membersToBeRemoved_membersToBeAdded_distributorsToBeRemoved_vMon_&Loracle/ias/cache/groupv2/ViewMonitor; broadcaster_1Loracle/ias/cache/groupv2/CoordinatorBroadcaster; resolver_.Loracle/ias/cache/groupv2/CoordinatorResolver; terminated_discoverAddresses_#[Loracle/ias/cache/groupv2/Address; networkIds_Ljava/util/HashSet;logger_Ljava/util/logging/Logger;Q(Loracle/ias/cache/groupv2/GroupMember;Loracle/ias/cache/groupv2/Configuration;)VCode Exceptionsinitn(ZLoracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/SequenceToken;)V bindListeners()VidentifyMyPublicAddressesfindOrBecomeCoordinator(Z)VdiscoverCoordinator%(I)Loracle/ias/cache/groupv2/Address;buildDiscoverListgetDiscoverList%()[Loracle/ias/cache/groupv2/Address;getTotalDiscoverNetwork()IgetPrimaryNetworkIDamIListeningAt%(Loracle/ias/cache/groupv2/Address;)ZconnectToCoordinator%(Loracle/ias/cache/groupv2/Address;)VconnectS(Loracle/ias/cache/groupv2/Address;II)Loracle/ias/cache/groupv2/EndPointConnection;asynclinkToOtherDistributors&([Loracle/ias/cache/groupv2/Address;)VbeACoordinator(Z)ZreplaceCoordinator recoverFromE(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;)VpromoteToCoordinatorF(Loracle/ias/cache/groupv2/View;ZLoracle/ias/cache/groupv2/MemberID;)VshutdownaddDistributoru(Loracle/ias/cache/groupv2/Address;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/EndPointConnection;)Z addClientS(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/EndPointConnection;)V sendToClient&([BLoracle/ias/cache/groupv2/Packet;)VforwardToCoordinator$(Loracle/ias/cache/groupv2/Packet;)JsendToi(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/Packet;Ljava/util/HashSet;Ljava/util/HashSet;)V sendToClientsV(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/View;Ljava/util/HashSet;)VG(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/Packet;)VsendToDistributorssendToDistributor$(Loracle/ias/cache/groupv2/Packet;)I replyToSenderQ(Loracle/ias/cache/groupv2/EndPointConnection;Loracle/ias/cache/groupv2/Packet;)V sendPacketToS([Loracle/ias/cache/groupv2/EndPointConnection;Loracle/ias/cache/groupv2/Packet;Z)VgetCoordinatorAddress$()Loracle/ias/cache/groupv2/Address;setCoordinatorEp0(Loracle/ias/cache/groupv2/EndPointConnection;)VstartAcceptingRequestwaitForInitCompleted(J)VisAlreadyConnectedTodoClientTerminationgetEndPointConnectionOfS(Loracle/ias/cache/groupv2/MemberID;Z)Loracle/ias/cache/groupv2/EndPointConnection;removeDistributorEpdoDistributorTerminationdoCoordinatorTerminationremoveDistributorFromView&(Loracle/ias/cache/groupv2/MemberID;)VcloseB(Ljava/util/Vector;Loracle/ias/cache/groupv2/EndPointConnection;)V markAsClosingaddPendingNewMember.(Loracle/ias/cache/groupv2/RegistrationInfo;)VgetMembersToBeAdded()Ljava/util/Vector;getDistributorsToBeRemovedgetMembersToBeRemovedgetDistributorAddressesdisposeConnectiongetNonExistClientsgetNonExistDistributorsgetInvalidClientEpsgetInvalidDistributorEpsgetViewMonitor(()Loracle/ias/cache/groupv2/ViewMonitor; isTerminated()ZisACoordinator isARoutersetRole(IZ)VsetAsDedicatedCoordinator mergeView#([Loracle/ias/cache/groupv2/View;)Venqueue+(ILoracle/ias/cache/groupv2/PacketHolder;)Vdequeue+(IJ)Loracle/ias/cache/groupv2/PacketHolder;toString()Ljava/lang/String;DI oracle.ias.cache.groupv2.Client   java/lang/Object  java/util/Vector  java/util/Hashtable      (oracle/ias/cache/groupv2/DistributorRole             $java/lang/CloneNotSupportedException%oracle/ias/cache/commx/GroupException Unable to restore sequence token        $oracle/ias/cache/groupv2/ViewMonitor         No listener defined !oracle/ias/cache/groupv2/Listener      oracle/ias/cache/groupv2/Address             oracle/ias/cache/groupv2/View  java/lang/Integer           Unable to locate the coordinator     java/lang/InterruptedException java/lang/StringBufferHUnable to find or become a group coordinator after reaching retry limit:   'oracle/ias/cache/groupv2/GcommException  oracle/ias/cache/groupv2/Packet        oracle/ias/cache/groupv2/Sender          Found coordinator at       java/util/HashSet java/util/TreeSet               Expect reply of , got       Connected to coordinator       java/lang/Exception      java/net/Socketjava/net/InetSocketAddress   Connected to distributor at +oracle/ias/cache/groupv2/EndPointConnection   java/io/IOExceptionUnable to connect to , retry= "No other distributors to be linked    !" # $ %Unhandled duplicated EndPoint Connected to distributor Unable to add distributor &   ' /oracle/ias/cache/groupv2/CoordinatorBroadcaster (,oracle/ias/cache/groupv2/CoordinatorResolver )* + , - . / 0 1 Won coordinator electionLost coordinator election 2%Unable to replace current coordinatorRecover from view ID= 3 4    5 6  74Unable to ask coordinator to recover the distributorPromoting to coordinator 89 :  Shutting down  ; <=  . >(PacketProcessor shutdown is interrupted:  ? @ #Encountered duplicated distributor A B Add EndPoint CDEncountered duplicated client  Add client No connection to client: Forward to coordinator E FForward  to Vid:   GHNo clients for Unable to send IJReply to sender directly K L M N to O P Q  R S T U V    URemoved connection for member: WXAlready removed: YX Z[ \]8Retry notifying coordinator for a disconnected member: ^_Lost connection Removed distributor connection  `a bUngraceful disconnection for c    de fgh   i j !oracle/ias/cache/groupv2/MemberID k l m Set new role *Unable to run as the dedicated coordinator Merge views  no p q rD put s t %oracle/ias/cache/groupv2/PacketHolder u remove high priority v  Viewchange in progress. Hold  remove is being terminated, is the coordinator Listeners: #.  Coordinator Connection=[] Client Connections: #,  Client Connection Endpoints:# Distributor Connection Endpoints: Distributor Connections:  Pending members to be removed: Distributors to be added: Pending members to be added: $oracle/ias/cache/groupv2/Distributor(oracle/ias/cache/groupv2/ConnectionOwner=(Loracle/ias/cache/groupv2/Configuration;Ljava/lang/String;)Vjava/util/logging/Logger getLogger.(Ljava/lang/String;)Ljava/util/logging/Logger;&oracle/ias/cache/groupv2/ConfigurationisRoutergetServerSocket()Ljava/net/ServerSocket;java/net/ServerSocket getLocalPortgenerate&(I)Loracle/ias/cache/groupv2/MemberID;setIDsetSequenceToken+(Loracle/ias/cache/groupv2/SequenceToken;)V*(Ljava/lang/String;Ljava/lang/Exception;)V/oracle/ias/cache/groupv2/PacketProcessorFactorycreateAPacketProcessorOfV(Loracle/ias/cache/groupv2/ConnectionOwner;)Loracle/ias/cache/groupv2/PacketProcessor;packetProcessor_*Loracle/ias/cache/groupv2/PacketProcessor;(oracle/ias/cache/groupv2/PacketProcessorstartcreateViewManager)(Loracle/ias/cache/groupv2/Distributor;)V getConfig*()Loracle/ias/cache/groupv2/Configuration;isDedicatedCoordinatorgetListenerAddresses(Ljava/lang/String;)V getBacklogL(Loracle/ias/cache/groupv2/Address;ILoracle/ias/cache/groupv2/Distributor;)VgetDiscoverAddressessize elementAt(I)Ljava/lang/Object;addPublicAddressgetMaxSystemInitRetrygetConfirmedNormineeAddressiterator()Ljava/util/Iterator;java/util/IteratorhasNextnext()Ljava/lang/Object;intValuegetViewManager(()Loracle/ias/cache/groupv2/ViewManager;$oracle/ias/cache/groupv2/ViewManagergetCurrentView!()Loracle/ias/cache/groupv2/View;clone addElement(Ljava/lang/Object;)VtoArray(([Ljava/lang/Object;)[Ljava/lang/Object;java/util/logging/LevelFINESTLjava/util/logging/Level; isLoggable(Ljava/util/logging/Level;)ZINFOlog.(Ljava/util/logging/Level;Ljava/lang/String;)VgetResolutionTimeout()Jjava/lang/ThreadsleepgetResolutionIntervalSEVEREappend,(Ljava/lang/String;)Ljava/lang/StringBuffer;(I)Ljava/lang/StringBuffer; INITRETRYgetID%()Loracle/ias/cache/groupv2/MemberID;'(ILoracle/ias/cache/groupv2/MemberID;)VsetBlockReceivergetMyAddressOntoBytes()[BsetData([B)V(I)V getNetworkIdgetConnectTimeout(Loracle/ias/cache/groupv2/Distributor;Loracle/ias/cache/groupv2/Address;Loracle/ias/cache/groupv2/Packet;ILjava/util/Vector;Ljava/util/Hashtable;IZI)Vput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; firstElement removeElement(Ljava/lang/Object;)ZgetReply#()Loracle/ias/cache/groupv2/Packet;getFlag'()Loracle/ias/cache/groupv2/PacketFlag;#oracle/ias/cache/groupv2/PacketFlagcontains(I)ZgetDataparse&([B)Loracle/ias/cache/groupv2/Address;,(Ljava/lang/Object;)Ljava/lang/StringBuffer;keys()Ljava/util/Enumeration;java/util/EnumerationhasMoreElements nextElementget&(Ljava/lang/Object;)Ljava/lang/Object;waitgetMyPublicAddresses(Ljava/util/Collection;)Vadd isListenedBy(Ljava/net/ServerSocket;)Zjava/lang/SystemcurrentTimeMillisgetConnectRetrysetAsDistributorgetVMId getCacheName)oracle/ias/cache/groupv2/RegistrationInfowrap(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/Address;ZLjava/lang/String;Ljava/lang/String;Ljava/lang/String;)Loracle/ias/cache/groupv2/RegistrationInfo;send$(Loracle/ias/cache/groupv2/Packet;)VreadgetTypeFINE(Z)Ljava/lang/String; REGISTRATION getOrigin'([B)Loracle/ias/cache/groupv2/MemberID;setType#([B)Loracle/ias/cache/groupv2/View;addView"(Loracle/ias/cache/groupv2/View;)VupdateToLatest&(I)[Loracle/ias/cache/groupv2/Address;*(Ljava/lang/String;Ljava/lang/Throwable;)V getHostNamegetPort isSSLEnabled getSSLManager'()Loracle/ias/cache/groupv2/SSLManager;#oracle/ias/cache/groupv2/SSLManagercreateSSLSocket()Ljava/net/Socket;(Ljava/lang/String;I)V(Ljava/net/SocketAddress;I)V setSoTimeoutgetEpThreadGroup()Ljava/lang/ThreadGroup;V(Ljava/lang/ThreadGroup;Ljava/net/Socket;ILoracle/ias/cache/groupv2/ConnectionOwner;)VsetRemoteAddressgetConnectRetryDelayequals containsKey getEndPoint/()Loracle/ias/cache/groupv2/EndPointConnection;isAReplysetTightlyBoundgetDestinationC(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)VisUseMulticastResolution+(Loracle/ias/cache/groupv2/Distributor;ZZ)VgetMulticastSocket()Ljava/net/MulticastSocket;F(Loracle/ias/cache/groupv2/Distributor;Ljava/net/MulticastSocket;ZJI)VN(Loracle/ias/cache/groupv2/Distributor;[Loracle/ias/cache/groupv2/Address;ZZ)V,(Loracle/ias/cache/groupv2/Distributor;ZJI)VjoincanBeCoordinatorconfirmNomineesetToConnectedMembersOnly'(Loracle/ias/cache/groupv2/MemberID;Z)V getViewID(J)Ljava/lang/StringBuffer;getCoordinatorID isTerminating&(Loracle/ias/cache/groupv2/MemberID;)ZreplaceDistributorFrom(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/MemberID;)Loracle/ias/cache/groupv2/View;setCoordinatorgetDisconnectTimeoutwaitForEmptyQueue(IJ)VWARNINGclearcleanupsetRemoteMemberID setNetworkIdTYPE[Ljava/lang/String; getSequenceFINERgetAllMembersOfI(Loracle/ias/cache/groupv2/MemberID;)[Loracle/ias/cache/groupv2/MemberID;getDistributorIDs&()[Loracle/ias/cache/groupv2/MemberID;setDestination setOrigin setAsReplysetAcksetAsCoordinator setAsRouterw(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/EndPointConnection;)Loracle/ias/cache/groupv2/PacketHolder;getRemoteAddressisAliveDISTRIBUTORINITTIMEOUTremovegetRemoteMemberIDlock(II)VunlockgetQueue(I)Ljava/util/Vector; removeMembers9(Ljava/util/Vector;Ljava/util/Vector;Ljava/util/Vector;)V viewContains'(ILoracle/ias/cache/groupv2/MemberID;)ZhasAnyMembersFrom'(Loracle/ias/cache/groupv2/MemberID;Z)ZdestroytoBeDisconnected addMembersK(Ljava/util/Vector;Ljava/util/Vector;Ljava/util/Vector;Ljava/util/Vector;)VkeySet()Ljava/util/Set; java/util/SettoPauseresethasset setPrefixmergeG([Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;Z)VgetQueueStatus getPacketQUEUE_TYPE_NAMES notifyAll isInProgressremoveElementAt isARequest B*,**+*Y * Y * Y *Y*Y*Y* Y * Y * Y * Y *Y, *%****2 !*"*#:%Y&'**()*)**+*, *,--*.*/Y*01*12*3*45*6*7(.1$%RF*48L+ %Y9:*+;=+!*;Y+2*4<*=S߱%;/*4>L=+?+@AN*-B*-C߱%} a=N*4D*E0*F *FGN-*H **IJN-*-K*LM: Y :*LNO:6P9QR:*SJN-*-K*TUVW: ?6O:XW*6 *Y*Z[*\]^*_,*FG*4`a *4ba:*4D8*d[ *deYfghij^kYlm$c% M*nN- -oY*pq:r*stuY-v: Y-w:6-D-2x3yY*-2*4z{:-2|W}~ ??y:W:M*\[ *\eYfh,j^Y: ~6:  % :  y:    ç :   ,Y::ç:,UXX]Xhpschx{{{%*YL*4> L+ +? *H*M>,+,2W+? *HY+N*-AH-*HW6*H+*H2x6*LRYWѱ*H*LN *H2x6*=>*+*2=  A**+*4z*4oY *pq:*p*+xs*4:ur*:*:d*[/*eYfhhhj^ e*4z**kYm:**+*W*\[!*\eYfhj^*:*T*T*+x%:***kY_Y\%? +:+6::6*4*: Y:Y:  *[!*eYfŶh j^Y*+x*:+ɧR:  ʧ: *[4*eYf̶h+Ͷhiζh j^*4υa: #c e+ +*Z[*Zж^+2x=oY*pqN-*stu-rY+v: Y+w:6+^+2*sњI*+2ҙ8yY*+2-*4z*4{:+2|W}~ ??jy:W::BԚ:*d[*deYfh-hj^s: * 6  1*d[*deYf׶hj^s7**\[O*\eYfh j^.*\[!*\eYfٶh j^: *d[*d ۧY::çk:  n #IQTcIY\\a\% x=*nN*3-*** *ݶ*F *F*49*Y**Y**ݶ*4`-FO*Y*-6 -6 *~6*Y**4`F*ݶ*F7*F:*F\***ݶ **F**4`i*\[*\^=**F*ݶ*\[*\^c%2*T*pM*d,۱ M )*\[#*\eYfh+j^+ *+,+N-*s-њ*-K:**3 *.*3 *+,oY*pq:*stur66*TU:q*j *X6*TU:*p 6 6::*d*4`a:CX[% #c%t*\^+-*p:*p**E*n::* *ݶ*Y**ݶ**4`i% *\[$*\eYfh*j^*F *F* *ݶ=**2 *2*** ** **4  **4  foY*pqM,r,*p u* YN6* ?(* @: *, :-ç :-*)*) *)*4 M*,* ** * ** ** ** ******1 *1**!c%* Y:*,ҙ3*d[!*deYfh,j^ì--,-+-+x* -W*+-|W*,-|W*Z[1*ZeYfh-2hζh,j^ç :BC%* YN*+ҙ1*d[!*deYfh+j^-ñ,,+*+,|W* , * ,W*[!*eYfh+j^-ç :-?@%WK*+N- *-, 1*d[$*deYf h+j^%E9*Z[!*ZeYf!h+j^**+ +"%TH*#[.*#eYf$h,%h+j^*,+-&*,+'%$ ,*p(:2*[$*eYf)h*pj^*Y:6f--2*P*2::*+ 0:*[!*eYf+h+j^ç :  w~F%]*YN*+::*, 0:*[!*eYf+h,j^-ç :- #RUUYU% ,,:*Y:6u*p2`--2*P*2::*+ 0:*[!*eYf+h+j^ç :  NUX%]*YN*+::*, 0:*[!*eYf+h,j^-ç :- #RUUYU% =*YN*~-ì*:k:*p*:*+ :*[!*eYf+h+j^-ç :-U_b \P*Z[!*ZeYf-h,j^,N,-.,*p/,0,,"1*+, %t`6+X+2 *+2, ?:*d[0*deYf+h,2h+2jۄ :.,*3 ,3*E ,4*,+56%* *7 +*+3'<**28 *29߱YB!e8* Y:*7 ç#* :ç ::ĸ!ekY<m 3#03383 >c#;>c% *+Ҭ2&* +=W+>M,*+?*+@ *,+A%$*YN*+BW*[!*eYfCh+j^-ç :-*TD*TUN-+8*Z[!*ZeYfEh+j^*TF*TF:*TF>*TU:**3C*Y:*+ *+Wç :*T***GHVoY*pq:+ u*X>3:*\[$*\eYfIh*pj^,W*4`J:1*T+K"*TU:%:>=@@D@P&/2bnqc%$~RN+-%*Y:*+Nç-:*Y:*+Nç :-#&&+&6EHHMH +7M+>N,*\[!*\eYfLh+j^*Y::*:-:*:+*BWç :*Y:*-Wç :  * +=W, *,BW*[!*eYfMh-j^B%j+7M+>N,6U*N*3*-N6*T-K6+Y:+*4bç ::HVYY^YCadc%$jV*+>M*+?>C*<*_ *,N>*4`a:*T,K>.8;c%$*TUM,+O@B!e*4`,*%*4ba:*TUM,+ͧ,+D*=*YN*+ *+W-ç :-*T***GH,69dy|||%$+YN6+?c+@:,L*4 P8:Q*[$*eYfRhjۄ-ç :-+&25cruuyuU9+YN6+?+@:,S-ç :-.1151N2*YM*+W,çN,-*T*T*U*V*GW%$***[?L*YM*&*~*~AL*X+YW,çN,-+ 588;8*+Z$*+Zj*+?*[\*+@*[]*[\FM*[]*[\,*[\*+^*[]*[\N*[]*[\-5BTTUTfs%$QE*TUL+*p(M Y N,)6,*,2Қ -,2W-%[O*TUL Y M+,N-76--*-2Қ-2*p ,-2W,%t Y L*YM*XN-N*TU:-_`:-YW6&2+*2W,ç :,+hkkok%t Y L*YM*XN-N*TU:-_`:-YW6&2+*2W,ç :,+hkkok%*1 *   *a   *a  VJ*b**cd*p1*\[$*\eYfeh*pj^xd*b**cdoY*pqL+r*+X*T*p+L*d[*df+ۻkY+8;%*\[*\g^*b**cdoY*pqM,r>+**+2h, *T+*pi+M*d[*df,ۻkY,.kn%i*GN-Y:*jñ,k:-,W*Z[**ZeYfl2hmhj^-nç : `]``e` :*G:Y:? ::D*3=*To36?@p:k:ԙa Dq*Z[**ZeYfl2hrhj^ðzp:k:sQH:*Z[**ZeYfl2hthj^ :q*Z[x*ZeYfl2huhj^Np:k:q*Z[**ZeYfl2huhj^ç :  !c$*-c (eYfL* +vhW*3 +whW*G*?+xhW=*,+yhW+`iW+zhW+*2W*+{hW+*W+|hW+}hW*s*YM*N6-Q-H-`:+~hW+iW+zhW+W+hW+*W,ç :,* V+hW* YM>* ?.+yhW+`iW+zhW+* @W,ç :,* V+hW* YM>* ?.+yhW+`iW+zhW+* @W,ç :,+hW*d*YM*N6-B-9-`:+yhW+iW+zhW+*W,ç : , *F+hW*YM>*?+*@W+hW,ç : , *F+hW*YM>*?+*@W+hW,ç : , *F+hW*YM>*?+*@W+hW,ç : , +hW+*hW+j    &`ccgc*--1-Jtww{w