Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\engine\Worker.class
?? 1?? ?? ? ? ? $? ??? #?? #? # # # # # # # # # # # # # # # # # # ! #" ## #$ #% &' ()* + ,-./ 0 1 q q2 ?2 ?3 q? ?? 45 6 (7 89: q ; < = > ?9@A B CDEFGHI J9K L 9M N OP #Q R OS TU9V W X YZ[ b\ b] c^ b_`a b c de m? f gh qi9j qk #l #m #no xp qrs tu v 4w xyz {9|9}~ ? ? ? ?k ? ? ? ?? #? ???9? ? ? ? ?\ ?] ??? ? ? ? x? ? x? ? x? ? ? ? ? ? ???9? ?? #?? q?? ?9? ? #?? ??? c\ ??? ? ? #? ? ? #? ? ? ? #? #? ?? ?? ?? ?? #? ? ? ????? ? #????????? #? #???? #? #? #? ? ? ??? c] ??? ?? ?? ?? ?2?? ?? ? ?? ?Y ?? ??? q????????? q? O?? #?? O? #? #? ????9??9? ????????? T? T? O??9? ?? ???? ???? ??? ?? agent Loracle/mgw/engine/Agent; scheduler Loracle/mgw/engine/Scheduler; msgs [Loracle/mgw/common/Message; msgids [Loracle/mgw/common/MessageID; isPers [Z msgExDeqMsgid Loracle/mgw/common/MessageID; msgExCount I msgExids msgExEx Loracle/mgw/common/MGWException; msgCount msgDeqCount msgDupCount srclink Loracle/mgw/common/MsgLink; targetlink srchd Loracle/mgw/common/OPHandle; targethd deqLogid enqLogid logsToCommit [Loracle/mgw/engine/LogId; logsToCommitCount numExMsgsToCommit logger Loracle/mgw/common/MgwLog; MAX_BYTES ConstantValue LOG_CLEANING_THREADSHOLD FACILITY Ljava/lang/String; COMPONENT <init> (ILoracle/mgw/engine/Agent;)V Code LineNumberTable LocalVariableTable this Loracle/mgw/engine/Worker; id myRun ()V i job Loracle/mgw/engine/JobData; jobFound Loracle/mgw/engine/SchRet; fe "Loracle/mgw/common/FatalException; rtEx Ljava/lang/RuntimeException; er Ljava/lang/Error; moveDupMsgs X(Loracle/mgw/engine/JobData;Loracle/mgw/engine/DeqLogRec;Loracle/mgw/engine/EnqLogRec;)V j mid incExCount Z existing foundMatchMsgId deRec Loracle/mgw/engine/DeqLogRec; enRec Loracle/mgw/engine/EnqLogRec; Exceptions avoidDupMsgs ;(Loracle/mgw/engine/JobData;Loracle/mgw/engine/DeqLogRec;)V deqMessages (Loracle/mgw/engine/JobData;)J byteCount exmid elem Loracle/mgw/engine/DupMsg; msge $Loracle/mgw/common/MessageException; message Loracle/mgw/common/Message; cons Loracle/mgw/common/MsgConsumer; nextDeqSeqNo J deqRec msgsLeft ge $Loracle/mgw/common/GatewayException; fae exceptionRecvd enqMessages (Loracle/mgw/engine/JobData;JZ)V enqEndMark logProd Loracle/mgw/common/MsgProducer; me msgProd enqRec ffe seqno isRecovery msgsProcessed enqLogUpdated commitMessages !(Loracle/mgw/engine/JobData;JZZ)V exqEndMark deqEndMark updateSeq unsetMissingMsg cleanJob (Loracle/mgw/engine/JobData;)V log ret dlogs [Loracle/mgw/engine/DeqLogRec; ex elogs [Loracle/mgw/engine/EnqLogRec; succeed recoverJob smallestSeqno k firstSeqno enqLog se $Loracle/mgw/common/SkipJobException; e deqLogs writeInitialEnqLogRec :(Loracle/mgw/engine/JobData;)Loracle/mgw/engine/EnqLogRec; rec collectEnqLogRec logmsg Loracle/mgw/common/LogMessage; logrec Loracle/mgw/engine/LogRec; logmid logCons enqlog collectDeqLogRecs X(Loracle/mgw/engine/JobData;Loracle/mgw/engine/EnqLogRec;)[Loracle/mgw/engine/DeqLogRec; trec n trec1 obj Ljava/lang/Object; obj1 deqTmp lrec perStatus exqLog m reqHasExRec erec largestExLogSeqno en_log tempdeqlogs Ljava/util/ArrayList; tempexqlogs logsToKeep lastEnqedSeq res processJob gge unScheduleProcessingJob returnHandle U(Loracle/mgw/common/MsgLink;Loracle/mgw/common/OPHandle;Loracle/mgw/engine/JobData;)V errid link hd setHandles (Z)V inbound writeDeqLog p(Loracle/mgw/common/MsgLink;Loracle/mgw/common/Message;Loracle/mgw/engine/JobData;)Loracle/mgw/common/MessageID; lProd loghd loglink retMsgid forceStop findAllRemovableLogs 8(Loracle/mgw/engine/JobData;Loracle/mgw/engine/DupMsg;)V lastSeqno currElem lids completeSending msgToSend msgCons startingIdx getDeqLogRecsForClean ;(Loracle/mgw/engine/JobData;)[Loracle/mgw/engine/DeqLogRec; getEnqLogRecsForClean ;(Loracle/mgw/engine/JobData;)[Loracle/mgw/engine/EnqLogRec; dumpJobLogRecs cleanJobLogRecs createDurableSub SourceFile Worker.java java/lang/StringBuilderOX worker O2 oracle/mgw/common/Message)* oracle/mgw/common/MessageID+,-.3,9:;:<=>=ABD2%&'(EF627282/01245 Engine looking for a job !"[#$%&%'2????????()*+,- oracle/mgw/common/FatalException.*/0 java/lang/RuntimeException java/lang/Error entering moveDupMsgs for job 1L23?4256789:;<L=>?@ABCDEFCGHI removed a message for JKLF leaving moveDupMsgs for job entering avoidDupMsgs for job %avoidDupMsgs is called for topic src. forwent an expired message for leaving avoidDupMsgs for job entering deqMessages for job MiNOP2QRSTUVW??XYZ[\]2^_`abW "oracle/mgw/common/MessageException "oracle/mgw/common/GatewayExceptioncWdOef0 !MessageException with null msgid. $MessageException with null msg body.ghi2j "oracle/mgw/common/SkipJobExceptionk?lm oracle/mgw/engine/DeqLogRecOnoWpq???0C2 oracle/mgw/engine/LogIdOrsW leaving deqMessages for job with seqno t deqMsgCount = u2vXwX entering enqMessages for job with request xyz{|} oracle/mgw/engine/EnqLogRecO~L??2?L?o?0@0?? unexpected MessageException?????F?h??X leaving enqMessages for job entering commitMessages for job ?y??L???2?0?L?0?X?X?h?F?F?X leaving commitMessages for job entering cleanJob for job ????X???Y !a deqlog being removed gets lost.C??????? "an enqlog being removed gets lost.?2 leaving cleanJob for job entering recoverJob for job ??????????????i?????L?L?2?2???W?m?? inconsistent in-memory logs found enq logs, deq logs for job ?X??qr?? recovering job deqseq= enqseq=?ede???X????X unexpected SkipJobException?? errorcode = leaving recoverJob for job ?L oracle/mgw/common/LogMessage??? 'unexpected destination log record type java/util/ArrayList?L?7???? "unexpected source log record type ?? entering processJob for job ?? failed to get opHandles for job ?Wst???? caught SkipJobException. leaving processJob for job ?? (failed to get a logging connection from ?????i?? !entering completeSending for job Q??X?? leaving completeSending for job Dumping sending log records for 9failed to get source side connection for dumping logs of &Dumping receiving log records for job >failed to get destination side connection for dumping logs of ? @failed to get destination side connections for cleaning logs of #an enqlog being removed gets lost. ? ;failed to get source side connections for cleaning logs of #an deqlog being removed gets lost. ?X "entering createDurableSub for job ?X !leaving createDurableSub for job oracle/mgw/engine/Worker oracle/mgw/engine/ManagedThr append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; (Ljava/lang/String;)V oracle/mgw/common/MgwConstants MAX_BATCH_SIZE oracle/mgw/engine/Agent getScheduler ()Loracle/mgw/engine/Scheduler; oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; getStop ()Z isTRACE_LITE (I)Z trace )(Ljava/lang/String;Ljava/lang/String;II)V oracle/mgw/engine/Scheduler findReadyJob ()Loracle/mgw/engine/SchRet; oracle/mgw/engine/SchRet schJob oracle/mgw/engine/JobData getSrcLink ()Loracle/mgw/common/MsgLink; getTargetLink action java/lang/String valueOf (I)Ljava/lang/String; oracle/mgw/common/MgwUtil FatalException L(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/FatalException; getMsg shutdown *(Ljava/lang/String;Ljava/lang/Throwable;)V pid srcNotAllowDeqByMsgId logseqNo msgidCount java/lang/Object equals (Ljava/lang/Object;)Z exQ Loracle/mgw/common/DestData; GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; guid oracle/mgw/common/MsgLink moveToExceptionQueue ?(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/DestData;Loracle/mgw/common/MessageID;)Loracle/mgw/common/MessageID; toIgnoreMissingMsgs (J)Z getIDAsString logMsg :(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)V setMissingMsgReq (J)V L(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)V removeMsg N(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/MessageID;)Z addDeqLogRec (Loracle/mgw/engine/DeqLogRec;)V setDeqSeqNo isJmsJob getConsumer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgConsumer; batchSize receive <(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/common/Message; dupData Loracle/mgw/engine/DupData; oracle/mgw/engine/DupData numDupMsgs ()I getMsgId ()Loracle/mgw/common/MessageID; getDupMsg 9(Loracle/mgw/common/MessageID;)Loracle/mgw/engine/DupMsg; oracle/mgw/engine/DupMsg m_action sendToExceptionQueue r(Loracle/mgw/common/OPHandle;Loracle/mgw/common/DestData;Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; isPersistent expires size getCode getReason +(ILjava/lang/String;Ljava/lang/Throwable;)V msgid setMsgCount (I)V retryCount writeFailureInfo jobMutex getDeqSeqNo ()J J(Ljava/lang/String;Ljava/lang/String;JI[Loracle/mgw/common/MessageID;[ZI)V loggingSupport toLogMessage ()Loracle/mgw/common/LogMessage; >(JLoracle/mgw/common/MessageID;Loracle/mgw/common/MessageID;)V getMsgCount (J)Ljava/lang/StringBuilder; jobStatus notifyAll notifyDeqWaiting waitForEnqueue (Loracle/mgw/engine/JobData;J)Z getProducer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgProducer; send Y(Loracle/mgw/common/Message;Loracle/mgw/common/MsgProducer;)Loracle/mgw/common/MessageID; I(Ljava/lang/String;Ljava/lang/String;JII[Loracle/mgw/common/MessageID;I)V destLogProd hasTopicAsDestLog destTopicLogCount destLogCons enqLogRec logmsgid setLogMsgid (Loracle/mgw/common/MessageID;)V commit (Loracle/mgw/common/OPHandle;)V setEnqLogRec (Loracle/mgw/engine/EnqLogRec;)V setEnqSeqNo incTotalNumMsgs oracle/mgw/common/MGWException notifyEnqWaiting waitForCommit hasTopicAsSrcLog srcLogProd m_seqno srcTopicLogCount m_exqLogMsgid srcLogCons m_deqLogMsgid unsetMissingMsgReq unsetToIgnoreMissingMsgs incTotalNumExMsgs delDeqLogRec setComSeqNo notifyComWaiting startOperation ()Loracle/mgw/common/OPHandle; java/lang/Thread yield getLogMsgid ((Ljava/lang/String;ILjava/lang/String;)V rollback logMsgEx =(Ljava/lang/String;ILjava/lang/String;Ljava/lang/Throwable;)V numWorkers init getDumpLogRecs setDumpLogRecs getCleanLogRecs setCleanLogRecs (Z)Z setMissingLogs isInbound logpid logguid numMsgEnqed logtype getNumLogs getComSeqNo getDeqLogRec (J)Loracle/mgw/engine/DeqLogRec; cleanDeqLogRecs writeStatistics getPoller ()Loracle/mgw/engine/PollingThr; oracle/mgw/engine/PollingThr notifyPollWaiting '(Ljava/lang/String;Ljava/lang/String;)V destLogBrow oracle/mgw/engine/LogRec toLogRec ?(Loracle/mgw/common/LogMessage;Loracle/mgw/common/MsgLink;Ljava/lang/String;Loracle/mgw/common/MsgLink;Z)Loracle/mgw/engine/LogRec; srcLogBrow add get (I)Ljava/lang/Object; remove addDupMsg ?(Loracle/mgw/engine/DeqLogRec;IILoracle/mgw/common/MessageID;)V numDupReqs setFailed (ILjava/lang/String;)V startLogOperation getLinkParamsNFactory +()Loracle/mgw/common/MsgLinkParamsNFactory; 'oracle/mgw/common/MsgLinkParamsNFactory getName m_isLast removeDupMsgsNReqs (J)[Loracle/mgw/engine/LogId; Y(Loracle/mgw/common/MsgConsumer;Loracle/mgw/common/MessageID;)Loracle/mgw/common/Message; incProcessedCount incExMsgsCount unsubDestLog unsubSrcLog resetLoggingInfo createAlterNativeSub !#$ %&