Edit D:\app\Administrator\product\11.2.0\dbhome_1\oc4j\javacache\lib\oracle\ias\cache\group\Transport.class
?? .? g ?hi g ?jk g ?l ?m ?n ?opq r ?st r ?u ?v ?w ?x ?y ?z ?{ ?| ?} ?~ ?? ?? ?? ?? ?????????? ?? ?? ?? ?? ?? ?? ?? ?? ?? ??? ?? ?? ??? 3? ??? 6? ??? 9? ?? ????? >? ???? ?? Br ??? ??? Hg? H? 3? H? H? l??? ??? ??????? H???? 9? ??? ?? ?? ? ?? ??? ???? ?? ?? ?? A?? l?? n? n????????? ??? v? ???? ?? ???????? ?? 6? ?? ?? 3? ?? ?? ?? ?? 9? ?? ?? ?? ? ? ? ?? ??? ?? ?? 3? ?? ?? ??? ?? ?? ???? ?? ? ? ?? ?? ? ? 2 ? ? ? ? ? ? ? ? ?? ?? ? ? ? ? ? ? ? ? ?? ? H ?!" ?#$ ?%& ?' B( ?) ?*+ ?? ? ?, ?-. ?/0 A1 ?2 ?3 ?4 ?56 ?g ?7 ?8 ?9 ?-: ?; ?<= ?> ?? >@A ?BC ?DEF ?G ?H ?I ?J ?KLM ?N ?OP G Q ?R ?S TU TV WW XY Z ?[\ W] W^ ?_ ` ab c d e ? ?f ?g ?h ?i 9j ? ?kl m Wn ?o p Wq ?rs ?tu v wxy 9z{ ?|} /~ /] /^ T- T??? /-? 9? 9? 9? n? ` ?? X ? 6? 9? W- ? ?? ?? ?? ?? O? l? ?? ? ?? 9? ?? 9? ?? ?? 9? 9? ?? ? ? ? ? ? ? ?? ?? ? ?? ? W? W? ? W?? ? W?? ?1? ?? ?? ???? x???? ?? ?? ?? ?? ??????????? ?? ? ?? ? ? ? 9??? ? ??? ?? ? ?? ? ? ?? DEFAULT_JOINGROUP_ATTEMPTS I ConstantValue CLEAN_INTERVAL DEFAULT_SOCK_CONNECT_TIMEOUT ? BACKLOG ( NODE_LISTENER_STARTUP_TIMEOUT J CONNECT_TIMEOUT_PROPERTY Ljava/lang/String; OPMNID OPNNORACLE_HOME LOGGER_NAME clean_interval_ s_timeout addrList Ljava/util/Vector; endPointList Ljava/util/Hashtable; ssep -Loracle/ias/cache/group/ServerSocketEndPoint; nlistener receivingQList localHost Ljava/net/InetAddress; TGNAME tg Ljava/lang/ThreadGroup; initializing Z terminated asQ #Loracle/ias/cache/group/AsyncQueue; sender Loracle/ias/cache/group/Sender; s_config $Loracle/ias/cache/commx/GroupConfig; broadcaster -Loracle/ias/cache/group/CoordinatorBroadcast; resolver ,Loracle/ias/cache/group/CoordinatorResolver; electionVotes enableColletingVotes localNLAddress Loracle/ias/cache/group/Address; nodeListernerLock Ljava/lang/Object; ctx gcomm_ )Loracle/ias/cache/group/GrpCommunication; gmgr_ %Loracle/ias/cache/group/GroupManager; failDect_ (Loracle/ias/cache/group/FailureDetector; mon_ Loracle/ias/cache/group/Monitor; sslMgr_ #Loracle/ias/cache/group/SSLManager; g_uid guid_lock [B seq_lock sequencer c_lock counter to_lock to_counter ton_lock receivedTONumber coordinator_lock member_lock total_lock logger_ Ljava/util/logging/Logger; <init> ,(Loracle/ias/cache/group/GrpCommunication;)V Code Exceptions getFailureDetector *()Loracle/ias/cache/group/FailureDetector; getGroupManager '()Loracle/ias/cache/group/GroupManager; getMonitor "()Loracle/ias/cache/group/Monitor; getSSLManager %()Loracle/ias/cache/group/SSLManager; dump ()V init (Z)V bootstrapGroup joinGroup (ZLjava/util/Vector;IJ)V discoverCoordinator (Ljava/util/Vector;)Z removeANodeFromList 8(Ljava/lang/String;Ljava/util/Vector;)Ljava/util/Vector; beACoordinator '(Z[Loracle/ias/cache/group/Address;IJ)Z broadcastConfirmation #(Loracle/ias/cache/group/Address;)V getLocalNodeListenerAddress "()Loracle/ias/cache/group/Address; 4(Ljava/util/Vector;)Loracle/ias/cache/group/Address; ssinit C(IILjava/io/Serializable;Ljava/net/InetAddress;Ljava/util/Vector;)V nlinit ()Z waitUtilNodeListenIsUp $(Loracle/ias/cache/group/Address;J)V findEmptySlot (Ljava/util/Vector;)I isNLStarted stopNodeListener createSocket *(Ljava/net/InetAddress;I)Ljava/net/Socket; +(Ljava/net/InetAddress;II)Ljava/net/Socket; createServerSocket ,(ILjava/lang/String;)Ljava/net/ServerSocket; 4(IILjava/net/InetAddress;Z[I)Ljava/net/ServerSocket; isBitSetEmpty (Ljava/util/BitSet;)Z arrayContains ([II)Z getAllPortsFrom ,(Ljava/util/Vector;Ljava/net/InetAddress;)[I connect C(Loracle/ias/cache/group/Address;Loracle/ias/cache/group/Address;)Z getCoordinatorFromANodeListener B(Loracle/ias/cache/group/Address;)Loracle/ias/cache/group/Address; sendElectionVoteTo P(Loracle/ias/cache/group/Address;Loracle/ias/cache/group/ElectionNotification;)V getASortedAddressList 5(Ljava/util/Vector;)[Loracle/ias/cache/group/Address; terminateNodeListenerAt term cleanupConnections send "(Loracle/ias/cache/group/Packet;)V syncSend sendTotalOrderedMsg F(Loracle/ias/cache/group/Packet;)Loracle/ias/cache/group/GrpReplyInfo; syncSendTotalOrderedMsg multicast G(Loracle/ias/cache/group/Packet;Z)Loracle/ias/cache/group/GrpReplyInfo; syncMulticast multicastTotalOrderedMsg syncMulticastTotalOrderedMsg registerReceivingQueue L(Ljava/lang/String;Loracle/ias/cache/commx/MessageQueue;Ljava/lang/Object;)V deregisterReceivingQueue :(Ljava/lang/String;Loracle/ias/cache/commx/MessageQueue;)V removeAddress removeEndPoint isMyself #(Loracle/ias/cache/group/Address;)Z setAddrList (Ljava/util/Vector;)V getAddrList ()Ljava/util/Vector; getEndPointList ()Ljava/util/Hashtable; getLocalAddress getCachedLocalNLAddress startNodeListener isReady isNLDeathDetectable addElectionVote 0(Loracle/ias/cache/group/ElectionNotification;)V clearElectionVoteBuffer toEnableCollectingVotes getACoordinatorVote /()Loracle/ias/cache/group/ElectionNotification; getRTG ()Ljava/lang/ThreadGroup; resetCleanInterval (I)V getTerminated setGUid (J)V getGUid ()J incGUid getSequencer setSequencer incSequencer getPacketSerial (I)J getReceivedTONumber setReceivedTONumber getCoordinatorLock ()Ljava/lang/Object; getMemberLock getTotalLock getRecentReadOf #(Loracle/ias/cache/group/Address;)J resetRecentCounter???? java/util/Vector?? java/util/Hashtable???????? java/lang/String ReceiverThreadGroup???? java/lang/ThreadGroup???????????????????? java/lang/Object?????????????????????????????? oracle.ias.cache.group.Transport??????? &oracle/ias/cache/group/FailureDetector???? oracle/ias/cache/group/Monitor?? #oracle/ias/cache/group/GroupManager??????? !oracle/ias/cache/group/SSLManager???? java/lang/Exception %oracle/ias/cache/commx/GroupException????? $--- Start dumping Transport Layer---?? java/lang/StringBuffer Current Coordinator at: ????????? NodeListener: ServerSocketEndpoint: ?? --- Start dumping EndPoint ---???? ?a oracle/ias/cache/group/EndPoint #?? . --- End dumping EndPoint --- "--- End dumping Transport Layer---?? &oracle.ias.cache.group.connect-timeout??????????? invalid connect timeout value??D?? ? !oracle/ias/cache/group/AsyncQueue oracle/ias/cache/group/Sender?? A +oracle/ias/cache/group/ServerSocketReceiver? ?? W?? ?RUWU&' F a ? !"U java/lang/InterruptedException#?$?%?%U&? !Unable to initialize coordinator.' ? /Unable to find or become the coordinator after attempt(s).( oracle/ias/cache/group/Unicaster)* oracle/ias/cache/group/Address?+,a- !.U/?0 +oracle/ias/cache/group/CoordinatorBroadcast1?2?3 *oracle/ias/cache/group/CoordinatorResolver45?6?7?89U: ;?<=> D 7Unable to find a local Address from the discoverer list??@A?B? oracle.ons.indexid oracle.ons.oraclehome?CD? +oracle/ias/cache/group/ServerSocketEndPoint?E java/net/BindExceptionF? Transport initialization failed.G??HI? #oracle/ias/cache/group/NodeListenerJ? &Unable to start Node Listener at port:K . L?"# 8Timeout while waiting for Node Listener to be available.M?N? java/util/BitSetOPRQR !Node Listener termination error. K? (oracle/ias/cache/group/GroupSocketOpener?STUV java/net/ServerSocket?W java/util/Random?U Invalid port range: -?RXRYZ java/io/IOException 1Unable to create server socket within port range:[\? java/lang/Integer]^?_`aR?bcd oracle/ias/cache/group/Packet?ef? &Register myself to the coordinator at g,hij?X?kl oracle/ias/cache/group/ViewmAnopaqWrWVWTUs?<= oracle/ias/cache/group/Receiver?tu 0Can't establish connection to a cache member at Qvwxy? Expected a view object from ?z . Got: {|}~? . Ignores packet: , $Failed to connect to coordinator at *? $oracle/ias/cache/group/StreamHandler???? Sent vote: to Unable to send vote: java/util/TreeSet?? %Unable to terminate Node Listener at ??12)??????P?? oracle/ias/cache/group/Job????-,?l????????????????????????????????? ????^W_U???W?? syncSend: ?? syncSend Warning: . ep:0/4/?, syncSendTotalOrderedMsg packet: #oracle/ias/cache/group/GrpReplyInfo?? syncSendTotalOrderedMsg: !syncSendTotalOrderedMsg Warning: , msg:3/???ABC?? Warning: Can't send msg from : Warning, no connection to Unable to send [ ] to [ ] syncMulticast: in view: in view: [W?U5/?????? syncMulticastTotalOrderedMsg: to view: ?v? ?? +oracle/ias/cache/group/ElectionNotification?R????W???? oracle/ias/cache/group/Transport (Ljava/lang/String;)V java/util/logging/Logger getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; N(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;)V 'oracle/ias/cache/group/GrpCommunication getGroupConfig &()Loracle/ias/cache/commx/GroupConfig; "oracle/ias/cache/commx/GroupConfig isSSLEnabled EXP_GRP_SSL_CONFIG java/util/logging/Level SEVERE Ljava/util/logging/Level; log .(Ljava/util/logging/Level;Ljava/lang/String;)V append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; getCoordinator ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; toString ()Ljava/lang/String; elements ()Ljava/util/Enumeration; java/util/Enumeration hasMoreElements nextElement (I)Ljava/lang/StringBuffer; java/lang/System getProperty &(Ljava/lang/String;)Ljava/lang/String; parseInt (Ljava/lang/String;)I WARNING isLoggable (Ljava/util/logging/Level;)Z C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V java/net/InetAddress getByName *(Ljava/lang/String;)Ljava/net/InetAddress; getLocalHost ()Ljava/net/InetAddress; EXP_GRP_NOLOCALHOST q(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/AsyncQueue;)V start getLowerPortBoundry ()I getUpperPortBoundry getTag ()Ljava/io/Serializable; getListenerList {(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/ServerSocketEndPoint;)V handler ,Loracle/ias/cache/group/ServerSocketHandler; *oracle/ias/cache/group/ServerSocketHandler isMulticast getMulticastInterval getResolutionTimeout addr setCoordinator setPosition setUid currentTimeMillis setTimeStamp initView (Loracle/ias/cache/group/View;)V clone removeElement (Ljava/lang/Object;)Z addElement (Ljava/lang/Object;)V java/lang/Thread sleep getHostName setNodeListenerHostname shutdown INFO isLocalConflict size elementAt (I)Ljava/lang/Object; ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/Address;Ljava/util/Vector;)V firstElement getNodeListener wait getIPString equals getMulticastAddress getMulticastPort ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Ljava/lang/String;ILoracle/ias/cache/group/Address;JZ)V getMulticastSocket ()Ljava/net/MulticastSocket; ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;[Loracle/ias/cache/group/Address;Loracle/ias/cache/group/Address;Ljava/net/MulticastSocket;)V ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;[Loracle/ias/cache/group/Address;Loracle/ias/cache/group/Address;JZ)V ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;[Loracle/ias/cache/group/Address;Loracle/ias/cache/group/Address;)V join canBeCoordinator confirmNominee toArray (([Ljava/lang/Object;)[Ljava/lang/Object; isOriginal getLocalPort 0(Ljava/net/InetAddress;ILjava/io/Serializable;)V getCacheName setCacheName (C)Ljava/lang/StringBuffer; setUserDefinedId c(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Address;Ljava/net/ServerSocket;)V EXP_GRP_PORTINUSE EXP_GRP_SOCKETINITFAIL *(Ljava/lang/String;Ljava/lang/Exception;)V port close getPort getMessage EXP_GRP_INTERNAL EXP_GRP_INVALIDPAR getPosition set get (I)Z >(Loracle/ias/cache/group/Transport;Ljava/net/InetAddress;IIZ)V ()Ljava/net/Socket; createSSLServerSocket 1(IILjava/net/InetAddress;)Ljava/net/ServerSocket; (IILjava/net/InetAddress;)V clear nextInt (I)I length getHostAddress intValue ip java/net/Socket getSoTimeout setSoTimeout ](Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Address;Ljava/net/Socket;)V put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; R(IILoracle/ias/cache/group/Address;Ljava/io/Serializable;Ljava/io/Serializable;J)V FINE write read !()Loracle/ias/cache/group/Packet; EXP_GRP_REPLYISNULL message Ljava/io/Serializable; getMembers addAll (Ljava/util/Collection;)Z lastElement getUid getTimeStamp SYSTEM_GROUP o(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/EndPoint;)V !Loracle/ias/cache/group/Receiver; &(Ljava/lang/Object;)Ljava/lang/Object; s Ljava/net/Socket; FINEST (Z)Ljava/lang/String; getClass ()Ljava/lang/Class; java/lang/Class getName flush =(Loracle/ias/cache/group/GrpCommunication;Ljava/net/Socket;)V setSoLinger (ZI)V (Ljava/util/Collection;)V stopit EXP_GRP_NOTINITIALIZED currentThread ()Ljava/lang/Thread; getThreadGroup type (ILjava/lang/Object;)V enqueue (Loracle/ias/cache/group/Job;)V destination EXP_GRP_NOCONNECTION getCurrentViewInfoRWLock 3(Ljava/lang/String;)Loracle/ias/cache/group/RWLock; oracle/ias/cache/group/RWLock acquireReadLock getCurrentViewInfo 5(Ljava/lang/String;)Loracle/ias/cache/group/ViewInfo; oracle/ias/cache/group/ViewInfo getMessageBuffer (()Loracle/ias/cache/group/MessageBuffer; releaseReadLock getLatestViewInfoRWLock getLatestViewInfo getView ()Loracle/ias/cache/group/View; getVid vid indexOf (Ljava/lang/Object;)I receiverIndex receiverPosition senderIndex $oracle/ias/cache/group/MessageBuffer updated getReceiveVector ()[J setReceiveArray ([J)V lock getSize reset getType save B(Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/View;)V setUpdated getEPList EXP_GRP_NOGROUPINFO setSequenceNumber fromMyself deliver ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/Packet;Loracle/ias/cache/group/MessageBuffer;)V getViewInfo 6(Ljava/lang/String;I)Loracle/ias/cache/group/ViewInfo; remove isNLDeathDetected notifyAll removeElementAt java/lang/Math round (F)I getRecentReadCounter values ()Ljava/util/Collection; resetRecentReadCounter ? 2 ?? ? ? ?? ? ?? ? ? ?? ? ? ?? ? ? ?? ? _ ?? ? ? ?? ? ? ?? ? / ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? O ?? ? ` L*? *? *? Y? ? *? Y? ? *? *? Y? ? *? *? Y? ? *? Y*? ? ? *? *? *? *? *? *? *? *? *? *? Y? ? *? * ? *?? !*?? "* #? %*?? &* ? '*?? (* ? )*?? ** #? +*?? ,*?? -*?? .*/? 0? 1*+? 2*? 3Y+*? 4? 5*? 6Y*? 2*? 7? 8*? 9Y*? 2*? :? ;*? 2? <? = ? !*? >Y*? 2? ?? @? M? BY? C? D? -<? A ? B ?? ? *? 5? ?? ? *? ;? ?? ? *? 8? ?? ? *? @? ?? ? ?*? 1? EF? G? HY? IL+J? KW+*? 5? L? MW*? 1? E+? N? G*? ? *? ? O+? HY? IP? K*? ? M? N? KW+? HY? IQ? K*? R? M? N? KW*? ? f? HY? IL+S? KW*? ? TM>,? U ? /,? V ? W:+X? KW+?? YW+Z? KW+? MW??+[? KW*? 1? E+? N? G*? 1? E\? G*? ;? ]? ?? ? ? {*? *? *? Y? ? **? 2? <? ^_? `M,? *? a? 0*,? b? a? %N*? 1? c? d? *? 1? ce-? f*? a*? ^? g ? **? ^? g ? h? ? *? i? ? #N? BY? HY? I? j? K-? k? K? N? D?*? ? -*? lY*? 2? m? *? nY*? 2**? ? o? *? ? p**? ^? q *? ^? r *? ^? s *? *? ^? t ? u*? R? vY*? 2**? R? w? x*? R? x? y ***? ^? t ? z? ? *? {? +**? ^? | *? ^? t *? ^? } *? ^? ~ ? *? *? 8? ?? 4 <