Edit D:\app\Administrator\product\11.2.0\dbhome_1\oc4j\javacache\lib\oracle\ias\cache\group\Receiver.class
?? .? ? ? ? ? ? ? ? ? ? ? ? ! "# $ % ?&' ?( )* +,- +. / ?01 +2 34 56 +7 8 Z9 : Z; )<= > )? Z@AB 5/ ?C )DEF )GH 8I J K LM N OP LQ R ?S ZT U VW ZX Y Z [ \ ] ^ _` a b cd e fg fhi j k Zl m no pqr fst u Zvw hx hy hz c{ O|} ~ ? c? ? ? f? f? ?? ?? L? Z? f? ?? Z?? ?? ?? Z? f? ?? f? ?? ?? Z? ? Z? ???? L? Z? ??? ??? 5? ? V?? ?? Z? h? ?? ?? 5? 5?? f? f? f???? f??? ??? ?? ?? Z?????????? f? Z? ? ??? Z????? ?? Z? Z? ?? ?? ? O?? Z ? Z? ????? Z? ? ?: ? V? ?? ???? ?? ? ???? +??? LOGGER_NAME Ljava/lang/String; ConstantValue counter I readCounter_lock [B work Z ep !Loracle/ias/cache/group/EndPoint; lazyInit_ acceptedSocket_ Ljava/net/Socket; gracefulClosed_ gcomm_ )Loracle/ias/cache/group/GrpCommunication; trans_ "Loracle/ias/cache/group/Transport; recentReads_ J logger_ Ljava/util/logging/Logger; <init> o(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/EndPoint;)V Code _(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Ljava/net/Socket;)V Exceptions? init ()V run stopit resetRecentReadCounter getRecentReadCounter ()J deliver ?(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/Packet;Loracle/ias/cache/group/MessageBuffer;)V process m(Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Transport;Loracle/ias/cache/group/Packet;)V <clinit>? ?? receiver ?? ? ? ? ? ? ? ? ? ? ? ? ? ?? java/lang/StringBuffer ? ? EndPoint Receiver [ ?? ?? ] ?? ?? ?? ? ? ? ? oracle/ias/cache/group/Address? ?? ? oracle/ias/cache/group/EndPoint ? ? ? java/lang/Exception ? ? (Unable to establish incoming connection. 4Error: Initialization TimeOut, receiver thread quit. %oracle/ias/cache/commx/GroupException ? ?? ? ? Received: ? ? from java/lang/Throwable ? ? ! Gracefully disconnected from . " Warning: Lost connection to #? $% &'( ) ? *+, -. / ? 0 ? ? ? 1 ? 234 56 78 9: ;< => ? ? @ AB C D EFG HI JKL M ? NO oracle/ias/cache/group/Packet PQR ?S T ? UV Reply REGISTER message to ?W . View: Can't reply REGISTER message to XY Can't reply READY message to Z% [8 oracle/ias/cache/group/View \ ] ^: _` ab Invalid coordinator index: ?c . Expected range: 0- de f% g h ij kV l ? -Can't handle a NEW_VIEW message. Got packet: 0? !Can't handle TERM system message. m ? n opq rs t% [Ju vw xV yz {|} ~ ? ? ? ? ?? ?w ? ? ?V +Unable to handle PING request. Got packet: java/lang/Error Ping error ?b ? x? Ping_ACK exception ?? Got KILL Message from *, shutting down group communication layer. ? ? ?? ?? Invalid KILL message ?? #? ?V ? ? ? ? Unable to forward packet: ?| ?? ?? Unable to flush view from: to .Unable to handle DELIVER request. Got packet: ?? $Unable to handle FLUSHOVER request: "oracle/ias/cache/group/TestCommand ?% java/lang/String ? ,Internal Error: Can't process USER MSG from ?| ? ? ? Holding message: , for current view: ? User Message Exception: 'Internal Error: Can't process USER MSG. Unknown PACKET. Got packet: <Receiver has encountered and discard the unexpected packet: ?? ? ? ?V ?V ?% ? come back. ?? ? ?V Delivered packet: , to Deliver Error. ? ??? ?3 ??? ? ?% #oracle/ias/cache/commx/MessageQueue #oracle/ias/cache/group/GroupMessage ?? ?? ?? Processed packet: oracle.ias.cache.group.Receiver ?? oracle/ias/cache/group/Receiver java/lang/Thread java/io/IOException oracle/ias/cache/group/Transport getRTG ()Ljava/lang/ThreadGroup; ,(Ljava/lang/ThreadGroup;Ljava/lang/String;)V addr Loracle/ias/cache/group/Address; append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; getShortName ()Ljava/lang/String; toString setName (Ljava/lang/String;)V setDaemon (Z)V java/net/Socket getInetAddress ()Ljava/net/InetAddress; getPort ()I (Ljava/net/InetAddress;I)V ](Loracle/ias/cache/group/GrpCommunication;Loracle/ias/cache/group/Address;Ljava/net/Socket;)V handler !Loracle/ias/cache/group/Receiver; java/util/logging/Level SEVERE Ljava/util/logging/Level; java/util/logging/Logger isLoggable (Ljava/util/logging/Level;)Z log C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V isReady ()Z sleep (J)V .(Ljava/util/logging/Level;Ljava/lang/String;)V read !()Loracle/ias/cache/group/Packet; 'oracle/ias/cache/group/GrpCommunication EXP_GRP_CON_TERMINATED getLocalAddress "()Loracle/ias/cache/group/Address; source equals (Ljava/lang/Object;)Z fromMyself FINEST ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; FINE getType INFO WARNING getMessage getCoordinatorLock ()Ljava/lang/Object; getMonitor "()Loracle/ias/cache/group/Monitor; oracle/ias/cache/group/Monitor toPause getFailureDetector *()Loracle/ias/cache/group/FailureDetector; &oracle/ias/cache/group/FailureDetector failureDetected 5(Loracle/ias/cache/group/Address;Ljava/lang/Object;)V reset close type endPointList Ljava/util/Hashtable; java/util/Hashtable put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; destination Ljava/io/Serializable; getAddrList ()Ljava/util/Vector; findEmptySlot (Ljava/util/Vector;)I setPosition (I)V incGUid getGUid setUid java/lang/System currentTimeMillis setTimeStamp addrList Ljava/util/Vector; java/util/Vector addElement (Ljava/lang/Object;)V getGroupManager '()Loracle/ias/cache/group/GroupManager; #oracle/ias/cache/group/GroupManager SYSTEM_GROUP currentAddrList 1(Ljava/lang/String;)Loracle/ias/cache/group/View; ssep -Loracle/ias/cache/group/ServerSocketEndPoint; +oracle/ias/cache/group/ServerSocketEndPoint R(IILoracle/ias/cache/group/Address;Ljava/io/Serializable;Ljava/io/Serializable;J)V lock write "(Loracle/ias/cache/group/Packet;)V (Z)Ljava/lang/String; joinGroup 4(Ljava/lang/String;Loracle/ias/cache/group/Packet;)V getMemberLock message getCid size getMembers elementAt (I)Ljava/lang/Object; setCoordinator #(Loracle/ias/cache/group/Address;)V (I)Ljava/lang/StringBuffer; setAddrList (Ljava/util/Vector;)V lastElement getUid setGUid setView (Loracle/ias/cache/group/View;)V flush terminated gotPinged getVid getViewInfo 6(Ljava/lang/String;I)Loracle/ias/cache/group/ViewInfo; oracle/ias/cache/group/ViewInfo getMessageBuffer (()Loracle/ias/cache/group/MessageBuffer; getReceiptTracker $oracle/ias/cache/group/MessageBuffer cleanup ([J)V update getSourceAddress )()Loracle/ias/cache/commx/NetworkAddress; 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; releaseReadLock getReceiveVector ()[J setReceiveArray getReceivedTONumber setReceivedTONumber send gotReply getSenderIndex ([JI)V isMyself #(Loracle/ias/cache/group/Address;)Z term getEndPointList ()Ljava/util/Hashtable; get &(Ljava/lang/Object;)Ljava/lang/Object; getView ()Loracle/ias/cache/group/View; ()Ljava/io/Serializable; hold EXP_GRP_INTERNAL EXP_GRP_VIEWINFOEMPTY getLatestViewInfoRWLock getLatestViewInfo endFlush C(Loracle/ias/cache/group/Receiver;Loracle/ias/cache/group/Packet;)V updateView getTarget getAction getDeliverRWLock getSequenceNumber getSequencer setSequencer getSerialNumber hasDelivered "(Loracle/ias/cache/group/Packet;)Z isTotal isFromMyself delivered replace getTotalLock getCoordinator multicastTotalOrderedMsg F(Loracle/ias/cache/group/Packet;)Loracle/ias/cache/group/GrpReplyInfo; isAtomic save getNodeCast ip Ljava/net/InetAddress; java/net/InetAddress receivingQList elements ()Ljava/util/Enumeration; java/util/Enumeration hasMoreElements nextElement (ILjava/lang/Object;)V ctx Ljava/lang/Object; enqueue '(Ljava/lang/Object;Ljava/lang/Object;)V getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? k _*,? ? *? *?? *? *-? *+? *,? -? )-? ? "*? Y? ? -? ? ? ? ? *? *? ? ? ? ? A 5*,? ? *? *?? *? *+? *,? *-? *? *? ? ? + ? ? ? ? r f? Y*? ? *? ? ? L*? Y*? +*? ? ? *? *? *? ? /*? ? ? %*? Y? ? *? ? ? ? ? ? ? ? ? + ? ? ? ?LMN6 *? ? *? ? : ? ? ? !? ? ? " ? #?*? ? $? 1? %? '? : '?? ? ? !? ? ? (? )?*? ?*? ? *L+? ? +Y? ,? -?*? ? .:++? /? 0? 1? ? 2? !? "? ? 2? Y? 3? +? 4? ? )? :? ? 5? !? .? ? 5? Y? 3? +? 6? 7? +? /? 4? ? )?: *? ? 9? ?*? ? ?: *? ? *? ? : *? :? 4? ? ;? !? (? ? ;? Y? <? ? 4=? ? ? )? @*? :? 9? ? >? !? -? ? >? Y? ?? ? 4=? ? @? ? ? )*? ? AY:?*? ? B? C*? ? $? *? ? D*? ? *? ? A? E*? ? B? F? :*? ? B? F?? :??*? ? G? : ? x*? Y: ?*Y? H a? H ? : ??+? I? ? ] W ? ? ? ? ? ? ? ? " ? ? ? ? ? ~*? +? /? *? ? J*? ? *? ? KW+? L? ?*? ? AY: ?*? *? ? M? N6 *? ? ? O*? ? P*? ? *? ? Q? R*? ? ? S? T*? ? U*? ? ? V*? ? W*? ? WW? X? Y:? ZY*? ? [? \+? / ? ]M ? : ??*? ? ^Y: ?*? ,? _ ? : ?? ? 2? !? o? ? 2? Y? `? +? /? a? b? ? 4? ? )? ?? ZY*? ? [? \+? / ? ]M*? ? ^Y: ?*? ,? _ ? : ?? f: ? ? ? !? '? ? ? Y? c? *? ? ? 4? ? #? 1*? ? AY: ?*? ? W*? ? WW? X+? d? 5: ? ? ? !? '? ? ? Y? e? *? ? ? 4? ? # ? ?: ??*? ? fY: ?*? ? B? C+? g? h:? i6 ? ' ? j? *? ? D? k ? l? ? m? 9? ? ? !? -? ? ? Y? n? ? op? ? j? o? ? )+? g? h? k:*? ? q? r? :? s*? ? Q? *? ? s? t*? ? W+? g? h? u*? ? W+? v*? ? B? F? U: *? ? w? -? ? ? !? !? ? ? Y? x? +? 4? ? #*? ? B? F? :*? ? B? F? ??: ??*? :*? ? AY: ?*? ? y? : ? ? ? !? ? ? z ? # ?I: ??*? ? B? {*? ? W*? ? WW? X+? |? }: ? ! ? ~:? +? ? ?? ?+? ? ZY *? ? .+? ? ? ]M*? ? W*? ? WW? X? ? ?*? ? W*? ? WW? X? ?: *? ? W*? ? WW? X? ? ? ? ~:,? ? ?,*? ? ? ?*? ,? ?q: *? ? w? -? ? ? !? !? ? ? Y? ? +? 4? ? #?8: ? ? ? !? ? ? ? ? #?*? ? B+? ? ? ?*? ? W*? ? WW? X+? |? }: ? % ? ~:? +? ? ?+? ? ?+? ??: ? ? ? !? ? ? ? ? #??+? g? : ? h*? ? ? =? ? ? !? '? ? ? Y? ? +? /? 4? ? ? )*? ? ?R*? ? ? ? ? : ?< ? y?3? ? ? !?'? ? ? Y? ? +? 4? ? )?*? ? W*? ? WW? X? ? ?*? ? W*? ? WW? X? ?: *? ? W*? ? WW? X? ? ? ? ?: ? ~:+? ? ZN-? |? ? *? *? -? ? ]-? |? ? Q*? ? W*? ? WW? X-? |? }: ? ~:? -? ? !? +Y? Y? ? ? ? ? ? ? -?1: ? ? ? !? !? ? ? Y? ? +? 4? ? #?6 6*? ? AY:?*? ? W*? ? WW? X? ? ?*? ? W*? ? WW? X? ? ?:*? ? W*? ? WW? X? ? ?? ?6 +? |6 ? *? ? W*+? ? ::? ? ? !? ,? ? ? Y? ? ? o? ? o? ? #?G:??+? ? ZN*? ? W*? ? WW? X? ? ?*? ? W*? ? WW? X? ?: *? ? W*? ? WW? X? ? ? ? ?: ? ~:-? |? ? *? *? -? ? +*? ? W*? ? WW? X+? |? }: ? ~:-? ??:? ? ? !? !? ? ? Y? ? +? 4? ? #?k*? ? fY:?*? ? W*? ? WW? X? ? /:? ? ? !? !? ? ? Y? ? +? 4? ? #?:??66+? ? ? H+? ? ?:? ? ? *? ? ? ? ? "? ? ???+? L? ? ?*? *? +? ?*? ? W*? ? WW? X+? |? }: ? 0 ? ?:? $ ? ~:+? ? ?: +? ? ?? +? ?S:? ? ? !? (? ? ? Y? ? +? /? a? ? ? #? *? ? W*? ? WW? X? ? ?6*? ? W*? ? WW? X? ? ?6*? ? W*? ? WW? X? ?: ? ?: ? ~:? *? ? W*? ? WW? X? ? ?6+? ?*? ? ?? *? +? ? ?+? |? ? m*? ? W*? ? WW? X+? |? }: ? ? ? ~:? ? 2? !? ,? ? 2? Y? ? +? 4? ? ? o? ? )? ?+? ? }+? |? ? +? ? ? h*? *? +? ? Y+? ? ?: ? +? ? ?+? ? ?? +? ?*? *? +? ? :? ? ? !? ? ? ?? #? /? ?:? ? ? !? ? ? ?? #? ? q:? ?: ? *? ? W*? ? WW? X? ? ?? *? ? W*? ? WW? X? ? ? ? ? ? !? ? ? ? Y? ? +? 4? ? )?: ? ? ? !? ? ? ? Y? ? +? 4? ? )?? / @ F I r 8??? ??? ??? ??? 8$' ',' ?JM MRM `kn nsn ??? ??? ??? 1GJ 1? ??? ?er ?e? r?? ??? ??? ??? ??? ? ?? ? ?=?? O # & f ? ? f ? ? ? ? > A A F A ? i ? ? : ? ? : ? ? ? ? ? ? ? ? /TW 8 ? ? ? *? ? ? ? 3 *? YL?* ? H+? M+?,? ? *? H? ? b .-? -,? ? ?,? ? *,? ? #,? ? ?? *+,? ?-? -,? ?-,? ?,? ? o,? ? ?? d+? ?:?++? D? ? ? +? ? >? !? ? ? >? ),? ? ? >,? ? )+,? ?*+,? ?-? -,? ?? :??*+,? ?-? -,? ?,? ? ++? D? ? ? ,? ? -,? ? ? 2? !? (? ? 2? Y? ? ,? 4? -? 4? ? )? :? ? ? !? ? ? ?? #? U ? ? ? ? ? : ; ? ? ?,? ? !,? ? N+? .:-? ?? ? ? ?+? ? ?-? ? ? %-? ? ? ?:? ?,? ?+? ? ? ?? ? 2? !? ? ? 2? Y? ? ,? 4? ? )? ? ? ? ? ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de