Edit D:\app\Administrator\product\11.2.0\dbhome_1\oc4j\javacache\lib\oracle\ias\cache\groupv2\ViewManager.class
?? . ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? &!" # $ % ?& ' () 2* 2+ ^, ^- ^. / ^0 12 3 4 5 6 6 ?% 7 8 9 +% : +; ^< = > ? ?@ A B C DE ?FG Q ?H QI QJ QK ?L DMN O QP ?QRS ^T ^U V ^W X DYZ['[\ ] h^[_ ` Dabc od efg ^hi tj t_ k l[mnonp hq r s tu v wx ?yz ?{| } ~ ???? ????? ' Q???? ? ??? LOGGER_NAME Ljava/lang/String; ConstantValue READ I WRITE CURRENT LATEST MAX_VIEW_ARCHIVE VIEW_TYPE_NAMES [Ljava/lang/String; LOCK_TYPE_NAMES TOTAL_VIEW_TYPE OP_ADD_MEMBER OP_REMOVE_MEMBER OP_ADD_DISTRIBUTOR OP_REMOVE_DISTRIBUTOR parent_ *Loracle/ias/cache/groupv2/ConnectionOwner; locks_ "[Loracle/ias/cache/groupv2/RWLock; views_ [Loracle/ias/cache/groupv2/View; archivedViewsList_ Ljava/util/List; archivedViews_ Ljava/util/Hashtable; viewChangeInProgress_ Z terminate_ logger_ Ljava/util/logging/Logger; <init> -(Loracle/ias/cache/groupv2/ConnectionOwner;)V Code P(Loracle/ias/cache/groupv2/ConnectionOwner;[Loracle/ias/cache/groupv2/Address;)V L(Loracle/ias/cache/groupv2/ConnectionOwner;Loracle/ias/cache/groupv2/View;)V addMembers K(Ljava/util/Vector;Ljava/util/Vector;Ljava/util/Vector;Ljava/util/Vector;)V Exceptions?? addPendingMembersFromQ R(Loracle/ias/cache/groupv2/View;Ljava/util/Vector;)Loracle/ias/cache/groupv2/View; removeMembers 9(Ljava/util/Vector;Ljava/util/Vector;Ljava/util/Vector;)V removePendingMembers addDistributor .(Loracle/ias/cache/groupv2/RegistrationInfo;)V replaceDistributor J(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/MemberID;Z)V I(Loracle/ias/cache/groupv2/Address;Loracle/ias/cache/groupv2/MemberID;Z)V replaceCoordinator '(Loracle/ias/cache/groupv2/MemberID;Z)V merge G([Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;Z)V execute l(ILoracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/Address;)V addView "(Loracle/ias/cache/groupv2/View;)V publishNewView flush ()V updateToLatest (Z)V changeEveryoneView (Ljava/util/Vector;)V getCurrentView !()Loracle/ias/cache/groupv2/View; getLatestView getView "(J)Loracle/ias/cache/groupv2/View; viewContains '(ILoracle/ias/cache/groupv2/MemberID;)Z &(ILoracle/ias/cache/groupv2/Address;)Z indexOf '(ILoracle/ias/cache/groupv2/MemberID;)I lock (II)V unlock isInProgress ()Z setInProgress shutdown toString ()Ljava/lang/String; <clinit> ? ? $oracle.ias.cache.groupv2.ViewManager??? ? ? ? ? ? ? oracle/ias/cache/groupv2/RWLock ? ? oracle/ias/cache/groupv2/View ? ? java/util/LinkedList??? ? ? java/util/Hashtable ? ? ? ???? ?? ? ? ? ? ? ??? ??? )oracle/ias/cache/groupv2/RegistrationInfo????? ?? ?? ????? ? ? ? ? %oracle/ias/cache/commx/GroupException ? ? java/lang/Exception Unexpected error ?? !oracle/ias/cache/groupv2/MemberID?????? ? ????? %oracle/ias/cache/groupv2/PacketHolder??????? ????????? ???????? ?? ????????????????? ? ????? ??????? java/lang/StringBuffer Execution failure ???? ? ????? Add new view, id:?????? Publish new view oracle/ias/cache/groupv2/Packet ??? ????????? Unable to publish new view ? java/lang/Long?? ???????? Update view to $oracle/ias/cache/groupv2/Distributor???? ? %Going to change everyone view to vid=? ? java/util/HashSet ?????????? ? ?? Acquire ? ? Locked ? ? view for ? ? Release ? ? Unlocked ? ? &Viewchange is in progress. Latest vid= $Viewchange is completed. Latest vid= ? In progress View= , archived view size=? java/lang/String current latest $oracle/ias/cache/groupv2/ViewManager java/lang/Object java/io/IOException $java/lang/CloneNotSupportedException java/util/logging/Logger getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; java/util/Collections synchronizedList "(Ljava/util/List;)Ljava/util/List; (oracle/ias/cache/groupv2/ConnectionOwner getID %()Loracle/ias/cache/groupv2/MemberID; I([Loracle/ias/cache/groupv2/Address;Loracle/ias/cache/groupv2/MemberID;)V java/util/Vector isEmpty firstElement ()Ljava/lang/Object; getMemberID getDistributorID isInSameJVMOfDistributor getUserDefinedId getTag addMemeberTo ?(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/MemberID;ZLjava/lang/String;Ljava/lang/String;)Loracle/ias/cache/groupv2/View; remove (I)Ljava/lang/Object; *(Ljava/lang/String;Ljava/lang/Exception;)V removeDistributorFrom c(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;)Loracle/ias/cache/groupv2/View; removeMemeberFrom equals (Ljava/lang/Object;)Z size ()I elementAt getPacket #()Loracle/ias/cache/groupv2/Packet; getOrigin /()Loracle/ias/cache/groupv2/EndPointConnection; getType isARequest getData ()[B parse /([B)Loracle/ias/cache/groupv2/RegistrationInfo; getFlag '()Loracle/ias/cache/groupv2/PacketFlag; #oracle/ias/cache/groupv2/PacketFlag containsDistributor getMyAddressOn %(I)Loracle/ias/cache/groupv2/Address; setDistributorAddress %(Loracle/ias/cache/groupv2/Address;)V setDistributorID &(Loracle/ias/cache/groupv2/MemberID;)V getVMId setInSameJVMOfDistributor addClient S(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/EndPointConnection;)V getCoordinatorID setCoordinator '([B)Loracle/ias/cache/groupv2/MemberID; getDistributorAddress $()Loracle/ias/cache/groupv2/Address; addDistributorTo ?(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/Address;Loracle/ias/cache/groupv2/MemberID;)Loracle/ias/cache/groupv2/View; replaceDistributorFrom ?(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/MemberID;)Loracle/ias/cache/groupv2/View; getDistributorIDByAddress G(Loracle/ias/cache/groupv2/Address;)Loracle/ias/cache/groupv2/MemberID; replaceCoordinatorFrom d([Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;)Loracle/ias/cache/groupv2/View; java/util/logging/Level SEVERE Ljava/util/logging/Level; isLoggable (Ljava/util/logging/Level;)Z append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; log C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V FINE getViewID ()J (J)Ljava/lang/StringBuffer; .(Ljava/util/logging/Level;Ljava/lang/String;)V '(ILoracle/ias/cache/groupv2/MemberID;)V setBlockReceiver toBytes setData ([B)V sendTo i(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/Packet;Ljava/util/HashSet;Ljava/util/HashSet;)V WARNING java/util/List &(Ljava/lang/Object;)Ljava/lang/Object; (J)V add put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; FINEST getViewMonitor (()Loracle/ias/cache/groupv2/ViewMonitor; $oracle/ias/cache/groupv2/ViewMonitor reset setForRegistered (I)V getQueue (I)Ljava/util/Vector; get iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next longValue contains &(Loracle/ias/cache/groupv2/MemberID;)Z %(Loracle/ias/cache/groupv2/Address;)Z indexOfMember &(Loracle/ias/cache/groupv2/MemberID;)I acquireReadLock acquireWriteLock releaseReadLock releaseWriteLock disable (I)Ljava/lang/StringBuffer; ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? j ^*? *? ? *+? *? ? ? *? ? ? *? Y? ? ? *? Y? ? =*? ? *? ? Y? S??? ? ? ? L @*+? >*? ? 2,? *? ? Y? S? *? ? Y,*? ? ? S??? ? ? ? * *+? >*? ? *? ,S??? ? ? ? <