Edit D:\app\Administrator\product\11.2.0\dbhome_1\ons\lib\oracle\eons\impl\OnsBridge.class
?? 1" )* ?+ ?, ?- ?. ?/ ?0 ?1 ?2 ?34 ) ?56 ) ?7 ?8 ?9:; ?< ?=>?@A )BC>DBE>F GH:I JK LMN #)O #P #Q #R ST ?UVWX ,Y Z[ Z\]^ 2) #_ ?` ab cd ?e ?f ?g ?h ?ij =k =l m +no Bk ?p Bl Zgq Br =r:s ?t uBvwxwyz ?{ |}B~ ?? ?? U? B? S?? ??>??v ??B? ?? ?? ?? ?? ?? ??:?? ?? |? ???? L? m? S? ?? U? B?? U??? ?? ??? z? C? #?? ???>? #??>? v??? ??? globalSerialVersionUID J ConstantValue 2? processId Ljava/lang/String; hostname receiver *Loracle/eons/impl/OnsBridgeReceiverThread; sender (Loracle/eons/impl/OnsBridgeSenderThread; shutdowntimeout I channel Loracle/eons/blab/BlabChannel; currentview Lorg/jgroups/View; viewlock Ljava/lang/Object; leavegrouplock initialstatereceived Z initialstatelock bridgeId tierinfo Loracle/eons/TierDiscoveryInfo; tierName? TierName InnerClasses Loracle/eons/ONS$TierName; myJgroupAddr Lorg/jgroups/Address; tierLocations Ljava/util/Map; Signature ILjava/util/Map<Lorg/jgroups/Address;Ljava/util/Set<Ljava/lang/String;>;>; bridgePeers Ljava/util/List; 'Ljava/util/List<Lorg/jgroups/Address;>; peerONS Loracle/eons/impl/ONSImpl; <init> <(Loracle/eons/impl/ONSImpl;Loracle/eons/TierDiscoveryInfo;)V Code LineNumberTable LocalVariableTable this Loracle/eons/impl/OnsBridge; ti addTierLocation &(Lorg/jgroups/Address;)Ljava/util/Set; addr tierIds Ljava/util/Set; LocalVariableTypeTable #Ljava/util/Set<Ljava/lang/String;>; :(Lorg/jgroups/Address;)Ljava/util/Set<Ljava/lang/String;>; removeTierLocation initChannel ?(Loracle/eons/TierDiscoveryInfo;)Loracle/eons/blab/BlabChannel; stateavailable ex Ljava/lang/Exception; ch createNewBridgeId ()Ljava/lang/String; e ipAddr getBridgeId realStartup ()Z startTime startSenderAndReceiver getHostName h localadd Ljava/net/InetAddress; shutdown ()V handleViewChange (Lorg/jgroups/View;)V i$ Ljava/util/Iterator; others addrtodelete newAddr laddrs message Loracle/eons/impl/JGroupMessage; delMsg delList deletedTierIds tierDisconnected addrsToDelete addrsToAdd newview 7Ljava/util/List<Loracle/eons/impl/LogicalAddressImpl;>; handleSetState (Lorg/jgroups/SetStateEvent;)V newstate Lorg/jgroups/SetStateEvent; receivedstate handleGetState (Lorg/jgroups/GetStateEvent;)V Lorg/jgroups/GetStateEvent; statepayload [B localAddress ()Lorg/jgroups/Address; ret getBridgeStatus? BRIDGESTATUS ()Loracle/eons/ONS$BRIDGESTATUS; getHorizontalTierInfo !()Loracle/eons/TierDiscoveryInfo; getTierName ()Loracle/eons/ONS$TierName; addressListFromView $(Lorg/jgroups/View;)Ljava/util/List; view ;(Lorg/jgroups/View;)Ljava/util/List<Lorg/jgroups/Address;>; uncheckedStringFromBytes ([B)Ljava/lang/String; "Ljava/lang/ClassNotFoundException; buf str leaveGroup getChannel ()Loracle/eons/blab/BlabChannel; getLocalAddrs ()Ljava/util/List; 9()Ljava/util/List<Loracle/eons/impl/LogicalAddressImpl;>; publish #(Loracle/eons/impl/JGroupMessage;)V forwardToGateway getBridgePeers ()Ljava/util/Collection; /()Ljava/util/Collection<Lorg/jgroups/Address;>; handleAddSubscriber ((Lorg/jgroups/Address;Ljava/util/List;)V laddr %Loracle/eons/impl/LogicalAddressImpl; src O(Lorg/jgroups/Address;Ljava/util/List<Loracle/eons/impl/LogicalAddressImpl;>;)V handleRemoveSubscriber toString tierId first a sb Ljava/lang/StringBuilder; <clinit> SourceFile OnsBridge.java ? ? java/lang/Object ? ? ? ? ? ? ? ? ? ? ? ?? ? ? ? ? ? java/util/HashMap ? ? java/util/ArrayList ? ? ? ? ? ??? ? ? ? ? ???? java/util/Set java/util/HashSet??????????? ????????? java/lang/StringBuilder stateavailable == ???? ???? ? ? java/lang/Exception &oracle/eons/impl/ONSLocalizedException ONS-5 ?????? ? 11.22.33.44 java/rmi/server/UID?? ? ????? ? ? ? ? ? ? ? ? ? ? ? (oracle/eons/impl/OnsBridgeReceiverThread ??? ?? ?? ? &oracle/eons/impl/OnsBridgeSenderThread ? ? UNKNOWNHOST ? ?? ? ?????? ??? org/jgroups/Address ? ????? ? oracle/eons/impl/JGroupMessage??? ?????? Bridge members exit detected: ? ?????? ? ? **** RECEIVED REMOTE STATE **** 3Bridge: Returning my state in response to GET_STATE java/lang/String java/lang/ClassNotFoundException? ??? Bridge forwarding msg ( ) from bridge: to gateway for tier ? #oracle/eons/impl/LogicalAddressImpl ? eONS Bridge: ? Bridge Tier Info: Tier Locations: ? sources (peers) - sourceOf , ? ? oracle/eons/impl/OnsBridge! oracle/eons/ONS$TierName oracle/eons/ONS$BRIDGESTATUS BRIDGE oracle/eons/blab/BlabChannel getLocalAddress java/util/Map get &(Ljava/lang/Object;)Ljava/lang/Object; java/util/List add (Ljava/lang/Object;)Z put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; remove oracle/eons/blab/BlabFactory createChannel getState (Lorg/jgroups/Address;J)Z oracle/eons/impl/OnsLogger logger Ljava/util/logging/Logger; java/util/logging/Level FINE Ljava/util/logging/Level; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (Z)Ljava/lang/StringBuilder; java/util/logging/Logger log .(Ljava/util/logging/Level;Ljava/lang/String;)V =(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V java/net/InetAddress getLocalHost ()Ljava/net/InetAddress; getHostAddress -(Ljava/lang/Object;)Ljava/lang/StringBuilder; java/lang/System currentTimeMillis ()J java/lang/Long (J)Ljava/lang/String; (Loracle/eons/impl/OnsBridge;)V start wait printStackTrace close (Ljava/util/Collection;)V iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next ()Ljava/lang/Object; org/jgroups/View containsMember (Lorg/jgroups/Address;)Z isEmpty &oracle/eons/impl/JGroupMessage$MSGTYPE MSGTYPE ADD_SUBSCRIBER (Loracle/eons/impl/JGroupMessage$MSGTYPE; S(Loracle/eons/impl/JGroupMessage$MSGTYPE;Ljava/lang/Object;Ljava/util/Collection;)V send 8(Loracle/eons/impl/JGroupMessage;Lorg/jgroups/Address;)V isLoggable (Ljava/util/logging/Level;)Z values java/util/Collection oracle/eons/impl/ONSImpl getLaddrsByTiers !(Ljava/util/Set;)Ljava/util/List; size ()I DEL_SUBSCRIBER org/jgroups/SetStateEvent getArg ()[B notifyAll oracle/eons/impl/OnsUtil convertObj2Bytes (Ljava/io/Serializable;)[B returnState ([B)V PRIMARY Loracle/eons/ONS$BRIDGESTATUS; getMembers ()Ljava/util/Vector; convertBytes2Obj ([B)Ljava/io/Serializable; SEVERE getLocalizedMessage C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V getLaddrsNotFromBridge $(Ljava/lang/String;)Ljava/util/List; originatedFrom (Ljava/lang/String;)Z type *()Loracle/eons/impl/JGroupMessage$MSGTYPE; getLocalTierId getTierId (C)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; keySet ()Ljava/util/Set; oracle/eons/ONS 0 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? r*? *? Y? ? *? Y? ? *? *? Y? ? *? *+? *? ? *,? *? Y? ? *? Y? ? **,? ? **? ? ? *? W? ? >