Edit D:\app\Administrator\product\11.2.0\dbhome_1\ons\lib\oracle\eons\blab\JGroupsChannel.class
?? 1? K ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? s ? ? ? ? ? ? ? ? ? ? ? % ? ? % % ?! ?" ?# t$%&' ()* +,- ./ 01 ?23456578 R9 :;< R= %>? %@ %A %B3CDE ?F ?GH ?IJ ?K ?LM ?N OP QR ?S KT ?U ?V ?W ?X ?Y ?Z[\ InnerClasses channel Lorg/jgroups/JChannel; INITIAL_MEMBERS_MAX I ConstantValue bothstacksConfigFd Ljava/lang/String; tcpConfigPreFd tcpConfigPostFd multicastConfigPreFd multicastConfigPostFd flushConfig <init> '(Ljava/lang/String;Ljava/lang/String;)V Code LineNumberTable LocalVariableTable provider #Loracle/eons/blab/JChannelProvider; this !Loracle/eons/blab/JGroupsChannel; props channelName version262 S Exceptions createChannel ?(Loracle/eons/TierDiscoveryInfo;)Loracle/eons/blab/BlabChannel; se Ljava/lang/SecurityException; securityConfig ce Lorg/jgroups/ChannelException; tdi Loracle/eons/TierDiscoveryInfo; blabChannel buildSecurityConfig 3(Loracle/eons/TierDiscoveryInfo;)Ljava/lang/String; ti sb Ljava/lang/StringBuilder; securitySettings Loracle/eons/SecuritySettings; getMulticastConfig E(Loracle/eons/TierDiscoveryInfo;Ljava/lang/String;)Ljava/lang/String; fdSock mcConfig mcAddr mcPort mcBindAddr getTcpConfig W(Loracle/eons/TierDiscoveryInfo;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; peerServer Loracle/eons/config/Member; i$ Ljava/util/Iterator; initialMembers discoveryLayer tcpConfig peerBuf disableFD ()Z disableFd Z useFlush isCoordinator retVal view Lorg/jgroups/View; viewId Lorg/jgroups/ViewId; close ()V getLocalAddress ()Lorg/jgroups/Address; getState (Lorg/jgroups/Address;J)Z target Lorg/jgroups/Address; timeout J]^ receive (J)Ljava/lang/Object;_ returnState ([B)V data [B send C(Lorg/jgroups/Address;Lorg/jgroups/Address;Ljava/io/Serializable;)V dst src obj Ljava/io/Serializable; (Lorg/jgroups/Message;)V msg Lorg/jgroups/Message; SourceFile JGroupsChannel.java ? ?`abc ?defghi .Obtaining channel from JChannelProvider262Impljkl (oracle/eons/blab/JChannelProvider262Impl .Obtaining channel from JChannelProviderOldImpl (oracle/eons/blab/JChannelProviderOldImplmno v wpqrstuvrwx oracle.eons.confighackyz{ java/lang/SecurityException ? ?|}~???? ? ? TCPGOSSIP ? ? TCPPING oracle/eons/blab/JGroupsChannel?? ? ? org/jgroups/ChannelException?i ONS-29k? java/lang/StringBuilder?? AUTH(?? ,auth_class=oracle.eons.blab.OracleX509Token; auth_value=??? ; keystore_type=PKCS12; keystore_path=?? keystore_password=?? cert_alias=?? cipher_type=RSA ): ENCRYPT( encrypt_entire_message=false; sym_init=56; sym_algorithm=Blowfish; asym_init=2048; asym_algorithm=RSA???????? FD_SOCK: bind_addr= FD_SOCK(bind_addr=UDP(mcast_addr=%s;mcast_port=%d;%sucast_recv_buf_size=20000000;ucast_send_buf_size=640000;mcast_recv_buf_size=25000000;mcast_send_buf_size=640000;use_incoming_packet_handler=false;loopback=true;ip_ttl=32;discard_incompatible_packets=true):PING(timeout=2000;num_initial_members=3): ? ? (FD(timeout=10000;max_tries=5;shun=true):?ERGE2(max_interval=10000;min_interval=5000):%sVERIFY_SUSPECT(timeout=1500):pbcast.NAKACK(gc_lag=50;retransmit_timeout=600,1200,2400,4000):UNICAST(timeout=1000,1500,2000):pbcast.STABLE(stability_delay=1000;desired_avg_gossip=20000;max_bytes=0):FRAG2(frag_size=50000):%spbcast.GMS(print_local_addr=false;join_timeout=3000;shun=true):FC(max_credits=33554432;min_threshold=0.01):pbcast.STATE_TRANSFER ? ? :pbcast.FLUSH(timeout=30000) java/lang/Object????????????? ??? oracle/eons/config/Member????? [???? ]???????? ?CP(bind_addr=%s;start_port=%d;end_port=%<d;loopback=true;send_buf_size=100000;recv_buf_size=200000;discard_incompatible_packets=true):%s(initial_hosts=%s;timeout=3000;num_initial_members=%d):?ERGE2(max_interval=10000;min_interval=5000):VERIFY_SUSPECT(timeout=1500):pbcast.NAKACK(gc_lag=100;retransmit_timeout=600,1200,2400,4800):pbcast.STABLE(stability_delay=1000;desired_avg_gossip=20000;max_bytes=400000):%spbcast.GMS(print_local_addr=true;join_timeout=5000;shun=true;view_bundling=true;max_bundling_time=50):FC(max_credits=2000000;min_threshold=0.10):FRAG2(frag_size=50000):pbcast.STATE_TRANSFER???? oracle.eons.disablefd?? DISABLEFD?{?? oracle.eons.useflush??????? ? ? ??? ? ? ? ? ? ? ? ? ? ? ? ? oracle/eons/blab/BlabChannel !oracle/eons/blab/JGroupsChannel$1 (org/jgroups/ChannelNotConnectedException "org/jgroups/ChannelClosedException org/jgroups/TimeoutException org/jgroups/Version encode (III)S version oracle/eons/impl/OnsLogger logger Ljava/util/logging/Logger; java/util/logging/Level INFO Ljava/util/logging/Level; java/util/logging/Logger log .(Ljava/util/logging/Level;Ljava/lang/String;)V !oracle/eons/blab/JChannelProvider getJChannel *(Ljava/lang/String;)Lorg/jgroups/JChannel; java/lang/Boolean TRUE Ljava/lang/Boolean; org/jgroups/JChannel setOpt (ILjava/lang/Object;)V FALSE connect (Ljava/lang/String;)V java/lang/System getProperty &(Ljava/lang/String;)Ljava/lang/String; 6$SwitchMap$oracle$eons$TierDiscoveryInfo$DiscoveryType [I oracle/eons/TierDiscoveryInfo getDiscoveryType DiscoveryType /()Loracle/eons/TierDiscoveryInfo$DiscoveryType; +oracle/eons/TierDiscoveryInfo$DiscoveryType ordinal ()I getTierId ()Ljava/lang/String; SEVERE @(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V getSecuritySettings ()Loracle/eons/SecuritySettings; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; oracle/eons/SecuritySettings getSecurityToken getKeystorePath getKeystorePassword getCertificateAlias toString getMulticastAddr getMulticastPort getBindAddr java/lang/Integer valueOf (I)Ljava/lang/Integer; java/lang/String format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; getMemberList ()Ljava/util/List; java/util/List iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next ()Ljava/lang/Object; getAddress ()Ljava/net/InetAddress; java/net/InetAddress getHostAddress getPort (I)Ljava/lang/StringBuilder; (C)Ljava/lang/StringBuilder; length setLength (I)V size getTcpListenAddr getTcpListenPort getBoolean (Ljava/lang/String;)Z getenv parseBoolean getView ()Lorg/jgroups/View; org/jgroups/View getVid ()Lorg/jgroups/ViewId; org/jgroups/ViewId getCoordAddress equals (Ljava/lang/Object;)Z ! K r v w x y z { | } z G ~ } z ] } z ^ ? } z E ? } z H ? } z J ? ? ? u*? ? >? ? ? ? ? ? Y? :? ? ? ? ? Y? :*+? ? *? ? ? *? ? ? *? ? ? *? ,? ? ? 6 ' ( * , / * 3 5 6 >