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_PREFIXLjava/lang/String; ConstantValueoALTER_USERNAMEIALTER_PASSWORDALTER_INBOUND_LOGQALTER_OUTBOUND_LOGQALTER_MAX_CONNSm_loggerLoracle/mgw/common/MgwLog;m_tracerLoracle/mgw/common/Trace; m_apiTracerLoracle/mgw/common/ApiTrace; m_linkParams)Loracle/mgw/common/MsgLinkParamsNFactory; m_linkName m_maxThreadsm_resetHandlesZ m_msgOphPool!Loracle/mgw/drivers/OPHandlePool; m_logOphPoolm_adminOphPool m_adminLock[B m_syncLogQLjava/lang/Object;m_valid m_foreignLink m_logDestsLjava/util/HashMap; m_logSetCachem_inboundLogQSeqm_outboundLogQSeqm_consumerInfoCachem_producerInfoCacheA(Loracle/mgw/common/MsgLinkParamsNFactory;IZILjava/lang/String;)VCodeLineNumberTableLocalVariableTablethisLoracle/mgw/drivers/BaseLink;params maxThreads foreignLink componentfacilityeventgetLinkParamsNFactory+()Loracle/mgw/common/MsgLinkParamsNFactory; isForeignLink()Z getTracer()Loracle/mgw/common/Trace;markLinkInvalid()VcheckValidLink Exceptions isValidLinkgwE$Loracle/mgw/common/GatewayException;isValidclosemethod closeLink handleEvent(Loracle/mgw/common/Event;)VeLjava/lang/Exception;Loracle/mgw/common/Event; processEvent periodicEventidleCheckEvent currentTimeJlogSetCache_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 regParamsremovedlogSetLoracle/mgw/common/LogIdSet;logSetCache_unregister (Loracle/mgw/common/LogIdSet;Z)Z unregParamslogSetCache_get1(Ljava/lang/String;Z)Loracle/mgw/common/LogIdSet;incrRef getConsumerP&(Ljava/lang/String;)Ljava/lang/Object;consIdregisterConsumerP/(Loracle/mgw/drivers/ConsumerProducerParams;Z)Z+Loracle/mgw/drivers/ConsumerProducerParams;unregisterConsumerP(Ljava/lang/String;Z)ZdecrRef putConsumerP@(Loracle/mgw/drivers/ConsumerProducerParams;Z)Ljava/lang/Object; preserveRef getProducerPprodIdregisterProducerPunregisterProducerP putProducerPregisterCPCacheT(Ljava/util/HashMap;Loracle/mgw/drivers/ConsumerProducerParams;ZLjava/lang/String;)ZoldPcacheidsuccessrefCountunregisterCPCache;(Ljava/util/HashMap;Ljava/lang/String;ZLjava/lang/String;)Zremove putCPCachee(Ljava/util/HashMap;Loracle/mgw/drivers/ConsumerProducerParams;ZLjava/lang/String;)Ljava/lang/Object; getLogDest(I)Loracle/mgw/common/DestData;qnametrcmwhichLogdestLoracle/mgw/common/DestData; getLogQDest0(Ljava/lang/String;)Loracle/mgw/common/DestData;verifyLogDestType(Loracle/mgw/common/DestData;)VlogDestsupport getLogQueue(I)Ljava/lang/String;getLogSetSequence(I)IseqalterLinkParams,(Loracle/mgw/common/MsgLinkParamsNFactory;)V oldParamsalter newParamsalterLinkCompareU(Loracle/mgw/common/MsgLinkParamsNFactory;Loracle/mgw/common/MsgLinkParamsNFactory;)I alterLinkV(Loracle/mgw/common/MsgLinkParamsNFactory;Loracle/mgw/common/MsgLinkParamsNFactory;I)VoldNameisAlter_resetHandles(I)ZisAlter_msgPoolSizeisAlter_inboundLogQisAlter_outboundLogQsetMsgPoolSize maxHandles resetHandlesge resetDoneinitHandlesFactoriescloseResetHandlesFactoriescloseAllConsumers(Ljava/lang/String;)V6(Ljava/lang/String;Loracle/mgw/drivers/OPHandlePool;)Viophs$[Loracle/mgw/drivers/PooledOPHandle;ophPoolcloseAllProducersalterAllConsumers8(Ljava/lang/String;Loracle/mgw/drivers/ConsumerParams;)VY(Ljava/lang/String;Loracle/mgw/drivers/ConsumerParams;Loracle/mgw/drivers/OPHandlePool;)Vge2consLoracle/mgw/common/MsgConsumer;alterCachedConsumerE(Loracle/mgw/common/MsgConsumer;Loracle/mgw/drivers/ConsumerParams;)ValterAllProducers8(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;)VY(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;Loracle/mgw/drivers/OPHandlePool;)VprodLoracle/mgw/common/MsgProducer;alterCachedProducerE(Loracle/mgw/common/MsgProducer;Loracle/mgw/drivers/ProducerParams;)V commitOph$(Loracle/mgw/drivers/BaseOPHandle;)VgwE3gwE2rethrowoph!Loracle/mgw/drivers/BaseOPHandle; trcString7(Loracle/mgw/drivers/ConsumerParams;)Ljava/lang/String;consP7(Loracle/mgw/drivers/ProducerParams;)Ljava/lang/String;prodP SourceFile BaseLink.java  p qr s tu oracle/mgw/common/Trace v oracle/mgw/common/ApiTrace w java/util/HashMap oracle/mgw/drivers/OPHandlePooljava/lang/StringBuilder xy .MsgOphPool zr {| } s .LogOphPool  .AdmOphPool  ~ "oracle/mgw/common/GatewayException BaseLink.close {Link closing:     Link closed: { {BaseLink.closeLink yBaseLink.handleEvent   r   java/lang/ExceptionBaseLink.processEvent periodic   idleCheck   BaseLink.periodicEventBaseLink.idleCheckEvent  BaseLink.logSetCache_registeroracle/mgw/common/LogIdSet r  |  C9 89 o r | O r D< r ;< r consumer ID not registered: BaseLink.registerConsumerP FGBaseLink.unregisterConsumerP MN z{BaseLink.putConsumerP PQproducer ID not registered: BaseLink.registerProducerPBaseLink.unregisterProducerP {BaseLink.putProducerP ojava/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/DestData YZ, queue=  r |   3log destination is a Queue but a Topic was expected3log destination is a Topic but a Queue was expected r rBaseLink.alterLinkParamsMsgLinkParamsNFactory ij kl r  rBaseLink.alterLinkalter=0x `  no po qo ro  BaseLink.resetHandles  resetting OPHandles x   o z| oracle/mgw/drivers/BaseOPHandle { | {      BaseLink.commitOph     commit error! consId: , dest: r , subName: r , isLog:   , isBrowser:  prodId:  oracle/mgw/drivers/BaseLinkjava/lang/Objectoracle/mgw/common/MsgLink BaseLink.'oracle/mgw/common/MsgLinkParamsNFactorygetName()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)Vappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;toStringgetConns()I/(Ljava/lang/String;ILoracle/mgw/common/Trace;)Voracle/mgw/common/MgwUtilGatewayExceptionN(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; exception(Ljava/lang/Throwable;)V methodEntrytrace(Ljava/lang/String;I)Vclearlog methodExit isTraceEntryoracle/mgw/common/Event'(Ljava/lang/String;Ljava/lang/String;)V((Ljava/lang/String;Ljava/lang/String;I)V isEventName(Ljava/lang/String;)Zjava/lang/SystemcurrentTimeMillis()J checkHandles(J)V!oracle/mgw/drivers/ProducerParamsgetId!oracle/mgw/drivers/ConsumerParamsK(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V incRefCountput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; isTraceExit toTraceString decRefCount&(Ljava/lang/Object;)Ljava/lang/Object; getProducerId getConsumerId getBrowserIdget(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 getNativeNameloggingSupportisBitSet(II)ZisTopicgetInboundLogQgetOutboundLogQgetUserisEqual((Ljava/lang/String;Ljava/lang/String;Z)Z getPasswordjava/lang/Integer toHexStringmsgLinkDescription(Z)Ljava/lang/String;java/lang/Mathmin(II)IsetMaxPoolSize allCheckedInjava/lang/StringvalueOfisLevel getAllHandles&()[Loracle/mgw/drivers/PooledOPHandle; closeConsumer closeProducer getConsumer3(Ljava/lang/String;)Loracle/mgw/common/MsgConsumer; getProducer3(Ljava/lang/String;)Loracle/mgw/common/MsgProducer;nvl_null&(Ljava/lang/Object;)Ljava/lang/String;commitrollbackgetDestNativeName getSubName isLogConsumer isBrowser isLogProducer!9#***+***+* * Y* * 6* Y* *Y***Y*Y*Y****YY* +!* "#*$*YY*% * "&*YY*' * "(**)Wj  '>AVafkv"H######A /*   /*   /*  4* '( F***567 + p ***L* +, +EF JLNQ  /*^ {-L*-.* Y/* 0*YM*1,çN,-*2**3** Y4* 5*-6.477:76 ~ *.2<@HOTqz{xy)7L*7.*8*#*&*(*76" ()&K9M*:*9+;<*YN*=*+>:* ,-ç :-*96'*?7::>:2  "'*,5AJ*, KKHD@M*:*@+;A+BC *D+EC*F*@G&   $+48C DDA+bHL*HA*F*HG*+.01+ 6IL*IAJA*# K*& K*( K*IG"BCEFG"H*J5K 63$!"+#$z L:6:*Y: »MY+,,N--OOP:QW*+RW), *,SW- *-TW *TW ç :   *U*LVGJ EKV[`glsy\ %&'()*)+, -./0R>*Y:+W3*+XYW>!*+Z[W*+\]W*+^]Wç : EHHMH.   $.8BP*RR-.R1P,234N*Y:*+_MN- -QWç :- '**/* $ 2 *44%442-.56@M*YN*+_M,ɻY`+ *-ç :-, 477;7 " $%&2(>* @@7>+89\aN**+ab OP*:4 ;<cN**+cd6*+ehjnoq47= ,>?\fN**+fg *:@ A6@M*YN*+_M,ɻYh+ *-ç :-, 477;7 2> @@B>+C9\iN**+ib *:4 D<jN**+jd6*+k4B= ,E?\lN**+lg *:@ FG ,m:*n-*oYpqrrsrtuA66+Y:+_v:  +,RWB,w69  w6+6 x6*Yy zç :  *U8*oYpqrr{rt|r}uGFR467;>>?AAFDQGWJ_KcLlQpRzU}VW[]^f\ QQH: I:4J>KALMN *n,*oYpqr,r~rtuA6:6+Y:,+,_: 6v66 +,Y:ç :   *Y, z*U6*oYdpqr,rrt|r}uGB~R 47:=BFMSYcot{RIJ=7O:=LPQN ,m:*n-*oYpqrrrtuA:+Y:+_:,vx+,R:ç :*U!*Yq GCmppup:;>CGOUajxHI:@J>fHRSfM*n *Y AN*Y:*:'*_N-*N*-RWç :*U@oYpr}r- -ru:*G-5illqlB%&'+*-+5-<.B1O2T5[6f9t;=BE><*T UV-WX+YZ+[\0*=+*+ *vw z{%/ 00]X+^+_`CM* * *M!* * *M,#(A CCVATab7=* **=* **="5 77V5cde: vM*.*=+ **YN*#Y:*:*+6*+ç :-ç :- N* -,*6.ILLQL&VYY]Y `c+F &. 4 = F T `cdlu>4f= gdvvhsija>,+>,+>,!+!>,+>,+>2 ;>@C$E(H3I8LGNKQZS_U*aahaf_gklj:*:#*Y A*+* +5****$*#*Y`,: *YW*#*Y`,: *YW*GV.3?GLTX`jpvHpmmhfg+no:gpo;gqo: gro;gsT**!<*#456 tu  L=**.=*#YN*&Y:*(Y:*#0*&&*(* 0*8**=ç :ç :-ç :-*+N*  * -,-: *  .hkkpk&vyy~y+fnpr tuy{&}.LVZ^ces*vw+x+yz{O*+*#*+*& 7z|Q,,YN,:6,22+:* ,-ç :-$03+ FIIMI6  $ 0 3 5 >D P >5 1}4~QQ7Q{O*+*#*+*&   B|Q,,YN,:6,22+:* ,-ç :-$03+ FIIMI6 3 4 6 8 9 ;$ ?0 D3 A5 C> 9D GP H>5 1}4~QQBQ[*+,*#*+,*& ^ _ ` 7h)R t--Y:-:6L2=2+:)*,:2+: * ,ç :  9@C+EQT+ hkkpkJ x y { } ~ % 3 9 @ C E Q T V _ ~e s \ V Ev3,Q}T~tt7th)t+[*+,*#*+,*&  Bh'R t--Y:-:6L2=2+:)*,:2+: * ,ç :  9@C+EQT+ hkkpkJ     % 3 9 @ C E Q T V _ e s \ V Ev3,Q}T~ttBth't+bM*:**U +<+N6+6*1*Y*U + -* -,:* ,+:* ,6*1*Y*U + -* -,O:*1*Y*U + -* -,***U +)-0+4;++4;$ ' ) *) /- Z0 11 54 98 :; LE Ms Sx Tz X Y < ? B G D F H L M S T X Y L M) S. T0 X; \E ]a `H 41 bb_+~JoY,pr+Orr+¶rör+ĶrŶr+ƶtǶr+ȶtu iJJ)f2oY,pɶr+Nrr+ʶrŶr+˶tu y22'