Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\BaseLink.class
?? 1? ?? ?? ?? ?? ?? ?? ?? ?? ??? ? ??? ? ??? ? ?? ?? ?? ?? ?? ?? ?? ?? ???? ? ?? ? ?? ? ?? ??? ??? ?? ?? ??? ?? ?? ? ?? ?? ?? ? ?? ??? ? ?? ? ?? ???? ?? ?? ??? ?? ??? ?? ??? ?? ?? M? M? ? ?? ?? ? M? M? M? ? M? ?? M? ?? M? ? ? ? ? ? v? o o o o? v? v o v? v !" # ?$% ?&'( ?) *+ ?, ?- ?./0 ?1 ?234 ?5 ?6 ?7 ?8 ?9:; <= ?> ?? ?@ ?A ?B CD EF GH ?I JK L M ?N OP ?Q ?R ?S ?T ?U ?V ?W ?X ?YZ ?[ ?\ ?] ^_ ?`ab ?cd ?ef ?gh ?ij ?c ?klmn CLASS_PREFIX Ljava/lang/String; ConstantValueo ALTER_USERNAME I ALTER_PASSWORD ALTER_INBOUND_LOGQ ALTER_OUTBOUND_LOGQ ALTER_MAX_CONNS m_logger Loracle/mgw/common/MgwLog; m_tracer Loracle/mgw/common/Trace; m_apiTracer Loracle/mgw/common/ApiTrace; m_linkParams )Loracle/mgw/common/MsgLinkParamsNFactory; m_linkName m_maxThreads m_resetHandles Z m_msgOphPool !Loracle/mgw/drivers/OPHandlePool; m_logOphPool m_adminOphPool m_adminLock [B m_syncLogQ Ljava/lang/Object; m_valid m_foreignLink m_logDests Ljava/util/HashMap; m_logSetCache m_inboundLogQSeq m_outboundLogQSeq m_consumerInfoCache m_producerInfoCache <init> A(Loracle/mgw/common/MsgLinkParamsNFactory;IZILjava/lang/String;)V Code LineNumberTable LocalVariableTable this Loracle/mgw/drivers/BaseLink; params maxThreads foreignLink component facility event getLinkParamsNFactory +()Loracle/mgw/common/MsgLinkParamsNFactory; isForeignLink ()Z getTracer ()Loracle/mgw/common/Trace; markLinkInvalid ()V checkValidLink Exceptions isValidLink gwE $Loracle/mgw/common/GatewayException; isValid close method closeLink handleEvent (Loracle/mgw/common/Event;)V e Ljava/lang/Exception; Loracle/mgw/common/Event; processEvent periodicEvent idleCheckEvent currentTime J logSetCache_register ?(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;Loracle/mgw/drivers/ConsumerParams;Loracle/mgw/drivers/ConsumerParams;Z)Loracle/mgw/common/LogIdSet; setId producerP #Loracle/mgw/drivers/ProducerParams; consumerP #Loracle/mgw/drivers/ConsumerParams; browserP regParams removed logSet Loracle/mgw/common/LogIdSet; logSetCache_unregister (Loracle/mgw/common/LogIdSet;Z)Z unregParams logSetCache_get 1(Ljava/lang/String;Z)Loracle/mgw/common/LogIdSet; incrRef getConsumerP &(Ljava/lang/String;)Ljava/lang/Object; consId registerConsumerP /(Loracle/mgw/drivers/ConsumerProducerParams;Z)Z +Loracle/mgw/drivers/ConsumerProducerParams; unregisterConsumerP (Ljava/lang/String;Z)Z decrRef putConsumerP @(Loracle/mgw/drivers/ConsumerProducerParams;Z)Ljava/lang/Object; preserveRef getProducerP prodId registerProducerP unregisterProducerP putProducerP registerCPCache T(Ljava/util/HashMap;Loracle/mgw/drivers/ConsumerProducerParams;ZLjava/lang/String;)Z oldP cache id success refCount unregisterCPCache ;(Ljava/util/HashMap;Ljava/lang/String;ZLjava/lang/String;)Z remove putCPCache e(Ljava/util/HashMap;Loracle/mgw/drivers/ConsumerProducerParams;ZLjava/lang/String;)Ljava/lang/Object; getLogDest (I)Loracle/mgw/common/DestData; qname trcm whichLog dest Loracle/mgw/common/DestData; getLogQDest 0(Ljava/lang/String;)Loracle/mgw/common/DestData; verifyLogDestType (Loracle/mgw/common/DestData;)V logDest support getLogQueue (I)Ljava/lang/String; getLogSetSequence (I)I seq alterLinkParams ,(Loracle/mgw/common/MsgLinkParamsNFactory;)V oldParams alter newParams alterLinkCompare U(Loracle/mgw/common/MsgLinkParamsNFactory;Loracle/mgw/common/MsgLinkParamsNFactory;)I alterLink V(Loracle/mgw/common/MsgLinkParamsNFactory;Loracle/mgw/common/MsgLinkParamsNFactory;I)V oldName isAlter_resetHandles (I)Z isAlter_msgPoolSize isAlter_inboundLogQ isAlter_outboundLogQ setMsgPoolSize maxHandles resetHandles ge resetDone initHandlesFactories closeResetHandlesFactories closeAllConsumers (Ljava/lang/String;)V 6(Ljava/lang/String;Loracle/mgw/drivers/OPHandlePool;)V i ophs $[Loracle/mgw/drivers/PooledOPHandle; ophPool closeAllProducers alterAllConsumers 8(Ljava/lang/String;Loracle/mgw/drivers/ConsumerParams;)V Y(Ljava/lang/String;Loracle/mgw/drivers/ConsumerParams;Loracle/mgw/drivers/OPHandlePool;)V ge2 cons Loracle/mgw/common/MsgConsumer; alterCachedConsumer E(Loracle/mgw/common/MsgConsumer;Loracle/mgw/drivers/ConsumerParams;)V alterAllProducers 8(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;)V Y(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;Loracle/mgw/drivers/OPHandlePool;)V prod Loracle/mgw/common/MsgProducer; alterCachedProducer E(Loracle/mgw/common/MsgProducer;Loracle/mgw/drivers/ProducerParams;)V commitOph $(Loracle/mgw/drivers/BaseOPHandle;)V gwE3 gwE2 rethrow oph !Loracle/mgw/drivers/BaseOPHandle; trcString 7(Loracle/mgw/drivers/ConsumerParams;)Ljava/lang/String; consP 7(Loracle/mgw/drivers/ProducerParams;)Ljava/lang/String; prodP SourceFile BaseLink.java ? ? ? ? ? ? ? ? ?pqr ? ?stu ? ? oracle/mgw/common/Trace ?v ? ? oracle/mgw/common/ApiTrace ?w ? ? java/util/HashMap ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? oracle/mgw/drivers/OPHandlePool java/lang/StringBuilderxy .MsgOphPoolzr{| ?} ? ?s .LogOphPool ? ? .AdmOphPool ? ?~? "oracle/mgw/common/GatewayException?? BaseLink.close?{ Link closing: ??? Link closed: ?{?{ BaseLink.closeLinky BaseLink.handleEvent???r?? java/lang/Exception BaseLink.processEvent?? periodic?? idleCheck ?? BaseLink.periodicEvent BaseLink.idleCheckEvent????? BaseLink.logSetCache_register oracle/mgw/common/LogIdSet??r? ???|??C989?o?r?|O??rD<?r;<?r?? consumer ID not registered: BaseLink.registerConsumerPFG BaseLink.unregisterConsumerPMNz{ BaseLink.putConsumerPPQ producer ID not registered: BaseLink.registerProducerP BaseLink.unregisterProducerP?{ BaseLink.putProducerP?o java/lang/StringBuffer ?? id=x? , incrRef=x? )oracle/mgw/drivers/ConsumerProducerParams?| "Entry already exists in cache for ?? , success= , refCount=x? , decrRef= No entry found in cache for , removed= , preserveRef=?? BaseLink.getLogDest whichLog=x?_` oracle/mgw/common/DestDataYZ , queue= ????r?|??? 3log destination is a Queue but a Topic was expected 3log destination is a Topic but a Queue was expected?r?r BaseLink.alterLinkParams MsgLinkParamsNFactoryijkl?r???r BaseLink.alterLink alter=0x??`??nopoqoro????? BaseLink.resetHandles? resetting OPHandlesx??????oz|?? oracle/mgw/drivers/BaseOPHandle?{?|?{???????????? BaseLink.commitOph????? commit error! consId: , dest: ?r , subName: ?r , isLog: ? , isBrowser: ? prodId: ? oracle/mgw/drivers/BaseLink java/lang/Object oracle/mgw/common/MsgLink BaseLink. 'oracle/mgw/common/MsgLinkParamsNFactory getName ()Ljava/lang/String; oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; ?(Loracle/mgw/common/Log;ILjava/lang/String;Ljava/lang/String;)V (Loracle/mgw/common/Trace;IIII)V append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString getConns ()I /(Ljava/lang/String;ILoracle/mgw/common/Trace;)V oracle/mgw/common/MgwUtil GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; exception (Ljava/lang/Throwable;)V methodEntry trace (Ljava/lang/String;I)V clear log methodExit isTraceEntry oracle/mgw/common/Event '(Ljava/lang/String;Ljava/lang/String;)V ((Ljava/lang/String;Ljava/lang/String;I)V isEventName (Ljava/lang/String;)Z java/lang/System currentTimeMillis ()J checkHandles (J)V !oracle/mgw/drivers/ProducerParams getId !oracle/mgw/drivers/ConsumerParams K(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V incRefCount put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; isTraceExit toTraceString decRefCount &(Ljava/lang/Object;)Ljava/lang/Object; getProducerId getConsumerId getBrowserId get (I)V ,(Ljava/lang/String;)Ljava/lang/StringBuffer; (Z)Ljava/lang/StringBuffer; getRefCount (I)Ljava/lang/StringBuffer; setRefCount (I)Ljava/lang/StringBuilder; getDestParams ()Loracle/mgw/common/DestParams; oracle/mgw/common/DestParams getNativeName loggingSupport isBitSet (II)Z isTopic getInboundLogQ getOutboundLogQ getUser isEqual ((Ljava/lang/String;Ljava/lang/String;Z)Z getPassword java/lang/Integer toHexString msgLinkDescription (Z)Ljava/lang/String; java/lang/Math min (II)I setMaxPoolSize allCheckedIn java/lang/String valueOf isLevel getAllHandles &()[Loracle/mgw/drivers/PooledOPHandle; closeConsumer closeProducer getConsumer 3(Ljava/lang/String;)Loracle/mgw/common/MsgConsumer; getProducer 3(Ljava/lang/String;)Loracle/mgw/common/MsgProducer; nvl_null &(Ljava/lang/Object;)Ljava/lang/String; commit rollback getDestNativeName getSubName isLogConsumer isBrowser isLogProducer! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? 9 ? ? ? ? #*? *? *+? *? *? *+? ? *? ? *? Y*? *? ? ? 6*? Y*? ? ? *? Y? ? *? *? *? Y? ? *? Y? ? *? Y? ? *?? *?? *? *? Y? Y? *? ? ? ? +? !*? ? "? #*? $*? Y? Y? *? ? %? ? *? ? "? &*? Y? Y? *? ? '? ? *? ? "? (*? *? )W? ? j ? ? ? ? ? ? ? '? >? A? V? a? f? k? v? ?? ?? ?? ?? ?? ?? ?? ????"? ? H # # ? # ? # ? # ? # ? A ? ? ? / *? ? ? ? ? / *? ? ? ? ? / *? ? ? ? ? 4 *? ? ? ' ( ? ? F *? ? ?*? ? *? ? 5 6 7 ? + ? p *? ? ? ?*? ? *?*? +? ,? + ? E F J L N Q ? ? / *? ? ? ^ ? ? ? {-L*? -? .*? ? Y? /? *? ? ? ? 0*YM?*? 1,? N,?-?*? 2*? ? *? ? 3*? *? ? Y? 4? *? ? ? ? 5*? -? 6? . 4 7 7 : 7 ? 6 ~ ? *? .? 2? <? @? H? O? T? q? z? ? { x ? ? y )7L*? 7? .*? 8*? #*? &*? (*? 7? 6? ? "