Edit D:\app\Administrator\product\11.2.0\dbhome_1\oc4j\javacache\lib\oracle\ias\cache\groupv2\Client.class
?? .? ?/ ?0 ?1 ?2 ?3 ?4 ?5 ?67 89 ?: ?; <= ?> ?@ ?AB C D <EF -G -H I JK 8LM CN O P Q 8R <S T U VW ?X ?YZ ?[ -\ (] ?^_ <` <a -b (c ?de (fg 5h 5i jk ?l mn (n opq <r <s tu (v Jwx yz ?{| G} ~ ~? <?? ?? ?? <? ?? ?? G? (? (? G? ?? ??? 5? X? (? G? V? (? G? ?? (? ?? V? (?? J?? 8? 5? ?? ?? ?? ?? ??? <? ?? ?? ?? ?? ?? ??? w? ??? z? z? ?? ?? ?? ?? ?? G? ?? G?? ?C? ?? ?? ?? G? ??? ?? G? G? G? G? G? J??? <? (???? G? ?? ?? ??? ?? G? ??????????? G? G? ?? V?? (? <? ?? J?? m? m?? ?? o? ?? ?? ??????? ?? ~?? o? ???? G? G? G? G?? ?? ?? ? ? ? G ? G G G ? ? ?Q LOGGER_NAME Ljava/lang/String; ConstantValue PREFIX socket_ Ljava/net/Socket; connection_ -Loracle/ias/cache/groupv2/EndPointConnection; member_ &Loracle/ias/cache/groupv2/GroupMember; isRegistered_ Z enableFailover_ userContext_ Ljava/lang/Object; userMsgQueue_ %Loracle/ias/cache/commx/MessageQueue; logger_ Ljava/util/logging/Logger; <init> Q(Loracle/ias/cache/groupv2/GroupMember;Loracle/ias/cache/groupv2/Configuration;)V Code Exceptions ?(Loracle/ias/cache/groupv2/GroupMember;Loracle/ias/cache/groupv2/Configuration;Loracle/ias/cache/commx/MessageQueue;Ljava/lang/Object;)V init ()V connect (Z)V register sendTo i(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/Packet;Ljava/util/HashSet;Ljava/util/HashSet;)V! send ?(Loracle/ias/cache/groupv2/MemberID;Ljava/io/Serializable;Ljava/io/InputStream;Ljava/lang/String;ZJZ)Loracle/ias/cache/groupv2/GcommReplyInfo; sendTotalOrderPacketToMyself $(Loracle/ias/cache/groupv2/Packet;)V preparePacketToSend ?(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/View;Ljava/io/Serializable;Ljava/io/InputStream;Ljava/lang/String;ZJ)Loracle/ias/cache/groupv2/Packet; sendToDistributor %(Loracle/ias/cache/groupv2/Packet;I)V waitForConfirmation ?(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/View;IJLoracle/ias/cache/groupv2/ReceiptHolder;)[Loracle/ias/cache/groupv2/Packet; acquireTotalOrderToken (IJ)J releaseTotalOrderToken disconnect getMemberList &()[Loracle/ias/cache/groupv2/MemberID; cleanup disposeConnection 0(Loracle/ias/cache/groupv2/EndPointConnection;)V replyToSender &(Loracle/ias/cache/groupv2/Packet;[B)V addClient S(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/EndPointConnection;)V setEnableFailover enqueue +(ILoracle/ias/cache/groupv2/PacketHolder;)V dequeue +(IJ)Loracle/ias/cache/groupv2/PacketHolder; enqueueUserMessage *(Loracle/ias/cache/groupv2/PacketHolder;)V enqueueViewChangeEvent A(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/View;)V toString ()Ljava/lang/String; <clinit> ? ? ? ?" ? ? ? ? ? ? ? ? ? ? oracle.ias.cache.groupv2.Client# $% ? ? &'( )* +,- ./ ? ? java/net/Socket ? 01 23 java/net/InetSocketAddress 4- 56 ?78 9: ;< java/lang/StringBuffer Connecting to => =? ,- @A B6 C D6E FG HI J +oracle/ias/cache/groupv2/EndPointConnection KL M6 ?N ? ? oracle/ias/cache/groupv2/Address O- P6 ?Q RS java/io/IOException T 'oracle/ias/cache/groupv2/GcommException U ? ?VW XY Z[\ ]^ _ java/lang/InterruptedException `a b6c da ef g: Set registration timeout= =h for ij oracle/ias/cache/groupv2/Packet ?kl m* n* op [Bq rs t- u-v wx yz {| }~ 6 w? $% %oracle/ias/cache/commx/GroupException ? ? ?? ? ?z ?? ?I ?z? ?? ?j ?j ?? ?f java/lang/Exception ?: Invalid view: @? ?? ??? ?? ?? ?f ? Completed registeration for ?6 ?? ?? ?6 'oracle/ias/cache/groupv2/GcommReplyInfo ?? ?? java/util/HashSet ?f ?? ?? ?? ? () ?I java/io/ByteArrayOutputStream java/io/ObjectOutputStream ?? ?? ?z ??? ?f Unable to serialize message ?a ?? ? ?? ?? ?? ?: Reached max send retry $Unable to send packet to distributor ?6 ?? Send retry of Packet= ?a ??? ? ?? Reached max wait ACK retry ? ? Resend ?a ? ? Ungraceful disconnection ? ?a ?? ?: Close connection: #Packet Processor shutdown failure: ? ? ?* Lost connection to Retry ( ) GroupMember initialization Launch Distributor ?? ?? Unable to launch Distributor _? %Unable to re-register to distributor BUnable to find or become a distributor after reaching retry limit: ? ?| ?I ?? Unable to enqueue user message ?~ ?? ??? ?? ?? put ?6 ?? %oracle/ias/cache/groupv2/PacketHolder ?f remove ?? ?a %oracle/ias/cache/groupv2/GroupMessage ??? $? Deliver ?* ?* ?* Reply to sender Unable to reply ACK to sender #oracle/ias/cache/groupv2/ViewChange ?+ &' Unable to flush onhold message Not registered yet, , connection=[ ] CL oracle/ias/cache/groupv2/Client (oracle/ias/cache/groupv2/ConnectionOwner java/net/SocketException $java/lang/CloneNotSupportedException =(Loracle/ias/cache/groupv2/Configuration;Ljava/lang/String;)V java/util/logging/Logger getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; getConfig *()Loracle/ias/cache/groupv2/Configuration; &oracle/ias/cache/groupv2/Configuration isSSLEnabled ()Z getSSLManager '()Loracle/ias/cache/groupv2/SSLManager; #oracle/ias/cache/groupv2/SSLManager createSSLSocket ()Ljava/net/Socket; setSoLinger (ZI)V getDistributorAddress $()Loracle/ias/cache/groupv2/Address; getHostName getPort ()I (Ljava/lang/String;I)V java/util/logging/Level INFO Ljava/util/logging/Level; isLoggable (Ljava/util/logging/Level;)Z append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; log .(Ljava/util/logging/Level;Ljava/lang/String;)V getConnectTimeout (Ljava/net/SocketAddress;I)V getLocalPort !oracle/ias/cache/groupv2/MemberID generate &(I)Loracle/ias/cache/groupv2/MemberID; setID &(Loracle/ias/cache/groupv2/MemberID;)V createViewManager getEpThreadGroup ()Ljava/lang/ThreadGroup; getNetworkId V(Ljava/lang/ThreadGroup;Ljava/net/Socket;ILoracle/ias/cache/groupv2/ConnectionOwner;)V getDistributorHostName getPortForClients (Ljava/lang/String;IZI)V setRemoteAddress %(Loracle/ias/cache/groupv2/Address;)V close CLIENTINITFAILURE *(Ljava/lang/String;Ljava/lang/Throwable;)V /oracle/ias/cache/groupv2/PacketProcessorFactory createAPacketProcessorOf V(Loracle/ias/cache/groupv2/ConnectionOwner;)Loracle/ias/cache/groupv2/PacketProcessor; packetProcessor_ *Loracle/ias/cache/groupv2/PacketProcessor; (oracle/ias/cache/groupv2/PacketProcessor start java/lang/Object wait getResolutionTimeout ()J getMaxSystemInitRetry java/lang/System currentTimeMillis setTimeout (I)V FINEST (I)Ljava/lang/StringBuffer; getID %()Loracle/ias/cache/groupv2/MemberID; '(ILoracle/ias/cache/groupv2/MemberID;)V $oracle/ias/cache/groupv2/GroupMember isACoordinator isADistributor getTag ()Ljava/io/Serializable; *oracle/ias/cache/groupv2/GcommSerializable bytesToString ([B)Ljava/lang/String; getVMId getCacheName )oracle/ias/cache/groupv2/RegistrationInfo wrap ?(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/Address;ZLjava/lang/String;Ljava/lang/String;Ljava/lang/String;)Loracle/ias/cache/groupv2/RegistrationInfo; toBytes ()[B setData ([B)V read #()Loracle/ias/cache/groupv2/Packet; getType w(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/EndPointConnection;)Loracle/ias/cache/groupv2/PacketHolder; REGISTRATION (Ljava/lang/String;)V setTightlyBound getOrigin parse '([B)Loracle/ias/cache/groupv2/MemberID; setRemoteMemberID getData oracle/ias/cache/groupv2/View #([B)Loracle/ias/cache/groupv2/View; getRemoteMemberID getCoordinatorID equals (Ljava/lang/Object;)Z setType SEVERE C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V (Ljava/lang/Throwable;)V getViewManager (()Loracle/ias/cache/groupv2/ViewManager; $oracle/ias/cache/groupv2/ViewManager addView "(Loracle/ias/cache/groupv2/View;)V indexOfMember &(Loracle/ias/cache/groupv2/MemberID;)I setIndex updateToLatest getMaxSendRetry lock (II)V getCurrentView !()Loracle/ias/cache/groupv2/View; getSize #(Loracle/ias/cache/groupv2/View;I)V addReciptHolder K(Loracle/ias/cache/groupv2/Packet;)Loracle/ias/cache/groupv2/ReceiptHolder; add ?(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/Packet;Ljava/util/HashSet;Ljava/util/HashSet;)Loracle/ias/cache/groupv2/ReceiptHolder; unlock setFromMyself setDestination (Ljava/io/OutputStream;)V writeObject (Ljava/lang/Object;)V toByteArray getFlag '()Loracle/ias/cache/groupv2/PacketFlag; #oracle/ias/cache/groupv2/PacketFlag set getViewID setViewId (J)V setForRegistered setTotalSequence setInputStream (Ljava/io/InputStream;)V setAttachedFilename WARNING getMaxInitRetryDelay join getSequence waitForReply &(JJ)[Loracle/ias/cache/groupv2/Packet; &oracle/ias/cache/groupv2/ReceiptHolder clear clearReciptHolder logExpiredRecipients getPendingMembers getTotalSequence setBlockReceiver shutdown toBeDisconnected getDisconnectTimeout waitForEmptyQueue (IJ)V FINE notifyAll getMemberIDs isTerminating getSequenceToken *()Loracle/ias/cache/groupv2/SequenceToken; startDistributor n(ZLoracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/SequenceToken;)Z setAsReply setOrigin setAck getPacket getQueue (I)Ljava/util/Vector; getQueueStatus (I)Z java/util/Vector addElement QUEUE_TYPE_NAMES [Ljava/lang/String; size firstElement ()Ljava/lang/Object; removeElementAt /()Loracle/ias/cache/groupv2/EndPointConnection; getViewId (ILjava/lang/Object;)V #oracle/ias/cache/commx/MessageQueue '(Ljava/lang/Object;Ljava/lang/Object;)V isARequest isRegistered isFromMyself ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? *+,? ? X ? 8 ,*,? ? *+? *? *? *-? *? * ? ? ? X L *? ? ? **? ? ? ? *? Y? ? *? ? *? ? L? Y+? +? ? M*? ? ? ? *? ? ? Y? ? ,? ? ? !*? ,*? ? "? #**? ? $? %? &*? '*? (Y*? )*? +? **? +? ,*? ,? -Y*? ? .*? ? /? 0? 1*? 2? L*? ,? *? ,? 4? 5Y? 6+? 7?**? 8? 9*? 9? :*? ,YL?*? ,? ;*? ,? <? M+? N+?-?*? ? ? ? 3 = ? X ? ?*? ? ? **? ? ? ? *? Y? ? *? ? *? ? M? Y,? ,? ? N*? ? ? ? *? ? ? Y? ? -? ? ? !*? -*? ? "? #? **? ? $? %? &*? '*? (Y*? )*? ,? **? +? ,*? ,? -Y*? ? .*? ? /? 0? 1? 3 X ? ?*? ? >?*? ? ?hh=? @B*? , ? A*? ? B? ? ,*? ? B? Y? C? ? DE? *? F? ? ? !:? GY*? F? H:*? ? I*? ? J?6:*? ? K? *? ? K? L? M:*? F? N*? ? O? P:? Q? R*? ,? S: *? ,? T: ? U? ? '* *? ,? V? W? @!e ??? XY? Y? Z?*? ,? [*? , ? \? ]? ^ ? _? `: *? ,? a ? b? c? *? ,? d? *? ,? d? /: *? ? f? Y? g? ? ? ? h? 5Y ? i?*? j ? k? * *? F? l? m*? j? n*? ? ? ? #*? ? ? Y? o? *? F? ? ? !? AD e X 3 ? X _ +: : 7 : :? **? ? p? q7 *? j? r*? j? s:*+,- ? t: ? u? (? * ? v? wY*? F? l? x:? J? ? U? * ? y: ? $? zY? {:*? F? |W* ? }: ? ? !:? ?:*? j? ~? *? ?* *? ? p? ?* *? ? p ? ?? * ? v? *? ? :? *? ? wY*? F? l? x: ? , q ? t ? ? ? ? ? ? ? X ) +? U? *? ? +? ?*+? V? ? X ? ?: +? +? GY*? F? H: +? ?+*? F? c? ? ? ? GY*? F? H: -? L? -? L? R? I: ? ?? ?: ? ? ? ?: -? ? ? ?: ? ? ? ? ? R? : ? 5Y? ? 7? ,? ? ? ? ?? ? ? ? ? ? ?? ? ? ? ? ? ? P ? ? 3 X ? ?> ? ? ?*? ,+? S? ?: ? 7*? ? ? ? *? ? ? Y? ? ? D? ? !? XY? Z?*? ,*? ? ?? ? :*? ? ? ? 2*? ? ? Y? ? ? D? ? D? +? ? ? !?b? e P _ b = X ? ?6:?*? ? p? ?*+? ?? ?:? ?: ? =? ?*+? ? ?*? ? ? ? *? ? ? Y? ? ? D? ? ! ?? ?+? U? +? ?? ?: ? `6 ? U+ 2? ?*? ? ? ? 3*? ? ? Y? ? ? D? ? D? +? ? ? !*+? ?? ???$? ! $ X X ? ?: ?7:? GY*? F? H:? ?*? j? r*? j? s:? b? ?*? y:*? j? ~? : *? j? ~ ?*? ?* ? ?: ? 2: ? ?7? : *? ? 5Y ? i?? ( C O O Q O d ? ? e X 3 ? GY*? F? HL+? ?*? ,+? S? L? e ?*? ? GY*? F? HL+? ?+*? F? ? R*? ,+? S? %M*? ,? 4*? ? ? ? *? ? ??,? h*? ,? ?**? ? ? ?**? ? ? ?*? ,*? ? ? ? M*? ? ? ? *? ? ??,? h*? 9? *? 9? ?*? 9*? ? ? ? M*? ? ? ? *? ? ??,? h*? ?*YM?*? ?,? N,?-? ( + 3 l z } = ? ? ? = ? ? ? ? ? ? X *? j? s? ? X *? ?*? ? ? w*? ? ?+? aM*? ? f? ? )*? ? f? Y? ? ,? ? +? ? ? !>: ?*? ? ??&*? ? *? ? ? ? * ? %*? ? ? Y? ? ? D? ? ? !*? ? Z? *? j? s:*? ? ? ? *? ? ? !*? ,*? ? ?? :*? ? ? ? *? ? ?? h**? ? ?? ? :*? ? 4*? ?*? 2*? ,? ;? a:*? ? f? ? *? ? f?? h *? ? ??*? ??*? ? f? ? %*? ? f? Y? ? d? D? ? !? ? ? ? ? e ? ? ? = e 6 *+? ?++? \? ?+*? F? ?++? ? ?+,? R*? ,+? S? 3 X !" ? X # *? ? $% ? ?? A*? ? :*,? ? 1N*? ? f? ? #*? ? f? Y? ? ,? ? ? ? !?*? ?-Y:?*? ? ?,? ?:-,? ?*? ? B? ? )*? ? B? Y? ? ?2? ? ? ? ? !-? ?? :?? X N Y ? Z ? ? ? ? ? &' ? ?:*? ?:Y:?? ? ? ? U:? P:? ? ?:? ?:? ?*? ? B? ? )*? ? B? Y? ? ?2? ? ? ? ? !? :??? ! = v y y ~ y () k G+? ?+? ?*? j? r,? ?*? j? s? ?? *+? W*? j? ~?*? j? ~? :*? j? ~?*? ? ?+? ? ?*? ? ? *? ? B? ? *? ? B? Y? ? ,? ? ? !,? ? ?,? ? ?,? ? ?*? ? B? ? *? ? B? Y? ? ,? ? ? !? GY,? U*? F? H:,? \? ?,? ? ?? ?,? ? ?? ?? ?*-? V? W? /:*? ? f? ? *? ? f? Y? ? ,? ? ? !? + A A C A ? X X *+ ? ?*? ? ? ?+,? ?*? ? ?-? ?*? ? ? :* ? ?:? ?*? ???:*? ? f? ? $*? ? f? Y? ? ? ? ? ? !??*? ? B? ? *? ? B? Y? ? -? ? ? !? 7 = @ X ,- N B? Y? L*? ? +? W+*? ? W*? ,? +? W+*? ,? W+? W+? ? . ? ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de