Edit D:\app\Administrator\product\11.2.0\dbhome_1\oc4j\javacache\lib\oracle\ias\cache\groupv2\ConnectionOwner.class
?? .?V WX ?YZ ?[ ?\] ^_ ?` ?a bc de ?fg ?h ?ijk l ?m n o bpq ?r s t bu ?vwx Y ?yz "o ?{| %Y ?} ~ ? ? ?? ~ ? ??? /Y /?? /? /? ??? ?? 6? ?? 6?? ;o "?? >? >? >?? "? "? ?? "?? ?? G? ? ??? ?? ?? ^??? /? ^??? U? ? ???? Y?? ]? ?? ?? ?? L? L? ?? ???? ?? Y? ? ?? ?? ?? ?? ?? Y? ??? Y? Y? ?? /????? ?? Y? ???? Y~ Y? W?? d? ?? ?????? ?? ?l X ??? ?? 6? U? ]? ?? ]?? Y? ?? ?? ?? 6?? ?Y b? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? %? ?? ?? %? %? ? ? ? W LOGGER_NAME Ljava/lang/String; ConstantValue SEND_QUEUE I RECEIVE_QUEUE DELIVERY_QUEUE RESOLUTION_QUEUE TOTALORDER_QUEUE ONHOLD_QUEUE TOTAL_QUEUE QUEUE_TYPE_NAMES [Ljava/lang/String; ENDPOINT_THREADGROUP JVM_ID_KEY WAIT_ACK_PAUSE d WAIT_ACK_LOG_INTERVAL X queues_ [Ljava/util/Vector; queueStatus_ [Z id_ #Loracle/ias/cache/groupv2/MemberID; logger_ Ljava/util/logging/Logger; config_ (Loracle/ias/cache/groupv2/Configuration; prefix_ idIndex_ senders_ ([Loracle/ias/cache/groupv2/PacketSender; allReceipts_ Ljava/util/HashMap; terminating_ Z vmgr_ &Loracle/ias/cache/groupv2/ViewManager; myPublicAddresses_ Ljava/util/Hashtable; epThGroup_ Ljava/lang/ThreadGroup; sslMgr_ %Loracle/ias/cache/groupv2/SSLManager; seqToken_ (Loracle/ias/cache/groupv2/SequenceToken; packetProcessor_ *Loracle/ias/cache/groupv2/PacketProcessor; disposeConnection 0(Loracle/ias/cache/groupv2/EndPointConnection;)V Exceptions addClient S(Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/EndPointConnection;)V enqueue +(ILoracle/ias/cache/groupv2/PacketHolder;)V dequeue +(IJ)Loracle/ias/cache/groupv2/PacketHolder; getVMId ()Ljava/lang/String; Code <init> =(Loracle/ias/cache/groupv2/Configuration;Ljava/lang/String;)V getQueue (I)Ljava/util/Vector; cleanQueue (I)V setEnableQueue (IZ)V getQueueStatus (I)Z getEpThreadGroup ()Ljava/lang/ThreadGroup; waitForEmptyQueue (IJ)V notify cleanup ()V getID %()Loracle/ias/cache/groupv2/MemberID; setID &(Loracle/ias/cache/groupv2/MemberID;)V setIndex setPrefix (Ljava/lang/String;)V getPrefix getConfig *()Loracle/ias/cache/groupv2/Configuration; createViewManager "(Loracle/ias/cache/groupv2/View;)V getViewManager (()Loracle/ias/cache/groupv2/ViewManager; getMyAddressOn %(I)Loracle/ias/cache/groupv2/Address; getMyPublicAddresses %()[Loracle/ias/cache/groupv2/Address; addPublicAddress %(Loracle/ias/cache/groupv2/Address;)V addReciptHolder ?(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/Packet;Ljava/util/HashSet;Ljava/util/HashSet;)Loracle/ias/cache/groupv2/ReceiptHolder; K(Loracle/ias/cache/groupv2/Packet;)Loracle/ias/cache/groupv2/ReceiptHolder; removeRecipient $(Loracle/ias/cache/groupv2/Packet;)V hasAll (J)Z clearReciptHolder (J)V clearExpiredReceipts waitForReply &(JJ)[Loracle/ias/cache/groupv2/Packet; processPacket Q(Loracle/ias/cache/groupv2/Packet;Loracle/ias/cache/groupv2/EndPointConnection;)V shutdown isTerminating ()Z getUniqueTempFilePath sendTo i(Loracle/ias/cache/groupv2/View;Loracle/ias/cache/groupv2/Packet;Ljava/util/HashSet;Ljava/util/HashSet;)V replyToSender S(Loracle/ias/cache/groupv2/EndPointConnection;Loracle/ias/cache/groupv2/Packet;[B)V getPacketProcessor ,()Loracle/ias/cache/groupv2/PacketProcessor; getSSLManager '()Loracle/ias/cache/groupv2/SSLManager; setSequenceToken +(Loracle/ias/cache/groupv2/SequenceToken;)V getSequenceToken *()Loracle/ias/cache/groupv2/SequenceToken; releaseToken toString <clinit> oracle.ias.gcomm.vmid ? ? ? ? (oracle.ias.cache.groupv2.ConnectionOwner ? ? ? ? E! "# ? ? java/util/Vector ? ? ? ? java/lang/ThreadGroup Connection EndPoints ' ? ? $% &' %oracle/ias/cache/groupv2/PacketSender ? ? ( ) *+ ,= java/lang/InterruptedException java/util/HashMap ? ? java/util/Hashtable ? ? &oracle/ias/cache/groupv2/SequenceToken ? ? - .' / C ? ? java/lang/StringBuffer 01 02 T &' $oracle/ias/cache/groupv2/ViewManager 12 3 ? ? 4 java/lang/Integer 56 oracle/ias/cache/groupv2/Address 7' 89 : $java/lang/CloneNotSupportedException ;<= >? @A java/lang/LongB C+ = DEF !oracle/ias/cache/groupv2/MemberIDG HI JK Exclude members for sq= 0L MN distributors for sq= ,oracle/ias/cache/groupv2/ClientReceiptHolder O &oracle/ias/cache/groupv2/ReceiptHolder Create receipt holder for sq= , size= P' ,oracle/ias/cache/groupv2/SingleReceiptHolder Q RE SE TU VW XE Y+ ZI Found no receipt for ack= . Ignore packet= T[ \] ^_` abc dE e9f g" h' i$ jI %Remove all receipts for distributor: kl mE n6 Receipt has already removed ack= 0o Completed ack= Clear all receipts for sq= "No receipt to check for expiration Check expired items from receipt holders p; qI Clear expired receipts for sq= r s+ Wait for replies of sq= 'oracle/ias/cache/groupv2/GcommException t ? u Timeout while waiting for replies of sq= ReceiptHolder= v ? wI Still waiting for replies of sq= -. xy z, {"| }~ . Did not get replies of sq= ? ? ?B ? ? java/rmi/server/UID ?? ? ? ?? ? ?U ?? !" ?$ ?= ?? ?9 S$ QR ?" ? , ID= Index= SequenceToken= Total pending recipients= View Manager: $ Total EndPoint connection threads: ?' java/lang/String Send Q Receive Q Delivery Q Resolution Q TotalOrder Q OnHold Q ? ?? ?? ?? (oracle/ias/cache/groupv2/ConnectionOwner java/lang/Object %oracle/ias/cache/commx/GroupException java/io/IOException java/lang/System getProperty &(Ljava/lang/String;)Ljava/lang/String; java/util/logging/Logger getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; &oracle/ias/cache/groupv2/Configuration isSSLEnabled #oracle/ias/cache/groupv2/SSLManager getInstance Q(Loracle/ias/cache/groupv2/ConnectionOwner;)Loracle/ias/cache/groupv2/SSLManager; setDaemon (Z)V getMaxSenderThreads ()I -(Loracle/ias/cache/groupv2/ConnectionOwner;)V start getInitTimeout ()J wait clear size notifyAll append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; (I)Ljava/lang/StringBuffer; P(Loracle/ias/cache/groupv2/ConnectionOwner;[Loracle/ias/cache/groupv2/Address;)V L(Loracle/ias/cache/groupv2/ConnectionOwner;Loracle/ias/cache/groupv2/View;)V get &(Ljava/lang/Object;)Ljava/lang/Object; getNetworkId clone ()Ljava/lang/Object; setNetworkId values ()Ljava/util/Collection; java/util/Collection toArray (([Ljava/lang/Object;)[Ljava/lang/Object; put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; oracle/ias/cache/groupv2/Packet getSequence containsKey (Ljava/lang/Object;)Z java/util/HashSet java/util/logging/Level FINEST Ljava/util/logging/Level; isLoggable (Ljava/util/logging/Level;)Z ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; log .(Ljava/util/logging/Level;Ljava/lang/String;)V ?(Loracle/ias/cache/groupv2/ConnectionOwner;Loracle/ias/cache/groupv2/View;[Loracle/ias/cache/groupv2/MemberID;[Loracle/ias/cache/groupv2/MemberID;Loracle/ias/cache/groupv2/Packet;)V getTotalPending N(Loracle/ias/cache/groupv2/ConnectionOwner;Loracle/ias/cache/groupv2/Packet;)V isRegistered isARequest getDestination ()[B parse '([B)Loracle/ias/cache/groupv2/MemberID; equals getAck WARNING (Z)Ljava/lang/String; addReceipt $(Loracle/ias/cache/groupv2/Packet;)I keySet ()Ljava/util/Set; java/util/Set iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next +oracle/ias/cache/groupv2/EndPointConnection getRemoteMemberID getType removeMember FINE removeDistributor &(Loracle/ias/cache/groupv2/MemberID;)I isFilledUp remove (J)Ljava/lang/StringBuffer; isExpired SEVERE notifyWaiters currentTimeMillis LOCKINTERRUPT *(Ljava/lang/String;Ljava/lang/Throwable;)V REPLYTIMEOUT INFO getCurrentView !()Loracle/ias/cache/groupv2/View; removeNonExistMembersFrom getRecipient oracle/ias/cache/groupv2/View contains &(Loracle/ias/cache/groupv2/MemberID;)Z getReplies $()[Loracle/ias/cache/groupv2/Packet; (oracle/ias/cache/groupv2/PacketProcessor process getTempPath java/io/File separator replace (CC)Ljava/lang/String; setAsReply getOrigin setDestination ([B)V setOrigin setAck setData send getOwner release activeCount java/lang/Runtime getRuntime ()Ljava/lang/Runtime; setProperty 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? 1 B ? ? $ *? *? *? *? ? *+? *,? *? ? ? **? ? *? ? *?? *? Y? ? *? ? > *? ? *? ? Y? S*? T???*+? ? ? > *? ? J*? ? Y*? S*? 2Y:?*? 2? *? 2+? ? ? :? :????*? Y? ? !*? "Y? #? $*? %Y? &? '? ? ? ? ? ? ? ? ? ? *? 2? 9 *? 2YM?*? 2? (,? N,?-? 9 *? 2YN?*? T-? :-?? *? 3? *? ? S /*? ):Y:?? *? ? ? :? :?? # & & + & 7 *? )M,YN?,? +-? :-?? ? y<*? ? 5*? 2YM?*? 2? (*? 2? +*? T,? N,?-???*? !YL?*? !? ,*? !? ++? :+??<*? ? *? 2? -??? / 2 2 5 2 D T W W [ W !" *? .? #$ *+? .? % 3 '*? *? /Y? 0*? ? 12? 1*? ? 3? 4? 5? &' *+? ? ( *? ? )* *? ? + *? 6Y**? 7? 8? 9? +, *? 6Y*+? :? 9? -. *? 9? /0 a M*? $? ;Y? <? =? >M,? 7*? 7N6-? (-2? ?? -2? @? >M,? A? :???,? 0 @ C B 12 P 4*? $YM?*? $? CN*? $? D6? >L-+? E W,? :,??+? ( + + / + 34 ! *? $? ;Y+? ?? <+? FW? 56 Z >? GY,? H? I::*? !Y:?*? !? J? ?:: -? I-? K? L:-? MW*? ? N? O? ,*? ? N? /Y? 0P? 1? 3Q? 1? R? 4? S? K? K? L: ? MW*? ? N? O? ,*? ? N? /Y? 0P? 1 ? 3T? 1? R? 4? S? UY*+ ,? V:*? !? WW*? !? +? *? !? X? Y:*? ? N? O? .*? ? N? /Y? 0Z? 1? R[? 1? \? 3? 4? S? : ? ?? 03 383 57 ? ? GY+? H? IMN*? !Y:?*? !,? J? !? ]Y*+? ^N*? !,-? WW*? !? +? *? !,? X? YN*? ? N? O? ,*? ? N? /Y? 0Z? 1,? R[? 1-? \? 3? 4? S? :??-? ? ? ? ? ? 89 ? ?+? _? "+? `? +? a? *? .+? a? b? c? ? GY+? d? IMN6*? !Y:?*? !,? X? YN-? >*? ? e? O? -*? ? e? /Y? 0f? 1,? Rg? 1+? h? 1? 4? S?-+? i6? :?? @ ? ? ? ? ? ? ? ? 8 ? ?*? !YM?*? !? jN-? ,?-? k :? l ? ?? m ? G:*? !? X? Y:? ??+? n:? ??+? o? ? p??+? o??*? ? q? O? !*? ? q? /Y? 0r? 1? R? 4? S? sW?y,? :,?? ? ? ? ? ? ? 8$ ? t*? !YM?*? !? jN-? ,?-? k :Y:?? l ? .? m ? G:*? !? X? Y:? ??+? p??? :??,? : ,? ? $ \ _ _ d _ l i l l p l :; ? ?>? GY ? I::*? !Y:?*? !? X? Y:? ? tY>? :*? !? uW? -*? ? N? O? *? ? N? /Y? 0v? 1 ? w? 4? S? :?? ? -*? ? N? O? *? ? N? /Y? 0x? 1 ? w? 4? S ? n q q v q <= j N*? !YN?*? !? GY ? I? uW*? ? N? O? *? ? N? /Y? 0y? 1 ? w? 4? S-? :-?? C F F J F >= ?*? !YN?*? !? j:? *? ? N? O? *? ? Nz? S-?*? ? N? O? +*? ? N? /Y? 0{? 1*? !? |? 3}? 1? 4? S? k :? l ? p? m ? G:*? !? X? Y:?? ? ~??*? ? ? O? .*? ? ? /Y? 0?? 1? \? 3? 1? R? 4? S? ?? ???-? :-?? 0 ? 1 ? ? ? ? ? ?@ ? Y::? GY ? I:? ?7*? ? N? O? !*? ? N? /Y? 0? 1? R? 4? S*? !Y: ?*? !? X? Y:? ?e!? 2? -*? ! ? *? !? X? Y:??: ? ?? ? ? ? ? : ? ?? Q*? ? e? O? 9*? ? e? /Y? 0? 1!? w? 1? 1? R? 1? R? 4? S? ?? ? ?6 7 ? ?Y: ?? t? ? ? ? ? : ? : ?? a7 ? ?e!? 6 ?? ? ???*? ? ? O? +*? ? ? /Y? 0? 1? R? 1? R? 4? S? U? ? U: *? ? ?: ? ??V? ]?N? ]: *? ? ?: ? ? ??1 ? ? ?6 ?!? t? L*? ? e? O? 4*? ? e? /Y? 0? 1!? w? 1? R? 1? R? 4? S? ?? ? ?*? !Y: ?*? !? uW ? : ??? ?:? ?? f ~ ? H ? ? ? ? ? # # #(# 2?B BGB AB *? ?+,? ? C *? ?*? 9? *? 9? ? DE *? ? F ? 3? ?? ?? /Y? 0*? ? ? 1? ? 1+? ?:_? ? 1? 4M,? GH B IJ 3 ',? ?,,? ? ?,*? ? ?,,? H? ?,? ?+,? ? KL *? ? MN *? ? OP *+? ? %? '? B QR *? '? S *? ? S$ d @*? ?,YN?+? ,? ?+? c? -?,? ?* ? ?:? *? ?-? :-?? 8 5 8 8 < 8 T ? ? /Y? 0L*? .? +? 1W+*? .? RW+? 1W+*? ? 3W+? 1W+*? '? RW*? !YM?*? !? '*? !? |? +? 1W+*? !? |? 3W+? 1W,? N,?-?+? 1W+*? 9? RW+? 1W+*? ? ? 3W+? 1W+? 4? F s v v y v U m Q? ??Y?Y?Y?Y?Y?? ? ?K?? ? ? ?? ?+? ? ?*? M*?,? , H K K N K
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de