Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\engine\Scheduler.class
?? 1, ? ? X ? X ? X ? X ? X ? ? ? X ? ? ? X ? ? ? X ? ? ? X ?????? X ? ? ? ? ? ? ? ? ? X ? ? ? ? ? ???????? ? ? ? ? ? ? ? # ? ? # ? ? ? ? ? ? # ? ? ? ? ? ? ? # ? ? ? ? ? ? 2 ? ? ? w@ ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? # ? ? ? ? ? ? ? ? ? ? ? X ? X ? X ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? agent Loracle/mgw/engine/Agent; jobMgr Loracle/mgw/engine/JobMgr; jobList Loracle/mgw/engine/JobList; deqWaiting Ljava/lang/Object; enqWaiting comWaiting logger Loracle/mgw/common/MgwLog; rt Ljava/lang/Runtime; threshold_mem J done Z MAX_WAIT_INTERVAL ConstantValue d FACILITY Ljava/lang/String; COMPONENT I <init> (Loracle/mgw/engine/Agent;I)V Code LineNumberTable LocalVariableTable this Loracle/mgw/engine/Scheduler; maxmem findReadyJob ()Loracle/mgw/engine/SchRet; e Ljava/lang/InterruptedException; interval timeLeft job Loracle/mgw/engine/JobData; j timeForNextRetry currentTime numJobs tabLocked Exceptions ? waitForEnqueue (Loracle/mgw/engine/JobData;J)Z noReady seqno waitForCommit notifyDeqWaiting ()V notifyEnqWaiting notifyComWaiting shutdown isLowMemory ()Z SourceFile Scheduler.java t ? java/lang/Object _ ` a ` b ` i j Y Z ? ? ? [ \ ? ? ? ] ^ ? ? ? c d ? ? ? e f g h ? ? Engine entering findReadyJob. ? ? ? ? java/lang/InterruptedException ? java/lang/StringBuilder Scheduler checking job p state = r status = r retryCount = r ` r oracle/mgw/engine/SchRet t ? h " to be scheduled to recover later. ? busy job ? job has no message wait for ! ms. checking for enq request " is not ready for enq request ? for commit request ! is not ready for commit request # ? ? ? ? ? ? ?$% ? total= &'() free= threshold=*+ oracle/mgw/engine/Scheduler oracle/mgw/common/FatalException oracle/mgw/engine/Agent getJobMgr ()Loracle/mgw/engine/JobMgr; oracle/mgw/engine/JobMgr createJobList ()Loracle/mgw/engine/JobList; oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; java/lang/Runtime getRuntime ()Ljava/lang/Runtime; isTRACE_HIGH (I)Z trace )(Ljava/lang/String;Ljava/lang/String;II)V lockJobsForScan wait (J)V unlockJobsForScan java/lang/System currentTimeMillis ()J oracle/mgw/engine/JobList refreshJobList ()I getNextJob ()Loracle/mgw/engine/JobData; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; oracle/mgw/engine/JobData pid jobState (I)Ljava/lang/StringBuilder; jobStatus retryCount toString ()Ljava/lang/String; jobMutex numWorkers (Loracle/mgw/engine/JobData;I)V needCreateAlterSub lastRetryTime isTRACE_LITE isNotPipelinable getComSeqNo getDeqSeqNo getMsgCount (J)Ljava/lang/StringBuilder; getEnqSeqNo notifyAll freeMemory gc totalMemory java/lang/String valueOf (J)Ljava/lang/String; logMsg L(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)V ! X Y Z [ \ ] ^ _ ` a ` b ` c d e f g h B i j k h l m o p l q r l s t u v ? _*? *? Y? ? *? Y? ? *? Y? ? *? *+? *+? ? **? ? ? *? ? *? ? *x? k? ? w 2 % * / 7 B I P ^ x _ y z _ Y Z _ { r | } v l ?*? ? ? *? ? *? ??<*? ? <*? YM?*? ? *? ? *? ? ????*? ? ,???*? ? ?? B? 7*? ? !66??*? ? ": *? ? ? M*? ? #Y? $%? & ? '? &(? & ? )? *+? & ? ,? *-? & ? .? *? /? ? 0Y: ? ? )? F ? , ?~? : Y? 1`? 1 Y? ,?~? ,? 2Y ? 3: ?,?? *? ? ? ? )? A ? ,~? 6 ? 4? . Y? ,?? ,? 2Y ? 3: ?,?? *? ? ? ? )? ?? ? ,@? ? ? .? ? 1? ?? ? .x x?7 5? 57 ? 7ae7 ? @ Y? ,?? , ? 7 Y? .`? .? 2Y ? 3: ?,?? *? ? ? !? B*? ? ? &*? ? #Y? $ ? '? &8? &? /? ? ? ? ,9~? E*? ? 9? 3*? ? #Y? $:? & ? '? &;? & ? ,? *? /? ? ? ? <? ? = ? >? ? ? ? ?? 8 Y? 1`? 1 Y? ,?? ,? 2Y ? 3: ?,?? *? ? ?*? ? 9? +*? ? #Y? $@? & ? '? &A? &? /? ? : ???8*? ? <*? ? ? '*? ? #Y? $B? &!? CD? &? /? *? !? ? :,? :,??? *? ? ? :? *? ? ??? A K N ?); 9o; ?; ??; ?; X; [?; ??; ??; 8; ;@; R?? 3 [? i+? 9q? ? ?? ?? ??? # [? i+? 9q? ? ?? ?? ??? w N S ) * / ! 0 # 4 * 5 , 7 3 : A <