Edit D:\app\Administrator\product\11.2.0\dbhome_1\oc4j\javacache\lib\oracle\ias\cache\group\CoordinatorBroadcast.class
?? . V ? U ? U ? U ? U ? ? ? U ? U ? U ? U ? U ? U ? U ? U ? U ? ? ? ? U ? U ? ? ? ? ? ? ? ? ? U ? ? ? ? ? 6? ? ? ? $ ? ? $ ? ? ? ? $ ? ? $ ? U ? U ? ? ? ? ? 2 ? ? 4 ? 4 ? 2 ? ? ? 9 ? ? ? ? ? U ? ? ? ? ? @ ? ? ? ? ? $ ? ? ? ? ? ? ? ? ? 9 ? ? L ? 9 ? L ? ? ? 9 ? ? ? ? ? ? LOGGER_NAME Ljava/lang/String; ConstantValue DEFAULT_LIFETIME J terminate_ Z myAddress_ Loracle/ias/cache/group/Address; multicastAddr_ Ljava/net/InetAddress; interval_ waiter_ Ljava/lang/Object; port_ I ms_ Ljava/net/MulticastSocket; msg_ [B elec_ -Loracle/ias/cache/group/ElectionNotification; endtime_ useMulticast_ nlAddrs_ ![Loracle/ias/cache/group/Address; gcomm_ )Loracle/ias/cache/group/GrpCommunication; trans_ "Loracle/ias/cache/group/Transport; logger_ Ljava/util/logging/Logger; <init> ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Ljava/lang/String;ILoracle/ias/cache/group/Address;JZ)V Code Exceptions ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;[Loracle/ias/cache/group/Address;Loracle/ias/cache/group/Address;JZ)V getMulticastSocket ()Ljava/net/MulticastSocket; shutdown ()V (J)V objectToByte (Ljava/lang/Object;)[B confirmNominee run w \ ] ^ _ ` a b [ java/lang/Object c d g h i j k l m [ n ] o p q r s t +oracle.ias.cache.group.CoordinatorBroadcast ? ? ? u v e f ? ? ? java/net/MulticastSocket w ? ? ? ? ? +oracle/ias/cache/group/ElectionNotification w ? ? ? java/lang/Exception %oracle/ias/cache/commx/GroupException ,Unable to broadcast coordinator availability w ? ? ? ? java/lang/StringBuffer %Coordinator Election Broadcaster at [ ? ? ? ? : ? ? ] ? ? ? ? ? ? Coordinator Election Broadcaster ? ? java/io/ByteArrayOutputStream java/io/ObjectOutputStream w ? ? ? ? ? java/io/IOException java/util/Vector ? ? ? ? ? ? is started. java/net/DatagramPacket w ? Broadcast election vote: ? to multicast address: "Failed to broadcast election vote: oracle/ias/cache/group/Unicaster w ? java/lang/InterruptedException f is terminated. +oracle/ias/cache/group/CoordinatorBroadcast java/lang/Thread java/util/logging/Logger getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; java/net/InetAddress getByName *(Ljava/lang/String;)Ljava/net/InetAddress; (I)V setTimeToLive joinGroup (Ljava/net/InetAddress;)V $(Loracle/ias/cache/group/Address;Z)V *(Ljava/lang/String;Ljava/lang/Exception;)V java/lang/System currentTimeMillis ()J append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; getHostAddress ()Ljava/lang/String; (I)Ljava/lang/StringBuffer; toString setName (Ljava/lang/String;)V setDaemon (Z)V notifyAll close (Ljava/io/OutputStream;)V writeObject (Ljava/lang/Object;)V toByteArray ()[B java/util/logging/Level INFO Ljava/util/logging/Level; isLoggable (Ljava/util/logging/Level;)Z getName log .(Ljava/util/logging/Level;Ljava/lang/String;)V ([BILjava/net/InetAddress;I)V send (Ljava/net/DatagramPacket;)V FINEST ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; oracle/ias/cache/group/Transport getCachedLocalNLAddress "()Loracle/ias/cache/group/Address; oracle/ias/cache/group/Address equals (Ljava/lang/Object;)Z isNLStarted ()Z contains ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/Address;Ljava/util/Vector;Loracle/ias/cache/group/ElectionNotification;)V add start wait size ()I s_timeout U V W X Y Z [ Y ! \ ] ^ _ ` a b [ c d e f g h i j k l m [ n ] o p q r s t u v w x y *? *? *? *? * ? *? Y? ? *? *? *? * ? *? *? *? *? *? ? *+? *,? *? *? *? *? *-? ? *? Y*? ? ? *? ? *? *? ? **? Y*? ? ? ? ? : ? Y ? ?* !? #a? *? $Y? %&? '*? ? (? ')? '*? ? *+? '? ,? -*? .? u ? ? z w { y ? ?*? *? *? *? * ? *? Y? ? *? *? *? * ? *? *? *? *? *? ? *+? *,? *? *? *? *-? *? Y*? ? ? ? :? Y? ?* !? #a? */? -*? .? t ? ? z | } y *? ? ~ y T 0*? *? YL?*? ? 0+? M+?,?*? ? *? ? 1? L? $ + . ~ ? y *? #a? ? ? ? y ( ? 2Y? 3M? 4Y,? 5N-+? 6,? 7? z 8 ? y d @*? Y*? ? ? *? ? ***? ? ? *? YL?*? ? 0+? M+?,? L? * 3 6 6 9 6 ; >