Edit D:\app\Administrator\product\11.2.0\dbhome_1\oc4j\javacache\lib\oracle\ias\cache\groupv2\DistributorPacketProcessor.class
?? .E ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ! "# $ % ?&' ( ) ?*+ ",-. /0 1 2 3 4 5 6 ?78 9: "; < = >? @A B C D E E F3 G H I J ?KL "M "NO oP Q oR S ?T "U V ?W ?X "Y ?Z [\]^ _ `a [b [cd e ?f g hijk ?l m n ?o ?p ?q ?r [s "t [u v "w xyz "{ | } ~ ?? l? ?? ?? ?? ?? ? ??? ? ? ?P? ?? ???? LOGGER_NAME Ljava/lang/String; ConstantValue distributor_ &Loracle/ias/cache/groupv2/Distributor; logger_ Ljava/util/logging/Logger; <init> -(Loracle/ias/cache/groupv2/ConnectionOwner;)V Code process Q(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/EndPointConnection;)V Exceptions coordinatorLookup getDistributorList? linkDistributor relinkDistributor electCoordinator R(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/EndPointConnection;Z)V disconnect Q(Loracle/ias/cache/groupv2/EndPointConnection;Loracle/ias/cache/groupv2/Packet;)V registerationRequest broadcast unicast replyAck replyAckLater reply newView viewChangeComplete closeDuplicatedDistributor switchCoordinator terminate getToken releaseToken updateTotalSequence removeTempFile (Ljava/lang/String;)V $oracle/ias/cache/groupv2/Distributor ? ? 3oracle.ias.cache.groupv2.DistributorPacketProcessor? ?? ? ? ? ?? ?? ?? java/lang/StringBuffer ?? Process ?? ?? ?? ?? ?? ? ? ? ? ? ? ? ? ? ? ?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?? Unsupported packet: Unrecognized packet: ?? java/lang/Exception ??? ?? PacketProcessor failure ?? ??? ?? ??? ??? ?? ?? ?? ?? ?? ?? ?? ?? ?? ??? ?? ?? ? ?? ?? ?? ?? ?? ??? ?? ?? ?? ?? Ignore lookup request ?? ?? ?? Connected from ?? Unexpected reply Unexpected request ? ?? ?? ?? ?? ?? ?? ?? ?? To be disconnected ? ?? ?? ?? ??? ?? ?? %oracle/ias/cache/commx/GroupException ?? ?? ?? ??? ? ? ? ? Unable to forward java/util/HashSet ?? ? ? ? ? ? ? ? Can't find any distributor for , view= Reply to sender ? View too old: ? ? ? ! " ? java/io/IOException Unable to reply ACK Reply ack later. Packet= #? $% &? '? (? )? *? ?+ ,- .? /0 1? 23 2Coordinator does not expect any new view request 5Coordinator does not expect any view change request 4? 56 7? 89: ; SequenceToken not available. oracle/ias/cache/groupv2/Packet ?< =? >? ?? @A B? Unable to contact token holder. C? ?? java/io/File ? ? D? 3oracle/ias/cache/groupv2/DistributorPacketProcessor (oracle/ias/cache/groupv2/PacketProcessor $java/lang/CloneNotSupportedException java/util/logging/Logger getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; java/util/logging/Level FINER Ljava/util/logging/Level; isLoggable (Ljava/util/logging/Level;)Z ()V append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; toString (Z)Ljava/lang/String; ()Ljava/lang/String; log .(Ljava/util/logging/Level;Ljava/lang/String;)V getType ()I isARequest ()Z SEVERE (I)Ljava/lang/StringBuffer; parent_ *Loracle/ias/cache/groupv2/ConnectionOwner; (oracle/ias/cache/groupv2/ConnectionOwner isTerminating C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V getOrigin ()[B !oracle/ias/cache/groupv2/MemberID parse '([B)Loracle/ias/cache/groupv2/MemberID; getData oracle/ias/cache/groupv2/Address &([B)Loracle/ias/cache/groupv2/Address; +oracle/ias/cache/groupv2/EndPointConnection setType (I)V setRemoteMemberID &(Loracle/ias/cache/groupv2/MemberID;)V setRemoteAddress %(Loracle/ias/cache/groupv2/Address;)V isACoordinator getNetworkId getMyAddressOn %(I)Loracle/ias/cache/groupv2/Address; toBytes setData ([B)V getCoordinatorAddress $()Loracle/ias/cache/groupv2/Address; getFlag '()Loracle/ias/cache/groupv2/PacketFlag; #oracle/ias/cache/groupv2/PacketFlag set isARouter replyToSender )oracle/ias/cache/groupv2/RegistrationInfo /([B)Loracle/ias/cache/groupv2/RegistrationInfo; getDistributorAddress getDistributorID %()Loracle/ias/cache/groupv2/MemberID; addDistributor u(Loracle/ias/cache/groupv2/Address;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/EndPointConnection;)Z getViewManager (()Loracle/ias/cache/groupv2/ViewManager; $oracle/ias/cache/groupv2/ViewManager .(Loracle/ias/cache/groupv2/RegistrationInfo;)V close forwardToCoordinator $(Loracle/ias/cache/groupv2/Packet;)J FINE ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; setTightlyBound (Z)V INFO replaceDistributor I(Loracle/ias/cache/groupv2/Address;Loracle/ias/cache/groupv2/MemberID;Z)V %oracle/ias/cache/groupv2/PacketHolder wrap w(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/EndPointConnection;)Loracle/ias/cache/groupv2/PacketHolder; enqueue +(ILoracle/ias/cache/groupv2/PacketHolder;)V containsDistributor equals (Ljava/lang/Object;)Z getMembersToBeRemoved ()Ljava/util/Vector; getDistributorsToBeRemoved getQueue (I)Ljava/util/Vector; FINEST java/util/Vector addElement (Ljava/lang/Object;)V removeMembers 9(Ljava/util/Vector;Ljava/util/Vector;Ljava/util/Vector;)V containsCoordinator getConfig *()Loracle/ias/cache/groupv2/Configuration; &oracle/ias/cache/groupv2/Configuration getInitTimeout ()J waitForInitCompleted (J)V isAlive getID setDistributorID getVMId java/lang/String setInSameJVMOfDistributor getMemberID addClient S(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/EndPointConnection;)V addPendingNewMember WARNING lock (II)V getCurrentView !()Loracle/ias/cache/groupv2/View; getRemoteMemberID add sendTo i(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/Packet;Ljava/util/HashSet;Ljava/util/HashSet;)V getViewId getView "(J)Loracle/ias/cache/groupv2/View; sendToClients V(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/View;Ljava/util/HashSet;)V getAttachedFilename unlock getDestination oracle/ias/cache/groupv2/View getDistributorOfMember H(Loracle/ias/cache/groupv2/MemberID;)Loracle/ias/cache/groupv2/MemberID; sendToClient G(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/Packet;)V sendToDistributor contains &(Loracle/ias/cache/groupv2/MemberID;)Z getViewID (J)Ljava/lang/StringBuffer; getEndPointConnectionOf S(Loracle/ias/cache/groupv2/MemberID;Z)Loracle/ias/cache/groupv2/EndPointConnection; sendPacketTo getSequence hasAll (J)Z clearReciptHolder setDestination setOrigin setAsReply setAck #([B)Loracle/ias/cache/groupv2/View; addView "(Loracle/ias/cache/groupv2/View;)V getCoordinatorID setCoordinatorEp 0(Loracle/ias/cache/groupv2/EndPointConnection;)V updateToLatest dequeue +(IJ)Loracle/ias/cache/groupv2/PacketHolder; setInProgress setRole (IZ)V shutdown getSequenceToken *()Loracle/ias/cache/groupv2/SequenceToken; &oracle/ias/cache/groupv2/SequenceToken acquiredBy '(ILoracle/ias/cache/groupv2/MemberID;)V setTotalSequence setViewId setBlockReceiver sendToDistributors $(Loracle/ias/cache/groupv2/Packet;)I setForRegistered release delete ? ? ? ? ? ? ? ? ? ? ? ? & *+? ? *? ? *+? ? ? ? ? ? ?*? ? ? ? $*? ? ? Y? ? +? ? ? ? +? ? g ? ? b k ? ? g ? 6 ? ? t } ? ? ? 6 $ -*+,? ?9*+,? ?0*+,? ?'*+,? ? *+,? ?*,+? ? +? ? *+,? ? ?*+,? ? ?+? ? *+,? ? ?*+,? ? ?*+,? ? ?*+,? ? ?*+,? ? ?*+,? ? ?*+,? ? ?*+,? ? ?*+,? ? ?+? ? *+,? !? ?*+,? ? ?*+,? "? w*+,? #? n*? ? $? ? a*? ? $? Y? %? +? ? ? ? ? =*? ? $? ? 0*? ? $? Y? &? +? ? '(? +? ? ? ? ? (N*? *? +? *? ? $? ? *? ? $,-? -? .?? ) ? _ ? ? ? ? ?+? .? /N+? 0? 1:,? 2,-? 3,? 4*? ? 5? +*? ? 6? 7? 8? 9? R*? ? ::? +? ;? <? 9*? ? =? &? 6? 6? +*? ? 6? 7? 8? 9? +? 8? 9*? ,+? >? ? ? _ ? ? ? ? ?,? 2+? 0? ?N*? ? 5? +*? -? @-? A,? B? *? ? C-? D? s,? E? l*? ? =? "*? -? @-? A,? B? O*? +? FX? C+? ;? <+? 9*? ? G? ? *? ? G? Y? H? +? I? ? *? ,+? >? ? ? _ ? ? ? ? ? ?+? ? ~,? 2+? 0? 1N+? .? /:,-? 4+? 9*? -,? B6? 6,? J*? ? K? ? 1*? ? K? Y? L? ? I? ? ? +? ;? <,? J*? ,+? >? ? _ ? ? ? ? ? ?*? ? 5? Y+? ? %+? 0? 1N+? .? /:*? ? C-? M? p*? ? $? ? c*? ? $? Y? N? +? I? ? ? C*? ? =? *? +? FX? -*? ? $? ? *? ? $? Y? O? +? I? ? ? ? _ ? ? ? ? ? N B+? .? /: ? ,? 2,? E+,? P:*? ? Q*? ? =? +? 0? 1:? 66? ? ? _ ? ? ? ? ?*? ? 5? ?,? ;? R? +? E? ?,? 0? /N,? .? /:-? S? b*? ? T:*? ? U:*? ? V:*? ? W? ? *? ? W? Y? X? -? I? ? -? Y*? ? C? Z? M+? E? F*? ? =? ',? ? ,? ;? [? +? E? $*? ,? FX? ,? ? ,? ;? [? +? E? ? ? _ ? ? ? ? : *? *? ? \? ]? ^? N,? E?,? `? ?+? 0? ?N*? ? 5? I+? ;? R? 4-*? ? a? b-? c? d? e? -? f? -? f*? -? g,? h*? -? i? ?*? ? =? +? ;? R? 0-*? ? a? b-? c? d? e? -? f? -? f+-? j? 9*? +? FX*? ? =? +? ;? R? *? -? g,? h? 9:*? ? k? ? &*? ? k? Y? l? +? ? ? ? -,? E? _ ? ? ? ) ? ? _ ? ? ? ? ? ?+? ;? R? ? +? ;? [? ? ~>*? ? C? m*? ? C? n: ? '? oY? p:,? q? rW*? +? s? *? ? C+? t? u:*? +? v? ? #:? ?:*+? w? x*? ? C? y?? 8 ~ ? ? ? ? ? _ ? ? ? ? ? ? ?+? ;? R? ? +? ;? [? ? ~>*? ? C? m*? ? C? n:+? z? /:? {:? ;*? ? $? ? T*? ? $? Y? |? ? I}? ? I? ? ? )*? ? a? S? *? +? ~? *? +? *? ? C? y? :*? ? C? y? 8 ? ? ? ? ? ? _ ? ? ? ? ? 7 *? ? ? ? *? ? W? Y? ?? +? I? ? +? z? /N:*? ? C? n:-? ? ?+? t? ?? 8*? ? W? ? $*? ? W? Y? ? ? ? ? ? *+,? ?-? {:*? ? a? S? *? -? ?:? *? ? ?:? &*? +? ? M:*+,? ? B:*+,? ? 7*? ? k? ? $*? ? k? Y? ? +? ? ? ? *+,? ? ? ? ? ? ? ? ? _ ? _ ? ? ? ? \ P+,? PN*? ? K? ? *? ? K? Y? ? +? I? ? *? ? 5? *? -? Q? *? -? Q? ? ? ? ? ?+N-? ;? R? ? -? ;? [? ? ~6*? +? ? ? *? +? ? ?*? ? W? ? *? ? W? Y? ?? +? I? ? -? .? /:*? ? ?:-? .:-? ?-*? ? a? ?-? ?--? ? ?*? -? P? Q? ? _ ? ? ? ? ?*? ? 5? ?+? ? }+? 0? ?*? ? C-? ?-? ?:*? ? ?:? *? ? ?*? ? C? ? :*? ? C? ??*? +-? v:*? ? ?:? m*? ? Q??*? +? FX? T+? ? 4*? ? $? ? @*? ? $? Y? ? +? ? ? ? ? *? +? ? ? *? +? ? ? $ D R R T R ? _ ? ? ? ? ? ? ?*? ? 5? n+? ? 4*? ? $? ? ?*? ? $? Y? ? +? ? ? ? ? g*? +? ? ? Y*? +? ? ?*? ? C? ?*? ? C? y? 4+? ? $*? ? C? ?*? +*? ? C? n? v? *? +? FX? ? ? _ ? ? ? ? ,? J,? E? ? ? ? 6 **? ? 5? *? ? ? *? ? =? *? +? FX? ? _ ? ? ? ? *? ? =? *? ? ? ? _ ? ? ? ? [*? ? C? m*? ? C? nN*? ? C? y*? ? 5?'*? ? ?:Y:?+? .? /? ? C*? ? W? ? !*? ? W? Y? ? ? I? ? +,? P:*? ? Q?? :??? ?7? ?+? .? /? ?:? ?-? ? ?? ?*? ? ?*? -? v? ?*? ? a? ?:? ?+? ? ?? ?? ?? ?+? .? ?-? ? ?*? ,? ? 1: *? ? k? ? *? ? k? ? -? ? *? +? FX? < ? ? ? ? ? ? ? ? ), ? ? _ ? ? ? ? c W*? ? 5? F*? ? ?*? ? C? nN? ?? ?:-? ? ?? ?*? ? ?*? -? v? *? +? FX? ? _ ? ? ? ? , *? ? 5? *? ? C? nN*? +-? v? ? _ ? ? ? +? ? ?+? ?,? ??
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de